This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0fa0830 [FLINK-17080][java,table] Fix possible NPE in
Utils#CollectHelper
add 0f83584 [FLINK-17103][table-planner-blink] Supports dynamic options
for Blink planner
No new revisions were added by this update.
Summary of changes:
...ection.html => table_config_configuration.html} | 16 +-
.../src/main/codegen/includes/parserImpls.ftl | 8 +-
.../apache/flink/sql/parser/dml/RichSqlInsert.java | 23 ++
.../flink/sql/parser/FlinkSqlParserImplTest.java | 6 -
.../flink/table/api/config/TableConfigOptions.java | 28 +-
.../flink/table/catalog/CatalogTableImpl.java | 5 +
.../flink/table/catalog/ConnectorCatalogTable.java | 5 +
.../operations/CatalogSinkModifyOperation.java | 13 +-
.../apache/flink/table/catalog/CatalogTable.java | 7 +
.../flink/table/factories/TableSinkFactory.java | 2 +-
.../table/planner/delegation/PlannerContext.java | 2 +
.../table/planner/hint/FlinkHintStrategies.java | 48 ++++
.../flink/table/planner/hint/FlinkHints.java | 70 +++++
.../operations/SqlToOperationConverter.java | 17 +-
.../table/planner/delegation/PlannerBase.scala | 18 +-
.../planner/plan/schema/CatalogSourceTable.scala | 38 ++-
.../planner/plan/schema/TableSourceTable.scala | 37 ++-
.../operations/SqlToOperationConverterTest.java | 34 +++
.../org.apache.flink.table.factories.TableFactory | 1 +
.../table/planner/plan/hint/OptionsHintTest.xml | 303 +++++++++++++++++++++
.../flink/table/api/TableEnvironmentITCase.scala | 2 +-
.../flink/table/api/TableEnvironmentTest.scala | 4 +-
.../table/planner/catalog/CatalogTableITCase.scala | 71 ++++-
.../table/planner/plan/hint/OptionsHintTest.scala | 198 ++++++++++++++
.../runtime/batch/sql/TableSourceITCase.scala | 8 +-
.../runtime/stream/sql/TableSourceITCase.scala | 8 +-
...bleSources.scala => testTableSourceSinks.scala} | 145 +++++++++-
.../table/sqlexec/SqlToOperationConverter.java | 4 +-
28 files changed, 1043 insertions(+), 78 deletions(-)
copy docs/_includes/generated/{security_auth_zk_section.html =>
table_config_configuration.html} (51%)
copy
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptionsInternal.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java
(51%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/hint/FlinkHintStrategies.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/hint/FlinkHints.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/hint/OptionsHintTest.xml
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/hint/OptionsHintTest.scala
rename
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/utils/{testTableSources.scala
=> testTableSourceSinks.scala} (86%)
