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
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 Mo
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
Is
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 no
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 wrote
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
expressions. Any ideas, Fabian or Alj
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
