[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095330#comment-17095330
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen] and [~dwysakowicz],
I've implemented
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064983#comment-17064983
]
Stephan Ewen commented on FLINK-14807:
--
Thanks a lot, that design document has made things clearer
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060887#comment-17060887
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community.
I've written a
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060077#comment-17060077
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen]
The client receives the data through REST calls
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060054#comment-17060054
]
Stephan Ewen commented on FLINK-14807:
--
Not sure I understand. What is the mechanism by which the
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058366#comment-17058366
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen]
Our current implementation (through
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057946#comment-17057946
]
Stephan Ewen commented on FLINK-14807:
--
I appreciate the enthusiasm of diving into implementation
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056695#comment-17056695
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community.
After a long offline discussion
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054621#comment-17054621
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen]
What I'm worrying about is not the stress on the
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053477#comment-17053477
]
Stephan Ewen commented on FLINK-14807:
--
Quick comment on the blob server / accumulator version:
*
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053298#comment-17053298
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen],
Thanks for the reply. I think we might need to
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052101#comment-17052101
]
Stephan Ewen commented on FLINK-14807:
--
Nice to see this lively discussion. I agree that we should
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051891#comment-17051891
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community!
I've implemented a POC of my
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049884#comment-17049884
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community,
After some implementation and
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046455#comment-17046455
]
Jiangjie Qin commented on FLINK-14807:
--
Yeah, that really depends on the implementation.
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046394#comment-17046394
]
Kurt Young commented on FLINK-14807:
{quote}The communication channel is always needed whether it is
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046376#comment-17046376
]
Jiangjie Qin commented on FLINK-14807:
--
{quote}Your first point is actually the root of complexity.
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046357#comment-17046357
]
Kurt Young commented on FLINK-14807:
[~becket_qin] Your first point is actually the root of
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046333#comment-17046333
]
Jiangjie Qin commented on FLINK-14807:
--
[~ykt836] not necessarily. Two major difference makes this
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045155#comment-17045155
]
Kurt Young commented on FLINK-14807:
A side comment: if we want this API fully deal with fault
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045113#comment-17045113
]
Jiangjie Qin commented on FLINK-14807:
--
We should probably first agree on the right solution to
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044034#comment-17044034
]
Caizhi Weng commented on FLINK-14807:
-
Thanks for the comment [~godfreyhe]. I'll list more details
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040585#comment-17040585
]
godfrey he commented on FLINK-14807:
Thanks for the propose, [~TsReaper].
About "What if the job
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033373#comment-17033373
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community,
I'm digging this up because I have
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022231#comment-17022231
]
Aljoscha Krettek commented on FLINK-14807:
--
I'm trying to continue the discussion here:
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022193#comment-17022193
]
Stephan Ewen commented on FLINK-14807:
--
I would like to understand this a bit more. Having two ways
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022084#comment-17022084
]
Kostas Kloudas commented on FLINK-14807:
I have to think about the whole issue more, but
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021889#comment-17021889
]
Aljoscha Krettek commented on FLINK-14807:
--
I think tying the job name to the environment would
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021318#comment-17021318
]
Stephan Ewen commented on FLINK-14807:
--
Have we ever considered putting the job name onto the
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019802#comment-17019802
]
Jingsong Lee commented on FLINK-14807:
--
Better to support {{collect(String jobName)}} to support
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016743#comment-17016743
]
Dawid Wysakowicz commented on FLINK-14807:
--
[~aljoscha] Good point. The scope of FLINK-13943
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016102#comment-17016102
]
Aljoscha Krettek commented on FLINK-14807:
--
[~dwysakowicz] Should this one really be closed?
>
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977437#comment-16977437
]
Aljoscha Krettek commented on FLINK-14807:
--
Currently there are no plans for the
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977396#comment-16977396
]
Kostas Kloudas commented on FLINK-14807:
Right now there is no Job Client yet on the master. It
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977380#comment-16977380
]
Stephan Ewen commented on FLINK-14807:
--
The call in the Table API needs support from the underlying
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977227#comment-16977227
]
Kostas Kloudas commented on FLINK-14807:
[~zjffdu] [~sewen] if I understand the issue correctly,
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976896#comment-16976896
]
Stephan Ewen commented on FLINK-14807:
--
[~kkloudas] [~aljoscha] Can you share some details what the
37 matches
Mail list logo
