Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC

2019-09-06 Thread Kenny Gorman
Grats Kostas! ^5^5 -kg From: Fabian Hueske Date: Friday, September 6, 2019 at 7:56 AM To: dev , user Subject: [ANNOUNCE] Kostas Kloudas joins the Flink PMC Hi everyone, I'm very happy to announce that Kostas Kloudas is joining the Flink PMC. Kostas is contributing to Flink for ma

Re: Read mongo datasource in Flink

2019-04-29 Thread Kenny Gorman
rties, good restart-ability and such.. Thanks Kenny Gorman Co-Founder and CEO www.eventador.io <http://www.eventador.io/> > On Apr 29, 2019, at 7:47 AM, Wouter Zorgdrager > wrote: > > Yes, that is correct. This is a really basic implementation that doesn't take > para

Re: Flink vs Spark streaming benchmark

2017-12-17 Thread Kenny Gorman
Nice write up! -kg > On Dec 16, 2017, at 4:59 PM, Fabian Hueske wrote: > > Hi, > > In case you haven't seen it yet. > Here's an analysis and response to Databricks' benchmark [1]. > > Best, Fabian > > [1] > https://data-artisans.com/blog/curious-case-broken-benchmark-revisiting-apache-flin

Re: Stumped writing to KafkaJSONSink

2017-10-18 Thread Kenny Gorman
case (so the same as yours but without the TableEnvironment argument). > > Does that work for you? > If not what kind of error and error message do you get? > > Best, Fabian > > 2017-10-18 1:28 GMT+02:00 Kenny Gorman : >> I am hoping you guys can help me. I am

Stumped writing to KafkaJSONSink

2017-10-17 Thread Kenny Gorman
I am hoping you guys can help me. I am stumped how to actually write to Kafka using Kafka09JsonTableSink using the Table API. Here is my code below, I am hoping you guys can shed some light on how this should be done. I don’t see any methods for the actual write to Kafka. I am probably doing som