[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014126#comment-17014126
]
Kostas Kloudas commented on FLINK-15533:
Thanks for the feedback [~lirui]! I ope
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013392#comment-17013392
]
Rui Li commented on FLINK-15533:
[~kkl0u] I just tried the latest branch and it fixes th
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012832#comment-17012832
]
Kostas Kloudas commented on FLINK-15533:
Sorry I just saw your message, I think
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012822#comment-17012822
]
Kostas Kloudas commented on FLINK-15533:
I think I get the problem. Before 1.10
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012781#comment-17012781
]
Rui Li commented on FLINK-15533:
Hi [~kkl0u], just confirmed the job succeeds if I write
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633
]
Kostas Kloudas commented on FLINK-15533:
Hi [~lirui], I tried it on the {{master
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011735#comment-17011735
]
Rui Li commented on FLINK-15533:
Hi [~kkl0u], I tried your patch and as I expected, it s
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011725#comment-17011725
]
Rui Li commented on FLINK-15533:
[~kkl0u] That's correct.
I also quickly tried with 1.9.
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011714#comment-17011714
]
Kostas Kloudas commented on FLINK-15533:
[~lirui] To summarize the problem, your
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011680#comment-17011680
]
Kostas Kloudas commented on FLINK-15533:
Hi [~lirui], I am also try to figure ou
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011669#comment-17011669
]
Rui Li commented on FLINK-15533:
Hi [~kkl0u], thanks for the quick fix. IIUC, the change
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011651#comment-17011651
]
Kostas Kloudas commented on FLINK-15533:
I have [branch|https://github.com/kl0u/
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011646#comment-17011646
]
Kostas Kloudas commented on FLINK-15533:
[~lzljs3620320] I made it a blocker but
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011623#comment-17011623
]
Kostas Kloudas commented on FLINK-15533:
Thanks for reporting this [~lirui] and
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011628#comment-17011628
]
Jingsong Lee commented on FLINK-15533:
--
[~kkl0u] Do you think this is blocker or cr
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011612#comment-17011612
]
Zili Chen commented on FLINK-15533:
---
Sounds reasonable.
cc [~kkl0u]
> Writing DataSt
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011599#comment-17011599
]
Rui Li commented on FLINK-15533:
When we create a {{DataStreamSink}}, we get parallelism
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011575#comment-17011575
]
Zili Chen commented on FLINK-15533:
---
The default value of {{parallelism.default}} is {
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011573#comment-17011573
]
Zili Chen commented on FLINK-15533:
---
Could you attach the running job DAG on JIRA? It
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011570#comment-17011570
]
Zili Chen commented on FLINK-15533:
---
>From my understanding if parallelism > 1, actual
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011566#comment-17011566
]
Rui Li commented on FLINK-15533:
I set {{parallelism.default}} to 1
> Writing DataStrea
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011564#comment-17011564
]
Zili Chen commented on FLINK-15533:
---
what is the value you set to {{parallelism.defaul
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011562#comment-17011562
]
Rui Li commented on FLINK-15533:
[~tison] If I set {{parallelism.default}} in flink-conf
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011546#comment-17011546
]
Zili Chen commented on FLINK-15533:
---
[~lzljs3620320] but how? I don't see a clear reas
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011538#comment-17011538
]
Jingsong Lee commented on FLINK-15533:
--
The second execution will be successful, Lo
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011530#comment-17011530
]
Rui Li commented on FLINK-15533:
[~lzljs3620320] Thanks for the suggestions. Yes it can
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011510#comment-17011510
]
Jingsong Lee commented on FLINK-15533:
--
Thanks [~lirui] for tracking this. Can you
[
https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011507#comment-17011507
]
Rui Li commented on FLINK-15533:
Hit this issue when working on FLINK-15511. These comme
28 matches
Mail list logo
