[
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}}
would
[
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}}
would
[
https://issues.apache.org/jira/browse/FLINK-17921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115882#comment-17115882
]
zhangminglei commented on FLINK-17921:
--
cc [~jgrier] Could you please take a look o
[
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
> RpcGlobalAggregateManager#updateGlobalA
[
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 (w
[
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}}
would
[
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}}
would
[
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 cause akka.t
zhangminglei created FLINK-17921:
Summary: RpcGlobalAggregateManager#updateGlobalAggregate would
cause akka.timeout
Key: FLINK-17921
URL: https://issues.apache.org/jira/browse/FLINK-17921
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-17919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115860#comment-17115860
]
zhangminglei commented on FLINK-17919:
--
Hi, [~tzulitai] Could you please take a loo
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
> StreamingFile
[
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 NMClientAsync in YarnResourc
[
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 StreamingFileSink
> ---
[
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 YarnResourceManager
> --
[
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 NMClientAsync in YarnResourceManag
[
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 si
[
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 column shou
[
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 from 1.
> --
[
https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617741#comment-16617741
]
zhangminglei commented on FLINK-10355:
--
Hi, [~lihongli] Thanks for opening this jir
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602721#comment-16602721
]
zhangminglei commented on FLINK-10114:
--
Thank you so much @vinoyang. Lots of users
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16599433#comment-16599433
]
zhangminglei commented on FLINK-10114:
--
I can't continue to work on this JIRA becau
[
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 StreamingFileSink
> -
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 writer
> ---
[
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 in a pro
[
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
> Avoid FileInpu
[
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/FileOutputStream
> ---
[
https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574080#comment-16574080
]
zhangminglei commented on FLINK-7829:
-
[~aljoscha] We should replace make the use of
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16571483#comment-16571483
]
zhangminglei commented on FLINK-5789:
-
Thank you [~till.rohrmann]
> Make Bucketing S
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16571065#comment-16571065
]
zhangminglei commented on FLINK-5789:
-
I would ask, in the future, We would not recom
[
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#copy
> ---
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563648#comment-16563648
]
zhangminglei commented on FLINK-9982:
-
[~lsy] Could you tell [~Zentol] what the enum
[
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#compile
>
[
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#copy
> ---
[
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 document
> -
[
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 document
> --
[
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#copy
> ---
>
>
[
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 8.6
> -
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16560532#comment-16560532
]
zhangminglei commented on FLINK-9825:
-
[~lsy] Now, You can push a PR to this issue. I
[
https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559782#comment-16559782
]
zhangminglei commented on FLINK-9985:
-
Thanks [~lsy] contribution to flink! You can f
[
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/windo
[
https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559771#comment-16559771
]
zhangminglei commented on FLINK-9982:
-
Hi, [~till.rohrmann] Could you add [~lsy] to c
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
C
[
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.
{code:java
[
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&focusedCommentId=16559754#comment-16559754
]
zhangminglei commented on FLINK-9982:
-
Hi, @vinoyang Since the bad network, So, I fai
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
Repor
[
https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559160#comment-16559160
]
zhangminglei commented on FLINK-9825:
-
Hi, [~Zentol] Could you please give [~lsy] a p
[
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 8.6
>
[
https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559128#comment-16559128
]
zhangminglei commented on FLINK-9651:
-
Hi, [~twalthr] Thanks and I am on my way to do
[
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 mechanism for Bucketing
[
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 complete
>
[
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 testRestoreBehaviourWithFaultyStateHandles
> (org.apache.flin
[
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-reader
[
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-reader
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 error
> -
>
>
[
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/j
[
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 19
> -
[
https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548968#comment-16548968
]
zhangminglei commented on FLINK-9236:
-
Hi, [~jiayichao] we are all looking forward to
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16548759#comment-16548759
]
zhangminglei commented on FLINK-4534:
-
Hi, [~gjy] Can we use a lightweight synchroniz
[
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.
The alter
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547449#comment-16547449
]
zhangminglei commented on FLINK-9675:
-
I will create the subtask for the rest of test
[
https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16547342#comment-16547342
]
zhangminglei commented on FLINK-9849:
-
Hi, [~yuzhih...@gmail.com] Is the problem rais
[
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 connector
> --
[
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 8.6
> ---
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536070#comment-16536070
]
zhangminglei commented on FLINK-9411:
-
[~triones] Are you still working on this ?
>
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Labels: (was: patch-available pull-request-available)
> Support orc rolling sink writer
> ---
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Description:
Currently, we only support {{StringWriter}}, {{SequenceFileWriter}} and
{{AvroKeyValu
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16534776#comment-16534776
]
zhangminglei edited comment on FLINK-9411 at 7/6/18 12:41 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16534776#comment-16534776
]
zhangminglei commented on FLINK-9411:
-
A short checkpoint time that whether lead to p
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9411:
Comment: was deleted
(was: Thanks for your feedback, [~StephanEwen]. What you mean is that every
t
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16527333#comment-16527333
]
zhangminglei commented on FLINK-9689:
-
Hi, [~satheeshravir] Please take a look on {{K
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16527316#comment-16527316
]
zhangminglei commented on FLINK-9411:
-
[~triones] Thanks for your feedback. The short
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. Users want
to do
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. However,
users wa
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524850#comment-16524850
]
zhangminglei edited comment on FLINK-9675 at 6/27/18 10:09 AM:
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524850#comment-16524850
]
zhangminglei commented on FLINK-9675:
-
+1,
There have been similar problems in hdfs
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9675:
---
Assignee: zhangminglei
> Avoid FileInputStream/FileOutputStream
> --
[
https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523501#comment-16523501
]
zhangminglei commented on FLINK-8886:
-
Hi,[~liurenjie1024] Thanks for the doc! I will
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want to
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want to
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want to
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Affects Version/s: 1.5.0
1.4.2
> Add bucket ready mechanism for BucketingSin
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Component/s: (was: State Backends, Checkpointing)
Streaming Connectors
> Add b
[
https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9609:
Description:
Currently, BucketingSink only support {{notifyCheckpointComplete}}. But users
want to
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei updated FLINK-9407:
Labels: patch-available (was: )
> Support orc rolling sink writer
> --
[
https://issues.apache.org/jira/browse/FLINK-9658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9658:
---
Assignee: zhangminglei
> Test data output directories are no longer cleaned up
> ---
[
https://issues.apache.org/jira/browse/FLINK-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9657:
---
Assignee: zhangminglei
> Suspicious output from Bucketing sink E2E test
> --
100 matches
Mail list logo