[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095330#comment-17095330
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen] and [~dwysakowicz],
I've impleme
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064983#comment-17064983
]
Stephan Ewen commented on FLINK-14807:
--
Thanks a lot, that design document has made
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060887#comment-17060887
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community.
I've written a
[do
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060077#comment-17060077
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen]
The client receives the data thr
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060054#comment-17060054
]
Stephan Ewen commented on FLINK-14807:
--
Not sure I understand. What is the mechanis
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058366#comment-17058366
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen]
Our current implementation (thro
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057946#comment-17057946
]
Stephan Ewen commented on FLINK-14807:
--
I appreciate the enthusiasm of diving into
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056695#comment-17056695
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community.
After a long offlin
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054621#comment-17054621
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen]
What I'm worrying about is not t
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053477#comment-17053477
]
Stephan Ewen commented on FLINK-14807:
--
Quick comment on the blob server / accumula
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053298#comment-17053298
]
Caizhi Weng commented on FLINK-14807:
-
Hi [~sewen],
Thanks for the reply. I think w
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052101#comment-17052101
]
Stephan Ewen commented on FLINK-14807:
--
Nice to see this lively discussion. I agree
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051891#comment-17051891
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community!
I've implemented a
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049884#comment-17049884
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community,
After some implemen
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046455#comment-17046455
]
Jiangjie Qin commented on FLINK-14807:
--
Yeah, that really depends on the implementa
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046394#comment-17046394
]
Kurt Young commented on FLINK-14807:
{quote}The communication channel is always need
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046376#comment-17046376
]
Jiangjie Qin commented on FLINK-14807:
--
{quote}Your first point is actually the roo
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046357#comment-17046357
]
Kurt Young commented on FLINK-14807:
[~becket_qin] Your first point is actually the
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046333#comment-17046333
]
Jiangjie Qin commented on FLINK-14807:
--
[~ykt836] not necessarily. Two major differ
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045155#comment-17045155
]
Kurt Young commented on FLINK-14807:
A side comment: if we want this API fully deal
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045113#comment-17045113
]
Jiangjie Qin commented on FLINK-14807:
--
We should probably first agree on the right
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044034#comment-17044034
]
Caizhi Weng commented on FLINK-14807:
-
Thanks for the comment [~godfreyhe]. I'll lis
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040585#comment-17040585
]
godfrey he commented on FLINK-14807:
Thanks for the propose, [~TsReaper].
About "Wha
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033373#comment-17033373
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community,
I'm digging this up
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022231#comment-17022231
]
Aljoscha Krettek commented on FLINK-14807:
--
I'm trying to continue the discussi
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022193#comment-17022193
]
Stephan Ewen commented on FLINK-14807:
--
I would like to understand this a bit more.
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022084#comment-17022084
]
Kostas Kloudas commented on FLINK-14807:
I have to think about the whole issue m
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17021889#comment-17021889
]
Aljoscha Krettek commented on FLINK-14807:
--
I think tying the job name to the e
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17021318#comment-17021318
]
Stephan Ewen commented on FLINK-14807:
--
Have we ever considered putting the job nam
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019802#comment-17019802
]
Jingsong Lee commented on FLINK-14807:
--
Better to support {{collect(String jobName)
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016743#comment-17016743
]
Dawid Wysakowicz commented on FLINK-14807:
--
[~aljoscha] Good point. The scope o
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016102#comment-17016102
]
Aljoscha Krettek commented on FLINK-14807:
--
[~dwysakowicz] Should this one real
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977437#comment-16977437
]
Aljoscha Krettek commented on FLINK-14807:
--
Currently there are no plans for th
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977396#comment-16977396
]
Kostas Kloudas commented on FLINK-14807:
Right now there is no Job Client yet on
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977380#comment-16977380
]
Stephan Ewen commented on FLINK-14807:
--
The call in the Table API needs support fro
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977227#comment-16977227
]
Kostas Kloudas commented on FLINK-14807:
[~zjffdu] [~sewen] if I understand the
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976896#comment-16976896
]
Stephan Ewen commented on FLINK-14807:
--
[~kkloudas] [~aljoscha] Can you share some
37 matches
Mail list logo