JDK11 编译的flink1.19的源码
因为他说没有sun.misc，所以启动用的jdk8
已连接到地址为 ''127.0.0.1:8339'，传输: '套接字'' 的目标虚拟机
Job has been submitted with JobID 0975ec264edfd11d236dd190e7708d70
The program finished with the following exception:
Hi,
这个报错一般是JDK版本不一致导致的。建议统一build flink和执行flink作业时的Java版本，（都用JDK8 或者 都用JDK11）。
用JDK11时没有sun.misc的问题可以试试勾选掉Idea的Settings-> Build, Execution and Deployment
-> Compiler-> Java Compiler的Use '--release' option for cross-compilation'
选项。
Best,
Biao Geng
z_mmG <13520871...@163.com> 于2024年4月30日周二
您好，根据您的指点，配置之后，重启了StandaloneSessionClusterEntrypoint和TaskManagerrunner，这个问题解决了，谢谢您
在 2024-04-30 15:45:18，"Biao Geng" 写道：
>Hi,
>
>这个报错一般是JDK版本不一致导致的。建议统一build flink和执行flink作业时的Java版本，（都用JDK8 或者 都用JDK11）。
>用JDK11时没有sun.misc的问题可以试试勾选掉Idea的Settings-> Build, Execution and Deployment
以处理时间为升序，处理结果肯定不会出现回撤的，因为往后的时间不会比当前时间小了，你可以在试试这个去重
On Tue, Apr 30, 2024 at 3:35 PM 焦童 wrote:
> 谢谢你的建议 但是top-1也会产生回撤信息
>
> > 2024年4月30日 15:27，ha.fen...@aisino.com 写道：
> >
> > 可以参考这个
> >
> https://nightlies.apache.org/flink/flink-docs-release-1.19/zh/docs/dev/table/sql/queries/deduplication/
> >
谢谢你的建议 但是top-1也会产生回撤信息
> 2024年4月30日 15:27，ha.fen...@aisino.com 写道：
>
> 可以参考这个
> https://nightlies.apache.org/flink/flink-docs-release-1.19/zh/docs/dev/table/sql/queries/deduplication/
> 1.11版本不知道是不是支持
>
> From: 焦童
> Date: 2024-04-30 11:25
> To: user-zh
> Subject: Flink sql retract to append
您好，按照您的指点，现在运行和编译都用的jdk11，已经没有sun.misc的报错了，但是提交job 还是报相同的错误
D:\software\jdk-11.0.7\bin\java.exe
-agentlib:jdwp=transport=dt_socket,address=127.0.0.1:11039,suspend=y,server=n
-Dlog.file=./log/flink-client.log
-Dlog4j.configuration=./conf/log4j-cli.properties
