This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4d8157f [FLINK-23531][table] Supports compact-changes in row-time
deduplicate mini-batch
add cbdd052 [hotfix][core] Support prefix maps in
UnmodifiableConfiguration
add 659ffa7 [FLINK-23498][streaming-java] Remove
StreamExecutionEnvironment.getConfiguration()
add bf55428 [FLINK-23498][streaming-java] Expose
StreamExecutionEnvironment.getConfiguration()
add 5b2535b [FLINK-23498][streaming-java] Expose an easier
StreamExecutionEnvironment.configure()
add d19d044 [hotfix][table-planner] Remove unused field from PlannerBase
add 7790702 [FLINK-23498][table] Introduce a full planner configuration
No new revisions were added by this update.
Summary of changes:
.../client/program/StreamContextEnvironment.java | 4 +-
.../apache/flink/configuration/Configuration.java | 8 +--
.../configuration/UnmodifiableConfiguration.java | 2 +-
.../configuration/DelegatingConfigurationTest.java | 6 +-
.../pyflink/datastream/tests/test_data_stream.py | 7 +--
.../tests/test_stream_execution_environment.py | 6 +-
...st_stream_execution_environment_completeness.py | 2 +-
.../table/tests/test_table_environment_api.py | 5 +-
flink-python/pyflink/util/java_utils.py | 10 ++--
.../apache/flink/python/util/PythonConfigUtil.java | 31 +++++-----
.../flink/python/util/PythonConfigUtilTest.java | 5 +-
.../api/java/ScalaShellStreamEnvironment.java | 3 +-
.../api/environment/RemoteStreamEnvironment.java | 10 ++--
.../environment/StreamExecutionEnvironment.java | 69 +++++++++++++++++-----
.../api/scala/StreamExecutionEnvironment.scala | 44 ++++++++++++--
.../java/internal/StreamTableEnvironmentImpl.java | 5 +-
.../apache/flink/table/delegation/Executor.java | 11 +++-
.../org/apache/flink/table/utils/ExecutorMock.java | 9 ++-
.../internal/StreamTableEnvironmentImpl.scala | 19 +++---
.../table/planner/delegation/DefaultExecutor.java | 16 ++++-
.../planner/delegation/PlannerConfiguration.java | 56 ++++++++++++++++++
.../plan/nodes/exec/batch/BatchExecExchange.java | 3 +-
.../exec/processor/DeadlockBreakupProcessor.java | 2 +-
.../MultipleInputNodeCreationProcessor.java | 2 +-
.../utils/InputPriorityConflictResolver.java | 6 +-
.../flink/table/planner/utils/ExecutorUtils.java | 4 +-
.../table/planner/delegation/BatchPlanner.scala | 6 +-
.../table/planner/delegation/PlannerBase.scala | 23 ++++++--
.../table/planner/delegation/StreamPlanner.scala | 4 +-
29 files changed, 267 insertions(+), 111 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/delegation/PlannerConfiguration.java
