[jira] [Updated] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class

2016-08-31 Thread zhangjing (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing updated FLINK-4547: - Description: Now every time call connect method in AkkaRpcService class using same address and same rpc g

[jira] [Created] (FLINK-4547) Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class

2016-08-31 Thread zhangjing (JIRA)
zhangjing created FLINK-4547: Summary: Return same object when call connect method in AkkaRpcService using same address and same rpc gateway class Key: FLINK-4547 URL: https://issues.apache.org/jira/browse/FLINK-4547

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

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

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-08-31 Thread beyond1920
GitHub user beyond1920 opened a pull request: https://github.com/apache/flink/pull/2451 [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor This pull request is to implement ResourceManager registration with TaskExecutor, which including:

[jira] [Updated] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs

2016-08-31 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-4546: --- Issue Type: New Feature (was: Bug) > Remove STREAM keyword and use batch sql parser for stream jobs > ---

[jira] [Created] (FLINK-4546) Remove STREAM keyword and use batch sql parser for stream jobs

2016-08-31 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4546: -- Summary: Remove STREAM keyword and use batch sql parser for stream jobs Key: FLINK-4546 URL: https://issues.apache.org/jira/browse/FLINK-4546 Project: Flink Issue Type:

[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=15454331#comment-15454331 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the iss

[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=15454332#comment-15454332 ] 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 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

[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 close it, and will open new pull request later --- 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 fe

[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=15454038#comment-15454038 ] ASF GitHub Bot commented on FLINK-4363: --- Github user wangzhijiang999 closed the pull

[GitHub] flink pull request #2400: [FLINK-4363] Implement TaskManager basic startup o...

2016-08-31 Thread wangzhijiang999
Github user wangzhijiang999 closed the pull request at: https://github.com/apache/flink/pull/2400 --- 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 featur

[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=15454001#comment-15454001 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the iss

[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 @StephanEwen If we merge this, flink-storm will compatible with all the storm which version higher than 1.0.0 And we can import "storm-rename-hack" to compatible with previous storm

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

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

[GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t...

2016-08-31 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2447#discussion_r77101490 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/SlotAllocationFuture.java --- @@ -20,73 +20,125 @@ import or

[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=15453914#comment-15453914 ] ASF GitHub Bot commented on FLINK-4516: --- Github user beyond1920 closed the pull requ

[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=15453913#comment-15453913 ] ASF GitHub Bot commented on FLINK-4516: --- Github user beyond1920 commented on the iss

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

2016-08-31 Thread beyond1920
Github user beyond1920 closed the pull request at: https://github.com/apache/flink/pull/2427 --- 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

[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 Hi @mxm , thanks so much. I already 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. If your project does not have this

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-31 Thread KurtYoung
Github user KurtYoung closed the pull request at: https://github.com/apache/flink/pull/2388 --- 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 e

[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=15453911#comment-15453911 ] ASF GitHub Bot commented on FLINK-4347: --- Github user KurtYoung closed the pull reque

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

2016-08-31 Thread zhangjing (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15453902#comment-15453902 ] zhangjing commented on FLINK-4535: -- Hi, Max, I already saw RetryingRegistration. Now it c

[GitHub] flink pull request #2450: [Flink-4458] Replace ForkableFlinkMiniCluster by L...

2016-08-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2450 [Flink-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster This PR is based on #2449. Thus, only the commits 5a2c70f and e07ad44 are relevant. The PR refactors the `LocalFl

[jira] [Commented] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces

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

[GitHub] flink pull request #2449: [FLINK-4455] [FLINK-4424] [networkenv] Make Networ...

2016-08-31 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2449 [FLINK-4455] [FLINK-4424] [networkenv] Make NetworkEnvironment independent of ActorGateway and JobManager association Makes the NetworkEnvironment independent of the JobManager association. Th

[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=15453595#comment-15453595 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on the issue:

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

2016-08-31 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @ramkrish86 , I squashed the commits before pushing.. Sorry about making it unable to see those recent changes. If you could still review this PR when you have time? --- If your project is set u

[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=15453564#comment-15453564 ] ASF GitHub Bot commented on FLINK-4482: --- Github user tedyu commented on the issue:

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

2016-08-31 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/2421 The test failure in flink-mesos is unrelated to 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 thi

[GitHub] flink pull request #2440: [FLINK-3755] Introduce key groups for key-value st...

2016-08-31 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2440 --- 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-3755) Introduce key groups for key-value state to support dynamic scaling

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

[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=15453451#comment-15453451 ] ASF GitHub Bot commented on FLINK-4544: --- Github user zentol commented on the issue:

[GitHub] flink issue #2445: [FLINK-4544] Refactor old CPU metric initialization

2016-08-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2445 But i see the issue that could arise, will rework the solution. --- 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-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=15453446#comment-15453446 ] ASF GitHub Bot commented on FLINK-4544: --- Github user zentol commented on the issue:

[GitHub] flink issue #2445: [FLINK-4544] Refactor old CPU metric initialization

2016-08-31 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2445 This is the pretty-much same code that the new CPU metric uses which has not caused issues so far. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Assigned] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-08-31 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3680: - Assignee: Ivan Mushketyk > Remove or improve (not set) text in the Job Plan UI >

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

2016-08-31 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15453388#comment-15453388 ] Scott Kidder commented on FLINK-4536: - Here's a chart of the thread count for each Tas

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-08-31 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15453387#comment-15453387 ] Ivan Mushketyk commented on FLINK-3680: --- I'll work on this. > Remove or improve (no

[jira] [Commented] (FLINK-4521) Fix "Submit new Job" panel in development mode

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

[GitHub] flink pull request #2448: [FLINK-4521] Enhance dashboard to show execution a...

2016-08-31 Thread mushketyk
GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2448 [FLINK-4521] Enhance dashboard to show execution attempts I've added support for displaying execution attempts in the dashboard. The JIRA item also includes that we should add accumulator

[jira] [Created] (FLINK-4545) Flink automatically manages TM network buffer

2016-08-31 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-4545: --- Summary: Flink automatically manages TM network buffer Key: FLINK-4545 URL: https://issues.apache.org/jira/browse/FLINK-4545 Project: Flink Issue Type: Wish

[jira] [Assigned] (FLINK-4456) Replace ActorGateway in Task by interface

2016-08-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4456: Assignee: Till Rohrmann > Replace ActorGateway in Task by interface > -

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

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

[GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t...

2016-08-31 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2447 [FLINK-4490] [distributed coordination] Decouple the JobManage's slots from the 'Instance' To allow for a future dynamic slot allocation and release model, the slots should not depend on 'Insta

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

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4539. --- > Duplicate/inconsistent logic for physical memory size in classes "Hardware" > and "EnvironmentInformati

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

2016-08-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4539. - Resolution: Fixed Fixed via 97a83a1fa62c06db19b09104d85c5e2bb850df0f > Duplicate/inconsistent log

[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=15452691#comment-15452691 ] ASF GitHub Bot commented on FLINK-4450: --- Github user StephanEwen commented on the is

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

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2439 There is an interesting question about how to proceed with that. If we merge this, the compatibility layer will only support Storm 1.0 programs, which are incompatible with prior versions

[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=15452699#comment-15452699 ] ASF GitHub Bot commented on FLINK-4544: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2445: [FLINK-4544] Refactor old CPU metric initialization

2016-08-31 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2445 Does this work? The reason for the initial reflection-based initialization was that the sun-specific class may not be available in some environments. I am unsure when the "ClassNotFound" error wi

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

2016-08-31 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2662: --- Priority: Critical (was: Major) > CompilerException: "Bug: Plan generation for Unions picked a ship s

[jira] [Updated] (FLINK-3190) Retry rate limits for DataStream API

2016-08-31 Thread Shannon Carey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon Carey updated FLINK-3190: - Fix Version/s: 1.1.0 > Retry rate limits for DataStream API >

[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

[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-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:

[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

[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

[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 >

[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] [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] [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] [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-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:

[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

[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 #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

[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 #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] [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:

[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:

[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

[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

[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] [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] [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

[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=15452387#comment-15452387 ] ASF GitHub Bot commented on FLINK-4543: --- GitHub user StephanEwen opened a pull reque

[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] [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

[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:

[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] [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

[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] [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] [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] [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

[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] [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

[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] [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

[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-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 #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] [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

[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] [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] [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

  1   2   >