[GitHub] flink issue #2441: [FLINK-3580] [table] Add current time point functions

2016-08-31 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2441 I thought about it again. Maybe I will rework it a little bit. --- 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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

2016-08-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2435#discussion_r76937451 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatListener.java --- @@ -0,0 +1,61 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451451#comment-15451451 ] ASF GitHub Bot commented on FLINK-4478: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

2016-08-31 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2435#discussion_r76938462 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatListener.java --- @@ -0,0 +1,62 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451471#comment-15451471 ] ASF GitHub Bot commented on FLINK-4478: --- Github user beyond1920 commented on a diff

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451484#comment-15451484 ] ASF GitHub Bot commented on FLINK-4478: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

2016-08-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2435#discussion_r76939200 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatListener.java --- @@ -0,0 +1,62 @@ +/* + * Licensed to the Apa

[jira] [Updated] (FLINK-4427) Add slot / Implement container releasing logic (Standalone / Yarn / Mesos)

2016-08-31 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4427: -- Assignee: (was: zhuhaifeng) > Add slot / Implement container releasing logic (Standalone / Yarn / Me

[jira] [Assigned] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable

2016-08-31 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng reassigned FLINK-4530: - Assignee: zhuhaifeng > Generalize TaskExecutorToResourceManagerConnection to be reusable > --

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2016-08-31 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 Jenkins run error: ``` Running org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase SUREFIRE-859: Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451674#comment-15451674 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the iss

[GitHub] flink issue #2438: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and Re...

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2438 Yeah, I think that makes sense. +1 --- 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 feat

[jira] [Commented] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package

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

[GitHub] flink issue #2402: [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokens...

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2402 +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-4436) Unclosed DataOutputBuffer in Utils#setTokensFor()

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

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2418 The string would be constant though, for all types of the same metric. Users would select the metric via "domain", let's say "flink.taskmanager.task.operator.numBytesOut". Then the user w

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[jira] [Commented] (FLINK-4536) Possible thread leak in Task Manager

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451781#comment-15451781 ] Stephan Ewen commented on FLINK-4536: - Could you past the output of jstack of one of t

[GitHub] flink pull request #2427: [FLINK-4516] [cluster management]leader election o...

2016-08-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2427#discussion_r76961323 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerHATest.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-4516) ResourceManager leadership election

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

[GitHub] flink issue #2427: [FLINK-4516] [cluster management]leader election of resou...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2427 Thank you for the update @beyond1920. I will merge your changes later on. --- 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 d

[jira] [Commented] (FLINK-4516) ResourceManager leadership election

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

[jira] [Created] (FLINK-4537) ResourceManager registration with JobManager

2016-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4537: - Summary: ResourceManager registration with JobManager Key: FLINK-4537 URL: https://issues.apache.org/jira/browse/FLINK-4537 Project: Flink Issue Ty

[jira] [Updated] (FLINK-4535) ResourceManager registration with TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4535: -- Summary: ResourceManager registration with TaskExecutor (was: ResourceManager process r

[jira] [Commented] (FLINK-4532) Allow independent metrics reporter for tasks

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15451887#comment-15451887 ] Stephan Ewen commented on FLINK-4532: - Concerning (2) - The next version of YARN / Mes

[jira] [Updated] (FLINK-4449) Heartbeat Manager integration with JobMaster / TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4449: -- Summary: Heartbeat Manager integration with JobMaster / TaskExecutor (was: Heartbeat Ma

[jira] [Commented] (FLINK-4532) Allow independent metrics reporter for tasks

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452013#comment-15452013 ] Stephan Ewen commented on FLINK-4532: - Concerning (1) - I think that would be a great

[jira] [Commented] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock

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

[jira] [Updated] (FLINK-4348) Implement slot allocation protocol

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4348: -- Summary: Implement slot allocation protocol (was: Implement communication from Resource

[GitHub] flink issue #2421: FLINK-4482 numUnsuccessfulCheckpointsTriggers is accessed...

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2421 I think it would be good to use the `triggerLock` only within the `triggerCheckpoint(...)` method. The access to `numUnsuccessfulCheckpointsTriggers` is not super critical, it is merely

[jira] [Updated] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4348: -- Summary: Implement slot allocation protocol with TaskExecutor (was: Implement slot allo

[jira] [Created] (FLINK-4538) Implement slot allocation protocol with JobMaster

2016-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4538: - Summary: Implement slot allocation protocol with JobMaster Key: FLINK-4538 URL: https://issues.apache.org/jira/browse/FLINK-4538 Project: Flink Iss

[GitHub] flink issue #2436: [FLINK-4528] [rpc] Marks main thread execution methods in...

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2436 Okay, that makes sense. This would need to be updated then such that the ResourceManager passes its MainThreadExecutionContext. --- If your project is set up for it, you can reply to th

[jira] [Commented] (FLINK-4528) Mark runAsync and scheduleAsync methods protected

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

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

2016-08-31 Thread liuyuzhong
Github user liuyuzhong closed the pull request at: https://github.com/apache/flink/pull/2439 --- 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-4450) update storm version to 1.0.0

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452048#comment-15452048 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong closed the pull requ

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

2016-08-31 Thread liuyuzhong
GitHub user liuyuzhong reopened a pull request: https://github.com/apache/flink/pull/2439 [FLINK-4450]update storm verion to 1.0.0 in flink-storm and flink-storm-examples This pull is for update storm version to 1.0.0 https://issues.apache.org/jira/browse/FLINK-4450 Becau

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452050#comment-15452050 ] ASF GitHub Bot commented on FLINK-4450: --- GitHub user liuyuzhong reopened a pull requ

[jira] [Created] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation"

2016-08-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4539: --- Summary: Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" Key: FLINK-4539 URL: https://issues.apache.org/jira/browse/FLINK-45

[jira] [Updated] (FLINK-4490) Decouple Slot and Instance

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4490: Fix Version/s: 1.2.0 > Decouple Slot and Instance > -- > > K

[jira] [Updated] (FLINK-4490) Decouple Slot and Instance

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4490: Component/s: (was: Scheduler) Distributed Coordination > Decouple Slot and Inst

[GitHub] flink issue #2427: [FLINK-4516] [cluster management]leader election of resou...

2016-08-31 Thread beyond1920
Github user beyond1920 commented on the issue: https://github.com/apache/flink/pull/2427 @mxm , Thanks for your review. And I change the ResourceManagerHATest to use a mocked RpcService instead of TestingSerialRpcService. --- If your project is set up for it, you can reply to this em

[jira] [Commented] (FLINK-4516) ResourceManager leadership election

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452058#comment-15452058 ] ASF GitHub Bot commented on FLINK-4516: --- Github user beyond1920 commented on the iss

[GitHub] flink issue #2436: [FLINK-4528] [rpc] Marks main thread execution methods in...

2016-08-31 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2436 Yes, will do that. On Wed, Aug 31, 2016 at 1:50 PM, Stephan Ewen wrote: > Okay, that makes sense. > > This would need to be updated then such that the ResourceManage

[jira] [Commented] (FLINK-4528) Mark runAsync and scheduleAsync methods protected

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

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

2016-08-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2439#discussion_r76975599 --- Diff: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java --- @@ -186,15 +177,15 @@ public void testCreate

[jira] [Commented] (FLINK-4532) Allow independent metrics reporter for tasks

2016-08-31 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452069#comment-15452069 ] Renkai Ge commented on FLINK-4532: -- [~StephanEwen] So should I close this issue and creat

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

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

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

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

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

2016-08-31 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2439#discussion_r76975635 --- Diff: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/SpoutOutputCollectorObserverTest.java --- @@ -17,14 +17,15 @@ */ pack

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-31 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452155#comment-15452155 ] Niels Basjes commented on FLINK-4485: - Today I tried to reproduce this problem with th

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

2016-08-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2418 Yes, that makes sense and can be done. However, we still have the issue that the keys/values in the variables map may not be JMX compliant. We may have to recreate the Hashtable after all. --- If yo

[jira] [Created] (FLINK-4540) Detached job execution may prevent cluster shutdown

2016-08-31 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4540: - Summary: Detached job execution may prevent cluster shutdown Key: FLINK-4540 URL: https://issues.apache.org/jira/browse/FLINK-4540 Project: Flink I

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452166#comment-15452166 ] Maximilian Michels commented on FLINK-4485: --- Interesting. But it occurs consiste

[jira] [Created] (FLINK-4541) Support for SQL NOT IN operator

2016-08-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4541: --- Summary: Support for SQL NOT IN operator Key: FLINK-4541 URL: https://issues.apache.org/jira/browse/FLINK-4541 Project: Flink Issue Type: Improvement

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-31 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 How should I view your latest commit ? Am not able to see the changes that you have mentioned above. Thanks @delding --- If your project is set up for it, you can reply to this email and have y

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452266#comment-15452266 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on the iss

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2418 We could lazily filter them in the `get(...)` methods. But looking at how much work `ObjectName` does internally, it seems like making JMX a zero overhead thing is a bit of a lost cause... -

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

[jira] [Assigned] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association

2016-08-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4424: Assignee: Till Rohrmann > Make network environment start-up/shutdown independent of JobMana

[jira] [Created] (FLINK-4542) Add support for MULTISET type and operations

2016-08-31 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4542: --- Summary: Add support for MULTISET type and operations Key: FLINK-4542 URL: https://issues.apache.org/jira/browse/FLINK-4542 Project: Flink Issue Type: Improvem

[GitHub] flink pull request #2442: [FLINK-4148] incorrect calculation minDist distanc...

2016-08-31 Thread xhumanoid
GitHub user xhumanoid opened a pull request: https://github.com/apache/flink/pull/2442 [FLINK-4148] incorrect calculation minDist distance in QuadTree Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration

[jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree

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

[jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

2016-08-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452344#comment-15452344 ] Timo Walther commented on FLINK-2980: - This tasks also includes implementing the funct

[jira] [Updated] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

2016-08-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-2980: Assignee: (was: Chengxiang Li) > Add CUBE/ROLLUP/GROUPING SETS operator in Table API. >

[jira] [Comment Edited] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

2016-08-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452344#comment-15452344 ] Timo Walther edited comment on FLINK-2980 at 8/31/16 2:14 PM: --

[jira] [Created] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

2016-08-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4543: --- Summary: Race Deadlock in SpilledSubpartitionViewTest Key: FLINK-4543 URL: https://issues.apache.org/jira/browse/FLINK-4543 Project: Flink Issue Type: Improvem

[GitHub] flink pull request #2443: [FLINK-3950] Implement MeterView

2016-08-31 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2443 [FLINK-3950] Implement MeterView In the JIRA discussion about FLINK-3950 @StephanEwen introduced the notion of a `MetricView`, a `Meter`that derives it's values from another Counter or Gauge. The `V

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

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

[jira] [Updated] (FLINK-4542) Add support for MULTISET type and operations

2016-08-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4542: Description: Add the MULTISET type and add operations like: MULTISET UNION, MULTISET UNION ALL, MUL

[jira] [Updated] (FLINK-4542) Add support for MULTISET type and operations

2016-08-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4542: Description: Add the MULTISET type and add operations like: MULTISET UNION, MULTISET UNION ALL, MUL

[GitHub] flink pull request #2444: [FLINK-4543] [network] Fix potential deadlock in S...

2016-08-31 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2444 [FLINK-4543] [network] Fix potential deadlock in SpilledSubpartitionViewAsyncIO The deadlock could occur in cases where the SpilledSubpartitionViewAsyncIO would simultaneously try to releas

[jira] [Commented] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

2016-08-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452387#comment-15452387 ] ASF GitHub Bot commented on FLINK-4543: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink issue #2444: [FLINK-4543] [network] Fix potential deadlock in SpilledS...

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2444 @uce I think you'd be the best person to review 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

[jira] [Commented] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

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

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452391#comment-15452391 ] Maximilian Michels commented on FLINK-4535: --- Hi [~jinyu.zj]! Just a few remarks:

[jira] [Updated] (FLINK-4542) Add support for MULTISET type and operations

2016-08-31 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4542: Description: Add the MULTISET type and add operations like: MULTISET UNION, MULTISET UNION ALL, MUL

[GitHub] flink issue #2400: [FLINK-4363] Implement TaskManager basic startup of all c...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2400 Removing merge commits, rebasing, and merging. --- 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

[GitHub] flink issue #2427: [FLINK-4516] [cluster management]leader election of resou...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2427 Thank you. Merging. --- 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-4516) ResourceManager leadership election

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

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

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

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2388 Thank you for your work @KurtYoung. Merging the 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 project does not have this feat

[jira] [Commented] (FLINK-4347) Implement SlotManager core

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

[jira] [Created] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

2016-08-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4544: --- Summary: TaskManager metrics are vulnerable to custom JMX bean installation Key: FLINK-4544 URL: https://issues.apache.org/jira/browse/FLINK-4544 Project: Flink

[GitHub] flink issue #2427: [FLINK-4516] [cluster management]leader election of resou...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2427 Auto-closing from a commit doesn't in the feature branch. Could you please close the PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2388 Auto-closing from a commit doesn't in the feature branch. Could you please close the PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[GitHub] flink issue #2400: [FLINK-4363] Implement TaskManager basic startup of all c...

2016-08-31 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2400 Auto-closing from a commit doesn't in the feature branch. Could you please close the PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-4347) Implement SlotManager core

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

[jira] [Commented] (FLINK-4516) ResourceManager leadership election

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

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

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

[jira] [Closed] (FLINK-4363) Implement TaskManager basic startup of all components in java

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4363. - Resolution: Fixed > Implement TaskManager basic startup of all components in java > --

[jira] [Resolved] (FLINK-4347) Implement SlotManager core

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4347. --- Resolution: Fixed > Implement SlotManager core > -- > >

[jira] [Resolved] (FLINK-4516) ResourceManager leadership election

2016-08-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4516. --- Resolution: Fixed > ResourceManager leadership election >

[GitHub] flink pull request #2445: [FLINK-4544] Refactor old CPU metric initializatio...

2016-08-31 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2445 [FLINK-4544] Refactor old CPU metric initialization This PR refactors the old CPU metric initialization code to no longer rely on reflection. Instead it eagerly casts the `OperatingSystemMXB

[GitHub] flink pull request #2446: [hotfix] Fixes unstable ContinuousFileMonitoringTe...

2016-08-31 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2446 [hotfix] Fixes unstable ContinuousFileMonitoringTest. R: @aljoscha Please review. This is a fix to the unstable test shown here: https://s3.amazonaws.com/archive.travis-ci.org/jobs/1562214

[jira] [Commented] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

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

[jira] [Assigned] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

2016-08-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4544: --- Assignee: Chesnay Schepler > TaskManager metrics are vulnerable to custom JMX bean in

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-08-31 Thread Ashish Walia (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15452676#comment-15452676 ] Ashish Walia commented on FLINK-2662: - I ran into the same problem with Flink 1.0.3 wh

  1   2   >