[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554655#comment-17554655
]
Etienne Chauchot commented on FLINK-26793:
--
> Just to double-check: Can we optimize anything on
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553465#comment-17553465
]
Etienne Chauchot commented on FLINK-26793:
--
[~arvid], I went through the code as promised:
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533731#comment-17533731
]
Etienne Chauchot commented on FLINK-26793:
--
[~arvid] just to let you know, I have not forgotten
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528228#comment-17528228
]
Etienne Chauchot commented on FLINK-26793:
--
[~arvid] thanks for your comment. I don't think
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527329#comment-17527329
]
Arvid Heise commented on FLINK-26793:
-
Just to double-check: Can we optimize anything on Flink side
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] I reproduced the behavior you
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518255#comment-17518255
]
Jay Ghiya commented on FLINK-26793:
---
absolutely. [~echauchot] makes sense. we have also started the
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518112#comment-17518112
]
Chesnay Schepler commented on FLINK-26793:
--
[~bumblebee] Have you actually observed performance
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518077#comment-17518077
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee], in the meantime, I made a [pure-flink
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517914#comment-17517914
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] thanks for the first answer. Can you
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517570#comment-17517570
]
Jay Ghiya commented on FLINK-26793:
---
Hi [~echauchot] - Regardin "query is not prepared ..." -> No this
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516904#comment-17516904
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] in particular do you see in Flink logs
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515978#comment-17515978
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] The only thing I can think of is that
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512859#comment-17512859
]
Jay Ghiya commented on FLINK-26793:
---
[~echauchot] thanks for initial analysis -> looks like the mapper
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512858#comment-17512858
]
Jay Ghiya commented on FLINK-26793:
---
Hi [~echauchot] -> We use following piece of code:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512513#comment-17512513
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] copying what I wrote on the ML:
On a
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511677#comment-17511677
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] how do you create the cassandra sink ?
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511086#comment-17511086
]
Martijn Visser commented on FLINK-26793:
I've assigned [~echauchot] to this ticket. Let's create
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511078#comment-17511078
]
Martijn Visser commented on FLINK-26793:
Thanks all!
Also good to read up on are the FLIPs that
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510720#comment-17510720
]
Jay Ghiya commented on FLINK-26793:
---
awesome thankyou [~echauchot] ! grateful!
> Flink Cassandra
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510717#comment-17510717
]
Etienne Chauchot commented on FLINK-26793:
--
[~bumblebee] splitting looks good to me. I guess
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510528#comment-17510528
]
Jay Ghiya commented on FLINK-26793:
---
[~echauchot] [~martijnvisser]- could we take this task and split
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510521#comment-17510521
]
Jay Ghiya commented on FLINK-26793:
---
[~martijnvisser] thankyou for explaining the gravity of the
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510394#comment-17510394
]
Etienne Chauchot commented on FLINK-26793:
--
I just saw this ticket. I think solving this perf
[
https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510320#comment-17510320
]
Martijn Visser commented on FLINK-26793:
[~bumblebee] The Cassandra connector isn't actively
25 matches
Mail list logo
