我有两个源,一个是Kafka源,一个是自定义源,我需要一个小时的睡眠自定义源,但我正在低于中断。com.hulu.hiveIngestion.HiveAddPartitionThread.run(HiveAddPartitionThread.java:48) at org.apache.flink.streaming.api
FLINK流:,我有来自kafkaconsumer的DataStreamString,这是JSON .addSource(new FlinkKafkaConsumer[)来接收这个流。org.apache.flink.api.scala.ClosureCleaner$.org$apache$flink$api$scala$ClosureCleaner$$clean(ClosureCleaner.scala:400)
at org