+1. We should also include FLINK-4618.
There isn’t a PR for it yet, but the fix should be fairly quick.
Gordon
On September 30, 2016 at 1:50:45 AM, Stephan Ewen (se...@apache.org) wrote:
+1 for including
- FLINK-4311
- FLINK-4702 (https://github.com/apache/flink/pull/2574)
- FLINK-4329 (h
Thank you Max for the pointer! I've started watching it, :-D
Cheers,
Liwei
On Wed, Sep 28, 2016 at 9:45 PM, Maximilian Michels wrote:
> Hi Liwei,
>
> I created this a while ago which is pretty much what you want as well:
> https://issues.apache.org/jira/browse/FLINK-3276
>
> Cheers,
> Max
>
> O
Neil Derraugh created FLINK-4718:
Summary: Confusing label in Parallel Streams Diagram
Key: FLINK-4718
URL: https://issues.apache.org/jira/browse/FLINK-4718
Project: Flink
Issue Type: Bug
Looks like what I am currently doing, or at least close.No need to copy the big
file on every node.Copy on one node. Read the data, and send it to a Kafka
cluster using KafkaProducer() object.Use KafkaIO() (in case its a Beam app).
Deploy to the node where the JM is running.It will be executed i
Any ideas?
--
View this message in context:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Use-specific-Task-Manager-for-heavy-computations-tp13747p13771.html
Sent from the Apache Flink Mailing List archive. mailing list archive at
Nabble.com.
I am trying to measure the currentLowWatermark throughout my dataflow, but
I am not seeing it for tasks with sources. For those tasks I see these
metrics:
lastCheckpointSize
numBytesInLocal
numBytesInRemote
numBytesOut
why am I not seeing currentLowWatermark on these tasks?
Thanks!
Dan
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 the job name?
The reason I ask is I would like a way to reflect the ver
Till Rohrmann created FLINK-4717:
Summary: Naive version of atomic stop signal with savepoint
Key: FLINK-4717
URL: https://issues.apache.org/jira/browse/FLINK-4717
Project: Flink
Issue Type:
+1 for including
- FLINK-4311
- FLINK-4702 (https://github.com/apache/flink/pull/2574)
- FLINK-4329 (https://github.com/apache/flink/pull/2546)
On Thu, Sep 29, 2016 at 3:38 PM, Ufuk Celebi wrote:
> +1... Personally, I'm a big fan of frequent bugfix releases :-)
>
> A user already report
Till Rohrmann created FLINK-4716:
Summary: Add trigger full recovery button to web UI
Key: FLINK-4716
URL: https://issues.apache.org/jira/browse/FLINK-4716
Project: Flink
Issue Type: Improvem
Till Rohrmann created FLINK-4715:
Summary: TaskManager should commit suicide after cancellation
failure
Key: FLINK-4715
URL: https://issues.apache.org/jira/browse/FLINK-4715
Project: Flink
I
Till Rohrmann created FLINK-4714:
Summary: Set task state to RUNNING after state has been restored
Key: FLINK-4714
URL: https://issues.apache.org/jira/browse/FLINK-4714
Project: Flink
Issue T
Domokos Miklós Kelen created FLINK-4713:
---
Summary: Implementing ranking evaluation scores for recommender
systems
Key: FLINK-4713
URL: https://issues.apache.org/jira/browse/FLINK-4713
Project: F
Domokos Miklós Kelen created FLINK-4712:
---
Summary: Implementing ranking predictions for ALS
Key: FLINK-4712
URL: https://issues.apache.org/jira/browse/FLINK-4712
Project: Flink
Issue Ty
Till Rohrmann created FLINK-4711:
Summary: TaskManager can crash due to failing
onPartitionStateUpdate call
Key: FLINK-4711
URL: https://issues.apache.org/jira/browse/FLINK-4711
Project: Flink
+1... Personally, I'm a big fan of frequent bugfix releases :-)
A user already reported running into the file source problem and
having a very hard time debugging it. This would be good to fix asap.
– Ufuk
On Thu, Sep 29, 2016 at 3:20 PM, Fabian Hueske wrote:
> Sounds good to me.
>
> Can we inc
Sounds good to me.
Can we include a fix for FLINK-4311 as well?
There is a PR [1] which is good to go IMO modulo resetting the updated
HBase dependency for the 1.1.3 fix.
For 1.2.0 we should start a discussion about bumping the version.
Cheers, Fabian
[1] https://github.com/apache/flink/pull/233
Hi all!
I wanted to bring up having a Flink 1.1.3 bugfix release in the near future.
There are some fixed right now in the release-1.1 branch already (merging
windows, optimizer union, ...) and there is a major bug that is currently
fixed in the master: https://issues.apache.org/jira/browse/FLINK
Sorry for that inconvenience. You are right about mentioning that in the
release notes (adding it even after the release).
We'll take that as feedback for the next release.
On Tue, Sep 27, 2016 at 9:42 PM, Chen Bekor wrote:
> thanks. worth mentioning in the release notes of 1.1.2 that file so
I agree with Max since it hard to foresee when Flip-6 is really done.
Cheers,
Till
On Wed, Sep 28, 2016 at 4:24 PM, Maximilian Michels wrote:
> Hi Eron,
>
> Great to see so much progress on the Mesos implementation! Thank you
> for sharing the code with us.
>
> I'm not entirely sure whether we
Stephan Ewen created FLINK-4710:
---
Summary: Remove transitive Guice dependency from Hadoop
Key: FLINK-4710
URL: https://issues.apache.org/jira/browse/FLINK-4710
Project: Flink
Issue Type: Bug
Holger Frydrych created FLINK-4709:
--
Summary: InputStreamFSInputWrapper does not close wrapped stream
Key: FLINK-4709
URL: https://issues.apache.org/jira/browse/FLINK-4709
Project: Flink
Iss
Stephan Ewen created FLINK-4708:
---
Summary: Scope Mini Kerberos Cluster dependencies as test
dependencies
Key: FLINK-4708
URL: https://issues.apache.org/jira/browse/FLINK-4708
Project: Flink
Is
23 matches
Mail list logo
