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 1ac4f3d182c [FLINK-33977][runtime] Support minimize TM number during
downscaling in adaptive scheduler
add 9d0f9156f60 [FLINK-37768] ConstraintEnforcer not handling all
constraints (#26540)
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 8 +-
.../table/api/config/ExecutionConfigOptions.java | 41 +-
.../plan/nodes/exec/common/CommonExecSink.java | 153 +---
...s.java => ConstraintEnforcerSemanticTests.java} | 22 +-
.../stream/ConstraintEnforcerTestPrograms.java | 823 +++++++++++++++++++++
.../runtime/operators/sink/ConstraintEnforcer.java | 361 ---------
.../sink/constraint/BinaryLengthConstraint.java | 117 +++
.../sink/constraint/CharLengthConstraint.java | 137 ++++
.../constraint/Constraint.java} | 27 +-
.../ConstraintEnforcer.java} | 43 +-
.../constraint/ConstraintEnforcerExecutor.java | 552 ++++++++++++++
.../sink/constraint/EnforcerException.java} | 38 +-
.../sink/constraint/NestedArrayConstraint.java | 102 +++
.../sink/constraint/NestedMapConstraint.java | 121 +++
.../sink/constraint/NestedRowConstraint.java | 99 +++
.../sink/constraint/NotNullConstraint.java | 73 ++
.../constraint/NotNullEnforcementStrategy.java | 36 +-
.../constraint/TypeLengthEnforcementStrategy.java | 39 +-
18 files changed, 2224 insertions(+), 568 deletions(-)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{DeletesByKeySemanticTests.java
=> ConstraintEnforcerSemanticTests.java} (51%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ConstraintEnforcerTestPrograms.java
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/ConstraintEnforcer.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/BinaryLengthConstraint.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/CharLengthConstraint.java
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/{process/PassAllCollector.java
=> sink/constraint/Constraint.java} (61%)
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/{RowKindSetter.java
=> constraint/ConstraintEnforcer.java} (52%)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/ConstraintEnforcerExecutor.java
copy
flink-table/{flink-table-common/src/main/java/org/apache/flink/table/data/utils/CastExecutor.java
=>
flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/EnforcerException.java}
(57%)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/NestedArrayConstraint.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/NestedMapConstraint.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/NestedRowConstraint.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/NotNullConstraint.java
copy
flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/NodeStatus.java
=>
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/NotNullEnforcementStrategy.java
(59%)
copy
flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/NodeStatus.java
=>
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/constraint/TypeLengthEnforcementStrategy.java
(54%)
