bigdata-examples flink 1.11.0官方代码中关于watermark的提取

官方代码中对于watermark的提取 org.apache.flink.table.filesystem.stream.PartitionTimeCommitTigger#committablePartitions方法中 toMills方法已经修改为本地时区了。

Nov 13 '20 08:11 zjw-zjw

嗯嗯，那就是确实是一个bug

Nov 13 '20 09:11 zhangjun0x01

你好，我在使用你的flink代码在yarn上执行任务时报了下面的错误：nosuchFieldError:JVM_DIRECT_MEMORY_LIMIT_ENABLED，然后我看了JobManagerOptions类中确实没有此字段，请问你遇到过吗

Jan 05 '21 12:01 dakeleblack

你好，我在使用你的flink代码在yarn上执行任务时报了下面的错误：nosuchFieldError:JVM_DIRECT_MEMORY_LIMIT_ENABLED，然后我看了JobManagerOptions类中确实没有此字段，请问你遇到过吗

还真没有遇到过

Jan 06 '21 03:01 zhangjun0x01

flink 1.11.0官方代码中 关于watermark的提取