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 69aca3e064b [FLINK-29841] fix the typo in
docs/content/docs/deployment/config.md
add d5276d7aa25 [FLINK-18808][streaming] Introduce helper builder class
for StreamConfigChainer.
add 835beb04ee2 [FLINK-18808][streaming] Introduce
OutputWithRecordsCountCheck.
add 24685395ccf [FLINK-18808][streaming] Include side outputs in
numRecordsOut metric
No new revisions were added by this update.
Summary of changes:
.../streaming/runtime/io/RecordWriterOutput.java | 43 +++-
.../runtime/tasks/BroadcastingOutputCollector.java | 24 +-
.../streaming/runtime/tasks/ChainingOutput.java | 16 +-
.../tasks/CopyingBroadcastingOutputCollector.java | 41 ++--
.../streaming/runtime/tasks/OperatorChain.java | 39 +++-
.../tasks/OutputWithChainingCheck.java} | 33 ++-
.../runtime/tasks/MultipleInputStreamTaskTest.java | 176 +++++++++++++++
.../runtime/tasks/OneInputStreamTaskTest.java | 101 +++++++++
.../streaming/runtime/tasks/OperatorChainTest.java | 5 +-
.../runtime/tasks/StreamConfigChainer.java | 242 +++++++++++++++++++--
.../runtime/tasks/TwoInputStreamTaskTest.java | 121 +++++++++++
11 files changed, 761 insertions(+), 80 deletions(-)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/{api/functions/query/QueryableValueStateOperator.java
=> runtime/tasks/OutputWithChainingCheck.java} (56%)
