[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Description:
As described in summary, {{RpcGlobalAggregateManager#updateGlobalAggregate
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Description:
As described in summary, {{RpcGlobalAggregateManager#updateGlobalAggregate
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115882#comment-17115882
]
zhangminglei commented on FLINK-17921:
--
cc [~jgrier] Could you please take a look on this ? Thank
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Affects Version/s: 1.8.1
1.10.1
> RpcGlobalAggregateMana
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Summary: RpcGlobalAggregateManager#updateGlobalAggregate would cause
unexpected akka.timeout
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Description:
As described in summary, {{RpcGlobalAggregateManager#updateGlobalAggregate
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Description:
As described in summary, {{RpcGlobalAggregateManager#updateGlobalAggregate
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17921:
-
Component/s: Runtime / Task
> RpcGlobalAggregateManager#updateGlobalAggregate would ca
zhangminglei created FLINK-17921:
Summary: RpcGlobalAggregateManager#updateGlobalAggregate would
cause akka.timeout
Key: FLINK-17921
URL: https://issues.apache.org/jira/browse/FLINK-17921
Project
[
https://issues.apache.org/jira/browse/FLINK-17919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115860#comment-17115860
]
zhangminglei commented on FLINK-17919:
--
Hi, [~tzulitai] Could you please take a look on this Jira
zhangminglei created FLINK-17919:
Summary: KafkaConsumerThread should add ratelimiter functionality
as well
Key: FLINK-17919
URL: https://issues.apache.org/jira/browse/FLINK-17919
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-17878:
-
Component/s: (was: Table SQL / API)
Connectors / FileSystem
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9410:
---
Assignee: zhangminglei (was: lihongli)
> Replace NMClient with NMClientAs
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-10114:
Assignee: lihongli (was: vinoyang)
> Support Orc for StreamingFileS
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9410:
---
Assignee: lihongli
> Replace NMClient with NMClientAsync in YarnResourceMana
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9410:
---
Assignee: (was: zhangminglei)
> Replace NMClient with NMClientAs
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-10355:
-
Comment: was deleted
(was: Hi, [~lihongli] Thanks for opening this jira. I would not think so
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-10355:
-
Component/s: (was: Java API)
Table API & SQL
> The order of the
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-10355:
-
Labels: easyfix (was: )
> The order of the column should start fro
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617741#comment-16617741
]
zhangminglei commented on FLINK-10355:
--
Hi, [~lihongli] Thanks for opening this jira. I would
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602721#comment-16602721
]
zhangminglei commented on FLINK-10114:
--
Thank you so much @vinoyang. Lots of users need
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16599433#comment-16599433
]
zhangminglei commented on FLINK-10114:
--
I can't continue to work on this JIRA because I've just
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-10114:
Assignee: (was: zhangminglei)
> Support Orc for StreamingFileS
zhangminglei created FLINK-10114:
Summary: Support Orc for StreamingFileSink
Key: FLINK-10114
URL: https://issues.apache.org/jira/browse/FLINK-10114
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei resolved FLINK-9411.
-
Resolution: Won't Fix
> Support parquet rolling sink wri
[
https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-7829:
Description: These methods are seductive for users but they should never
actually use them
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9675:
Affects Version/s: 1.4.1
1.4.2
1.5.1
> Av
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9675:
Fix Version/s: 1.7.0
> Avoid FileInputStream/FileOutputStr
[
https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574080#comment-16574080
]
zhangminglei commented on FLINK-7829:
-
[~aljoscha] We should replace make the use of {{BucketingSink
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571483#comment-16571483
]
zhangminglei commented on FLINK-5789:
-
Thank you [~till.rohrmann]
> Make Bucketing Sink independ
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571065#comment-16571065
]
zhangminglei commented on FLINK-5789:
-
I would ask, in the future, We would not recommend users
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9982:
---
Assignee: dalongliu (was: zhangminglei)
> NPE in EnumValueSerializer#c
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563648#comment-16563648
]
zhangminglei commented on FLINK-9982:
-
[~lsy] Could you tell [~Zentol] what the enum field in your
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei resolved FLINK-9614.
-
Resolution: Won't Fix
> Improve the error message for Compiler#comp
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9982:
---
Assignee: zhangminglei (was: dalongliu)
> NPE in EnumValueSerializer#c
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9985:
---
Assignee: zhangminglei (was: dalongliu)
> Incorrect parameter order in docum
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9985:
---
Assignee: dalongliu
> Incorrect parameter order in docum
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9982:
---
Assignee: dalongliu
> NPE in EnumValueSerializer#c
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9825:
---
Assignee: dalongliu
> Upgrade checkstyle version to
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560532#comment-16560532
]
zhangminglei commented on FLINK-9825:
-
[~lsy] Now, You can push a PR to this issue. If you face any
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559782#comment-16559782
]
zhangminglei commented on FLINK-9985:
-
Thanks [~lsy] contribution to flink! You can feel free to open
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9985:
Description:
https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/stream/operators
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559771#comment-16559771
]
zhangminglei commented on FLINK-9982:
-
Hi, [~till.rohrmann] Could you add [~lsy] to contribution list
zhangminglei created FLINK-9985:
---
Summary: Incorrect parameter order in document
Key: FLINK-9985
URL: https://issues.apache.org/jira/browse/FLINK-9985
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9982:
Description:
When execute the flink job in flink 1.3.2 version. We met the below error
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9982:
Affects Version/s: 1.3.3
1.4.1
1.4.2
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559754#comment-16559754
]
zhangminglei commented on FLINK-9982:
-
Hi, @vinoyang Since the bad network, So, I failed to provided
zhangminglei created FLINK-9982:
---
Summary: NPE in EnumValueSerializer#copy
Key: FLINK-9982
URL: https://issues.apache.org/jira/browse/FLINK-9982
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559160#comment-16559160
]
zhangminglei commented on FLINK-9825:
-
Hi, [~Zentol] Could you please give [~lsy] a permission
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9825:
---
Assignee: (was: zhangminglei)
> Upgrade checkstyle version to
[
https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559128#comment-16559128
]
zhangminglei commented on FLINK-9651:
-
Hi, [~twalthr] Thanks and I am on my way to do this.
>
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Fix Version/s: (was: 1.6.1)
1.7.0
> Add bucket ready mechan
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6103
Hi, @tillrohrmann I found more than one user found this issue and affect
their work. I suggest we can merge this PR as a temporary solution until the
travis turn green.
---
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
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
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Fix Version/s: 1.6.1
> Add bucket ready mechanism for BucketingSink when checkpoint compl
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6378
Could you please push code and trigger the travis again ?
---
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6380
[FLINK-9614] [table] Improve the error message for Compiler#compile
## What is the purpose of the change
Improve the error message for Compiler#compile
You can merge this pull request
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6336
Hi, @ubyyj Thanks for your contribution! It looks good to me.
---
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9900:
Affects Version/s: 1.5.1
> Failed to testRestoreBehaviourWithFaultyStateHand
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6378
@TisonShadowsong is right. You can verify that and i think it might be a
bug.
---
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6378
@YCjia The travis test failed. Could you take a look on what is happening ?
---
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6375#discussion_r203997376
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6375#discussion_r203995868
--- Diff:
flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6375
Hi, @tillrohrmann Could you please take a look on this PR ? Actually, I
don't know which committer is more familiar with ```BucketingSink```. Thank you
so much.
---
[
https://issues.apache.org/jira/browse/FLINK-9901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9901:
Description: From this benchmark report
https://arnaudroger.github.io/blog/2017/03/20/faster
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6365
Thanks @yanghua for pointing this out!
---
[
https://issues.apache.org/jira/browse/FLINK-9901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9901:
Description: From this benchmark report
https://arnaudroger.github.io/blog/2017/03/20/faster
zhangminglei created FLINK-9901:
---
Summary: Refactor InputStreamReader to Channels.newReader
Key: FLINK-9901
URL: https://issues.apache.org/jira/browse/FLINK-9901
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-9896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9896:
---
Assignee: zhangminglei
> Fix flink documentation er
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9900:
Description:
https://api.travis-ci.org/v3/job/405843617/log.txt
Tests run: 1, Failures: 0, Errors
zhangminglei created FLINK-9900:
---
Summary: Failed to testRestoreBehaviourWithFaultyStateHandles
(org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)
Key: FLINK-9900
URL: https://issues.apache.org
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6375
[FLINK-9609] [connectors] Add bucket ready mechanism for BucketingSinâ¦
## What is the purpose of the change
Currently, BucketingSink only support ```notifyCheckpointComplete```.
However
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6365
Hi, @yanghua I do not use a inner maven repo. It seems does not work for
me.Exclude SNAPSHOT dependency and add a stable glassfish but still useless.
---
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6365
@yanghua Could you please take on look this issue also ?
---
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9236:
---
Assignee: jiayichao (was: Stephen Jason)
> Use Apache Parent POM
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6365
Hi, @tedyu I found an issue when upgrade the hbase version to either 2.0.1
or 2.1.0. Both can lead problem. ```Failed to read artifact descriptor for
org.glassfish:javax.el:jar 3.0.1-b06
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548968#comment-16548968
]
zhangminglei commented on FLINK-9236:
-
Hi, [~jiayichao] we are all looking forward to you first
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16548759#comment-16548759
]
zhangminglei commented on FLINK-4534:
-
Hi, [~gjy] Can we use a lightweight synchronization mechanism
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
Hi, @hequn8128 I will create another jira for ```new InputStreamReader```
refactor issue. What do you think ?
---
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9675:
Description:
They rely on finalizers (before Java 11), which create unnecessary GC load
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
Thank you very much! @hequn8128 ! I will take a look.
---
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6365
Thanks @yanghua you are right! I just want waiting the travis ending. then
give the old and new version's dependency tree.
---
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6365
[FLINK-9849] [hbase] Hbase upgrade
## What is the purpose of the change
Upgrade hbase version to 2.0.1 for hbase connector
You can merge this pull request into a Git repository
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547449#comment-16547449
]
zhangminglei commented on FLINK-9675:
-
I will create the subtask for the rest of test code path
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547342#comment-16547342
]
zhangminglei commented on FLINK-9849:
-
Hi, [~yuzhih...@gmail.com] Is the problem raised by this FLINK
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
Hi, @tedyu I have updated the code. Please check again. Thank you very much.
---
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
@tedyu Could you please take a look on this ? Thank you very much.
---
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6335
Thanks @yanghua I will push the rest of the code then and fix the travis
error.
---
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6335
[FLINK-9675] [fs] Avoid FileInputStream/FileOutputStream
## What is the purpose of the change
Avoid using FileInputStream/FileOutputStream because they rely on
finalizers (before Java
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9849:
---
Assignee: zhangminglei
> Upgrade hbase version to 2.0.1 for hbase connec
Github user zhangminglei closed the pull request at:
https://github.com/apache/flink/pull/5375
---
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5375
Hi, @tillrohrmann . You are welcome ~ I still have a lot of other flink
jira will be addressed by me in the future.
---
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9825:
---
Assignee: zhangminglei
> Upgrade checkstyle version to
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
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
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
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
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
1 - 100 of 585 matches
Mail list logo
