[GitHub] flink issue #2645: [FLINK-4838] remove STREAM keyword in StreamSQLExample

2016-10-21 Thread manuzhang
Github user manuzhang commented on the issue: https://github.com/apache/flink/pull/2645 Any more comments? --- 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,

[jira] [Commented] (FLINK-4838) remove STREAM keyword in StreamSQLExample

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15596638#comment-15596638 ] ASF GitHub Bot commented on FLINK-4838: --- Github user manuzhang commented on the issue:

[jira] [Commented] (FLINK-4204) Clean up gelly-examples

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

[GitHub] flink issue #2670: [FLINK-4204] [gelly] Clean up gelly-examples

2016-10-21 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2670 I pushed a commit to remove the `GraphMetrics` example. I think providing drivers for all library methods is both desirable and ambitious. If we like the form and functionality of the

[jira] [Commented] (FLINK-3674) Add an interface for Time aware User Functions

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

[jira] [Resolved] (FLINK-3674) Add an interface for Time aware User Functions

2016-10-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3674. - Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[jira] [Resolved] (FLINK-4852) ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime

2016-10-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4852. - Resolution: Fixed Fix Version/s: (was: 1.1.4) Fixed in

[jira] [Resolved] (FLINK-4877) Refactorings around FLINK-3674 (User Function Timers)

2016-10-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4877. - Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[GitHub] flink pull request #2570: [FLINK-3674] Add an interface for Time aware User ...

2016-10-21 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2570 --- 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-4852) ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime

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

[jira] [Commented] (FLINK-4852) ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595701#comment-15595701 ] ASF GitHub Bot commented on FLINK-4852: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595702#comment-15595702 ] ASF GitHub Bot commented on FLINK-3030: --- Github user iampeter commented on the issue:

[GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec...

2016-10-21 Thread iampeter
Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2448 @rmetzger will you be merging? if so, `flink-runtime-web/web-dashboard/web/js/index.js` just needs a `gulp` --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request #2656: [FLINK-4852] Remove Non-Multiplexing StreamRecordS...

2016-10-21 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2656 --- 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 #2656: [FLINK-4852] Remove Non-Multiplexing StreamRecordSerializ...

2016-10-21 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2656 Manually merged --- 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

[jira] [Commented] (FLINK-3030) Enhance Dashboard to show Execution Attempts

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595682#comment-15595682 ] ASF GitHub Bot commented on FLINK-3030: --- Github user iampeter commented on the issue:

[GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec...

2016-10-21 Thread iampeter
Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2448 @mushketyk could you try `npm view gulp-stylus` ? --- 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] [Commented] (FLINK-4204) Clean up gelly-examples

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595656#comment-15595656 ] ASF GitHub Bot commented on FLINK-4204: --- Github user vasia commented on the issue:

[GitHub] flink issue #2670: [FLINK-4204] [gelly] Clean up gelly-examples

2016-10-21 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2670 Hi @greghogan, I really like the cleanup and new organization! Two thoughts: - is the plan to add drivers for all library methods? - shall we remove the `GraphMetrics` example since

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

2016-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595581#comment-15595581 ] Fabian Hueske commented on FLINK-4604: -- Hi [~anmu], I think we can implement and add support for

[GitHub] flink pull request #2669: [FLINK-4871] [mini cluster] Add memory calculation...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2669#discussion_r84509867 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java --- @@ -96,11 +101,20 @@ public void

[jira] [Commented] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

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

[jira] [Commented] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

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

[jira] [Commented] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

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

[jira] [Commented] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

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

[GitHub] flink pull request #2669: [FLINK-4871] [mini cluster] Add memory calculation...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2669#discussion_r84509754 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java --- @@ -96,11 +101,20 @@ public void

[GitHub] flink pull request #2669: [FLINK-4871] [mini cluster] Add memory calculation...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2669#discussion_r84508885 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java --- @@ -162,4 +180,63 @@ public String toString() {

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

2016-10-21 Thread Evgeny Kincharov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595552#comment-15595552 ] Evgeny Kincharov commented on FLINK-4315: - [~fhueske] , [~greghogan] , could you look at new

[GitHub] flink pull request #2655: [FLINK-4851] [rm] Introduce FatalErrorHandler and ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2655#discussion_r84506385 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java --- @@ -145,6 +171,10 @@ public void

[jira] [Created] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator

2016-10-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4884: --- Summary: Eagerly Store MergingWindowSet in State in WindowOperator Key: FLINK-4884 URL: https://issues.apache.org/jira/browse/FLINK-4884 Project: Flink

[GitHub] flink pull request #2655: [FLINK-4851] [rm] Introduce FatalErrorHandler and ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2655#discussion_r84507291 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingFatalErrorHandler.java --- @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager

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

[jira] [Commented] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions

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

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84501182 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -202,101 +205,125 @@ public void shutDown() throws

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84501742 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -471,6 +498,149 @@ public void shutDownCluster(final

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84500048 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -202,101 +205,125 @@ public void shutDown() throws

[GitHub] flink issue #2651: [FLINK-4847] Let RpcEndpoint.start/shutDown throw excepti...

2016-10-21 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2651 LGTM --- 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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84500271 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -202,101 +205,125 @@ public void shutDown() throws

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84501555 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -471,6 +498,149 @@ public void shutDownCluster(final

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84500666 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -202,101 +205,125 @@ public void shutDown() throws

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84502118 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -471,6 +498,149 @@ public void shutDownCluster(final

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

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

2016-10-21 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-4541: Assignee: Alexander Shoshin > Support for SQL NOT IN operator >

[jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions

2016-10-21 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595359#comment-15595359 ] Alexander Shoshin commented on FLINK-2118: -- Fabian, thank you for the fast responce! > Table API

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

2016-10-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2678 I think it's fine to make `KafkaTableSource` public. However, I think users usually want to go for a version-specific `KafkaTableSource` like `Kafka090TableSource`. The version-specific sources

[jira] [Commented] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

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

[jira] [Closed] (FLINK-2118) Table API fails on composite filter conditions

2016-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2118. Resolution: Not A Bug Hi Alexander, I agree and will close the issue. Thanks for looking into

[jira] [Created] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-21 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4883: - Summary: Prevent UDFs implementations through Scala singleton objects Key: FLINK-4883 URL: https://issues.apache.org/jira/browse/FLINK-4883 Project: Flink

[jira] [Commented] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595160#comment-15595160 ] ASF GitHub Bot commented on FLINK-4876: --- GitHub user attachmentgenie opened a pull request:

[GitHub] flink pull request #2680: [FLINK-4876] Allow web interface to be bound to a ...

2016-10-21 Thread attachmentgenie
GitHub user attachmentgenie opened a pull request: https://github.com/apache/flink/pull/2680 [FLINK-4876] Allow web interface to be bound to a specific ip/interface/inetHost Currently the web interface automatically binds to all interfaces on 0.0.0.0. IMHO there are some use cases

[jira] [Commented] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

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

[GitHub] flink pull request #2679: [FLINK-4882] [flip-6] Remove exceptions from HighA...

2016-10-21 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2679 [FLINK-4882] [flip-6] Remove exceptions from HighAvailabilityServiceswhere not necessary Cleanup of the interface `HighAvailabilityServices` so that only methods which really throw an

[jira] [Comment Edited] (FLINK-3695) ValueArray types

2016-10-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595078#comment-15595078 ] Greg Hogan edited comment on FLINK-3695 at 10/21/16 1:39 PM: - I was thinking

[jira] [Comment Edited] (FLINK-3695) ValueArray types

2016-10-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595078#comment-15595078 ] Greg Hogan edited comment on FLINK-3695 at 10/21/16 1:34 PM: - I was thinking

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2671#discussion_r84463868 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java --- @@ -99,8 +111,12 @@ public

[jira] [Commented] (FLINK-4773) Introduce an OperatorIOMetricGroup

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

[GitHub] flink issue #2667: README.md - Description of the bluemix specif…

2016-10-21 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2667 Thank you for your contribution! --- 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

[GitHub] flink issue #2614: [FLINK-4773] Intoduce OperatorIOMetricGroup

2016-10-21 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2614 Iv'e rebased the branch and will merge it once travis passes. --- 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

[GitHub] flink pull request #2667: README.md - Description of the bluemix specif…

2016-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2667 --- 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] [Updated] (FLINK-3695) ValueArray types

2016-10-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3695: -- Component/s: (was: Gelly) Type Serialization System > ValueArray types >

[jira] [Commented] (FLINK-3695) ValueArray types

2016-10-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595078#comment-15595078 ] Greg Hogan commented on FLINK-3695: --- I have changed this ticket's component to "gelly" since with

[jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table

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

[GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta...

2016-10-21 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2673 Thanks for the PR @wuchong. I tried to build a Table API program with the flink-table dependency, but the compilation failed with the following error message: > Caused by:

[jira] [Commented] (FLINK-4875) operator name not correctly inferred

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

[GitHub] flink issue #2676: [FLINK-4875] [metrics] Use correct operator name

2016-10-21 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2676 +1 to merge this change. --- 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

[jira] [Updated] (FLINK-3695) ValueArray types

2016-10-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3695: -- Component/s: (was: Type Serialization System) Gelly > ValueArray types >

[GitHub] flink issue #2668: Add EvaluateDataSetOperation for LabeledVector. This clos...

2016-10-21 Thread thvasilo
Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/2668 Hello Thomas, thank you for your contribution! I took a brief look so some initial comments: This seems to be making changes to `MLUtils` which AFAIK is outside the scope of this

[GitHub] flink issue #2614: [FLINK-4773] Intoduce OperatorIOMetricGroup

2016-10-21 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2614 I think this is a good refactoring. +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

[GitHub] flink issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTri...

2016-10-21 Thread manuzhang
Github user manuzhang commented on the issue: https://github.com/apache/flink/pull/2671 @mxm updated. Thanks for teaching me more about the internals. Ignoring the old Timer make things much simpler actually. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

2016-10-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595061#comment-15595061 ] ASF GitHub Bot commented on FLINK-4862: --- Github user manuzhang commented on the issue:

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2671#discussion_r84465826 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java --- @@ -88,9 +96,13 @@ public

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

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

[GitHub] flink issue #2650: [FLINK-4563] [metrics] scope caching not adjusted for mul...

2016-10-21 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2650 correct; we could also use a `String[]` and `CharacterFilter[]`. --- 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

[jira] [Commented] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

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

[GitHub] flink pull request #2660: [FLINK-4833] properly log exceptions in CountMinHe...

2016-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2660 --- 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 #2615: [FLINK-4772] [FLINK-4775] Metric Store enhancement...

2016-10-21 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2615 --- 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-4772) Store metrics in MetricStore as strings

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

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2671#discussion_r84465211 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java --- @@ -88,9 +96,13 @@ public

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2671#discussion_r84464275 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java --- @@ -45,6 +45,12 @@

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-21 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2671#discussion_r84464167 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java --- @@ -88,9 +96,13 @@ public

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

2016-10-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595029#comment-15595029 ] Fabian Hueske commented on FLINK-4743: -- Hi [~tonycox], Thanks for looking into this issue. Timo is

[jira] [Updated] (FLINK-4874) Document how to enable Flink web interface in local execution

2016-10-21 Thread Krishna Prasad Anna Ramesh Kumar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krishna Prasad Anna Ramesh Kumar updated FLINK-4874: Description: The local environment section in the local

[jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions

2016-10-21 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15595011#comment-15595011 ] Alexander Shoshin commented on FLINK-2118: -- I agree with [~RenkaiGe]. {{'name \!== "Pete" &&

[jira] [Created] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

2016-10-21 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4882: Summary: Cleanup throws exception clause in HighAvailabilityServices Key: FLINK-4882 URL: https://issues.apache.org/jira/browse/FLINK-4882 Project: Flink

[jira] [Commented] (FLINK-4878) ReduceTaskExternalITCase.testMultiLevelMergeCombiningReduceTask test instable

2016-10-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15594938#comment-15594938 ] Robert Metzger commented on FLINK-4878: --- Fixed logging, so that we can understand the issue better

[jira] [Closed] (FLINK-4881) Docker: Remove dependency on shared volumes

2016-10-21 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4881. - Resolution: Fixed Merged with 58a16c1007c97809bdd46c93632abd90c0ce5c4b. > Docker: Remove

[jira] [Commented] (FLINK-4780) Ability to use UDP protocol in metrics-graphite

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

[GitHub] flink pull request #2677: [FLINK-4780] Make GraphiteReporter protocol config...

2016-10-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2677 --- 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] [Created] (FLINK-4881) Docker: Remove dependency on shared volumes

2016-10-21 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4881: - Summary: Docker: Remove dependency on shared volumes Key: FLINK-4881 URL: https://issues.apache.org/jira/browse/FLINK-4881 Project: Flink Issue

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

2016-10-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-4623: Assignee: Anton Solovev > Create Physical Execution Plan of a DataStream >

[jira] [Updated] (FLINK-4880) FlinkML - Implement Feature hashing (Data pre-processing)

2016-10-21 Thread Thomas FOURNIER (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas FOURNIER updated FLINK-4880: --- Description: I'm going to work on feature hashing, as it is a point mentioned on the FlinkML

  1   2   >