[flink] branch master updated: [hotfix][streaming] Fix BucketStateSerializerTest on Windows

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 06f8fe8  [hotfix][streaming] Fix BucketStateSerializerTest on Windows
06f8fe8 is described below

commit 06f8fe87421493280f6602aeb73153e677844542
Author: boshu Zheng <blues....@gmail.com>
AuthorDate: Thu Mar 21 19:04:28 2019 +0800

    [hotfix][streaming] Fix BucketStateSerializerTest on Windows
---
 .../api/functions/sink/filesystem/BucketStateSerializerTest.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializerTest.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializerTest.java
index 55360a4..f2c1f8b 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializerTest.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializerTest.java
@@ -115,7 +115,7 @@ public class BucketStateSerializerTest {
                Assert.assertEquals(1L, statuses.length);
                Assert.assertTrue(
                                statuses[0].getPath().getPath().startsWith(
-                                               (new 
Path(testBucket.getParent(), ".test.inprogress")).toString())
+                                               (new 
Path(testBucket.getParent(), ".test.inprogress")).getPath())
                );
        }
 
@@ -184,7 +184,7 @@ public class BucketStateSerializerTest {
 
                for (int i = 0; i < noOfTasks; i++) {
                        for (int j = 0; j < 2 + i; j++) {
-                               final String part = new Path(bucketPath, 
"part-" + i + '-' + j).toString();
+                               final String part = new Path(bucketPath, 
"part-" + i + '-' + j).getPath();
                                Assert.assertTrue(paths.contains(part));
                                paths.remove(part);
                        }
@@ -195,7 +195,7 @@ public class BucketStateSerializerTest {
 
                // verify that the in-progress file is still there
                Assert.assertTrue(paths.iterator().next().startsWith(
-                               (new Path(testBucket.getParent(), 
".test-2.inprogress").toString())));
+                               (new Path(testBucket.getParent(), 
".test-2.inprogress").getPath())));
        }
 
        @Test
@@ -258,7 +258,7 @@ public class BucketStateSerializerTest {
 
                for (int i = 0; i < noOfTasks; i++) {
                        for (int j = 0; j < 2 + i; j++) {
-                               final String part = new Path(bucketPath, 
"test-" + i + '-' + j).toString();
+                               final String part = new Path(bucketPath, 
"test-" + i + '-' + j).getPath();
                                Assert.assertTrue(paths.contains(part));
                                paths.remove(part);
                        }