[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

2016-09-07 Thread chobeat
Github user chobeat commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r7389 --- Diff: docs/apis/cli.md --- @@ -187,6 +187,8 @@ Action "run" compiles and runs a program.

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

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

[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-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470051#comment-15470051 ] ASF GitHub Bot commented on FLINK-4547: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2455: [FLINK-4547] [cluster management] when call connec...

2016-09-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2455#discussion_r77782622 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java --- @@ -189,7 +191,49 @@ public void stop() {

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-07 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2452 @liuyuzhong Let's wait a couple more days for the community to respond. You don't have to close the PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470412#comment-15470412 ] Simone Robutti commented on FLINK-4565: --- The resulting API should look like `ds1.join(ds2).where('a

[jira] [Assigned] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

2016-09-07 Thread Kirill Morozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirill Morozov reassigned FLINK-4506: - Assignee: Kirill Morozov > CsvOutputFormat defaults allowNullValues to false, even

[GitHub] flink pull request #2477: [FLINK-4506] CsvOutputFormat defaults allowNullVal...

2016-09-07 Thread kirill-morozov-epam
GitHub user kirill-morozov-epam opened a pull request: https://github.com/apache/flink/pull/2477 [FLINK-4506] CsvOutputFormat defaults allowNullValues to false, even … You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470437#comment-15470437 ] Fabian Hueske commented on FLINK-4565: -- I thought rather of something like this: {{ds1.where('a in

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470472#comment-15470472 ] Simone Robutti commented on FLINK-4565: --- That's exactly why I'm asking it: I had no idea what to use

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

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

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

2016-09-07 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2443#discussion_r77821528 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -105,7 +106,9 @@ public void

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-07 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470419#comment-15470419 ] ramkrishna.s.vasudevan commented on FLINK-3322: --- I am able to handle cases for the iterative

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

2016-09-07 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2443#discussion_r77814628 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MeterView.java --- @@ -0,0 +1,70 @@ +/* + * Licensed to the

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

2016-09-07 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2443 Overall a good change. Once my two comments are addressed, +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

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

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

[jira] [Commented] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470488#comment-15470488 ] ASF GitHub Bot commented on FLINK-4506: --- GitHub user kirill-morozov-epam opened a pull request:

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

2016-09-07 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2443#discussion_r77815865 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -105,7 +106,9 @@ public void

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

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

[jira] [Commented] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470397#comment-15470397 ] ASF GitHub Bot commented on FLINK-4589: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request #2476: [FLINK-4589] Fix Merging of Covering Window in Mer...

2016-09-07 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/2476 [FLINK-4589] Fix Merging of Covering Window in MergingWindowSet This also adds two new test cases for that problem. R: @StephanEwen You can merge this pull request into a Git repository

[jira] [Created] (FLINK-4591) Select star does not work with grouping

2016-09-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4591: --- Summary: Select star does not work with grouping Key: FLINK-4591 URL: https://issues.apache.org/jira/browse/FLINK-4591 Project: Flink Issue Type: Improvement

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

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

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77787126 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java --- @@ -15,11 +15,27 @@ * See the License

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

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

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-07 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2452 @mxm OK. --- 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] [Created] (FLINK-4588) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4588: --- Summary: Fix Merging of Covering Window in MergingWindowSet Key: FLINK-4588 URL: https://issues.apache.org/jira/browse/FLINK-4588 Project: Flink Issue

[jira] [Updated] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-09-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4579: - Issue Type: Improvement (was: Bug) > Add StateBackendFactory for RocksDB Backend >

[jira] [Created] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4589: --- Summary: Fix Merging of Covering Window in MergingWindowSet Key: FLINK-4589 URL: https://issues.apache.org/jira/browse/FLINK-4589 Project: Flink Issue

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-09-07 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r7227 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java --- @@ -122,14 +123,25 @@ public abstract Class

[GitHub] flink issue #2455: [FLINK-4547] [cluster management] when call connect metho...

2016-09-07 Thread beyond1920
Github user beyond1920 commented on the issue: https://github.com/apache/flink/pull/2455 @tillrohrmann @StephanEwen , thanks for your review. I changed the code based on your comment, including two points: 1. Change the JIRA and the PR subject line to better reflect the actual

[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-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469997#comment-15469997 ] ASF GitHub Bot commented on FLINK-4547: --- Github user beyond1920 commented on the issue:

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

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470065#comment-15470065 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-07 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77783497 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java --- @@ -15,11 +15,27 @@ * See the License for the

[jira] [Closed] (FLINK-4376) Implement job master skeleton for managing single job

2016-09-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-4376. - Resolution: Duplicate I think this is duplicated with https://issues.apache.org/jira/browse/FLINK-4408 >

[jira] [Updated] (FLINK-4406) Implement job master registration at resource manager

2016-09-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4406: -- Assignee: (was: Kurt Young) > Implement job master registration at resource manager >

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-09-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r77827675 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInfoFactory.java --- @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache

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

2016-09-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2443#discussion_r77825932 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -105,7 +106,9 @@ public void

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-09-07 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r77842627 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -792,12 +832,40 @@ else if (t instanceof Class) {

[jira] [Created] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint

2016-09-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4592: --- Summary: Fix flaky test ScalarFunctionsTest.testCurrentTimePoint Key: FLINK-4592 URL: https://issues.apache.org/jira/browse/FLINK-4592 Project: Flink Issue

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

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470705#comment-15470705 ] ASF GitHub Bot commented on FLINK-3950: --- Github user zentol commented on a diff in the pull request:

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

2016-09-07 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2443#discussion_r77829590 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -105,7 +106,9 @@ public void

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

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

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

2016-09-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2440#discussion_r77856665 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java --- @@ -0,0 +1,97 @@ +/* + * Licensed to the

[jira] [Resolved] (FLINK-4585) Fix broken links in index.md

2016-09-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4585. --- Resolution: Fixed Resolved in

[GitHub] flink pull request #2478: [FLINK-4595] Close FileOutputStream in ParameterTo...

2016-09-07 Thread apivovarov
GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2478 [FLINK-4595] Close FileOutputStream in ParameterTool https://issues.apache.org/jira/browse/FLINK-4595 You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-4595) Close FileOutputStream in ParameterTool

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471823#comment-15471823 ] ASF GitHub Bot commented on FLINK-4595: --- GitHub user apivovarov opened a pull request:

[jira] [Created] (FLINK-4595) Close FileOutputStream in ParameterTool

2016-09-07 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4595: -- Summary: Close FileOutputStream in ParameterTool Key: FLINK-4595 URL: https://issues.apache.org/jira/browse/FLINK-4595 Project: Flink Issue

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-07 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Attachment: FLINK4586Test.scala Scala unit test > NumberSequenceIterator and Accumulator threading issue >

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-09-07 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes updated FLINK-4586: Attachment: (was: FLINK4586Test.scala) > NumberSequenceIterator and Accumulator threading issue >

[jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

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

[jira] [Created] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

2016-09-07 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4590: - Summary: Some Table API tests are failing when debug lvl is set to DEBUG Key: FLINK-4590 URL: https://issues.apache.org/jira/browse/FLINK-4590 Project: Flink

[jira] [Created] (FLINK-4596) Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml

2016-09-07 Thread Nagarjun Guraja (JIRA)
Nagarjun Guraja created FLINK-4596: -- Summary: Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml Key: FLINK-4596 URL:

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

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472525#comment-15472525 ] ASF GitHub Bot commented on FLINK-4537: --- GitHub user beyond1920 opened a pull request:

[GitHub] flink pull request #2479: [FLINK-4537] [cluster management] ResourceManager ...

2016-09-07 Thread beyond1920
GitHub user beyond1920 opened a pull request: https://github.com/apache/flink/pull/2479 [FLINK-4537] [cluster management] ResourceManager registration with JobManager This pull request is to implement ResourceManager registration with JobManager, which including: 1. Check

[jira] [Assigned] (FLINK-4551) Heartbeat Manager integration with JobMaster

2016-09-07 Thread zhangjing (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing reassigned FLINK-4551: Assignee: zhangjing > Heartbeat Manager integration with JobMaster >

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

2016-09-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4427: -- Summary: Implement container releasing logic (Standalone / Yarn / Mesos) (was: Add slot / Implement

[jira] [Commented] (FLINK-1526) Add Minimum Spanning Tree library method and example

2016-09-07 Thread Olga Golovneva (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472586#comment-15472586 ] Olga Golovneva commented on FLINK-1526: --- Hi, I was wondering what is the current state for this

[jira] [Comment Edited] (FLINK-1707) Add an Affinity Propagation Library Method

2016-09-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389 ] Josep Rubió edited comment on FLINK-1707 at 9/8/16 3:49 AM: Hi [~vkalavri], I

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-07 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472401#comment-15472401 ] Jark Wu commented on FLINK-4591: It seems that {{GROUP BY *}} is not allowed in SQL. Maybe we can throw a

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-07 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77943543 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -52,15 +58,28 @@ * */ public

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

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

[jira] [Commented] (FLINK-4408) Submit Job and setup ExecutionGraph

2016-09-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472703#comment-15472703 ] ASF GitHub Bot commented on FLINK-4408: --- GitHub user KurtYoung opened a pull request:

[GitHub] flink pull request #2480: [FLINK-4408][JobManager] Introduce JobMasterRunner...

2016-09-07 Thread KurtYoung
GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/2480 [FLINK-4408][JobManager] Introduce JobMasterRunner and implement job submission & setting up the ExecutionGraph Introduce JobMasterRunner to deal with job level leader election and make

[jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

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

[GitHub] flink issue #2440: [FLINK-3755] Introduce key groups for key-value state to ...

2016-09-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2440 I don't think that this is giving us the correct inverse for ```computeOperatorIndexForKeyGroup(...)```. Our test ```CheckpointCoordinatorTest::testCreateKeyGroupPartitions()```generates

[jira] [Commented] (FLINK-4572) Convert to negative in LongValueToIntValue

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

[GitHub] flink issue #2469: [FLINK-4572] [gelly] Convert to negative in LongValueToIn...

2016-09-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2469 Do you have a second use case in mind for adding this function to `MathUtils`? My thought would be to keep this separate to avoid confusion between signed and unsigned downcasts. --- If your

[jira] [Created] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast

2016-09-07 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4594: - Summary: Validate lower bound in MathUtils.checkedDownCast Key: FLINK-4594 URL: https://issues.apache.org/jira/browse/FLINK-4594 Project: Flink Issue Type: Bug

[GitHub] flink issue #2469: [FLINK-4572] [gelly] Convert to negative in LongValueToIn...

2016-09-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2469 Looks good. Does it make sense to add to extend the `MathUtils.checkedDownCast(...)` function, or add a `MathUtils.checkedSignedDownCast(...)` function? --- If your project is set up for it,

[jira] [Commented] (FLINK-4572) Convert to negative in LongValueToIntValue

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

[jira] [Updated] (FLINK-4593) Fix PageRank algorithm example

2016-09-07 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4593: --- Flags: Patch > Fix PageRank algorithm example > -- > >

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

2016-09-07 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2440#discussion_r77870173 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java --- @@ -0,0 +1,97 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

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

[jira] [Updated] (FLINK-4585) Fix broken links in index.md

2016-09-07 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4585: --- Flags: Patch > Fix broken links in index.md > > >

[jira] [Created] (FLINK-4593) Fix PageRank algorithm example

2016-09-07 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4593: -- Summary: Fix PageRank algorithm example Key: FLINK-4593 URL: https://issues.apache.org/jira/browse/FLINK-4593 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-4593) Fix PageRank algorithm example

2016-09-07 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4593: --- Description: This page https://flink.apache.org/features.html shows the code which

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-07 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77768256 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java --- @@ -89,32 +93,37 @@ public

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

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469797#comment-15469797 ] Simone Robutti commented on FLINK-4565: --- Actually the confusing part is that the translation to the

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-07 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r77769044 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java --- @@ -89,32 +93,37 @@ public

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

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

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469836#comment-15469836 ] Fabian Hueske commented on FLINK-4565: -- SQL {{IN}} does not require a special implementation because

[jira] [Assigned] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simone Robutti reassigned FLINK-4565: - Assignee: Simone Robutti > Support for SQL IN operator > --- > >

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469851#comment-15469851 ] Simone Robutti commented on FLINK-4565: --- I imagined it could happen that way and I was going to open

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469873#comment-15469873 ] Timo Walther commented on FLINK-4565: - Calcite translates the IN operator in

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469879#comment-15469879 ] Timo Walther commented on FLINK-4565: - It seems my answer was to late. Yes, I would also go for the