You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/07/17 11:49:51 UTC
[flink] branch master updated (2efb89a -> a1b1758)
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 2efb89a [FLINK-13307][tests] Fix SourceStreamTaskTest test instability.
add a1b1758 [FLINK-13168][table] Clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner
No new revisions were added by this update.
Summary of changes:
.../java/internal/StreamTableEnvironmentImpl.java | 10 ++--
.../flink/table/api/EnvironmentSettings.java | 26 +++++-----
.../table/api/internal/TableEnvironmentImpl.java | 24 +++++----
.../flink/table/catalog/ConnectorCatalogTable.java | 2 +
.../operations/TableSourceQueryOperation.java | 1 +
.../operations/utils/OperationTreeBuilder.java | 8 +--
.../utils/factories/AggregateOperationFactory.java | 8 +--
.../utils/factories/SetOperationFactory.java | 8 +--
.../utils/factories/SortOperationFactory.java | 8 +--
.../factories/ComponentFactoryServiceTest.java | 4 +-
.../table/factories/utils/TestPlannerFactory.java | 2 +-
.../internal/StreamTableEnvironmentImpl.scala | 2 +-
.../flink/table/catalog/CatalogCalciteSchema.java | 7 ++-
.../table/catalog/CatalogManagerCalciteSchema.java | 7 ++-
.../flink/table/catalog/DatabaseCalciteSchema.java | 34 +++++++++----
.../flink/table/executor/BlinkExecutorFactory.java | 8 +--
.../table/operations/DataStreamQueryOperation.java | 2 +
.../operations/RichTableSourceQueryOperation.java | 13 +++--
.../flink/table/planner/BlinkPlannerFactory.java | 8 +--
.../PushFilterIntoTableSourceScanRule.scala | 2 +-
.../PushPartitionIntoTableSourceScanRule.scala | 2 +-
.../PushProjectIntoTableSourceScanRule.scala | 2 +-
.../table/plan/schema/TableSourceSinkTable.scala | 12 -----
.../flink/table/plan/schema/TableSourceTable.scala | 12 +++--
.../apache/flink/table/planner/BatchPlanner.scala | 2 +-
.../apache/flink/table/planner/PlannerBase.scala | 7 ++-
.../apache/flink/table/planner/StreamPlanner.scala | 2 +-
.../plan/nodes/resource/MockNodeTestBase.java | 26 +++++-----
.../parallelism/FinalParallelismSetterTest.java | 6 +--
.../parallelism/ShuffleStageGeneratorTest.java | 6 +--
.../flink/table/plan/batch/sql/TableSourceTest.xml | 16 ++++++
.../plan/nodes/resource/ExecNodeResourceTest.xml | 16 +++---
.../table/plan/stream/sql/TableSourceTest.xml | 32 ++++++++++++
.../flink/table/catalog/CatalogTableITCase.scala | 8 +--
.../flink/table/codegen/agg/AggTestBase.scala | 4 +-
.../codegen/agg/AggsHandlerCodeGeneratorTest.scala | 2 +-
.../table/codegen/agg/batch/BatchAggTestBase.scala | 2 +-
.../table/plan/batch/sql/TableSourceTest.scala | 42 ++++++++++++++--
.../plan/nodes/resource/ExecNodeResourceTest.scala | 18 +++----
.../table/plan/stream/sql/TableSourceTest.scala | 37 +++++++++++++-
.../apache/flink/table/util/TableTestBase.scala | 57 +++++++++++-----------
.../apache/flink/table/util/testTableSources.scala | 34 ++++++-------
.../flink/table/catalog/CatalogCalciteSchema.java | 8 +--
.../table/catalog/CatalogManagerCalciteSchema.java | 10 ++--
.../flink/table/catalog/DatabaseCalciteSchema.java | 8 +--
.../table/executor/StreamExecutorFactory.java | 2 +-
.../flink/table/planner/StreamPlannerFactory.java | 2 +-
.../flink/table/api/internal/TableEnvImpl.scala | 22 +++++----
.../table/catalog/ExternalCatalogSchema.scala | 11 +++--
.../flink/table/catalog/ExternalTableUtil.scala | 14 +++---
.../logical/FlinkLogicalTableSourceScan.scala | 2 +-
.../rules/dataSet/BatchTableSourceScanRule.scala | 2 +-
.../datastream/StreamTableSourceScanRule.scala | 2 +-
.../flink/table/plan/schema/TableSourceTable.scala | 8 ++-
.../apache/flink/table/planner/StreamPlanner.scala | 2 +-
.../table/catalog/DatabaseCalciteSchemaTest.java | 4 +-
.../table/catalog/ExternalCatalogSchemaTest.scala | 2 +-
57 files changed, 386 insertions(+), 242 deletions(-)