[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752055#comment-17752055
]
Yue Ma commented on FLINK-31238:
[~pnowojski] [~srichter] [~yunta] [~masteryhx]
Sorry for the late
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750127#comment-17750127
]
Hangxiang Yu commented on FLINK-31238:
--
[~mayuehappy] Thanks a lot for your efforts!
If the pr/FLIP
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745875#comment-17745875
]
Yue Ma commented on FLINK-31238:
[~yunta] ok , sorry for the delay:(
> Use IngestDB to speed up
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745874#comment-17745874
]
Yue Ma commented on FLINK-31238:
[~pnowojski] Sorry for missing your comment. The newly added api in
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17743700#comment-17743700
]
Yun Tang commented on FLINK-31238:
--
Since the feature freeze date for flink-1.18 is July 24th, and no
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740998#comment-17740998
]
Piotr Nowojski commented on FLINK-31238:
[~mayuehappy] thanks for your work on this! Really nice
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736879#comment-17736879
]
Yue Ma commented on FLINK-31238:
[~srichter]
Thanks very much for the reply, I hope to continue this
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734183#comment-17734183
]
Stefan Richter commented on FLINK-31238:
[~mayuehappy] Thanks for working on this topic! I saw
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706254#comment-17706254
]
Yue Ma commented on FLINK-31238:
[~yunta]
Thanks for the reply, I have written the detailed design plan
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699160#comment-17699160
]
Yun Tang commented on FLINK-31238:
--
[~mayuehappy] Thanks for the reply.
Considering the efforts to
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698227#comment-17698227
]
Yue Ma commented on FLINK-31238:
[~yunta] Thanks for replying ~
Yes, in the current implementation both
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698215#comment-17698215
]
Yue Ma commented on FLINK-31238:
[~masteryhx] Thanks for the reply, I understand your concerns. It's a
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697815#comment-17697815
]
Yun Tang commented on FLINK-31238:
--
[~mayuehappy] Thanks for the great work!
If my understanding is
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697787#comment-17697787
]
Hangxiang Yu commented on FLINK-31238:
--
[~mayuehappy] , Thanks for your detailed explanation.
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697239#comment-17697239
]
Yue Ma commented on FLINK-31238:
[~yunta] [~klion26] [~ym] [~roman]
Can you guys take a look at the
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694835#comment-17694835
]
Yue Ma commented on FLINK-31238:
[~masteryhx] Thanks for reply.
1. In our current implementation,
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694813#comment-17694813
]
Hangxiang Yu commented on FLINK-31238:
--
Thank you for sharing the design. The duration of rescaling
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694475#comment-17694475
]
Yue Ma commented on FLINK-31238:
1. IngestExternalFile will use global_seq_no, but when we rewrite, the
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694438#comment-17694438
]
Yanfei Lei commented on FLINK-31238:
Thanks for your sharing, this drastically reduces the number of
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693994#comment-17693994
]
Yue Ma commented on FLINK-31238:
[~Yanfei Lei] thanks a lot for reply. Let me give an example to
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693957#comment-17693957
]
Yanfei Lei commented on FLINK-31238:
[~mayuehappy] Great work! I also tried to use ingest() to
21 matches
Mail list logo
