在与Cassandra一起进行Flink流实验时,我在MapFunction中生成INSERT语句时遇到了一个有趣的问题。) at se.hiq.bjornper.testenv.cassandra.SOCassandraQueryTest.mainjava.util.Map.Entry;
import org.apache.flink<
/apache/flink/api/common/serialization/SerializationSchema;Lorg/apache/flink/elasticsearch7/shaded/org$translateToPlan$1.apply(StreamPlanner.scala:69)
at scala.collection.TraversableLike$$anonfun$map$1.apply(Traver
我使用的是Flink 1.10.0版本和Java1.8
05:39:14.260 [Source: Custom Source -> Flat Map (5/12)] WARN org.apache.flink.streaming.api.operators.BackendRestorerProceduretask and sending final execution state CANCELED to JobManager for task Source: Custom Source -> Flat Ma
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) at scala.collection.mutable.ResizableArray$class.foreachscala.collection.mutable.ArrayBuffer.foreach(Array