Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r75086698
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -70,6 +70,85 @@ public void testCopyFromLocal()
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r75086582
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74982416
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74974171
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74961561
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74957429
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74776047
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -70,6 +70,85 @@ public void
Github user cresny commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74774950
--- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ---
@@ -255,4 +257,33 @@ private Utils() {
}
return result;
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743404
--- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ---
@@ -255,4 +257,33 @@ private Utils() {
}
return result;
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743303
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -70,6 +70,85 @@ public void testCopyFromLocal()
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743269
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -19,18 +19,18 @@
import
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743234
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743009
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74742684
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -46,12 +47,13 @@ public void run() {
GitHub user cresny opened a pull request:
https://github.com/apache/flink/pull/2288
Feature/s3 a fix
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items into
15 matches
Mail list logo