[jira] [Assigned] (FLINK-4928) Implement FLIP-6 YARN Application Master Runner

2016-10-27 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuai.xu reassigned FLINK-4928: --- Assignee: shuai.xu > Implement FLIP-6 YARN Application Master Runner >

[jira] [Assigned] (FLINK-4927) Implement FLI-6 YARN Resource Manager

2016-10-27 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuai.xu reassigned FLINK-4927: --- Assignee: shuai.xu > Implement FLI-6 YARN Resource Manager > - >

[jira] [Created] (FLINK-4952) Add Scala API for KeyedStream.flatMap

2016-10-27 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4952: - Summary: Add Scala API for KeyedStream.flatMap Key: FLINK-4952 URL: https://issues.apache.org/jira/browse/FLINK-4952 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4951) Better Javadocs for KeyedStream.flatMap

2016-10-27 Thread Manu Zhang (JIRA)
Manu Zhang created FLINK-4951: - Summary: Better Javadocs for KeyedStream.flatMap Key: FLINK-4951 URL: https://issues.apache.org/jira/browse/FLINK-4951 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15614076#comment-15614076 ] ASF GitHub Bot commented on FLINK-4378: --- Github user wenlong88 commented on the issue:

[GitHub] flink issue #2356: [FLINK-4378]Enable RollingSink to custom HDFS client conf...

2016-10-27 Thread wenlong88
Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/2356 all of the test in travis have passed. thanks for merging this. ^_^ --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15614058#comment-15614058 ] ASF GitHub Bot commented on FLINK-4923: --- Github user zhuhaifengleon commented on a diff in the pull

[GitHub] flink pull request #2693: [FLINK-4923] [Metrics] Expose input/output buffers...

2016-10-27 Thread zhuhaifengleon
Github user zhuhaifengleon commented on a diff in the pull request: https://github.com/apache/flink/pull/2693#discussion_r85463825 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -347,6 +348,12 @@ public Task( //

[jira] [Created] (FLINK-4950) Add support to include multiple Yarn application entries in Yarn properties file

2016-10-27 Thread Vijay Srinivasaraghavan (JIRA)
Vijay Srinivasaraghavan created FLINK-4950: -- Summary: Add support to include multiple Yarn application entries in Yarn properties file Key: FLINK-4950 URL:

[jira] [Created] (FLINK-4949) Refactor Gelly driver inputs

2016-10-27 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4949: - Summary: Refactor Gelly driver inputs Key: FLINK-4949 URL: https://issues.apache.org/jira/browse/FLINK-4949 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #2708: [FLINK-4946] [scripts] Load jar files from subdire...

2016-10-27 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2708 [FLINK-4946] [scripts] Load jar files from subdirectories of lib The Flink classpath is a concatenation of jar files in lib/. This commit includes files from subdirectories of lib/ in the

[jira] [Commented] (FLINK-4946) Load jar files from subdirectories of lib

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15613223#comment-15613223 ] ASF GitHub Bot commented on FLINK-4946: --- GitHub user greghogan opened a pull request:

[jira] [Commented] (FLINK-4948) Consider using checksums or similar to detect bad checkpoints

2016-10-27 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15613064#comment-15613064 ] Jamie Grier commented on FLINK-4948: Makes sense. Maybe a scheme where we can verify that the

[jira] [Commented] (FLINK-4948) Consider using checksums or similar to detect bad checkpoints

2016-10-27 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612892#comment-15612892 ] Gyula Fora commented on FLINK-4948: --- I think in general this would be very nice but what about tools

[jira] [Created] (FLINK-4948) Consider using checksums or similar to detect bad checkpoints

2016-10-27 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-4948: -- Summary: Consider using checksums or similar to detect bad checkpoints Key: FLINK-4948 URL: https://issues.apache.org/jira/browse/FLINK-4948 Project: Flink

[jira] [Created] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

2016-10-27 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-4947: -- Summary: Make all configuration possible via flink-conf.yaml and CLI. Key: FLINK-4947 URL: https://issues.apache.org/jira/browse/FLINK-4947 Project: Flink

[jira] [Created] (FLINK-4946) Load jar files from subdirectories of lib

2016-10-27 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4946: - Summary: Load jar files from subdirectories of lib Key: FLINK-4946 URL: https://issues.apache.org/jira/browse/FLINK-4946 Project: Flink Issue Type: Improvement

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-10-27 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2664 @StephanEwen latest commit assembles connectors into separate directories. I'll create a ticket for loading jar files from subdirectories of`lib`. --- If your project is set up for it,

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612777#comment-15612777 ] ASF GitHub Bot commented on FLINK-4861: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN

2016-10-27 Thread Makman2
Github user Makman2 commented on the issue: https://github.com/apache/flink/pull/2704 Feel free to cherry-pick my commit into your branch and close this PR :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612697#comment-15612697 ] ASF GitHub Bot commented on FLINK-4943: --- Github user Makman2 commented on the issue:

[jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612673#comment-15612673 ] ASF GitHub Bot commented on FLINK-4887: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612675#comment-15612675 ] ASF GitHub Bot commented on FLINK-4887: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612690#comment-15612690 ] ASF GitHub Bot commented on FLINK-4943: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN

2016-10-27 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2704 I keep an `_minutiae` branch and push that every few months, typically after a release. There are fixed costs at each level of Flink's ticketing / pull request / verify / commit process. ---

[GitHub] flink pull request #2699: [FLINK-4887] [execution graph] Introduce TaskManag...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2699#discussion_r85392726 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/StackTrace.java --- @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2699: [FLINK-4887] [execution graph] Introduce TaskManag...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2699#discussion_r85390985 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/StackTraceSampleResponse.java --- @@ -0,0 +1,57 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612672#comment-15612672 ] ASF GitHub Bot commented on FLINK-4887: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2699: [FLINK-4887] [execution graph] Introduce TaskManag...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2699#discussion_r85383836 --- Diff: flink-tests/src/test/resources/log4j-test.properties --- @@ -18,7 +18,7 @@ # Set root logger level to OFF to not flood build logs

[jira] [Commented] (FLINK-4887) Replace ActorGateway by TaskManagerGateway interface

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612674#comment-15612674 ] ASF GitHub Bot commented on FLINK-4887: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink issue #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN

2016-10-27 Thread Makman2
Github user Makman2 commented on the issue: https://github.com/apache/flink/pull/2704 Though I wouldn't fix more than this one (except I stumble over some typos again) :3 Is there already a larger ticket? @greghogan --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612618#comment-15612618 ] ASF GitHub Bot commented on FLINK-4943: --- Github user Makman2 commented on the issue:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612488#comment-15612488 ] ASF GitHub Bot commented on FLINK-4939: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-10-27 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2707 [FLINK-4939] GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint So far the GenericWriteAheadSink expected that the subtask that wrote a temporary buffer

[jira] [Commented] (FLINK-4889) Make InstanceManager independent of ActorRef

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612480#comment-15612480 ] ASF GitHub Bot commented on FLINK-4889: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2698: [FLINK-4889] [InstanceManager] Remove ActorRef dep...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2698 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612477#comment-15612477 ] ASF GitHub Bot commented on FLINK-4945: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #2706: [FLINK-4945] KafkaConsumer logs wrong warning about confi...

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2706 R @rmetzger --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[jira] [Updated] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-10-27 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4939: -- Summary: GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending

[jira] [Commented] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612472#comment-15612472 ] ASF GitHub Bot commented on FLINK-4945: --- GitHub user StefanRRichter opened a pull request:

[GitHub] flink pull request #2706: [FLINK-4945] KafkaConsumer logs wrong warning abou...

2016-10-27 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2706 [FLINK-4945] KafkaConsumer logs wrong warning about confirmation for … This PR fixes an unjustified warning about unknown checkpoints in FlinkKafkaConsumerBase. You can merge this pull

[jira] [Updated] (FLINK-4939) GenericWriteAheadSink: Decouple the subtask creating a pending checkpoint from the one commiting it.

2016-10-27 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4939: -- Summary: GenericWriteAheadSink: Decouple the subtask creating a pending checkpoint from the one

[jira] [Commented] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

2016-10-27 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612467#comment-15612467 ] Greg Hogan commented on FLINK-4823: --- How are you creating your {{Graph}}? Each vertex represented in the

[jira] [Commented] (FLINK-4889) Make InstanceManager independent of ActorRef

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612452#comment-15612452 ] ASF GitHub Bot commented on FLINK-4889: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2698: [FLINK-4889] [InstanceManager] Remove ActorRef dependency...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2698 Looks good +1 to merge this --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Assigned] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-10-27 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4945: - Assignee: Stefan Richter > KafkaConsumer logs wrong warning about confirmation for

[jira] [Created] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-10-27 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4945: - Summary: KafkaConsumer logs wrong warning about confirmation for unknown checkpoint Key: FLINK-4945 URL: https://issues.apache.org/jira/browse/FLINK-4945 Project:

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612315#comment-15612315 ] ASF GitHub Bot commented on FLINK-2608: --- Github user chermenin commented on a diff in the pull

[GitHub] flink pull request #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread chermenin
Github user chermenin commented on a diff in the pull request: https://github.com/apache/flink/pull/2623#discussion_r85369265 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java --- @@ -710,7 +712,103 @@ public String toString()

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612306#comment-15612306 ] ASF GitHub Bot commented on FLINK-2608: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2623 I like this approach. One minor question, otherwise +1 to go here --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612301#comment-15612301 ] ASF GitHub Bot commented on FLINK-2608: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2623#discussion_r85368023 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java --- @@ -710,7 +712,103 @@ public String

[jira] [Commented] (FLINK-4733) Port WebFrontend to new metric system

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612284#comment-15612284 ] ASF GitHub Bot commented on FLINK-4733: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2616: [FLINK-4733] Port WebInterface to metric system

2016-10-27 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2616 I tested the change locally, it works. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612219#comment-15612219 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #2690: [FLINK-4894] [network] Don't request buffer after ...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2690 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612217#comment-15612217 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-4715) TaskManager should commit suicide after cancellation failure

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612273#comment-15612273 ] ASF GitHub Bot commented on FLINK-4715: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2652: [FLINK-4715] Fail TaskManager with fatal error if ...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2652 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-4715) TaskManager should commit suicide after cancellation failure

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4715. -- Resolution: Fixed Fix Version/s: 1.1.4 Fixed in cc6655b (release-1.1), 27fd249 (master). >

[jira] [Commented] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612253#comment-15612253 ] ASF GitHub Bot commented on FLINK-4894: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4894. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed in 529534f (release-1.1),

[jira] [Reopened] (FLINK-4510) Always create CheckpointCoordinator

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-4510: > Always create CheckpointCoordinator > --- > > Key:

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612226#comment-15612226 ] Ufuk Celebi commented on FLINK-4510: Fixed in {{b420750}} (release-1.1). > Always create

[jira] [Closed] (FLINK-4510) Always create CheckpointCoordinator

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4510. -- Resolution: Fixed Fix Version/s: 1.1.4 > Always create CheckpointCoordinator >

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1561#comment-1561 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612221#comment-15612221 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612215#comment-15612215 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85360067 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeSessionWindowsWindowsTest.java --- @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85361303 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java --- @@ -0,0 +1,369 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85360454 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeTriggerTest.java --- @@ -0,0 +1,153 @@

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612218#comment-15612218 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85359630 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java --- @@ -0,0 +1,123 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85361208 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java --- @@ -0,0 +1,369 @@

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612216#comment-15612216 ] ASF GitHub Bot commented on FLINK-4552: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85359406 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java --- @@ -0,0 +1,123 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85360968 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/PurgingTriggerTest.java --- @@ -0,0 +1,149 @@

[jira] [Commented] (FLINK-4733) Port WebFrontend to new metric system

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612172#comment-15612172 ] ASF GitHub Bot commented on FLINK-4733: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2616: [FLINK-4733] Port WebInterface to metric system

2016-10-27 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2616 Thank you for rebasing. This run: had the following error: https://s3.amazonaws.com/archive.travis-ci.org/jobs/170428661/log.txt ``` Failed tests:

[jira] [Resolved] (FLINK-4756) NullPointerException on submiting a job with StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster

2016-10-27 Thread Ruwen Moos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruwen Moos resolved FLINK-4756. --- Resolution: Not A Bug Version of flink for the cluster and in the maven project were to far apart.

[GitHub] flink issue #2694: [FLINK-4925] [metrics] Integrate meters into IOMetricGrou...

2016-10-27 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2694 +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-4925) Integrate meters into IOMetricGroups

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612162#comment-15612162 ] ASF GitHub Bot commented on FLINK-4925: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612146#comment-15612146 ] ASF GitHub Bot commented on FLINK-2597: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request #2705: [FLINK-2597][FLINK-4050] Add wrappers for Kafka se...

2016-10-27 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2705 [FLINK-2597][FLINK-4050] Add wrappers for Kafka serializers, test for partitioner and documentation This pull requests addresses the following JIRAs: - [FLINK-2597 Add a test for

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612123#comment-15612123 ] ASF GitHub Bot commented on FLINK-2608: --- Github user chermenin commented on the issue:

[GitHub] flink issue #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2623 I exclude Kryo as a dependency from Chill and add simple test to check Java collections. Tests added to `flink-tests` because it is depends on `flink-runtime` (where used Chill). --- If your

[GitHub] flink issue #2696: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a q...

2016-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2696 Thanks for the review @StephanEwen. Yes let's do it as you've proposed. I've opened an [issue](https://issues.apache.org/jira/browse/FLINK-4944) for replacing Akka's death watch with our own

[jira] [Closed] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

2016-10-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4037. --- Resolution: Fixed Fix Version/s: 1.2.0 > Introduce ArchivedExecutionGraph without any

[GitHub] flink pull request #2697: [backport] [FLINK-3347] [akka] Add QuarantineMonit...

2016-10-27 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2697 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612084#comment-15612084 ] ASF GitHub Bot commented on FLINK-3347: --- Github user tillrohrmann commented on the issue:

[jira] [Created] (FLINK-4944) Replace Akka's deatch watch with own heartbeat on the TM side

2016-10-27 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4944: Summary: Replace Akka's deatch watch with own heartbeat on the TM side Key: FLINK-4944 URL: https://issues.apache.org/jira/browse/FLINK-4944 Project: Flink

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612066#comment-15612066 ] ASF GitHub Bot commented on FLINK-3347: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink issue #2691: [FLINK-4910] Introduce safety net for closing file system...

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2691 Thanks for the reviews @StephanEwen and @aljoscha ! I addressed your comments in my last commit. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4910) Introduce safety net for closing file system streams

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611984#comment-15611984 ] ASF GitHub Bot commented on FLINK-4910: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611981#comment-15611981 ] ASF GitHub Bot commented on FLINK-4876: --- Github user attachmentgenie commented on the issue:

[GitHub] flink issue #2680: [FLINK-4876] Allow web interface to be bound to a specifi...

2016-10-27 Thread attachmentgenie
Github user attachmentgenie commented on the issue: https://github.com/apache/flink/pull/2680 @StephanEwen seems reasonable thing to do, i updated the code to use the new ConfigOption method --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611940#comment-15611940 ] ASF GitHub Bot commented on FLINK-4943: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611963#comment-15611963 ] ASF GitHub Bot commented on FLINK-3347: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2697: [backport] [FLINK-3347] [akka] Add QuarantineMonitor whic...

2016-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2697 Thanks for the review @StephanEwen. I will change the configuration name and then merge the PR into the release-1.1 branch. Travis passed locally and the failing test cases are

  1   2   3   >