Re: Reading csv file

Option 1. Provide command-line parameter following https://stackoverflow.com/questions/2066307/how-do-you-input-commandline-argument-in-intellij-idea Option 2. Directly set `String inputPath = "/home/alaa/Downloads/sorted_data.csv";` Best, tison. alaa 于2019年4月1日周一 下午2:42写道： > So what should i

Re: End-to-end exactly-once semantics in simple streaming app

Hi, thanks for your reply and sorry for the late response. The problem is, I am unsure how I should implement the two-phase-commit pattern, because my JDBC connection is within a .map()/.flatMap() operator, and it is NOT a data sink. As written in my original question, my stream setup is a sim

Re: Reading csv file

So , What I should do -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

So what should i do ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading csv file

Hi, Isn't it because you do not provide command-line arguments? Best, tison. alaa 于2019年4月1日周一 下午2:33写道： > Hi, > > I am following the Taxi example provided on > "http://training.data-artisans.com/exercises/taxiData.html";, however, I > got > the following error message when I run AreasTotalPe

Reading csv file

Hi, I am following the Taxi example provided on "http://training.data-artisans.com/exercises/taxiData.html";, however, I got the following error message when I run AreasTotalPerHour.java at my Intellij IDE.

Re: kafka corrupt record exception

Hi As you said, consume from ubuntu terminal has the same error, maybe you could send a email to kafka user maillist. Best, Congxian On Apr 1, 2019, 05:26 +0800, Sushant Sawant , wrote: > Hi team, > I am facing this exception, > org.apache.kafka.common.KafkaException: Received exception when fet

kafka corrupt record exception

Hi team, I am facing this exception, org.apache.kafka.common.KafkaException: Received exception when fetching the next record from topic_log-3. If needed, please seek past the record to continue consumption. at org.apache.kafka.clients.consumer.internals.Fetcher$PartitionRecords.fetchReco

Re: Infinitely requesting for Yarn container in Flink 1.5

Thanks Rong, I will follow that issue. > On Mar 30, 2019, at 6:42 AM, Rong Rong > wrote: > > Hi Qi, > > I think the problem may be related to another similar problem reported in a > previous JIRA [1]. I think a PR is also in discussion. > > Thanks, > Rong > > [1]