Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
# Changelog

## [Unreleased]
### Fixed
- Fixed http sink NEP issue when flink job restore from checkpoint.

## [0.23.0] - 2025-11-07

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,11 @@ public StatefulSinkWriter<InputT, BufferedRequestState<HttpSinkRequestEntry>> re
Collection<BufferedRequestState<HttpSinkRequestEntry>> recoveredState)
throws IOException {

ElementConverter<InputT, HttpSinkRequestEntry> elementConverter = getElementConverter();
if (elementConverter instanceof SchemaLifecycleAwareElementConverter) {
((SchemaLifecycleAwareElementConverter<?, ?>) elementConverter).open(context);
}

return new HttpSinkWriter<>(
getElementConverter(),
context,
Expand Down