This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch FLINK-11843
in repository https://gitbox.apache.org/repos/asf/flink.git.
discard 7d36f6a [FLINK-11843] Move DispatcherService into
AbstractDispatcherLeaderProcess
discard cfe2124 [FLINK-11843] Forward shut down future from Dispatcher
through to the DispatcherRunnerImplNG
discard e2fb247 [FLINK-11843] Properly remove job graphs which have been
removed from the JobGraphStore
discard 8a553ba [FLINK-11843] Ignore duplicate job submission due to false
positive onAddedJobGraph callbacks
discard 8e6be09 [FLINK-11843] Delete DispatcherHATest
discard 59097e2 [FLINK-11843] Delete
ZooKeeperHADispatcherTest#testStandbyDispatcherJobRecovery
discard 7153ed9 [FLINK-11843] Remove
ZooKeeperHADispatcherTest#testJobGraphRelease
discard 67501eb [FLINK-11843] Remove
ZooKeeperHADispatcherTest#testStandbyDispatcherJobExecution
discard 11a1fab [FLINK-11843] Remove
DispatcherHATest#testGrantingRevokingLeadership
discard 8150b73 [FLINK-11843] Remove
DispatcherHATest#testJobRecoveryWhenChangingLeadership
discard 71adbf9 [FLINK-11843] Port
DispatcherHATest#testRevokeLeadershipTerminatesJobManagerRunners
discard 6067096 [FLINK-11843] Remove
DispatcherHATest#testFailingRecoveryIsFatalError
discard c69ee95 [FLINK-11843] Pass in explicit JobGraphWriter in
DispatcherTests
discard 2e63b26 [hotfix] Pass in DispatcherServices into TestingDispatcher
discard d0c10fe [FLINK-11843] Port DispatcherResourceCleanupTest
discard 55f4e13 [FLINK-11843] Clean up DispatcherTest
discard cf1bb18 [FLINK-11843] Port DispatcherTest#testJobRecovery
discard f0e7649 [FLINK-11843] Port
DispatcherTest#testJobSubmissionErrorAfterJobRecovery
discard 47da25f [FLINK-11843] Port
DispatcherTest#testFatalErrorAfterJobIdRecoveryFailure
discard 149fba4 [FLINK-11843] Port
DispatcherTest#testFatalErrorAfterJobRecoveryFailure
discard 8a388c9 [FLINK-11843] Port
DispatcherTest#testJobSuspensionWhenDispatcherLosesLeadership
discard ae9134a [FLINK-11843] Remove DispatcherTest#testLeaderElection
discard 8d92fcc [FLINK-11843] Port DispatcherTest
discard 1e7f19e [hotfix] Remove explicit JobGraphWriter from Dispatcher
constructor
discard e0dcfe3 [FLINK-11843] Add proper per-job mode support
discard 065708a [FLINK-11843] Create AbstractDispatcherLeaderProcess
discard ca03a4f [FLINK-11843] Port MiniDispatcherTest to not do leader
election for the MiniDispatcher
discard 207c29c [FLINK-XXXX] Allow MetricNames.NUM_RUNNING_JOBS to be
registered multiple times
discard 27b91a3 [FLINK-XXXX] Support unregistering metrics from
AbstractMetricGroup
discard d7f18e0 [hotfix] Let AbstractMetricGroupTest extend TestLogger
discard 86bb552 [FLINK-11843] Don't close JobManagerMetricGroup in Dispatcher
discard c2a020f [hotfix] Improve ZooKeeperDispatcherRunnerImplTest to use
TestingRpcServiceResource
discard 7892d64 [hotfix] Remove Dispatcher leader retrieval service from
DispatcherRunnerImplTest.testJobRecoveryUnderLeaderChange
discard a75ea9d [hotfix] Improve DispatcherRunnerImplTest to use
TestingRpcServiceResource
discard aea096e [FLINK-11843] Enable DispatcherRunnerImplTest for
DispatcherRunnerImplNG
discard c77cf01 [FLINK-11665] Port ZooKeeperDispatcherRunnerImplTest to use
DispatcherRunnerImplNG
discard f361b52 [hotfix] Enable DispatcherRunnerImplNG
discard ad0d835 [FLINK-11843] Make Dispatcher a PermanentlyFencedRpcEndpoint
discard 9dd1e0b [FLINK-XXXX] Add TriFunctionWithException
discard c84de9e [FLINK-11843] Restrict Dispatcher to only use JobGraphWriter
instead of JobGraphStore
discard e835218 [FLINK-11843] Remove job recovery from Dispatcher
discard 1cedd69 [FLINK-XXXX] Extract JobGraphWriter from JobGraphStore
discard eb4c55c [FLINK-11843] Allow passing collection of recovered jobs to
Dispatcher
discard ee9b7df [FLINK-11843] Remove JobGraphListener from Dispatcher
discard 14ba51a [FLINK-11843] Allow to pass JobGraphStore into Dispatcher via
DispatcherServices
discard b48815b [FLINK-11843] Rename DispatcherFactoryServices into
PartialDispatcherFactoryServices
discard 637b0e7 [FLINK-11843] Add factory implementations
discard 10be004 [FLINK-XXXX] Add JobGraphStoreFactory
discard 8a0281b [hotfix] Fix checkstyle violations in RpcEndpoint
discard d587712 [FLINK-11843] Add DispatcherLeaderProcessImpl
discard 38c0c0e [hotfix] Use simulated self-type idiom in
TestingRestful/DispatcherGateway.Builder
discard f5f0806 [hotfix] Add FutureUtils.completedVoidFuture
discard a0f9363 [FLINK-11843] Add DispatcherRunnerImplNG with
DispatcherLeaderProcess abstraction
discard da2a666 [FLINK-XXXX] Replace LeaderContender#getAddress with
#getDescription
discard a1be7c5 [hotfix] Fix checkstyle violations in LeaderElectionService
discard ed86e96 [FLINK-XXXX] Change LeaderElectionService#confirmLeadership
to accept leader address
discard 168c2e5 [hotfix] Remove Scala Promise from LeaderRetrievalUtils
discard 30d196a [FLINK-XXXX] Move Akka specific parsing out of
LeaderConnectionInfo
discard e3f49ef [FLINK-XXXX] Add test case for FLINK-11843
discard fc8a6ec [FLINK-XXXX] Finish unit test for FLINK-11665
discard 24c8cdd [FLINK-XXXX] Add DispatcherRunnerImplTest
discard 463d0dc Simplify component factories
discard abcd50d Simplify component structure
discard 5c60f33 [FLINK-11843] Add DispatcherRunner
discard 311d2cb [FLINK-XXXX] Extend
DispatcherResourceManagerComponentFactory.create to take ioExecutor
discard fb04121 [FLINK-XXXX] Upgrade InMemoryJobGraphStore to
TestingJobGraphStore
discard 6700861 [FLINK-XXXX] Add PermanentlyFencedRpcEndpoint
discard 58c0abc [FLINK-XXXX] Remove TestingJobManagerRunnerFactory and rename
TestingJobManagerRunnerFactoryNG
discard 87ae286 [FLINK-XXXX] Port DispatcherResourceCleanupTest to use
TestingJobManagerRunnerFactoryNG
discard 1a564e5 [FLINK-XXXX] Replace TestingJobManagerRunnerFactory with
TestingJobManagerRunnerFactoryNG in DispatcherTest
discard d6b0915 [FLINK-XXXX] Port ZooKeeperHaDispatcherTest to use
TestingJobManagerRunnerFactoryNG
discard 22f159eb [FLINK-XXXX] Port DispatcherHATest to use
TetingJobManagerRunnerFactoryNG
discard 4530fd5 [FLINK-XXXX] Port MiniDispatcherTest to use new
TestingJobManagerRunnerFactoryNG
discard d344d6b [FLINK-XXXX] Introduce JobManagerRunner interface
discard 6e9db64 [FLINK-XXXX] Encapsulate Dispatcher services in
DispatcherServices
discard bec55ed [FLINK-XXXX] Add FutureUtils#forward utility
discard 666b633 [hotfix] Remove Exception from
ZooKeeperUtils#createLeaderRetrievalService
discard ec2d970 [FLINK-14205] Return DuplicateJobSubmissionException if
submitted job is a duplicate
add 9015f3f [hotfix][runtime] Remove RestartBackoffTimeStrategyOptions
and use RestartStrategyOptions instead
add 9266f14 [FLINK-12709][runtime] Add NoRestartBackoffTimeStrategy which
suppresses all task restarts
add 13aca92 [FLINK-12709][runtime] Implement
RestartBackoffTimeStrategyFactoryLoader which also respects legacy restart
strategy configs
add 63cdae9 [FLINK-14139][rest] Fix potential memory leak problem of rest
server.
add 0c11dff [FLINK-14183] Remove scala duration usages from FutureUtils
and other related classes
add d528ea0 [FLINK-14183] Remove scala duration usages from
LeaderRetrievalUtils, ConnectionUtils and other related classes
add e8ced9a [FLINK-14183] Remove scala duration usages from TestingUtils
add 8182080 [FLINK-14183] Remove scala duration usages from
MetricRegistryImplTest
add ca56b63 [FLINK-14114][client] Shift down ClusterClient#timeout to
RestClusterClient
add 2b608e3 [FLINK-14016][python][flink-table-planner] Introduce
DataStreamPythonCalc for Python function execution
new 5dfb350 [FLINK-14205] Return DuplicateJobSubmissionException if
submitted job is a duplicate
new 4db921e [hotfix] Remove Exception from
ZooKeeperUtils#createLeaderRetrievalService
new 4d979b3 [FLINK-XXXX] Add FutureUtils#forward utility
new 5cc3fae [FLINK-XXXX] Encapsulate Dispatcher services in
DispatcherServices
new e24fdf7 [FLINK-XXXX] Introduce JobManagerRunner interface
new fd20b14 [FLINK-XXXX] Port MiniDispatcherTest to use new
TestingJobManagerRunnerFactoryNG
new 3f43dc1 [FLINK-XXXX] Port DispatcherHATest to use
TetingJobManagerRunnerFactoryNG
new 352bd5c [FLINK-XXXX] Port ZooKeeperHaDispatcherTest to use
TestingJobManagerRunnerFactoryNG
new 748ff6b [FLINK-XXXX] Replace TestingJobManagerRunnerFactory with
TestingJobManagerRunnerFactoryNG in DispatcherTest
new 21605cc [FLINK-XXXX] Port DispatcherResourceCleanupTest to use
TestingJobManagerRunnerFactoryNG
new c7014b1 [FLINK-XXXX] Remove TestingJobManagerRunnerFactory and rename
TestingJobManagerRunnerFactoryNG
new a2f0420 [FLINK-XXXX] Add PermanentlyFencedRpcEndpoint
new f360aa4 [FLINK-XXXX] Upgrade InMemoryJobGraphStore to
TestingJobGraphStore
new 602fba6 [FLINK-XXXX] Extend
DispatcherResourceManagerComponentFactory.create to take ioExecutor
new 2745b5a [FLINK-11843] Add DispatcherRunner
new 82911d2 Simplify component structure
new e3afaa2 Simplify component factories
new bf88cf0 [FLINK-XXXX] Add DispatcherRunnerImplTest
new 94377ff [FLINK-XXXX] Finish unit test for FLINK-11665
new 6763680 [FLINK-XXXX] Add test case for FLINK-11843
new 5401c31 [FLINK-XXXX] Move Akka specific parsing out of
LeaderConnectionInfo
new f6cf831 [hotfix] Remove Scala Promise from LeaderRetrievalUtils
new 7b9d4ae [FLINK-XXXX] Change LeaderElectionService#confirmLeadership
to accept leader address
new 21b96aa [hotfix] Fix checkstyle violations in LeaderElectionService
new 48e5717 [FLINK-XXXX] Replace LeaderContender#getAddress with
#getDescription
new 56a39b7 [FLINK-11843] Add DispatcherRunnerImplNG with
DispatcherLeaderProcess abstraction
new edc1096 [hotfix] Add FutureUtils.completedVoidFuture
new 9dff2d2 [hotfix] Use simulated self-type idiom in
TestingRestful/DispatcherGateway.Builder
new 529e637 [FLINK-11843] Add DispatcherLeaderProcessImpl
new f7e9172 [hotfix] Fix checkstyle violations in RpcEndpoint
new 8775b0d [FLINK-XXXX] Add JobGraphStoreFactory
new 55996de [FLINK-11843] Add factory implementations
new 478b448 [FLINK-11843] Rename DispatcherFactoryServices into
PartialDispatcherFactoryServices
new 799c5ac [FLINK-11843] Allow to pass JobGraphStore into Dispatcher via
DispatcherServices
new f02a5d3 [FLINK-11843] Remove JobGraphListener from Dispatcher
new ea319a1 [FLINK-11843] Allow passing collection of recovered jobs to
Dispatcher
new fd596f8 [FLINK-XXXX] Extract JobGraphWriter from JobGraphStore
new 0c50c23 [FLINK-11843] Remove job recovery from Dispatcher
new 71df4dd [FLINK-11843] Restrict Dispatcher to only use JobGraphWriter
instead of JobGraphStore
new 2806cae [FLINK-XXXX] Add TriFunctionWithException
new 6ab9bca [FLINK-11843] Make Dispatcher a PermanentlyFencedRpcEndpoint
new 48dfa5f [hotfix] Enable DispatcherRunnerImplNG
new 584972e [FLINK-11665] Port ZooKeeperDispatcherRunnerImplTest to use
DispatcherRunnerImplNG
new 2c0064d [FLINK-11843] Enable DispatcherRunnerImplTest for
DispatcherRunnerImplNG
new 1b30946 [hotfix] Improve DispatcherRunnerImplTest to use
TestingRpcServiceResource
new 4d00154 [hotfix] Remove Dispatcher leader retrieval service from
DispatcherRunnerImplTest.testJobRecoveryUnderLeaderChange
new c4bd79d [hotfix] Improve ZooKeeperDispatcherRunnerImplTest to use
TestingRpcServiceResource
new 76da049 [FLINK-11843] Don't close JobManagerMetricGroup in Dispatcher
new 8555b74 [hotfix] Let AbstractMetricGroupTest extend TestLogger
new a70e332 [FLINK-XXXX] Support unregistering metrics from
AbstractMetricGroup
new 5b55711 [FLINK-XXXX] Allow MetricNames.NUM_RUNNING_JOBS to be
registered multiple times
new 32876f9 [FLINK-11843] Port MiniDispatcherTest to not do leader
election for the MiniDispatcher
new 6493745 [FLINK-11843] Create AbstractDispatcherLeaderProcess
new 1df8f01 [FLINK-11843] Add proper per-job mode support
new 0bee842 [hotfix] Remove explicit JobGraphWriter from Dispatcher
constructor
new fc6f2c7 [FLINK-11843] Port DispatcherTest
new 8ccdf09 [FLINK-11843] Remove DispatcherTest#testLeaderElection
new 767d76f [FLINK-11843] Port
DispatcherTest#testJobSuspensionWhenDispatcherLosesLeadership
new 3af9b14 [FLINK-11843] Port
DispatcherTest#testFatalErrorAfterJobRecoveryFailure
new 4d13eba [FLINK-11843] Port
DispatcherTest#testFatalErrorAfterJobIdRecoveryFailure
new 0eba565 [FLINK-11843] Port
DispatcherTest#testJobSubmissionErrorAfterJobRecovery
new eccd443 [FLINK-11843] Port DispatcherTest#testJobRecovery
new 61cad5d [FLINK-11843] Clean up DispatcherTest
new 924fcbb [FLINK-11843] Port DispatcherResourceCleanupTest
new 808edbd [hotfix] Pass in DispatcherServices into TestingDispatcher
new 935e020 [FLINK-11843] Pass in explicit JobGraphWriter in
DispatcherTests
new bda20f5 [FLINK-11843] Remove
DispatcherHATest#testFailingRecoveryIsFatalError
new 0598446 [FLINK-11843] Port
DispatcherHATest#testRevokeLeadershipTerminatesJobManagerRunners
new ff2dcb0 [FLINK-11843] Remove
DispatcherHATest#testJobRecoveryWhenChangingLeadership
new 48a9209 [FLINK-11843] Remove
DispatcherHATest#testGrantingRevokingLeadership
new 2c926e7 [FLINK-11843] Remove
ZooKeeperHADispatcherTest#testStandbyDispatcherJobExecution
new 625b19b [FLINK-11843] Remove
ZooKeeperHADispatcherTest#testJobGraphRelease
new 069039f [FLINK-11843] Delete
ZooKeeperHADispatcherTest#testStandbyDispatcherJobRecovery
new 80d3a32 [FLINK-11843] Delete DispatcherHATest
new 20d6661 [FLINK-11843] Ignore duplicate job submission due to false
positive onAddedJobGraph callbacks
new ea6c8f5 [FLINK-11843] Properly remove job graphs which have been
removed from the JobGraphStore
new d9d2b68 [FLINK-11843] Forward shut down future from Dispatcher
through to the DispatcherRunnerImplNG
new dbbf791 [FLINK-11843] Move DispatcherService into
AbstractDispatcherLeaderProcess
new 2a0bf74 [FLINK-11843] Remove old DispatcherRunnerImpl and
DispatcherRunnerFactoryImpl
new 454ff36 [hotfix] Improve logging in DispatcherResourceManagerComponent
new dfa4e33 [FLINK-11843] Rename various newly introduced classes
new 5c70d0c [FLINK-11843] Move
DispatcherRunnerImplTest#testJobRecoveryUnderLeaderChange to
DefaultDispatcherRunnerITCase
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 (7d36f6a)
\
N -- N -- N refs/heads/FLINK-11843 (5c70d0c)
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.
The 82 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
...estart_backoff_time_strategy_configuration.html | 36 ----
.../apache/flink/client/program/ClusterClient.java | 7 +-
.../client/program/rest/RestClusterClient.java | 8 +
.../RestartBackoffTimeStrategyOptions.java | 74 -------
.../webmonitor/LeaderRetrievalHandlerTest.java | 8 +-
.../runtime/webmonitor/WebFrontendITCase.java | 29 +--
.../webmonitor/testutils/HttpTestClient.java | 13 +-
.../flink/runtime/concurrent/FutureUtils.java | 22 +-
.../flink/runtime/dispatcher/Dispatcher.java | 2 +-
...nerImplNG.java => DefaultDispatcherRunner.java} | 6 +-
...ry.java => DefaultDispatcherRunnerFactory.java} | 18 +-
...viceImpl.java => DefaultDispatcherService.java} | 8 +-
...y.java => DefaultDispatcherServiceFactory.java} | 8 +-
.../runner/DispatcherRunnerFactoryImpl.java | 56 -----
.../dispatcher/runner/DispatcherRunnerImpl.java | 97 ---------
.../JobDispatcherLeaderProcessFactoryFactory.java | 4 +-
...pl.java => SessionDispatcherLeaderProcess.java} | 8 +-
... => SessionDispatcherLeaderProcessFactory.java} | 8 +-
...ssionDispatcherLeaderProcessFactoryFactory.java | 6 +-
.../runner/StoppedDispatcherLeaderProcess.java | 2 +-
.../DispatcherResourceManagerComponent.java | 7 +
...bDispatcherResourceManagerComponentFactory.java | 4 +-
...nDispatcherResourceManagerComponentFactory.java | 4 +-
.../FailureRateRestartBackoffTimeStrategy.java | 32 ++-
.../FixedDelayRestartBackoffTimeStrategy.java | 24 ++-
.../flip1/NoRestartBackoffTimeStrategy.java | 63 ++++++
.../RestartBackoffTimeStrategyFactoryLoader.java | 139 ++++++++++++
...CheckpointingEnabledRestartStrategyFactory.java | 6 +-
.../apache/flink/runtime/net/ConnectionUtils.java | 13 +-
.../flink/runtime/rest/FileUploadHandler.java | 11 +
.../runtime/taskexecutor/TaskManagerRunner.java | 3 +-
.../flink/runtime/util/LeaderRetrievalUtils.java | 43 +---
.../flink/runtime/dispatcher/DispatcherTest.java | 4 +-
...ase.java => DefaultDispatcherRunnerITCase.java} | 94 +++++++-
...GTest.java => DefaultDispatcherRunnerTest.java} | 30 +--
.../runner/DispatcherRunnerImplTest.java | 206 ------------------
...ava => SessionDispatcherLeaderProcessTest.java} | 38 ++--
...a => ZooKeeperDefaultDispatcherRunnerTest.java} | 10 +-
...estartBackoffTimeStrategyFactoryLoaderTest.java | 179 ++++++++++++++++
.../LeaderChangeClusterComponentsTest.java | 7 +-
.../ZooKeeperLeaderRetrievalTest.java | 12 +-
.../runtime/metrics/MetricRegistryImplTest.java | 5 +-
.../runtime/minicluster/TestingMiniCluster.java | 4 +-
.../flink/runtime/rest/FileUploadHandlerTest.java | 34 +++
.../flink/runtime/rpc/akka/AkkaRpcActorTest.java | 4 +-
.../flink/runtime/testingUtils/TestingUtils.scala | 6 +-
.../flink/table/functions/FunctionDefinition.java | 7 +
.../flink/table/functions/FunctionLanguage.java | 32 +++
.../apache/flink/table/calcite/CalciteConfig.scala | 31 +++
.../org/apache/flink/table/plan/Optimizer.scala | 39 ++++
.../apache/flink/table/plan/StreamOptimizer.scala | 4 +-
.../apache/flink/table/plan/nodes/CommonCalc.scala | 1 -
.../table/plan/nodes/dataset/DataSetCalc.scala | 1 -
.../plan/nodes/datastream/DataStreamCalc.scala | 43 +---
.../DataStreamCalcBase.scala} | 67 +-----
.../nodes/datastream/DataStreamPythonCalc.scala | 68 ++++++
.../flink/table/plan/rules/FlinkRuleSets.scala | 10 +-
.../plan/rules/datastream/DataStreamCalcRule.scala | 15 +-
...lcRule.scala => DataStreamPythonCalcRule.scala} | 25 ++-
.../logical/PythonScalarFunctionSplitRule.scala | 211 ++++++++++++++++++
.../apache/flink/table/plan/util/PythonUtil.scala | 68 ++++++
.../table/calcite/CalciteConfigBuilderTest.scala | 55 +++++
.../plan/PythonScalarFunctionSplitRuleTest.scala | 238 +++++++++++++++++++++
.../recovery/ProcessFailureCancelingITCase.java | 4 +-
64 files changed, 1532 insertions(+), 789 deletions(-)
delete mode 100644
docs/_includes/generated/restart_backoff_time_strategy_configuration.html
delete mode 100644
flink-core/src/main/java/org/apache/flink/configuration/RestartBackoffTimeStrategyOptions.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherRunnerImplNG.java
=> DefaultDispatcherRunner.java} (97%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherRunnerImplNGFactory.java
=> DefaultDispatcherRunnerFactory.java} (79%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherServiceImpl.java
=> DefaultDispatcherService.java} (86%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherServiceImplFactory.java
=> DefaultDispatcherServiceFactory.java} (90%)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunnerFactoryImpl.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunnerImpl.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherLeaderProcessImpl.java
=> SessionDispatcherLeaderProcess.java} (97%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherLeaderProcessImplFactory.java
=> SessionDispatcherLeaderProcessFactory.java} (88%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/NoRestartBackoffTimeStrategy.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartBackoffTimeStrategyFactoryLoader.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherRunnerImplNGITCase.java
=> DefaultDispatcherRunnerITCase.java} (57%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherRunnerImplNGTest.java
=> DefaultDispatcherRunnerTest.java} (93%)
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunnerImplTest.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/{DispatcherLeaderProcessImplTest.java
=> SessionDispatcherLeaderProcessTest.java} (90%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/{ZooKeeperDispatcherRunnerImplTest.java
=> ZooKeeperDefaultDispatcherRunnerTest.java} (96%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartBackoffTimeStrategyFactoryLoaderTest.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionLanguage.java
copy
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/{dataset/DataSetCalc.scala
=> datastream/DataStreamCalcBase.scala} (51%)
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamPythonCalc.scala
copy
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/datastream/{DataStreamCalcRule.scala
=> DataStreamPythonCalcRule.scala} (69%)
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonScalarFunctionSplitRule.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/PythonUtil.scala
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/PythonScalarFunctionSplitRuleTest.scala
