Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6283#discussion_r202070020
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/RestartStrategyTest.java
---
@@ -33,12 +33,11 @@
public class RestartStrategyTest extends TestLogger {
/**
- * Tests that in a streaming use case where checkpointing is enabled, a
- * fixed delay with Integer.MAX_VALUE retries is instantiated if no
other restart
- * strategy has been specified.
+ * Tests that in a streaming use case where checkpointing is enabled,
there is no default strategy set on the
+ * client side.
*/
@Test
- public void testAutomaticRestartingWhenCheckpointing() throws Exception
{
+ public void testNoDefaultStrategyOnClientSideWhenCheckpointing() throws
Exception {
--- End diff --
Maybe `testNoDefaultStrategyOnClientSideWhenCheckpointingEnabled`
---
