[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-27 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r213064055 ## File path: pulsar-io/hdfs/src/main/java/org/apache/pulsar/io/hdfs/AbstractHdfsConfig.java ## @@ -0,0 +1,87 @@

[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-23 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r212455850 ## File path: tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/HdfsContainer.java ##

[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-23 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r212455767 ## File path: pulsar-io/hdfs/src/test/java/org/apache/pulsar/io/hdfs/sink/HdfsSinkConfigTests.java ## @@ -0,0

[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-23 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r212455521 ## File path: pulsar-io/hdfs/src/main/java/org/apache/pulsar/io/hdfs/AbstractHdfsConfig.java ## @@ -0,0 +1,172 @@

[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-23 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r212455382 ## File path: pulsar-io/hdfs/src/main/java/org/apache/pulsar/io/hdfs/AbstractHdfsConfig.java ## @@ -0,0 +1,172 @@

[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-23 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r212455416 ## File path: pulsar-io/hdfs/src/main/java/org/apache/pulsar/io/hdfs/AbstractHdfsConfig.java ## @@ -0,0 +1,172 @@

[GitHub] david-streamlio commented on a change in pull request #2409: Added HDFS Sink

2018-08-23 Thread GitBox
david-streamlio commented on a change in pull request #2409: Added HDFS Sink URL: https://github.com/apache/incubator-pulsar/pull/2409#discussion_r212455487 ## File path: pulsar-io/hdfs/src/main/java/org/apache/pulsar/io/hdfs/AbstractHdfsConfig.java ## @@ -0,0 +1,172 @@