Right now, we use UnionState to store the `nextCheckpointId` in the Iceberg
sink use case, because we can't retrieve the checkpointId from
the FunctionInitializationContext during the restore case. But we can move
away from it if the restore context provides the checkpointId.
On Sat, Sep 12, 2020
Thanks, I missed the fact that this issue was created early.
вс, 13 сент. 2020 г., 14:58 Chesnay Schepler :
> This is a known issue: https://issues.apache.org/jira/browse/FLINK-9844
>
> On 9/11/2020 8:34 PM, Vladislav Keda wrote:
>
> Hi Flink Community,
>
> I was trying to submit a flink job on a
This is a known issue: https://issues.apache.org/jira/browse/FLINK-9844
On 9/11/2020 8:34 PM, Vladislav Keda wrote:
Hi Flink Community,
I was trying to submit a flink job on a standalone cluster
using RestClusterClient. After waiting for job submission, I got JobID
correctly and tried to dele
