[jira] [Created] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired.

2016-02-23 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-3487: Summary: [SQL] FilterAggregateTransposeRule does not transform logical plan as desired. Key: FLINK-3487 URL: https://issues.apache.org/jira/browse/FLINK-3487 Project:

[jira] [Created] (FLINK-3486) [SQL] Use Project to rename all record fields would fail following Project.

2016-02-23 Thread Chengxiang Li (JIRA)
Chengxiang Li created FLINK-3486: Summary: [SQL] Use Project to rename all record fields would fail following Project. Key: FLINK-3486 URL: https://issues.apache.org/jira/browse/FLINK-3486 Project: Fl

[jira] [Updated] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

2016-02-23 Thread sahitya pavurala (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sahitya pavurala updated FLINK-3485: Summary: The SerializedListAccumulator value doest seem to be right (was: The accumulator v

[jira] [Updated] (FLINK-3485) The accumulator value doest seem to be right

2016-02-23 Thread sahitya pavurala (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sahitya pavurala updated FLINK-3485: Attachment: screenshot-1.png > The accumulator value doest seem to be right > --

[jira] [Updated] (FLINK-3485) The accumulator value doest seem to be right

2016-02-23 Thread sahitya pavurala (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sahitya pavurala updated FLINK-3485: Description: When run flink examples, the accumulator value keeps changing, as it shows the

[jira] [Created] (FLINK-3485) The accumulator value doest seem to be right

2016-02-23 Thread sahitya pavurala (JIRA)
sahitya pavurala created FLINK-3485: --- Summary: The accumulator value doest seem to be right Key: FLINK-3485 URL: https://issues.apache.org/jira/browse/FLINK-3485 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService

2016-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15160062#comment-15160062 ] ASF GitHub Bot commented on FLINK-3461: --- Github user sahitya-pavurala commented on t

[GitHub] flink pull request: redundant check in getting leadership status

2016-02-23 Thread sahitya-pavurala
Github user sahitya-pavurala commented on the pull request: https://github.com/apache/flink/pull/1700#issuecomment-188014656 I just found a Jira for this [https://issues.apache.org/jira/browse/FLINK-3461] . Please review. --- If your project is set up for it, you can reply to this em

[GitHub] flink pull request: redundant check in getting leadership status

2016-02-23 Thread sahitya-pavurala
GitHub user sahitya-pavurala opened a pull request: https://github.com/apache/flink/pull/1700 redundant check in getting leadership status Don't need to check again in ZooKeeperLeaderElectionService as LeaderLatch already checks for it. You can merge this pull request into a Git re

[GitHub] flink pull request: redundant check in getting leadership status

2016-02-23 Thread sahitya-pavurala
Github user sahitya-pavurala closed the pull request at: https://github.com/apache/flink/pull/1693 --- 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 featu

[GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of...

2016-02-23 Thread shikhar
Github user shikhar commented on the pull request: https://github.com/apache/flink/pull/1690#issuecomment-188002588 @rmetzger the test failures were because we had `auto.commit.enable=false` in the standard `KafkaTestEnvironmentImpl` standard props and it wasn't respecting that previo

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15160028#comment-15160028 ] ASF GitHub Bot commented on FLINK-3398: --- Github user shikhar commented on the pull r

[jira] [Commented] (FLINK-3478) Flink serves arbitary files through the web interface

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

[GitHub] flink pull request: [FLINK-3478] [runtime-web] Don't serve files o...

2016-02-23 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1697#issuecomment-187979852 Just verified via telnet that this fixes the issue by comparing behaviour in 1.0.0 RC0 and this PR. Would be nice if someone confirms this. The error happens when yo

[jira] [Commented] (FLINK-3478) Flink serves arbitary files through the web interface

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

[GitHub] flink pull request: [FLINK-3478] [runtime-web] Don't serve files o...

2016-02-23 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1697#issuecomment-187974689 Addressed the comments and made sure that nothing is broken in standalone and YARN. --- If your project is set up for it, you can reply to this email and have your reply ap

[GitHub] flink pull request: [FLINK-3463] implement calc translation

2016-02-23 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1696#issuecomment-187937363 I think we can also remove `FlinkProject` and `FlinkFilter` since there are no rules left that translate to these RelNodes. Otherwise looks good to me. --- If your

[jira] [Commented] (FLINK-3463) Implement Calc Support

2016-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159737#comment-15159737 ] ASF GitHub Bot commented on FLINK-3463: --- Github user fhueske commented on the pull r

[jira] [Comment Edited] (FLINK-1733) Add PCA to machine learning library

2016-02-23 Thread Thang Nguyen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159603#comment-15159603 ] Thang Nguyen edited comment on FLINK-1733 at 2/23/16 8:40 PM: --

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

2016-02-23 Thread Thang Nguyen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159603#comment-15159603 ] Thang Nguyen commented on FLINK-1733: - Hey folks, just wanted to update you on my prog

[GitHub] flink pull request: [FLINK-3478] [runtime-web] Don't serve files o...

2016-02-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1697#discussion_r53841086 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/files/StaticFileServerHandler.java --- @@ -196,16 +198,22 @@ public void channel

[jira] [Commented] (FLINK-3478) Flink serves arbitary files through the web interface

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

[jira] [Updated] (FLINK-3469) Improve documentation for grouping keys

2016-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3469: -- Issue Type: Improvement (was: Bug) > Improve documentation for grouping keys >

[jira] [Updated] (FLINK-3469) Improve documentation for grouping keys

2016-02-23 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3469: -- Summary: Improve documentation for grouping keys (was: Fix documentation for grouping keys) > Improve

[jira] [Commented] (FLINK-3435) Change interplay of Ingestion Time and Event Time

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

[GitHub] flink pull request: [FLINK-3435] Proparly separate IngestionTime a...

2016-02-23 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1699 [FLINK-3435] Proparly separate IngestionTime and EventTime This pull request changes the interplay between **Event Time** and **Ingestion Time** Prior to this pull request, both time ch

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

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

[GitHub] flink pull request: [FLINK-3478] [runtime-web] Don't serve files o...

2016-02-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1697#issuecomment-187824804 +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 e

[jira] [Resolved] (FLINK-2021) Rework examples to use ParameterTool

2016-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2021. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in http://git-wip-us.apache.org/repos/a

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

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

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

2016-02-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159365#comment-15159365 ] ASF GitHub Bot commented on FLINK-3257: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-3257] Add Exactly-Once Processing Guara...

2016-02-23 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1668#issuecomment-187827823 I can't really add anything to the timeout question :D As for the snapshotting. I would go with the ListState as that potentially provides very efficient impleme

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

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

[GitHub] flink pull request: [FLINK-3257] Add Exactly-Once Processing Guara...

2016-02-23 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/1668#issuecomment-187825999 Thanks @tillrohrmann for the feedback! I merged `ForwardingOneInputTask` into `StreamIterationSink`. One more think I missed pointing out is that when th

[jira] [Commented] (FLINK-3478) Flink serves arbitary files through the web interface

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

[jira] [Commented] (FLINK-3454) Add test dependencies on packaged jars

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

[GitHub] flink pull request: [FLINK-3454] Add test dependencies on packaged...

2016-02-23 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1698 [FLINK-3454] Add test dependencies on packaged jars You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 3454_add_test_dependencie

[jira] [Commented] (FLINK-3478) Flink serves arbitary files through the web interface

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

[GitHub] flink pull request: [FLINK-3478] [runtime-web] Don't serve files o...

2016-02-23 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1697 [FLINK-3478] [runtime-web] Don't serve files outside of web folder Previously it was possible to request arbitrary files via the web interface by specifying a relative file path (this usually does not w

[jira] [Commented] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159299#comment-15159299 ] Robert Metzger commented on FLINK-3483: --- I'm using Version 48.0.2564.97 (64-bit) Ma

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1641#discussion_r53816034 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/SlotAllocationTest.java --- @@ -40,17 +48,142 @@ public void test() {

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

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

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1641#issuecomment-187797165 As far as I can tell, the changes look good to me. However, documentation is missing. I think the old `startNewResourceGroup` and `isolateResources` should be remov

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1641#discussion_r53817674 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/SlotAllocationTest.java --- @@ -40,17 +48,142 @@ public void test() {

[jira] [Resolved] (FLINK-3315) Fix Slot Sharing in Streaming API

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3315. -- Resolution: Fixed Fixed via c40cfd317947b6b0f384ac3e067c0939a4586810 > Fix Slot Sharing in Stre

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[jira] [Created] (FLINK-3484) Add setSlotSharingGroup documentation

2016-02-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3484: Summary: Add setSlotSharingGroup documentation Key: FLINK-3484 URL: https://issues.apache.org/jira/browse/FLINK-3484 Project: Flink Issue Type: Task Affe

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1641#discussion_r53816021 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/SlotAllocationTest.java --- @@ -40,17 +48,142 @@ public void test() {

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1641#discussion_r53811724 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/StreamTransformation.java --- @@ -334,10 +339,7 @@ public bo

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1641#discussion_r53811188 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java --- @@ -533,4 +563,33 @@ private StreamGraph ge

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[jira] [Resolved] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3418. -- Resolution: Fixed Fixed via 7ddc078e68d645bac2829de9634e3373a59be551 > RocksDB HDFSCopyFromLoca

[jira] [Resolved] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3426. -- Resolution: Fixed Fixed via dc4d147d202c8b59e30b7a73c626d2ba9473dad2 > JobManagerLeader[Re]Elec

[jira] [Commented] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

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

[jira] [Commented] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

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

[GitHub] flink pull request: [FLINK-3426] Fixed JobManagerLeader[Re]Electio...

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

[GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e...

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

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API

2016-02-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1641#discussion_r53808877 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java --- @@ -533,4 +563,33 @@ private StreamGraph

[GitHub] flink pull request: [FLINK-3416] [py] Support for spaces in flink ...

2016-02-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1674#discussion_r53794490 --- Diff: flink-dist/src/main/flink-bin/bin/pyflink2.bat --- @@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion SET bin=%~dp0 SET FLINK_ROOT_DIR=%bin%.

[jira] [Commented] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159108#comment-15159108 ] Robert Metzger commented on FLINK-3483: --- I can confirm the issue for Chrome on Linux

[GitHub] flink pull request: [FLINK-3434] Prevent NPE in ClieFrotend#getCli...

2016-02-23 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/1695 [FLINK-3434] Prevent NPE in ClieFrotend#getClient() CliFrontend#getClient() can enocunter a NullPointerException when executing ``` yarnCluster = flinkYarnClient.deploy(); yarnCluster.con

[GitHub] flink pull request: [FLINK-3416] [py] Support for spaces in flink ...

2016-02-23 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1674#discussion_r53791882 --- Diff: flink-dist/src/main/flink-bin/bin/pyflink2.bat --- @@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion SET bin=%~dp0 SET FLINK_ROOT_DIR=%bi

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

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

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-23 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-187764378 @rmetzger Thanks, it's been a nice starter, thanks to both you and @fhueske for the help! --- If your project is set up for it, you can reply to this email and h

[jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zach Cox updated FLINK-3483: Description: In the Chrome browser on OS X (Version 48.0.2564.116 (64-bit)) the job graph visualization doe

[jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zach Cox updated FLINK-3483: Attachment: firefox-job-graph.png Screenshot of job graph in OS X Firefox browser. > Job graph visualizatio

[jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zach Cox updated FLINK-3483: Attachment: safari-job-graph.png Screenshot of job graph in OS X Safari browser. > Job graph visualization

[jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zach Cox updated FLINK-3483: Attachment: chrome-job-graph.png Screenshot of job graph in OS X Chrome browser. > Job graph visualization

[jira] [Commented] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null

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

[jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zach Cox updated FLINK-3483: Attachment: Screen Shot 2016-02-23 at 9.40.44 AM.png Screenshot of job graph visualization in OS X Chrome.

[jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zach Cox updated FLINK-3483: Attachment: (was: Screen Shot 2016-02-23 at 9.40.44 AM.png) > Job graph visualization not working proper

[jira] [Created] (FLINK-3483) Job graph visualization not working properly in OS X Chrome

2016-02-23 Thread Zach Cox (JIRA)
Zach Cox created FLINK-3483: --- Summary: Job graph visualization not working properly in OS X Chrome Key: FLINK-3483 URL: https://issues.apache.org/jira/browse/FLINK-3483 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

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

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-187752847 +1 to merge the changes. I rebased the code already locally. Right now, I'm running a final travis test. If it passes, I'll merge the change. --- If your proj

[jira] [Created] (FLINK-3482) Implement Union Support

2016-02-23 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3482: Summary: Implement Union Support Key: FLINK-3482 URL: https://issues.apache.org/jira/browse/FLINK-3482 Project: Flink Issue Type: Sub-task Componen

[GitHub] flink pull request: [FLINK-3434] Prevent NPE in ClientFrontend#get...

2016-02-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1695#issuecomment-187748356 +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 e

[GitHub] flink pull request: [FLINK-3463] implement calc translation

2016-02-23 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1696 [FLINK-3463] implement calc translation This PR implements the `DataSetCalcRule`, so that filters, projections, and their combinations are now translated to `FlinkCalc`s. `FlinkFilterRule`, `FlinkPro

[jira] [Commented] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types

2016-02-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159045#comment-15159045 ] Chesnay Schepler commented on FLINK-3471: - that is specifically for columns that a

[jira] [Commented] (FLINK-3416) [py] .bat files fail when path contains spaces

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

[jira] [Commented] (FLINK-3463) Implement Calc Support

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

[jira] [Commented] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types

2016-02-23 Thread Ken Geis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159028#comment-15159028 ] Ken Geis commented on FLINK-3471: - There is current code in JDBCInputFormat that avoids Ja

[jira] [Commented] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null

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

[jira] [Commented] (FLINK-3416) [py] .bat files fail when path contains spaces

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

[GitHub] flink pull request: added support for Main-Class separated by / in...

2016-02-23 Thread fs111
Github user fs111 commented on a diff in the pull request: https://github.com/apache/flink/pull/1694#discussion_r53786826 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarListHandler.java --- @@ -85,7 +85,8 @@ public boolean accept(File dir

[jira] [Commented] (FLINK-3169) Drop {{Key}} type from Record Data Model

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

[GitHub] flink pull request: [FLINK-3169] Remove Key class

2016-02-23 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1667#issuecomment-187719913 Ok, I've removed the distributions that @fhueske listed, removed a few javadoc references to the Key class, and NormalizableKey no longer extends the Value interface. -

[jira] [Resolved] (FLINK-3416) [py] .bat files fail when path contains spaces

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3416. -- Resolution: Fixed Fixed via 407c285158a96dfd0c959f45724148632173175f > [py] .bat files fail whe

[jira] [Closed] (FLINK-3459) Make build SBT compatible

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3459. Resolution: Fixed Fixed via 3b47ad2ba18351841ad19af28b0945a1f96299db > Make build SBT compatible >

[jira] [Closed] (FLINK-3458) Shading broken in flink-shaded-hadoop

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3458. Resolution: Fixed Fixed via b204888fd1c40938568ce8243f5bd5b44491d8e0 > Shading broken in flink-shad

[jira] [Closed] (FLINK-3460) Make flink-streaming-connectors' flink dependencies provided

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3460. Resolution: Fixed Fixed via 939768a1b7efbec92dabad7b43de0f693ce97e6f > Make flink-streaming-connect

[jira] [Updated] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3438: - Assignee: Stefano Baghino > ExternalProcessRunner fails to detect ClassNotFound exception because

[jira] [Resolved] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3438. -- Resolution: Fixed Fixed via 8b29c14325e90f575dc360caed9111d6218924ad > ExternalProcessRunner fa

[jira] [Resolved] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3433. -- Resolution: Fixed Fixed via 77c1deedd859fed99970e27a6885856275ae23a9 > Return value from Object

[jira] [Resolved] (FLINK-3410) setting setNumberOfExecutionRetries to 0 still leads to RESTARTs.

2016-02-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3410. -- Resolution: Fixed Fixed via 6323ed44d6dd051b09f9de9f8fbb95495b82cad6 > setting setNumberOfExecu

  1   2   3   >