You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/11/12 10:10:13 UTC
[flink] branch FLINK-14651 updated (1657e4d -> 31de348)
This is an automated email from the ASF dual-hosted git repository.
gary pushed a change to branch FLINK-14651
in repository https://gitbox.apache.org/repos/asf/flink.git.
discard 1657e4d fix test_queryable_state_restart_tm
discard 021a0fd Ignore exception JobException: Recovery is suppressed by
discard ba2a267 Ignore RegionFailoverITCase#testMultiRegionFailover
discard daefe6e Ignore AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure
discard 26dc7b0 Ignore failing YARN tests
discard d5d3d09 [FLINK-14651][runtime] Fix Kafka08ITCase#testFailOnNoBroker
discard 16d578e [FLINK-14651][runtime] Fix SchedulerNGFactoryFactoryTest#createLegacySchedulerFactoryByDefault
discard 4594bbe [FLINK-14651][runtime] Fix KafkaConsumerTestBase#runFailOnNoBrokerTest
discard 3e9879e [FLINK-14651][travis] Disable scheduler_ng Travis stages
discard 705ae78 [FLINK-14636][runtime] Remove NoOpFailoverStrategy
discard 788f4bf [FLINK-14600][runtime] Enable DefaultScheduler by default
discard 9733b22 Temporarily disable notifications from TravisCI
add 0f33630 [FLINK-14374][runtime] Expose scheduler type constants in SchedulerNGFactoryFactory
add 6aa0a67 [FLINK-14374][runtime,tests] Run RegionFailoverITCase also with DefaultScheduler enabled
add 7baf6875 [hotfix][docs] Fix broken table that describes 'numberOfRestarts' metric
add 51c2421 [hotfix][runtime] Rename metric 'numberOfRestarts' to 'numRestarts'
add 644d658 [FLINK-14164][runtime] Make metric 'fullRestarts' compatible with NG scheduler
add 658cea3 [FLINK-14660][sql cli] add 'SHOW MODULES' to SQL CLI
add 767bf99 [FLINK-14420][doc] Add documentation for pluggable module
add 55686bc [FLINK-14656][table-planner-blink] blink planner should also fetch catalog statistics for permanent table (#10119)
add 98456ea Temporarily disable notifications from TravisCI
add ba4ce49 [FLINK-14600][runtime] Enable DefaultScheduler by default
add bee2e02 [FLINK-14636][runtime] Remove NoOpFailoverStrategy
add e9e1999 [FLINK-14651][travis] Disable scheduler_ng Travis stages
add fd5483b [FLINK-14651][runtime] Fix KafkaConsumerTestBase#runFailOnNoBrokerTest
add 598086e [FLINK-14651][runtime] Fix SchedulerNGFactoryFactoryTest#createLegacySchedulerFactoryByDefault
add ad66442 [FLINK-14651][runtime] Fix Kafka08ITCase#testFailOnNoBroker
add 55b304e Ignore AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure
add 4ccc8d7 Ignore exception JobException: Recovery is suppressed by
add 31de348 fix test_queryable_state_restart_tm
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (1657e4d)
\
N -- N -- N refs/heads/FLINK-14651 (31de348)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
docs/dev/table/hive/hive_functions.md | 36 ++++++
docs/dev/table/hive/hive_functions.zh.md | 36 ++++++
docs/dev/table/modules.md | 126 +++++++++++++++++++++
docs/dev/table/modules.zh.md | 126 +++++++++++++++++++++
docs/monitoring/metrics.md | 6 +-
docs/monitoring/metrics.zh.md | 6 +-
.../dispatcher/SchedulerNGFactoryFactory.java | 13 ++-
.../executiongraph/ExecutionGraphBuilder.java | 2 -
.../metrics/NumberOfFullRestartsGauge.java | 47 --------
.../apache/flink/runtime/metrics/MetricNames.java | 3 +-
.../flink/runtime/scheduler/SchedulerBase.java | 5 +-
.../apache/flink/table/client/cli/CliClient.java | 20 ++++
.../flink/table/client/cli/SqlCommandParser.java | 4 +
.../flink/table/client/gateway/Executor.java | 5 +
.../table/client/gateway/local/LocalExecutor.java | 9 ++
.../flink/table/client/cli/CliClientTest.java | 5 +
.../flink/table/client/cli/CliResultViewTest.java | 5 +
.../planner/catalog/DatabaseCalciteSchema.java | 18 +--
.../planner/catalog/CatalogStatisticsTest.java | 105 +++++++++++++----
.../resources/explain/testGetStatsFromCatalog.out | 32 ------
.../test/checkpointing/RegionFailoverITCase.java | 32 +++++-
.../ZooKeeperHighAvailabilityITCase.java | 4 +-
.../flink/yarn/YARNHighAvailabilityITCase.java | 3 -
23 files changed, 518 insertions(+), 130 deletions(-)
create mode 100644 docs/dev/table/modules.md
create mode 100644 docs/dev/table/modules.zh.md
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/metrics/NumberOfFullRestartsGauge.java
delete mode 100644 flink-table/flink-table-planner-blink/src/test/resources/explain/testGetStatsFromCatalog.out