azagrebin commented on a change in pull request #14199:
URL: https://github.com/apache/flink/pull/14199#discussion_r532397107
##########
File path:
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/FileSourceTextLinesITCase.java
##########
@@ -61,20 +82,83 @@
@ClassRule
public static final TemporaryFolder TMP_FOLDER = new TemporaryFolder();
- @ClassRule
- public static final MiniClusterWithClientResource MINI_CLUSTER = new
MiniClusterWithClientResource(
- new MiniClusterResourceConfiguration.Builder()
- .setNumberTaskManagers(1)
- .setNumberSlotsPerTaskManager(PARALLELISM)
- .build());
+ private static TestingMiniCluster miniCluster;
- //
------------------------------------------------------------------------
+ private static TestingEmbeddedHaServices highAvailabilityServices;
+
+ private static CompletedCheckpointStore checkpointStore;
+
+ @BeforeClass
+ public static void setupClass() throws Exception {
+ highAvailabilityServices = new
HaServices(TestingUtils.defaultExecutor(),
+ () -> checkpointStore,
+ new StandaloneCheckpointIDCounter());
+
+ final Configuration configuration = createConfiguration();
+
+ miniCluster = new TestingMiniCluster(
+ new TestingMiniClusterConfiguration.Builder()
+ .setConfiguration(configuration)
+ .setNumTaskManagers(1)
+ .setNumSlotsPerTaskManager(PARALLELISM)
+
.setRpcServiceSharing(RpcServiceSharing.DEDICATED)
+ .build(),
+ () -> highAvailabilityServices);
+
+ miniCluster.start();
+ }
+
+ private static Configuration createConfiguration() throws IOException {
+ final Configuration configuration = new Configuration();
+ configuration.set(CheckpointingOptions.STATE_BACKEND,
"filesystem");
Review comment:
I think, we can remove `filesystem`. I think it is just a leftover from
my experiments that the checkpoint data stays available between fail-overs.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
