Re: I/O reactor status: STOPPED after moving to elasticsearch7 connector

2021-10-13 Thread Itamar Syn-Hershko
t didn't seem to fix > any issues > > Problem is that once this happens it does not fix itself. That instance of > the sink will continuously get those exceptions until we restart the job. I > tried to look for any logs before that but couldn't find anything >

Re: Flink running in k8s pod - pod is able to access S3 bucket, flink does not

2021-01-31 Thread Itamar Syn-Hershko
la.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) > ~[flink-dist_2.12-1.12.1.jar:1.12.1] > at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) > ~[flink-dist_2.12-1.12.1.jar:1.12.1] > at > > akka.pattern.PipeToSupport$PipeableFuture$

Re: [DISCUSS] Drop connectors for Elasticsearch 2.x and 5.x

2020-02-10 Thread Itamar Syn-Hershko
. > > What do you think? Should we drop both versions? Drop only the 2.x > connector? Or keep them both? > > Best, > > Dawid > > > -- [image: logo] <https://bigdataboutique.com/> Itamar Syn-Hershko CTO, Founder ita...@bigdataboutique.com https://bigdatabo

Re: Flink Elasticsearch upsert document in ES

2020-02-10 Thread Itamar Syn-Hershko
sert in case document not found or do not > insert if document is already there. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ > -- [image: logo] <https://bigdataboutique.com/> Itamar Syn-Hershko CTO, Founder ita

Re: Flink and Presto integration

2020-01-27 Thread Itamar Syn-Hershko
n here is thus more at catalog level since I would > use Presto for exploring data from UI and Flink to process it because once > the configuration part has finished (since I have many Flink jobs that I > don't want to throw away or rewrite). > > On Mon, Jan 27, 2020 at 2:30 PM

Re: Flink and Presto integration

2020-01-27 Thread Itamar Syn-Hershko
<https://bigdataboutique.com/> Itamar Syn-Hershko CTO, Founder +972-54-2467860 ita...@bigdataboutique.com https://bigdataboutique.com <https://www.linkedin.com/in/itamar-syn-hershko-78b25013> <https://twitter.com/synhershko> <https://www.youtube.com/channel/UCBHr7lM2u6SCWPJvcKug-Yg>

Re: PubSub source throwing grpc errors

2020-01-19 Thread Itamar Syn-Hershko
Hi Itamar, > > could you share a bit more details about the serialization problem. Which > class is not serializable and where does it originate from? > > Cheers, > Till > > On Tue, Jan 14, 2020 at 9:47 PM Itamar Syn-Hershko < > ita...@bigdataboutique.com> wr

Re: PubSub source throwing grpc errors

2020-01-14 Thread Itamar Syn-Hershko
bsub version than 1.62.0. I assume that the others > might know more about it. > > [1] https://github.com/googleapis/google-cloud-java/issues/3648 > > Cheers, > Till > > On Mon, Jan 13, 2020 at 12:19 PM Itamar Syn-Hershko < > ita...@bigdataboutique.com> wrote: >

PubSub source throwing grpc errors

2020-01-13 Thread Itamar Syn-Hershko
:530) at java.base/java.lang.Thread.run(Thread.java:834) ``` Thanks! -- [image: logo] <https://bigdataboutique.com/> Itamar Syn-Hershko ita...@bigdataboutique.com https://bigdataboutique.com <https://www.linkedin.com/in/itamar-syn-hershko-78b25013> <https://twitter.com/syn