[jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

Elias Levy created FLINK-4027: - Summary: FlinkKafkaProducer09 sink can lose messages Key: FLINK-4027 URL: https://issues.apache.org/jira/browse/FLINK-4027 Project: Flink Issue Type: Bug

RE: Apache Flink Web Monitor Api

Hi Ufuk, Thank you for your response. We've seen the cancel and run operations in code.However, it would be very nice to add restart operation. We're now implementing custom api to restart flink app. > From: u...@apache.org > Date: Mon, 6 Jun 2016 15:57:48 +0200 > Subject: Re: Apache Flink Web

[jira] [Created] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation

Dyana Rose created FLINK-4026: - Summary: Fix code, grammar, and link issues in the Streaming documentation Key: FLINK-4026 URL: https://issues.apache.org/jira/browse/FLINK-4026 Project: Flink

Re: Apache Flink Web Monitor Api

Hey Ozan! For cancel and submit, yes: - cancel: /jobs/:jobid/cancel - submit: /jars/upload and /jars/:jarid/run You can look into WebRuntimeMonitor class for more details about the submission. Cancellation should be straight forward. Restart is currently not supported via the REST API and I'm

Re: How to run table api in 1.1-SNAPSHOT

Yes, it's the name "count" that caused the problem, thanks for your explanation. Still, the word-count example uses an embarrassing field name in table API case that I would naturally use "select word, count" in SQL while forgetting the keyword... On Mon, Jun 6, 2016 at 4:31 PM, Ufuk Celebi

Re: How to run table api in 1.1-SNAPSHOT

On Mon, Jun 6, 2016 at 8:35 AM, Vasiliki Kalavri wrote: > column "count"? Can you try renaming it to "myCount" or something else? I For String expressions, it's also possible to escape it via "...as `count`...", but I'm not sure how this translates to the DSL

Apache Flink Web Monitor Api

Hi everyone, We need to implement api functions to cancel, restart and start the flink job. Is there any way to add these functions to WebMonitor api?Is there any plan to implement these functions to WebMonitor api? Thanks. Ozan

Re: How to run table api in 1.1-SNAPSHOT

Hi Cody, could it be you're getting this error because you've named a SQL table column "count"? Can you try renaming it to "myCount" or something else? I think the parser recognizes the aggregate function instead :) Cheers, -V. On Jun 2, 2016 1:56 PM, "Cody Innowhere"