The hello world example works fine in Flink 1.14.X, but flink sql with kafka is
not working , I have tried several times in two different enviroments.
Sorry , I forgot tell you it's in flink sql with kafka. Job is
%flink.ssql(parallelism = 1)
DROP TABLE IF EXISTS aa;
CREATE TABLE aa(
Zeppelin 0.10.1 supports Flink 1.14.x, have you tried to run the hello
world example which don't require kafka connector ?
On Tue, May 10, 2022 at 1:44 PM 李 wrote:
>
> Hi:
> I found zepplin 0.10.1 does not work with flink 1.14.2 and 1.14.4
> using kafka connector, but it workes with flink
Hi:
I found zepplin 0.10.1 does not work with flink 1.14.2 and 1.14.4 using
kafka connector, but it workes with flink 1.13.1.
Does it means zepplin does not work with flink 1.14? Or anybody meet the
same problem and solve it?
Thank you.
The Exception is:
Job failed during
