[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630674#comment-15630674 ] ASF GitHub Bot commented on FLINK-4983: --- Github user siliconcat commented on the issue:

[jira] [Commented] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService

2016-11-02 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630678#comment-15630678 ] Gyula Fora commented on FLINK-4992: --- Well, it doesn't have to be Strings but there should be a way of

[jira] [Resolved] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

2016-11-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-4315. -- Resolution: Done Fix Version/s: (was: 2.0.0) 1.2.0 Done for 1.2.0

[jira] [Commented] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService

2016-11-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630631#comment-15630631 ] Stephan Ewen commented on FLINK-4992: - Would having different timer services solve this? The side of

[jira] [Created] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

2016-11-02 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5002: - Summary: Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers Key: FLINK-5002 URL: https://issues.apache.org/jira/browse/FLINK-5002 Project: Flink Issue

[jira] [Closed] (FLINK-4623) Create Physical Execution Plan of a DataStream

2016-11-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4623. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-02 Thread siliconcat
Github user siliconcat commented on the issue: https://github.com/apache/flink/pull/2737 Ok, what about this? Black and white for the favicon in browsers. In colour for the mobile screens. Generated using the favicon generator above... Couldn't test the iphone, as I don't

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630729#comment-15630729 ] ASF GitHub Bot commented on FLINK-4964: --- Github user tfournier314 commented on the issue:

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

2016-11-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630704#comment-15630704 ] Stephan Ewen commented on FLINK-4022: - Ah, okay, this is relevant when there are initially idle

[GitHub] flink issue #2510: FLINK-3322 Allow drivers and iterators to reuse the memor...

2016-11-02 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2510 @StephanEwen - Any comments/feedback here. A gentle reminder !! --- 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

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

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631588#comment-15631588 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

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

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631587#comment-15631587 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

2016-11-02 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2495 @StephanEwen - Any comments/feedback here. A gentle reminder !! --- 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

[jira] [Closed] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4743. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with

[jira] [Commented] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

2016-11-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630624#comment-15630624 ] Stephan Ewen commented on FLINK-4999: - I am skeptical about locks acquired by metrics that block the

[jira] [Updated] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh

2016-11-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5001: Priority: Blocker (was: Critical) > Ensure that the Kafka 0.9+ connector is compatible with >

[jira] [Commented] (FLINK-4990) Remove JAR option from savepoint disposal

2016-11-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15630637#comment-15630637 ] Stephan Ewen commented on FLINK-4990: - +1 > Remove JAR option from savepoint disposal >

[GitHub] flink issue #2740: [FLINK-4964] [ml]

2016-11-02 Thread tfournier314
Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2740 Yes, I've just updated the PR title --- 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] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

2016-11-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631405#comment-15631405 ] Tzu-Li (Gordon) Tai commented on FLINK-4576: Ah, right. Got lost on this part mid-discussion.

[jira] [Created] (FLINK-4994) Don't Clear Trigger State and Merging Window Set When Purging

2016-11-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4994: --- Summary: Don't Clear Trigger State and Merging Window Set When Purging Key: FLINK-4994 URL: https://issues.apache.org/jira/browse/FLINK-4994 Project: Flink

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86138100 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala --- @@ -377,11 +378,79 @@ class

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86138263 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala --- @@ -377,11 +378,79 @@ class

[GitHub] flink issue #2738: [FLINK-4991] [taskmanager] Fix too aggressive timeout and...

2016-11-02 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2738 Travis passed here: https://travis-ci.org/uce/flink/builds/172551729 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

[GitHub] flink pull request #2740: Implement StringIndexer

2016-11-02 Thread tfournier314
GitHub user tfournier314 opened a pull request: https://github.com/apache/flink/pull/2740 Implement StringIndexer Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86138673 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala --- @@ -377,11 +378,79 @@ class

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86138204 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala --- @@ -377,11 +378,79 @@ class

[GitHub] flink issue #2740: Implement StringIndexer

2016-11-02 Thread tfournier314
Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2740 I'd like to make this operation scalable: - by sorting globally - then by doing something like "zipWithIndex" (don't know if it is possible) - then collect() val mapper =

[jira] [Commented] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask

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

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

2016-11-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629062#comment-15629062 ] Fabian Hueske commented on FLINK-3869: -- I like that idea, [~aljoscha]. +1 from me to add a {{reduce}}

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629126#comment-15629126 ] ASF GitHub Bot commented on FLINK-4743: --- Github user fhueske commented on the issue:

[jira] [Closed] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask

2016-11-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4991. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed in {{30a53ef}} (master),

[GitHub] flink issue #2720: [FLINK-4623] Create Physical Execution Plan of a DataStre...

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2720 +1 to merge. Btw @tonycox, please leave a brief comment when you update a PR. Otherwise, we won't get an email and the update might not be noticed until somebody looks at the PR.

[jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

2016-11-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3869: Assignee: Yassine Marzougui (was: Aljoscha Krettek) > WindowedStream.apply with

[GitHub] flink issue #2740: Implement StringIndexer

2016-11-02 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2740 Is there a JIRA issue for this PR? If so, could you include it in the PR title? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4713) Implementing ranking evaluation scores for recommender systems

2016-11-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629109#comment-15629109 ] Gábor Hermann commented on FLINK-4713: -- We have managed to rework the evaluation framework proposed

[GitHub] flink pull request #2706: [FLINK-4945] KafkaConsumer logs wrong warning abou...

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

[jira] [Resolved] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-11-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4945. --- Resolution: Fixed Thank you for fixing the issue. Merged to master in

[jira] [Updated] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-11-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4945: -- Component/s: Kafka Connector > KafkaConsumer logs wrong warning about confirmation for unknown

[jira] [Updated] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-11-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4945: -- Fix Version/s: 1.2.0 > KafkaConsumer logs wrong warning about confirmation for unknown

[jira] [Updated] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

2016-11-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3869: Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-3957) >

[jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629201#comment-15629201 ] ASF GitHub Bot commented on FLINK-4315: --- Github user kenmy commented on the issue:

[jira] [Created] (FLINK-4996) Make CrossHint @Public

2016-11-02 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4996: - Summary: Make CrossHint @Public Key: FLINK-4996 URL: https://issues.apache.org/jira/browse/FLINK-4996 Project: Flink Issue Type: Improvement Components:

[jira] [Updated] (FLINK-4997) Extending Window Function Metadata

2016-11-02 Thread Ventura Del Monte (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ventura Del Monte updated FLINK-4997: - External issue URL: (was:

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

2016-11-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629341#comment-15629341 ] Stephan Ewen commented on FLINK-4022: - Thinking about this, I am actually not sure that we need the

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86081029 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-4445) Ignore unmatched state when restoring from savepoint

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

[GitHub] flink pull request #2712: [FLINK-4445] Add option to ignore unmapped checkpo...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2712 --- 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 pull request #2714: [FLINK-4935] [webfrontend] Submit job with savepoi...

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

[jira] [Commented] (FLINK-4935) Submit job with savepoint via REST API

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

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

2016-11-02 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629091#comment-15629091 ] Jamie Grier commented on FLINK-4022: I also think this would be a great feature and a few Flink users

[GitHub] flink pull request #2738: [FLINK-4991] [taskmanager] Fix too aggressive time...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2738 --- 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 #2686: [FLINK-4743] The sqrt/power function not accept the real ...

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2686 Great! +1 to merge :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask

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

[jira] [Commented] (FLINK-4623) Create Physical Execution Plan of a DataStream

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629134#comment-15629134 ] ASF GitHub Bot commented on FLINK-4623: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

2016-11-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629137#comment-15629137 ] Aljoscha Krettek commented on FLINK-4576: - Hi, I think the watermark needs to be collected across

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629167#comment-15629167 ] Aljoscha Krettek commented on FLINK-3659: - Yep ;-) > Add ConnectWithBroadcast Operation >

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

2016-11-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629178#comment-15629178 ] Tzu-Li (Gordon) Tai commented on FLINK-4022: This is currently blocked by FLINK-4576, which

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

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

[GitHub] flink issue #2484: [FLINK-4177] Harden CassandraConnectorTest

2016-11-02 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2484 @StephanEwen I've rebased and updated the PR. The tests now use the `TestJvmProcess` class to setup the cassandra instance and have a fixed deadline for the initial connection instead of a fixed

[jira] [Created] (FLINK-4995) YarnFlinkResourceManagerTest JobManager Lost Leadership test failed

2016-11-02 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4995: -- Summary: YarnFlinkResourceManagerTest JobManager Lost Leadership test failed Key: FLINK-4995 URL: https://issues.apache.org/jira/browse/FLINK-4995 Project: Flink

[jira] [Commented] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

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

[GitHub] flink issue #2637: [FLINK-4315] Deprecate Hadoop dependent methods in flink-...

2016-11-02 Thread kenmy
Github user kenmy commented on the issue: https://github.com/apache/flink/pull/2637 Thanks @fhueske for a detailed review. Done all except moving Hadoop-related tests into flink-hadoop-compatibility. I'll do it sometime later. IMO this is the out of scope of issue "Deprecate

[jira] [Updated] (FLINK-4997) Extending Window Function Metadata

2016-11-02 Thread Ventura Del Monte (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ventura Del Monte updated FLINK-4997: - Description:

[jira] [Created] (FLINK-4997) Extending Window Function Metadata

2016-11-02 Thread Ventura Del Monte (JIRA)
Ventura Del Monte created FLINK-4997: Summary: Extending Window Function Metadata Key: FLINK-4997 URL: https://issues.apache.org/jira/browse/FLINK-4997 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

2016-11-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629345#comment-15629345 ] Maximilian Michels commented on FLINK-4998: --- This is related to FLINK-2213. > ResourceManager

[jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers

2016-11-02 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4999: - Summary: Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers Key: FLINK-4999 URL: https://issues.apache.org/jira/browse/FLINK-4999 Project: Flink Issue Type:

[GitHub] flink pull request #2741: [FLINK-4998][yarn] fail if too many task slots are...

2016-11-02 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2741 [FLINK-4998][yarn] fail if too many task slots are configured This fails the deployment of the Yarn application if the number of task slots are configured to be larger than the maximum virtual cores

[GitHub] flink issue #2637: [FLINK-4315] Deprecate Hadoop dependent methods in flink-...

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2637 Thanks for the update @kenmy! +1 to merge. Regarding moving the Hadoop tests from `flink-tests` to `flink-hadoop-compatibility` I agree. Let's do this as a separate issue. Do you want

[jira] [Created] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

2016-11-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4998: - Summary: ResourceManager fails when num task slots > Yarn vcores Key: FLINK-4998 URL: https://issues.apache.org/jira/browse/FLINK-4998 Project: Flink

[jira] [Commented] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

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

[jira] [Commented] (FLINK-4944) Replace Akka's death watch with own heartbeat on the TM side

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

[GitHub] flink pull request #2742: [FLINK-4944] Replace Akka's death watch with own h...

2016-11-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2742 [FLINK-4944] Replace Akka's death watch with own heartbeat on the TM side This PR introduces the HeartbeatActor which is used by the TaskManager to monitor the JobManager. The

[jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629424#comment-15629424 ] ASF GitHub Bot commented on FLINK-4315: --- Github user fhueske commented on the issue:

[GitHub] flink pull request #2743: [FLINK-4996] [core] Make CrossHint @Public

2016-11-02 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2743 [FLINK-4996] [core] Make CrossHint @Public You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 4996_make_crosshint_public

[jira] [Commented] (FLINK-4996) Make CrossHint @Public

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

[jira] [Commented] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629550#comment-15629550 ] ASF GitHub Bot commented on FLINK-4998: --- Github user mxm commented on the issue:

[GitHub] flink issue #2741: [FLINK-4998][yarn] fail if too many task slots are config...

2016-11-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2741 Added a test case to verify the error reporting. --- 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

[jira] [Created] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService

2016-11-02 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-4992: - Summary: Expose String parameter for timers in Timely functions and TimerService Key: FLINK-4992 URL: https://issues.apache.org/jira/browse/FLINK-4992 Project: Flink

[GitHub] flink pull request #2713: [backport] [FLINK-4445] Add option to ignore unmap...

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

[jira] [Closed] (FLINK-4935) Submit job with savepoint via REST API

2016-11-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4935. -- Resolution: Implemented Fix Version/s: 1.2.0 Implemented in {{c6c88ce}} (master). > Submit job

[jira] [Closed] (FLINK-4445) Ignore unmatched state when restoring from savepoint

2016-11-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4445. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed in {{74c0770 c0e620f}}

[jira] [Commented] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

2016-11-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628033#comment-15628033 ] Ufuk Celebi commented on FLINK-4398:

[jira] [Assigned] (FLINK-4832) Count/Sum 0 elements

2016-11-02 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4832: --- Assignee: Anton Mushin > Count/Sum 0 elements > > >

[jira] [Commented] (FLINK-4445) Ignore unmatched state when restoring from savepoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628029#comment-15628029 ] ASF GitHub Bot commented on FLINK-4445: --- Github user uce closed the pull request at:

[jira] [Created] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask

2016-11-02 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4991: -- Summary: TestTask hangs in testWatchDogInterruptsTask Key: FLINK-4991 URL: https://issues.apache.org/jira/browse/FLINK-4991 Project: Flink Issue Type: Bug

[GitHub] flink issue #2723: [FLINK-3617] Simple fix for OptionSerializer.

2016-11-02 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2723 @StephanEwen I restored test to check `toString()` method. This check added into `deepEquals()` method and performed only if `toString()` is overridden. In other cases this check is useless, isn't

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628050#comment-15628050 ] ASF GitHub Bot commented on FLINK-3617: --- Github user chermenin commented on the issue:

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86089087 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86090398 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-3659) Add ConnectWithBroadcast Operation

2016-11-02 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628205#comment-15628205 ] Gyula Fora commented on FLINK-3659: --- I agree that we should try to keep the API as it is now (if

[jira] [Commented] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService

2016-11-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628302#comment-15628302 ] Aljoscha Krettek commented on FLINK-4992: - +1 > Expose String parameter for timers in Timely

[GitHub] flink issue #2727: [FLINK-4923] [Metrics] Initializes patch for Expose input...

2016-11-02 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2727 will merge this later on --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

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

<    1   2   3   >