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