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