Jayant Ameta created FLINK-10310:
Summary: Cassandra Sink - Handling failing requests
Key: FLINK-10310
URL: https://issues.apache.org/jira/browse/FLINK-10310
Project: Flink
Issue Type: Improv
Hi Michael,
have you considered trying out the EsInputFormat [1] with
Flink's HadoopInputFormatBase? That way reading from ElasticSearch might
already work out of the box. If not, then adding a dedicated ElasticSearch
input format would definitely be helpful.
[1] https://github.com/elastic/elasti
Dear community,
this is the weekly community update thread #37. Please post any news and
updates you want to share with the community to this thread.
# Flink Forward Berlin 2018 over
Last week the community met in Berlin for the 4th edition of Flink Forward
2018 [1]. It was great to see people c
Hi Vino,
Thank you for following up and creating the issue.
Best,
Gary
On Sun, Sep 9, 2018 at 10:02 AM, vino yang wrote:
> Hi Gary,
>
> Hi Gary, your guess about the scene is correct.
> We encountered this problem a month or two ago (sorry, there is no context
> log, but I think the problem is
Hi Gary,
Hi Gary, your guess about the scene is correct.
We encountered this problem a month or two ago (sorry, there is no context
log, but I think the problem is clear and not difficult to reproduce),
we will directly split it into trigger savepoint and cancel operation.
Devin worked with me at
vinoyang created FLINK-10309:
Summary: Cancel flink job occurs java.net.ConnectException
Key: FLINK-10309
URL: https://issues.apache.org/jira/browse/FLINK-10309
Project: Flink
Issue Type: Bug
