You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/03/21 11:04:35 UTC
[flink] branch master updated: [hotfix][streaming] Fix
BucketStateSerializerTest on Windows
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 <bl...@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);
}