This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 00f2c62  [FLINK-25817] Unify logic between TaskExecutor.requestSlot 
and TaskExecutor.tryLoadLocalAllocationSnapshots
     add e921c4c  [FLINK-25984][core] Remove deprecated API usages

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/connectors/hive/HiveOptions.java  |  3 ++
 .../apache/flink/configuration/AkkaOptions.java    |  3 ++
 .../flink/configuration/AlgorithmOptions.java      |  4 ++
 .../flink/configuration/BlobServerOptions.java     | 10 ++++
 .../flink/configuration/CheckpointingOptions.java  |  5 ++
 .../apache/flink/configuration/ClusterOptions.java |  6 +++
 .../flink/configuration/ConfigConstants.java       |  4 +-
 .../apache/flink/configuration/CoreOptions.java    | 25 ++++++++--
 .../configuration/HeartbeatManagerOptions.java     |  2 +
 .../configuration/HighAvailabilityOptions.java     | 13 ++++++
 .../flink/configuration/HistoryServerOptions.java  |  8 ++++
 .../flink/configuration/JMXServerOptions.java      |  1 +
 .../flink/configuration/JobManagerOptions.java     | 11 +++++
 .../apache/flink/configuration/MetricOptions.java  | 18 ++++++++
 .../NettyShuffleEnvironmentOptions.java            | 24 +++++++++-
 .../flink/configuration/OptimizerOptions.java      |  3 ++
 .../flink/configuration/QueryableStateOptions.java |  8 ++++
 .../configuration/ResourceManagerOptions.java      |  7 +++
 .../apache/flink/configuration/RestOptions.java    | 13 ++++++
 .../configuration/RestartStrategyOptions.java      |  2 +
 .../org/apache/flink/configuration/WebOptions.java | 17 ++++++-
 .../flink/configuration/ConfigOptionTest.java      | 10 +++-
 .../flink/configuration/ConfigurationTest.java     | 38 +++++++++++-----
 .../tests/DataStreamAllroundTestJobFactory.java    | 53 ++++++++++++++++------
 .../HeavyDeploymentStressTestProgram.java          |  5 +-
 .../NettyShuffleMemoryControlTestProgram.java      |  3 ++
 .../flink/streaming/tests/TtlTestConfig.java       | 12 +++--
 .../tests/StatefulStreamJobUpgradeTestProgram.java |  1 +
 .../fs/s3/common/AbstractS3FileSystemFactory.java  |  4 ++
 .../metrics/influxdb/InfluxdbReporterOptions.java  | 12 ++++-
 .../PrometheusPushGatewayReporterOptions.java      |  7 +++
 .../org/apache/flink/python/PythonOptions.java     | 10 ++++
 .../runtime/clusterframework/BootstrapTools.java   |  2 +-
 .../runtime/entrypoint/ClusterEntrypoint.java      |  1 +
 .../component/FileJobGraphRetriever.java           |  2 +-
 .../runtime/shuffle/ShuffleServiceOptions.java     |  1 +
 .../state/RocksDBNativeMetricOptions.java          | 22 +++++++++
 .../table/api/config/ExecutionConfigOptions.java   | 10 ++++
 .../table/api/config/OptimizerConfigOptions.java   | 10 ++++
 .../planner/plan/metadata/FlinkRelMdRowCount.scala |  1 +
 .../table/planner/plan/optimize/RelNodeBlock.scala |  2 +
 .../rules/logical/JoinDeriveNullFilterRule.scala   |  1 +
 .../physical/batch/BatchPhysicalJoinRuleBase.scala |  6 ++-
 .../batch/BatchPhysicalSortMergeJoinRule.scala     |  1 +
 .../physical/batch/BatchPhysicalSortRule.scala     |  1 +
 .../physical/stream/IncrementalAggregateRule.scala |  1 +
 .../table/planner/plan/utils/FlinkRexUtil.scala    |  5 +-
 .../planner/plan/utils/WindowEmitStrategy.scala    |  2 +
 48 files changed, 359 insertions(+), 51 deletions(-)

Reply via email to