Does PieCloudDB support Flink?
I want to synchronize the data in MySQL to PieCloudDB for data analysis. Does PieCloudDB offer native support for using Apache Flink as a data synchronization tool? Are there any specific configurations or plugins that need to be set up within PieCloudDB to enable Flink?
In Flink’s production environment, does ExecutionEnvironment mean the environment of the TaskManager?
I am new to Apache Flink.
Is it possible to run multiple instances of JobManger in HA for Flink deployed by Kubernetes Operator 1.9
Basically, we have a lower environment cluster that we are using for multiple environments [Dev, QA, STG]. So I have deployed the Flink Kubernetes Operator 1.8 in a Flink Namespace, then the first JobManager in flink-dev namespace, a second one in a flink-qa namespace, and the last one in the flink-stg namespace. The only way I can get the JobManagers to work is to remove the high-availability annotations. If I add the high-availability annotations, I am getting the error further below:
Undocumented rule for recognizing a POJO type in Flink 1.18 : Class without fields must not be POJO?
Out of blue, I found the Java class generated out of an Avro schema stop working. Flink complains “Expecting type to be a PojoTypeInfo” for the generated class. Dig a little deeper, I discovered that a class must first be recognized a POJO type first, then a AvroTypeInfo
can be derived.
How do I listen to checkpoints/savepoin creation in Flink?
I have a flink app, in which I want to listen to checkpoint/savepoint creation events. How do I do that?
Flink standalone mode, Flink task completed but disk space not reclaimed
Flink standalone mode, Flink task completed running, temporary files deleted, but disk space not reclaimed, lsof shows occupied by jobmanager process
[enter image description here](https://i.stack.imgur.com/JYlXw.png)