I need help to figure out the problem with sql-client.
With postgres-cdc jar copied to lib and execute the following sql statements,
got ClassNotFoundException.
Error:
Flink SQL> SELECT * FROM shipments;
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException:
o
Yes, it's possible. You may refer to the example here:
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/serialization/types_serialization/#most-frequent-issues
Best,
Zhanghao Chen
From: patricia lee
Sent: Thursday, July 10,
Hi,
Thanks for the update.
One more question though..
If we set it to pipeline, it means it will get applied to the whole project
itself?
The problem is, our set up, is that the project has the registerPojoType as
params. Therefore there would be different class serialization for each
executionE
Hi Patricia,
You may register the type using the new config pipeline.serialization-config
[1]. I've created a new JIRA issue [2] to fix the doc.
[1]
https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/deployment/config/#pipeline-serialization-config
[2] https://issues.apache.org/jira
Hi,
We are currently migrating from Flink version 1.18 to Flink version 2.0.
We have this configuration:
StreamExecutionEnvironment env = new StreamExecutionEnvironment();
env.setRegisterTypes(MyClass.class);
In flink 2.0, if our understanding is correct, we'll use this registerPojoType
instead
Hi,
We are currently migrating our flink projects from version 1.18 to 2.0.
We have this part of the codes that we set the model in the
StreamExecutionEnvironment env = new StreamExecutionEnvironment();
env.setRegisterTypes(MyClass.class);
Right now in Flink 2.0, I followed this
