SOD-DOB

How do I set up stateBackend and save checkpoints in HDFS?

Run on k8s, it's throw RemotingTimeoutException

1

my Flink Job run on k8s with flink-kubernetes-operator [https://github.com/apache/flink-kubernetes-operator]([flink-kubernetes-operator]) Tasks always report errors from time to time, but it doesn’t always appear  but when I execute it on the...

I have a question about DEFAULT_START_MESSAGE_OFFSET

2

`public static final long DEFAULT_START_MESSAGE_OFFSET = -1;` Why is the default value -1? It causes the following error： ``` java.lang.RuntimeException: org.apache.rocketmq.client.exception.MQClientException: offset < 0 For more information, please visit the...