Skip to content

Commit 15fcdf8

Browse files
committed
build issue
1 parent e35ca62 commit 15fcdf8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import pekko.stream.connectors.elasticsearch.{ impl, _ }
2121
import pekko.stream.javadsl.Source
2222
import pekko.stream.{ Attributes, Materializer }
2323
import pekko.util.ccompat.JavaConverters._
24-
import com.fasterxml.jackson.core.{ JsonFactory, StreamReadConstraints, StreamWriteConstraints }
24+
import com.fasterxml.jackson.core.{ JsonFactory, JsonFactoryBuilder, StreamReadConstraints, StreamWriteConstraints }
2525
import com.fasterxml.jackson.databind.ObjectMapper
2626
import com.fasterxml.jackson.databind.json.JsonMapper
2727
import com.fasterxml.jackson.databind.node.{ ArrayNode, NumericNode }
@@ -180,7 +180,7 @@ object ElasticsearchSource {
180180
val streamWriteConstraints = StreamWriteConstraints.builder
181181
.maxNestingDepth(config.getInt("write.max-nesting-depth"))
182182
.build
183-
val jsonFactory = JsonFactory.builder
183+
val jsonFactory = JsonFactory.builder.asInstanceOf[JsonFactoryBuilder]
184184
.streamReadConstraints(streamReadConstraints)
185185
.streamWriteConstraints(streamWriteConstraints)
186186
.build

0 commit comments

Comments
 (0)