Timo Walther created FLINK-8129:
---
Summary: Add a union type
Key: FLINK-8129
URL: https://issues.apache.org/jira/browse/FLINK-8129
Project: Flink
Issue Type: New Feature
Components:
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262178#comment-16262178
]
Xingcan Cui commented on FLINK-7797:
Hi [~fhueske], I'd like to work on it. :D
> Add support for
Fabian Hueske created FLINK-8128:
Summary: Add Latency/Throughput Section to Table API / SQL docs
Key: FLINK-8128
URL: https://issues.apache.org/jira/browse/FLINK-8128
Project: Flink
Issue
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r152513656
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -301,81 +306,388 @@
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262225#comment-16262225
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7716:
---
Assignee: Gary Yao (was: Hai Zhou UTC+8)
> Port JobManagerMetricsHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-7717:
---
Assignee: Gary Yao (was: Hai Zhou UTC+8)
> Port TaskManagerMetricsHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262171#comment-16262171
]
Fabian Hueske commented on FLINK-7797:
--
[~xccui], you implemented the INNER JOIN. Do you want to work
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262199#comment-16262199
]
Fabian Hueske commented on FLINK-6101:
--
Thanks for working on this [~lincoln.86xy]!
I think support
[
https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262211#comment-16262211
]
Fabian Hueske commented on FLINK-8118:
--
Hi [~xccui],
1. I think offsets should be configured via the
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-7797:
Assignee: Xingcan Cui
> Add support for windowed outer joins for streaming tables
>
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262185#comment-16262185
]
Fabian Hueske commented on FLINK-7797:
--
Excellent! Thank you! :-)
> Add support for windowed outer
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262244#comment-16262244
]
Konstantin Lalafaryan commented on FLINK-7913:
--
[~aljoscha], [~tzulitai] do you have an
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5041
---
[
https://issues.apache.org/jira/browse/FLINK-8117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262182#comment-16262182
]
ASF GitHub Bot commented on FLINK-8117:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262218#comment-16262218
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r152512614
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -301,81 +306,388 @@
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4946
Thanks, @greghogan . I will make a first refinement based on your
suggestions.
---
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263442#comment-16263442
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user asfgit closed the pull request at:
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/5040
Thanks for the prompt review @twalthr . Yeah I think generalizing the
codegen part would be great.
Also do you think I can put in TableAPI support in this PR as well? I will
update the
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263600#comment-16263600
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user walterddr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263443#comment-16263443
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263755#comment-16263755
]
lincoln.lee commented on FLINK-6101:
[~fhueske] Agree with you that SQL is not perfect. But in this
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4670
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5043
---
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16263669#comment-16263669
]
ASF GitHub Bot commented on FLINK-7967:
---
Github user zhangminglei commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152528590
--- Diff: docs/concepts/runtime.md ---
@@ -28,10 +28,10 @@ under the License.
## Tasks and Operator Chains
-For distributed execution,
[
https://issues.apache.org/jira/browse/FLINK-8130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-8130:
---
Fix Version/s: (was: 1.4.0)
1.5.0
> Javadocs link for snapshot release is not
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152527676
--- Diff: docs/concepts/programming-model.md ---
@@ -33,53 +33,52 @@ Flink offers different levels of abstraction to develop
streaming/batch applicat
[
https://issues.apache.org/jira/browse/FLINK-4877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262336#comment-16262336
]
ASF GitHub Bot commented on FLINK-4877:
---
Github user vim-wj closed the pull request at:
Github user vim-wj commented on the issue:
https://github.com/apache/flink/pull/4877
@greghogan , @StephanEwen ,sorry fo my late reply.I will close this pull
request.
---
[
https://issues.apache.org/jira/browse/FLINK-4877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262333#comment-16262333
]
ASF GitHub Bot commented on FLINK-4877:
---
Github user vim-wj commented on the issue:
Github user vim-wj closed the pull request at:
https://github.com/apache/flink/pull/4877
---
Piotr Nowojski created FLINK-8132:
-
Summary: FlinkKafkaProducer011 can commit incorrect transaction
during recovery
Key: FLINK-8132
URL: https://issues.apache.org/jira/browse/FLINK-8132
Project:
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262383#comment-16262383
]
lincoln.lee commented on FLINK-6101:
[~fhueske] I think it's not about the cost of implementation,
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262383#comment-16262383
]
lincoln.lee edited comment on FLINK-6101 at 11/22/17 11:53 AM:
---
[~fhueske] I
GitHub user casidiablo opened a pull request:
https://github.com/apache/flink/pull/5051
[hotfix] [javadocs] Fixed typo in Trigger doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/casidiablo/flink patch-1
Alternatively you
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5029
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5012
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5020
---
[
https://issues.apache.org/jira/browse/FLINK-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262280#comment-16262280
]
ASF GitHub Bot commented on FLINK-8113:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262279#comment-16262279
]
ASF GitHub Bot commented on FLINK-8070:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5042
---
[
https://issues.apache.org/jira/browse/FLINK-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262282#comment-16262282
]
ASF GitHub Bot commented on FLINK-8084:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5044
---
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262281#comment-16262281
]
ASF GitHub Bot commented on FLINK-8126:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-8131:
---
Assignee: Aljoscha Krettek
> Update to Kafka 0.11.0.2
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8131:
Priority: Blocker (was: Major)
> Update to Kafka 0.11.0.2
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8113.
---
Resolution: Fixed
1.5: 400d2a3888fd6044be054ef634bc9682c3724b3e
> Bump maven-shade-plugin to
[
https://issues.apache.org/jira/browse/FLINK-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8084.
---
Resolution: Fixed
1.5: a2f10b158835d27264fe1569d27810ad2513b7e8
> Remove japicmp
[
https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8131:
Fix Version/s: 1.4.0
> Update to Kafka 0.11.0.2
>
>
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152535711
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262328#comment-16262328
]
ASF GitHub Bot commented on FLINK-4822:
---
GitHub user taizilongxu opened a pull request:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152535417
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7712:
Assignee: (was: Tzu-Li (Gordon) Tai)
> Port JarDeleteHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7714:
Assignee: (was: Tzu-Li (Gordon) Tai)
> Port JarPlanHandler to new REST endpoint
>
GitHub user taizilongxu opened a pull request:
https://github.com/apache/flink/pull/5050
[FLINK-4822] Ensure that the Kafka 0.8 connector is compatible with kâ¦
## What is the purpose of the change
When we deploy the taskmanager in docker of our cluster, it's hard to
[
https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7715:
Assignee: (was: Tzu-Li (Gordon) Tai)
> Port JarRunHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262266#comment-16262266
]
ASF GitHub Bot commented on FLINK-7841:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8070.
---
Resolution: Fixed
Fix Version/s: 1.4.0
1.4: 56c78cbcfd6fddd7af0fee0ee8c179b7a75fb1a7
Aljoscha Krettek created FLINK-8131:
---
Summary: Update to Kafka 0.11.0.2
Key: FLINK-8131
URL: https://issues.apache.org/jira/browse/FLINK-8131
Project: Flink
Issue Type: Bug
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5049
[FLINK-8081][metrics] Annotate 'MetricRegistry#getReporters' with '@Vâ¦
## What is the purpose of the change
`MetricRegistry#getReporters()` is only used for testing purposes to
provide
[
https://issues.apache.org/jira/browse/FLINK-8081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262296#comment-16262296
]
ASF GitHub Bot commented on FLINK-8081:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8022:
Fix Version/s: 1.4.0
> Kafka at-least-once tests fail occasionally
>
[
https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8022:
Priority: Blocker (was: Critical)
> Kafka at-least-once tests fail occasionally
>
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262314#comment-16262314
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262307#comment-16262307
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262310#comment-16262310
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152536536
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,1511 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262338#comment-16262338
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user fhueske commented on a diff in the pull
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5029
Looks good, thanks!
Merging to master and 1.4...
---
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8126.
---
Resolution: Fixed
1.5: c6879cd59a10f6a371ec6b08b0a38ef34719b054
> Update and fix checkstyle
[
https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8131.
---
Resolution: Fixed
Updated on release-1.4 in
7ed2cef83723fadb63f5cccf35ade1c9c78725e2
Updated
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5044
merging,
---
[
https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7702.
---
Resolution: Fixed
> Javadocs are not being built
>
>
>
Aljoscha Krettek created FLINK-8130:
---
Summary: Javadocs link for snapshot release is not correct
Key: FLINK-8130
URL: https://issues.apache.org/jira/browse/FLINK-8130
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7702:
Fix Version/s: (was: 1.5.0)
1.4.0
> Javadocs are not being built
>
[
https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262268#comment-16262268
]
Aljoscha Krettek commented on FLINK-7702:
-
I created FLINK-8130. This issue was properly fixed for
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152506343
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,1511 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262303#comment-16262303
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152513215
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,1511 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262306#comment-16262306
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262316#comment-16262316
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262311#comment-16262311
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152508692
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,1511 @@
+/*
+ * Licensed to the Apache Software
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152518464
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152526459
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,429 @@
+/*
+ * Licensed to the Apache
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152524790
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152531212
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java
---
@@ -0,0 +1,429 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262318#comment-16262318
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262319#comment-16262319
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262305#comment-16262305
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152519868
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -355,4 +355,21 @@ public void addComparatorField(int
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152502704
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152501940
--- Diff: flink-connectors/flink-orc/pom.xml ---
@@ -0,0 +1,112 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152518885
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152499605
--- Diff: docs/dev/table/sourceSinks.md ---
@@ -485,6 +486,50 @@ val csvTableSource = CsvTableSource
{% top %}
+### OrcTableSource
+
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152510004
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,1511 @@
+/*
+ * Licensed to the Apache Software
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152503422
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262313#comment-16262313
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in the pull
1 - 100 of 218 matches
Mail list logo
