[
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
>
[
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 cause
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 NMClientAsync in
[
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
[
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 column
[
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=16617741#comment-16617741
]
zhangminglei commented on FLINK-10355:
--
Hi, [~lihongli] Thanks for opening this jira. I would not
[
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 this
[
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 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
[
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
[
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=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=16571483#comment-16571483
]
zhangminglei commented on FLINK-5789:
-
Thank you [~till.rohrmann]
> Make Bucketing Sink independent
[
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 to
[
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=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#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=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://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 that
[
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=16559128#comment-16559128
]
zhangminglei commented on FLINK-9651:
-
Hi, [~twalthr] Thanks and I am on my way to do this.
> Add a
[
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
[
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
>
[
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://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
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:
[
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,
zhangminglei created FLINK-9900:
---
Summary: Failed to testRestoreBehaviourWithFaultyStateHandles
(org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)
Key: FLINK-9900
URL:
[
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=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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536070#comment-16536070
]
zhangminglei commented on FLINK-9411:
-
[~triones] Are you still working on this ?
> Support parquet
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16534776#comment-16534776
]
zhangminglei edited comment on FLINK-9411 at 7/6/18 12:41 PM:
--
A short
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16534776#comment-16534776
]
zhangminglei commented on FLINK-9411:
-
A short checkpoint time that whether lead to poor compression
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527333#comment-16527333
]
zhangminglei commented on FLINK-9689:
-
Hi, [~satheeshravir] Please take a look on
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527316#comment-16527316
]
zhangminglei commented on FLINK-9411:
-
[~triones] Thanks for your feedback. The shortcomings with
[
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
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524850#comment-16524850
]
zhangminglei edited comment on FLINK-9675 at 6/27/18 10:09 AM:
---
+1,
There
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524850#comment-16524850
]
zhangminglei commented on FLINK-9675:
-
+1,
There have been similar problems in hdfs HDFS Performance
[
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=16523501#comment-16523501
]
zhangminglei commented on FLINK-8886:
-
Hi，[~liurenjie1024] Thanks for the doc! I will take a look on
[
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
[
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
[
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
[
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
[
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
[
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
[
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
