[jira] [Closed] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend

2016-12-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5146. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in e4f802dd502f38b922f668c2813728d55

[jira] [Closed] (FLINK-5173) Upgrade RocksDB dependency

2016-12-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5173. --- Resolution: Fixed Implemented for 1.2 in 6e98a9357903b113f76b2a7e91e2049c6e88fb35 > Upgrade R

[jira] [Commented] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-12-02 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15717488#comment-15717488 ] Kurt Young commented on FLINK-5185: --- [~fhueske]Sure, i will open one. > Decouple BatchT

[GitHub] flink issue #2927: [docs] Replace broken link.

2016-12-02 Thread mindprince
Github user mindprince commented on the issue: https://github.com/apache/flink/pull/2927 Added another unrelated doc fix to this PR instead of creating a new PR. Let me know if that's not fine and I will create another PR. --- If your project is set up for it, you can reply to this e

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2016-12-02 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15717166#comment-15717166 ] Chen Qin commented on FLINK-4460: - Ongoing implementation reflecting feedbacks, missing wi

[jira] [Closed] (FLINK-5220) Flink SQL projection pushdown

2016-12-02 Thread zhangjing (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing closed FLINK-5220. Resolution: Duplicate > Flink SQL projection pushdown > - > > Ke

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

2016-12-02 Thread zhangjing (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15717000#comment-15717000 ] zhangjing commented on FLINK-5220: -- Hi, Fabian. I understand, I would close this jira. Th

[GitHub] flink pull request #2927: [docs] Replace broken link.

2016-12-02 Thread mindprince
GitHub user mindprince opened a pull request: https://github.com/apache/flink/pull/2927 [docs] Replace broken link. This variable was removed in dc5062557a55 You can merge this pull request into a Git repository by running: $ git pull https://github.com/mindprince/flink docs-fi

[GitHub] flink pull request #2924: [FLINK-5229] [tm] Discard completed checkpoints if...

2016-12-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2924 --- 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 enab

[jira] [Commented] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15716049#comment-15716049 ] ASF GitHub Bot commented on FLINK-5229: --- Github user asfgit closed the pull request

[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-02 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2762 Hi @fhueske I've updated PR according to your review. Best regards, Ivan. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715968#comment-15715968 ] ASF GitHub Bot commented on FLINK-3871: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715864#comment-15715864 ] Stephan Ewen commented on FLINK-5240: - This is fixed in 1.1.4 via 59f61bf6cb8351cec936

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

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715854#comment-15715854 ] ASF GitHub Bot commented on FLINK-4927: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource Manager

2016-12-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2808 I have started to and merge this together with #2744 (both are needed together to compile). Will file a few JIRA issues with followups. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715843#comment-15715843 ] ASF GitHub Bot commented on FLINK-5074: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2903: [FLINK-5074] [runtime] add a zookeeper based running job ...

2016-12-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2903 Looks good to me! I think it would be good to add a test to this, based on a Curator TestingServer. This test here gives an example how to use the TestingServer: https://github.c

[jira] [Commented] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715821#comment-15715821 ] ASF GitHub Bot commented on FLINK-5229: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2924: [FLINK-5229] [tm] Discard completed checkpoints if a subs...

2016-12-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2924 Thanks for testing it @uce and @StephanEwen. Really good finding with the bug. I'll fix it and then I will merge the branch. --- If your project is set up for it, you can reply to this email an

[jira] [Commented] (FLINK-3870) Add IntelliJ code style file

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715801#comment-15715801 ] ASF GitHub Bot commented on FLINK-3870: --- Github user dawidwys closed the pull reques

[GitHub] flink pull request #1963: [FLINK-3870][docs] Added IntelliJ code style

2016-12-02 Thread dawidwys
Github user dawidwys closed the pull request at: https://github.com/apache/flink/pull/1963 --- 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 en

[jira] [Commented] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715800#comment-15715800 ] ASF GitHub Bot commented on FLINK-5229: --- Github user uce commented on the issue:

[GitHub] flink issue #2924: [FLINK-5229] [tm] Discard completed checkpoints if a subs...

2016-12-02 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2924 Tested this with a job that fails during checkpointing and it works like a charm for both chained and non chained state, but I found another issue with discarding pending checkpoints. The task states map

[jira] [Created] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2016-12-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5241: Summary: Introduce AbstractStreamOperator get CloseableRegistry Key: FLINK-5241 URL: https://issues.apache.org/jira/browse/FLINK-5241 Project: Flink Issue Ty

[jira] [Commented] (FLINK-5226) Eagerly project unused attributes

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715683#comment-15715683 ] ASF GitHub Bot commented on FLINK-5226: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #2926: [FLINK-5226] [table] Use correct DataSetCostFactor...

2016-12-02 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2926 [FLINK-5226] [table] Use correct DataSetCostFactory and improve DataSetCalc costs. - Improved DataSetCalc costs make projections cheap and help to push them down. - Adapted existing tests that

[jira] [Created] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling

2016-12-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5240: --- Summary: Properly Close StateBackend in StreamTask when closing/canceling Key: FLINK-5240 URL: https://issues.apache.org/jira/browse/FLINK-5240 Project: Flink

[jira] [Created] (FLINK-5239) Properly unpack thrown exceptions in RPC methods

2016-12-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5239: --- Summary: Properly unpack thrown exceptions in RPC methods Key: FLINK-5239 URL: https://issues.apache.org/jira/browse/FLINK-5239 Project: Flink Issue Type: Sub-

[jira] [Commented] (FLINK-4547) when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715563#comment-15715563 ] Stephan Ewen commented on FLINK-4547: - [~jinyu.zj] Is this issue complete? Can it be c

[jira] [Updated] (FLINK-4959) Write Documentation for ProcessFunction

2016-12-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4959: Summary: Write Documentation for ProcessFunction (was: Write Documentation for Timely FlatM

[jira] [Commented] (FLINK-4705) Instrument FixedLengthRecordSorter

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715512#comment-15715512 ] ASF GitHub Bot commented on FLINK-4705: --- Github user greghogan commented on the issu

[GitHub] flink issue #2617: [FLINK-4705] Instrument FixedLengthRecordSorter

2016-12-02 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2617 @StephanEwen, no worries about deferring this. Performance is nice but scaling and stability certainly takes precedence. Just wanted to make sure there was ample time between review and release.

[jira] [Created] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager

2016-12-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5238: --- Summary: Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager Key: FLINK-5238 URL: https://issues.apache.org/jira/browse/FLINK-5238 Proj

[jira] [Resolved] (FLINK-4836) Implement Mini Cluster

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4836. - Resolution: Fixed Assignee: Stephan Ewen Fixed in {{flip-6}} branch. > Implement Mini Clust

[jira] [Closed] (FLINK-4836) Implement Mini Cluster

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4836. --- > Implement Mini Cluster > -- > > Key: FLINK-4836 > UR

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715487#comment-15715487 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90664938 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/SSLStoreOverlay.java --- @@ -0,0 +1,124 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715494#comment-15715494 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715486#comment-15715486 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715492#comment-15715492 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715491#comment-15715491 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90454802 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/AbstractContainerOverlay.java --- @@ -0,0 +1,72 @@ +/* + * Licen

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90664759 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/HadoopUserOverlay.java --- @@ -0,0 +1,83 @@ +/* + * Licensed to

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90666953 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java --- @@ -542,42 +542,10 @@ protected static File as

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90454287 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/ContainerOverlay.java --- @@ -0,0 +1,37 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715493#comment-15715493 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715490#comment-15715490 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715495#comment-15715495 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90664795 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/Krb5ConfOverlay.java --- @@ -0,0 +1,111 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715488#comment-15715488 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715489#comment-15715489 ] ASF GitHub Bot commented on FLINK-5091: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90665396 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/overlays/HadoopConfOverlayTest.java --- @@ -0,0 +1,119 @@ +/* + * License

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90666707 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/overlays/HadoopConfOverlayTest.java --- @@ -0,0 +1,119 @@ +/* + * License

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90664693 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/FlinkDistributionOverlay.java --- @@ -0,0 +1,126 @@ +/* + * Lice

[GitHub] flink pull request #2915: [FLINK-5091] Formalize the Mesos AppMaster environ...

2016-12-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2915#discussion_r90664782 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/KeytabOverlay.java --- @@ -0,0 +1,102 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-5209) Fix TaskManager metrics

2016-12-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5209. - Resolution: Fixed Fixed in 4e336c692b74f218ba09844a46f49534e3a210e9 > Fix TaskManager metrics > -

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2016-12-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715453#comment-15715453 ] Tzu-Li (Gordon) Tai commented on FLINK-4022: I would like to move along with t

[jira] [Commented] (FLINK-5209) Fix TaskManager metrics

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715446#comment-15715446 ] ASF GitHub Bot commented on FLINK-5209: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2902: [FLINK-5209] [webfrontend] Fix TaskManager metrics

2016-12-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2902 --- 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 enab

[GitHub] flink pull request #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-12-02 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2216 --- 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 enab

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715438#comment-15715438 ] ASF GitHub Bot commented on FLINK-4173: --- Github user zentol closed the pull request

[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

2016-12-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715440#comment-15715440 ] Tzu-Li (Gordon) Tai commented on FLINK-5017: I agree that this isn't a blocker

[jira] [Created] (FLINK-5237) Consolidate and harmonize Window Translation Tests

2016-12-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5237: --- Summary: Consolidate and harmonize Window Translation Tests Key: FLINK-5237 URL: https://issues.apache.org/jira/browse/FLINK-5237 Project: Flink Issue

[jira] [Commented] (FLINK-5234) Inform user about classpath configuration

2016-12-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715422#comment-15715422 ] Maximilian Michels commented on FLINK-5234: --- I thought about always logging the

[jira] [Commented] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails

2016-12-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715405#comment-15715405 ] Till Rohrmann commented on FLINK-5229: -- Thanks for the pointer [~aljoscha]. The PR I'

[jira] [Resolved] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set

2016-12-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5128. Resolution: Fixed Fix Version/s: 1.2.0 > Get Kafka partitions in FlinkKafkaPr

[jira] [Commented] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set

2016-12-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715378#comment-15715378 ] Tzu-Li (Gordon) Tai commented on FLINK-5128: Resolved in {{master}} with http

[jira] [Commented] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715374#comment-15715374 ] ASF GitHub Bot commented on FLINK-5128: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2893: [FLINK-5128]Get Kafka partitions in FlinkKafkaProd...

2016-12-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2893 --- 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 enab

[jira] [Created] (FLINK-5236) User jar classpath should come first in classpath

2016-12-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-5236: - Summary: User jar classpath should come first in classpath Key: FLINK-5236 URL: https://issues.apache.org/jira/browse/FLINK-5236 Project: Flink Iss

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715367#comment-15715367 ] ASF GitHub Bot commented on FLINK-4574: --- GitHub user tony810430 opened a pull reques

[GitHub] flink pull request #2925: [FLINK-4574] [kinesis]Strengthen fetch interval im...

2016-12-02 Thread tony810430
GitHub user tony810430 opened a pull request: https://github.com/apache/flink/pull/2925 [FLINK-4574] [kinesis]Strengthen fetch interval implementation in Kinesis consumer I used Timer to implement it. If "flink.shard.getrecords.intervalmillis" is set by default value, which

[jira] [Created] (FLINK-5235) HBase classpath automatically added to Flink classpath

2016-12-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-5235: - Summary: HBase classpath automatically added to Flink classpath Key: FLINK-5235 URL: https://issues.apache.org/jira/browse/FLINK-5235 Project: Flink

[GitHub] flink pull request #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG li...

2016-12-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2886#discussion_r90653350 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1046,11 +1046,10 @@ class TaskManager( networ

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

2016-12-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715340#comment-15715340 ] Chesnay Schepler commented on FLINK-3962: - yes, there is still a LOG.error call in

[jira] [Commented] (FLINK-5226) Eagerly project unused attributes

2016-12-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715341#comment-15715341 ] Fabian Hueske commented on FLINK-5226: -- I found the issue. The planner was not initia

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

2016-12-02 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715324#comment-15715324 ] Jared Stehler commented on FLINK-3962: -- I'm still seeing this in sentry; is it possib

[jira] [Assigned] (FLINK-5226) Eagerly project unused attributes

2016-12-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-5226: Assignee: Fabian Hueske > Eagerly project unused attributes > -

[jira] [Commented] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715335#comment-15715335 ] Stephan Ewen commented on FLINK-5140: - Similar as the actual request for a slot via th

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-02 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2886 The changes and the test look good to me. While waiting for Travis, I will test this with an HA cluster. We can merge this if everything succeeds. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715333#comment-15715333 ] ASF GitHub Bot commented on FLINK-5179: --- Github user uce commented on the issue:

[jira] [Assigned] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5140: --- Assignee: Stephan Ewen > NoResourceAvailableException is thrown while starting a new job > --

[jira] [Commented] (FLINK-5234) Inform user about classpath configuration

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715330#comment-15715330 ] Stephan Ewen commented on FLINK-5234: - Classpaths are logged on debug level by all com

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

2016-12-02 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715327#comment-15715327 ] Jared Stehler commented on FLINK-3962: -- (v1.1.3) java.lang.IllegalArgumentException:

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-02 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2886 Actually, i don't know whether @rmetzger did review the functional changes; but that's only a single line. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715296#comment-15715296 ] ASF GitHub Bot commented on FLINK-5229: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715309#comment-15715309 ] ASF GitHub Bot commented on FLINK-5179: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715302#comment-15715302 ] ASF GitHub Bot commented on FLINK-5179: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG li...

2016-12-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2886#discussion_r90652945 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1046,11 +1046,10 @@ class TaskManager( networ

[GitHub] flink pull request #2924: [FLINK-5229] [tm] Discard completed checkpoints if...

2016-12-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2924 [FLINK-5229] [tm] Discard completed checkpoints if a subsequent operator's checkpoint fails In case of a failure of any StreamOperator#snapshotState method, all up to this point created St

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715290#comment-15715290 ] ASF GitHub Bot commented on FLINK-5179: --- Github user uce commented on a diff in the

[jira] [Created] (FLINK-5234) Inform user about classpath configuration

2016-12-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-5234: - Summary: Inform user about classpath configuration Key: FLINK-5234 URL: https://issues.apache.org/jira/browse/FLINK-5234 Project: Flink Issue Type:

[GitHub] flink pull request #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG li...

2016-12-02 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2886#discussion_r90651728 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -1046,11 +1046,10 @@ class TaskManager( network.g

[jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

2016-12-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4396: --- Fix Version/s: (was: 1.1.4) > GraphiteReporter class not found at startup of jobmanager >

[jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

2016-12-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715283#comment-15715283 ] Ufuk Celebi commented on FLINK-4396: Good idea > GraphiteReporter class not found at

[jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

2016-12-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715278#comment-15715278 ] Ufuk Celebi commented on FLINK-5048: I would like to have this in 1.1.4, if feasible.

[jira] [Closed] (FLINK-4904) Add a limit for how much data may be spilled in checkpoint alignments

2016-12-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4904. --- Resolution: Duplicate Fix Version/s: (was: 1.1.4) (was: 1.2.0) > Add

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715275#comment-15715275 ] ASF GitHub Bot commented on FLINK-5179: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-5179) MetricRegistry life-cycle issues with HA

2016-12-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715273#comment-15715273 ] ASF GitHub Bot commented on FLINK-5179: --- Github user zentol commented on the issue:

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-02 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2886 Someone has to review the test and then we're good to go IMO. --- 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 h

  1   2   3   >