Skip to content

Commit

Permalink
Fix most producer tests in streaming.connectors.psc by calling super.…
Browse files Browse the repository at this point in the history
…snapshotState() instead of supersSnapshotState(); table API and some checkpoint migration tests remaining
  • Loading branch information
jeffxiang committed Oct 15, 2024
1 parent e873e57 commit d781fec
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1158,7 +1158,7 @@ private void flush(FlinkPscProducer.PscTransactionState transaction) throws Flin

@Override
public void snapshotState(FunctionSnapshotContext context) throws Exception {
supersSnapshotState(context);
super.snapshotState(context);

nextTransactionalIdHintState.clear();
// To avoid duplication only first subtask keeps track of next transactional id hint.
Expand Down

0 comments on commit d781fec

Please sign in to comment.