- 29 1月, 2019 2 次提交
- 28 1月, 2019 7 次提交
-
-
由 Till Rohrmann 提交于
The lifecycle methods should not have a RPC timeout. Instead the implementations now use the RpcUtils#INF_TIMEOUT as the timeout.
-
由 Till Rohrmann 提交于
For a better separation of concerns in the JobManagerRunner, this commit introduces a JobMasterService which only exposes the JobMaster's lifecycle methods to the JobManagerRunner. This allows for an easier substitution when testing the JobManagerRunner. This closes #7563.
-
由 Benchao Li 提交于
-
由 leesf 提交于
-
由 Yun Tang 提交于
This closes #7544.
-
由 Aljoscha Krettek 提交于
We add this with the hope of finding clues about FLINK-9920.
-
由 Dawid Wysakowicz 提交于
-
- 26 1月, 2019 5 次提交
-
-
由 Gary Yao 提交于
-
由 Gary Yao 提交于
This closes #7486.
-
由 tison 提交于
-
由 Andrey Zagrebin 提交于
Test non concurrent access of StateSnapshotTransformer Refactor out testNonConcurrentSnapshotTransformerAccess to separte StateSnapshotTransformerTest use element serializer from new meta info, duplicate it in rocksdb transformer factory, test concurrent access for element serializer This closes #7320.
-
由 Gary Yao 提交于
Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to flip6 codebase: * Remove assertions that rely on log messages only * Move part where TMs are killed to YARNHighAvailabilityITCase * Rename test to a proper name that describes what it does * Add Javadoc explaning what this test does [FLINK-11390][tests] Move comment to right position [FLINK-11390][tests] Reuse YarnClient from super class Move waitUntilCondition to YarnTestBase [FLINK-11390][tests] Extract method parse hostname Extract method getOnlyApplicationReport Extract method submitJob Extract method getNumberOfSlotsPerTaskManager Extract method getFlinkConfigFromRestApi Delete useless comment Rename: runner -> yarnSessionClusterRunner Delete useless sleep & refactor Reorder methods and add static keyword where possible This closes #7546.
-
- 25 1月, 2019 7 次提交
-
-
由 klion26 提交于
Summary: This patch add the ability about uploading state files using multithread when snapshoting. Differential Revision: https://aone.alibaba-inc.com/code/D818724 This closes #7351.
-
由 Till Rohrmann 提交于
- Moved JobManagerHARecoveryTest#testJobRecoveryWhenLosingLeadership to DispatcherHATest#testJobRecoveryWhenChangingLeadership - Moved JobManagerHARecoveryTest#testFailingJobRecovery to DispatcherHATest#testFailingRecoveryIsAFatalError This closes #7539.
-
由 Till Rohrmann 提交于
The builder creates a TestingHighAvailabilityServices with the standalone implementation of the individual services.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
- 24 1月, 2019 8 次提交
-
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
This commit slightly refactors and cleans up the handling of over sized messages. This closes #6876.
-
由 yanghua 提交于
-
由 Till Rohrmann 提交于
Removed testClientNonDetachedListeningBehaviour because the test was only relevant for the JobClientActor. Moved testJobPersistencyWhenJobManagerShutdown to DispatcherHATest#testPersistedJobGraphWhenDispatcherIsShutDown. This closes #7526.
-
由 Till Rohrmann 提交于
- Moved JobManagerStartupTest#testStartupWithPortInUse to BootstrapToolsTest#testActorSystemInstantiationFailureWhenPortOccupied - Moved JobManagerStartupTest#testJobManagerStartupFails to BlobServerTest#testFailureIfStorageDirectoryCannotBeCreated This closes #7541.
-
由 Till Rohrmann 提交于
-
由 Thomas Weise 提交于
-
由 zhijiang 提交于
[FLINK-11282][network] Merge StreamRecordWriter into RecordWriter
-
- 23 1月, 2019 8 次提交
-
-
由 libenchao 提交于
This closes #7569
-
由 Gary Yao 提交于
Port YARNSessionCapacitySchedulerITCase#testClientStartup to new flip6 codebase. Rename test to testStartYarnSessionClusterInQaTeamQueue. Remove -n command line parameter & argument.
-
由 Till Rohrmann 提交于
The JobManagerProcessReapingTest is no longer relevant since we don't start a ProcessReaper as it used to be the case in the legacy mode.
-
由 Till Rohrmann 提交于
This commit renames JobManagerCleanupITCase into BlobsCleanupITCase and uses the MiniCluster instead of the TestingCluster to execute the tests. This closes #7524.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #7553.
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
Those tests were implemented before we had the state schema evolution feature in Flink 1.7, and were implemented using the old legacy serialization compatibility APIs. Moreoever, the behaviours that they test are already more comprehensively covered in StateBackendMigrationTestBase.
-
由 Tzu-Li (Gordon) Tai 提交于
[FLINK-11328] [cep] Snapshots of NFA-related serializers should be a CompositeTypeSerializerSnapshot
-
- 22 1月, 2019 1 次提交
-
-
由 Tzu-Li (Gordon) Tai 提交于
[FLINK-11328] [core] Upgrade parameterless / singleton serializers to use new serialization compatibility APIs
-
- 21 1月, 2019 1 次提交
-
-
由 Timo Walther 提交于
-
- 19 1月, 2019 1 次提交
-
-
由 sunhaibotb 提交于
This closes #7403
-