Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r204233444
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java
---
@@ -0,0 +1,252 @@
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r204232617
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r204231919
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java
---
@@ -0,0 +1,252 @@
Github user sagarl commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200217627
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java
---
@@ -0,0 +1,252 @@
+/*
Github user sagarl commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200217021
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java
---
@@ -0,0 +1,252 @@
+/*
Github user yuruiz commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r201630927
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200892031
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200890648
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200889912
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200889601
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200888987
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -54,6 +54,14 @@ under the License.
true
+
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200888235
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200879243
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200879624
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200878724
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -54,6 +54,14 @@ under the License.
true
+
Github user wgtmac commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200879775
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Soft
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200833563
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200831458
--- Diff:
flink-connectors/flink-orc/src/test/java/org/apache/flink/orc/OrcFileWriterTest.java
---
@@ -0,0 +1,40 @@
+/**
+ * Licensed to the Ap
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200831360
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830833
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830078
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830111
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830013
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830153
--- Diff:
flink-connectors/flink-orc/src/test/java/org/apache/flink/orc/OrcFileWriterTest.java
---
@@ -0,0 +1,40 @@
+/**
+ * Licensed to the Apache So
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6075
[FLINK-9407] [hdfs connector] Support orc rolling sink writer
## What is the purpose of the change
In production environment, we often write file in orc format. So, this PR
support a writer
25 matches
Mail list logo