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
