Hey Dan!
On Thu, Sep 29, 2016 at 10:58 PM, dan bress wrote:
> If I deploy a job to Flink called "A"(set my
> streamExecutionEnvironment.execute("A"), that checkpoints state. Then I
> cancel "A" and deploy the same job but call it "B", will it pick up A's
> state? Or is checkpointing key'd by th
Flavio Pompermaier created FLINK-4719:
-
Summary: KryoSerializer random exception
Key: FLINK-4719
URL: https://issues.apache.org/jira/browse/FLINK-4719
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-4720:
---
Summary: Implement an archived version of the execution graph
Key: FLINK-4720
URL: https://issues.apache.org/jira/browse/FLINK-4720
Project: Flink
Issu
Hello Dan,
the technical reason is that this metric is only collected in the
*InputProcessor classes, which aren't used for source tasks.
I do recall that there were discussions about source watermarks, but
frankly i don't remember why we didn't add them.
In order to add them one would only
I think what you describe, Chesnay, is exactly what we should do...
On Fri, Sep 30, 2016 at 1:15 PM, Chesnay Schepler
wrote:
> Hello Dan,
>
> the technical reason is that this metric is only collected in the
> *InputProcessor classes, which aren't used for source tasks.
>
> I do recall that ther
I think what you're suggesting is to load a large file into Kafka which will
replicate it and make it available to all nodes. However, that is not what I
want.
What I want is to run a specific transformation step on a specific
TaskManager.
--
View this message in context:
http://apache-flink-m
Awesome! It would definitely help me troubleshoot lagging watermarks if i
can see what watermark all my sources have seen. Thanks for looking into
this!
Dan
On Fri, Sep 30, 2016 at 5:48 AM Stephan Ewen wrote:
> I think what you describe, Chesnay, is exactly what we should do...
>
> On Fri, Se
Ufuk,
Thanks for the answer. In 1.1.X, If I deploy job "Job-V1", run for a
while, trigger a save point, cancel the job, submit job "Job-V2" and resume
save point. Will Job-V2 understand the savepoint from Job-V1?
What is the scope of a savepoint? Who does it belong to? A Job? A
TaskMana
Ashish Walia created FLINK-4721:
---
Summary: Getting exception when using a key of type Option[String]
in distinct operation
Key: FLINK-4721
URL: https://issues.apache.org/jira/browse/FLINK-4721
Project:
