seatunnel
seatunnel copied to clipboard
[Bug] [seatunnel-translation-flink] Seatunnel Flink translation doesn't support 1.19.1
trafficstars
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
When I tried to run the seatunnel with flink 1.19.1, I got the below exception:
Caused by: java.lang.NoSuchFieldException: runtimeContext
at java.lang.Class.getDeclaredField(Class.java:2070)
at org.apache.seatunnel.translation.flink.sink.FlinkSinkWriterContext.getStreamingRuntimeContextForV15(FlinkSinkWriterContext.java:76)
SeaTunnel Version
2.3.5
SeaTunnel Config
none
Running Command
org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample#main
Error Exception
Caused by: java.lang.NoSuchFieldException: runtimeContext
at java.lang.Class.getDeclaredField(Class.java:2070)
at org.apache.seatunnel.translation.flink.sink.FlinkSinkWriterContext.getStreamingRuntimeContextForV15(FlinkSinkWriterContext.java:76)
Zeta or Flink or Spark Version
Flink 1.19.1
Java or Scala Version
java 8
Screenshots
No response
Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct