Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

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

Open
zjw-zjw opened this issue Nov 13, 2020 · 3 comments
Open

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

zjw-zjw opened this issue Nov 13, 2020 · 3 comments

Comments

@zjw-zjw
Copy link

zjw-zjw commented Nov 13, 2020

官方代码中对于watermark的提取
org.apache.flink.table.filesystem.stream.PartitionTimeCommitTigger#committablePartitions方法中
toMills方法已经修改为本地时区了。
@zjw-zjw zjw-zjw changed the title flink 1.11.0官方代码中 碎玉watermark的提取 flink 1.11.0官方代码中 关于watermark的提取 Nov 13, 2020
@zhangjun0x01
Copy link
Owner

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

@dakeleblack
Copy link

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

@zhangjun0x01
Copy link
Owner

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

还真没有遇到过

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@zhangjun0x01 @dakeleblack @zjw-zjw