[FLINK-5165] Checkpointing tests using FsStatebackend fail on Windows

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.1.3
• Fix Version/s: 1.3.0, 1.4.0
• Component/s: Tests
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 25/Nov/16 15:22
• Updated: 11/May/17 14:32
• Resolved: 11/May/17 14:32

Description

testTumblingTimeWindowWithKVStateMinMaxParallelism[StateBackend = FILE](org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase)  Time elapsed: 0.103 sec  <<< ERROR!
java.lang.IllegalArgumentException: Cannot use the root directory for checkpoints.
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.validateAndNormalizeUri(FsStateBackend.java:246)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:155)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:124)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:105)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:86)
        at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.initStateBackend(EventTimeWindowCheckpointingITCase.java:118)

testTumblingTimeWindow[StateBackend = FILE](org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase)  Time elapsed: 0.014 sec  <<< ERROR!
java.lang.IllegalArgumentException: Cannot use the root directory for checkpoints.
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.validateAndNormalizeUri(FsStateBackend.java:246)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:155)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:124)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:105)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:86)
        at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.initStateBackend(EventTimeWindowCheckpointingITCase.java:118)

testTumblingTimeWindowWithKVStateMaxMaxParallelism[StateBackend = FILE](org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase)  Time elapsed: 0.011 sec  <<< ERROR!
java.lang.IllegalArgumentException: Cannot use the root directory for checkpoints.
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.validateAndNormalizeUri(FsStateBackend.java:246)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:155)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:124)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:105)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:86)
        at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.initStateBackend(EventTimeWindowCheckpointingITCase.java:118)

testPreAggregatedTumblingTimeWindow[StateBackend = FILE](org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase)  Time elapsed: 0.005 sec  <<< ERROR!
java.lang.IllegalArgumentException: Cannot use the root directory for checkpoints.
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.validateAndNormalizeUri(FsStateBackend.java:246)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:155)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:124)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:105)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:86)
        at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.initStateBackend(EventTimeWindowCheckpointingITCase.java:118)

testPreAggregatedSlidingTimeWindow[StateBackend = FILE](org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase)  Time elapsed: 0 sec  <<< ERROR!
java.lang.IllegalArgumentException: Cannot use the root directory for checkpoints.
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.validateAndNormalizeUri(FsStateBackend.java:246)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:155)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:124)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:105)
        at org.apache.flink.runtime.state.filesystem.FsStateBackend.<init>(FsStateBackend.java:86)
        at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.initStateBackend(EventTimeWindowCheckpointingITCase.java:118)

This happens because the Path class does not detect Windows paths when a scheme is present.