This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 61a9973 Revert [FLINK-19027][tests] Decrease checkpoint timeout to avoid livelocking in UnalignedCheckpointITCase. add bd1e1f3 [hotfix] Do not cache DataOutput in StatusWatermarkValve add b8e8cd9 [hotfix] Alllow declaring which ordering direction should be tested add 63bdbc9 [FLINK-19472] Implement a one input sorting DataInput add cf40acd [FLINK-19472] Add an option to enable sorted inputs for operators add fc0e28d [FLINK-19472] Regenerate config options No new revisions were added by this update. Summary of changes: .../generated/algorithm_configuration.html | 6 + .../flink/configuration/AlgorithmOptions.java | 8 + .../flink/configuration/ConfigConstants.java | 5 + .../api/common/typeutils/ComparatorTestBase.java | 82 ++++--- .../operators/sort/NormalizedKeySorter.java | 2 +- .../runtime/operators/sort/SpillingThread.java | 10 +- .../flink/streaming/api/graph/StreamConfig.java | 17 +- .../flink/streaming/api/graph/StreamGraph.java | 4 + .../flink/streaming/api/graph/StreamNode.java | 10 + .../api/graph/StreamingJobGraphGenerator.java | 1 + .../operators/sort/BytesKeyNormalizationUtil.java | 85 +++++++ .../sort/FixedLengthByteKeyComparator.java | 178 ++++++++++++++ .../api/operators/sort/KeyAndValueSerializer.java | 188 +++++++++++++++ .../api/operators/sort/SortingDataInput.java | 229 ++++++++++++++++++ .../sort/VariableLengthByteKeyComparator.java | 182 ++++++++++++++ .../runtime/io/StreamMultipleInputProcessor.java | 2 +- .../runtime/io/StreamTaskNetworkInput.java | 4 +- .../runtime/io/StreamTwoInputProcessor.java | 4 +- .../runtime/streamstatus/StatusWatermarkValve.java | 22 +- .../runtime/tasks/AbstractTwoInputStreamTask.java | 4 + .../runtime/tasks/MultipleInputStreamTask.java | 5 + .../runtime/tasks/OneInputStreamTask.java | 35 ++- .../sort/FixedLengthByteKeyComparatorTest.java | 70 ++++++ .../sort/FixedLengthKeyAndValueSerializerTest.java | 73 ++++++ .../sort/SerializerComparatorTestData.java | 109 +++++++++ .../api/operators/sort/SortingDataInputITCase.java | 243 +++++++++++++++++++ .../api/operators/sort/SortingDataInputTest.java | 268 +++++++++++++++++++++ .../sort/VariableLengthByteKeyComparatorTest.java | 68 ++++++ .../VariableLengthKeyAndValueSerializerTest.java | 70 ++++++ .../runtime/io/StreamTaskNetworkInputTest.java | 12 +- .../streamstatus/StatusWatermarkValveTest.java | 166 ++++++------- .../runtime/SortingBoundedInputITCase.java | 194 +++++++++++++++ 32 files changed, 2212 insertions(+), 144 deletions(-) create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/BytesKeyNormalizationUtil.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/FixedLengthByteKeyComparator.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/KeyAndValueSerializer.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/SortingDataInput.java create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/VariableLengthByteKeyComparator.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/FixedLengthByteKeyComparatorTest.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/FixedLengthKeyAndValueSerializerTest.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/SerializerComparatorTestData.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/SortingDataInputITCase.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/SortingDataInputTest.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/VariableLengthByteKeyComparatorTest.java create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/VariableLengthKeyAndValueSerializerTest.java create mode 100644 flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SortingBoundedInputITCase.java