This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 7a00b0e6840 [FLINK-38291][REST] Reduce thread lock overhead for REST
handlers (#26951)
add 4e3c684c51b [hotfix] Improve logging in StreamTask#cleanUp
add 4472b08c3c9 [hotfix] Better error message in TaskTest
add faa30fdc5c4 [hotfix] Extract Task#transitionStateOnFailure
add fcb934c0451 [hotfix][test] Rewrite testWithRocksDbBackendIncremental
to not depend on close not being called on failures
add 573e3dfc392 [hotfix][test] Rewrite ValidatingSink to not throw
exception during closing
add 5689cdf7130 [hotfix][table] Safeguard bunch of operators and functions
from throwing NPE on close
add 3772e4ec749 [hotfix][task] Allow AutoCloseableRegistry to close in the
registration order
add dc2627b565d [FLINK-38180][task] Clean up task after switching to FAILED
add ae96dc0a006 [hotfix] Improve comment about Task's state transitions
No new revisions were added by this update.
Summary of changes:
.../flink/core/fs/AutoCloseableRegistry.java | 13 ++-
.../org/apache/flink/runtime/taskmanager/Task.java | 106 +++++++++++----------
.../source/ContinuousFileReaderOperator.java | 6 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 7 +-
.../apache/flink/runtime/taskmanager/TaskTest.java | 65 +++++++++++++
.../codegen/NestedLoopJoinCodeGenerator.scala | 2 +-
.../codegen/agg/batch/AggCodeGenHelper.scala | 3 +-
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 2 +-
.../fusion/spec/HashAggFusionCodegenSpec.scala | 3 +-
.../runtime/operators/join/HashJoinOperator.java | 4 +-
.../operators/join/SortMergeJoinFunction.java | 4 +-
.../KeyedStateCheckpointingITCase.java | 17 ++--
.../test/checkpointing/utils/ValidatingSink.java | 2 +-
.../ReinterpretDataStreamAsKeyedStreamITCase.java | 3 +-
14 files changed, 167 insertions(+), 70 deletions(-)
