This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b0b2625 [fix] error in EmbeddedJobClient
add 6675979 [FLINK-19741] Let timer service skip reading raw keyed state
if it isn't the writer
add 13f2f7b [FLINK-19748] Skip key groups that don't have a defined
stream offset
add 12a2ade [FLINK-19748] [test] Adjust raw keyed state test to only
write some key groups
No new revisions were added by this update.
Summary of changes:
docs/ops/state/state_backends.md | 2 +
.../state/api/input/KeyedStateInputFormat.java | 3 +-
.../api/operators/AbstractStreamOperator.java | 27 +++-
.../api/operators/AbstractStreamOperatorV2.java | 27 +++-
.../api/operators/StreamTaskStateInitializer.java | 5 +-
.../operators/StreamTaskStateInitializerImpl.java | 34 ++++-
.../api/operators/AbstractStreamOperatorTest.java | 146 +++++++++++++++++++++
.../StateInitializationContextImplTest.java | 3 +-
.../operators/StreamOperatorStateHandlerTest.java | 3 +-
.../StreamTaskStateInitializerImplTest.java | 6 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 5 +-
11 files changed, 247 insertions(+), 14 deletions(-)
