[jira] [Updated] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

2016-10-24 Thread Sajeev Ramakrishnan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sajeev Ramakrishnan updated FLINK-4902: --- Description: Dear Team, I have the following tasks chained as a single subtask.

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

2016-10-24 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604147#comment-15604147 ] Renkai Ge commented on FLINK-4883: -- I tried to use object to extend UDF, but I haven't got a failure,

[jira] [Commented] (FLINK-4886) Example in Machine Learning Quickstart Guide causes error

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

[jira] [Commented] (FLINK-4886) Example in Machine Learning Quickstart Guide causes error

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

[GitHub] flink pull request #2682: [FLINK-4886] [docs] Update ML quickstart loading s...

2016-10-24 Thread ch33hau
Github user ch33hau closed the pull request at: https://github.com/apache/flink/pull/2682 --- 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 #2682: [FLINK-4886] [docs] Update ML quickstart loading svm test...

2016-10-24 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/2682 Sorry I just noticed that similar PR (https://github.com/apache/flink/pull/2658) has been created, in a way more complete compare to my PR. So I will close mine and sorry for creating

[jira] [Created] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

2016-10-24 Thread Sajeev Ramakrishnan (JIRA)
Sajeev Ramakrishnan created FLINK-4902: -- Summary: Flink Task Chain not getting input in a distributed manner Key: FLINK-4902 URL: https://issues.apache.org/jira/browse/FLINK-4902 Project: Flink

[jira] [Created] (FLINK-4901) Build DCOS Docker image

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4901: --- Summary: Build DCOS Docker image Key: FLINK-4901 URL: https://issues.apache.org/jira/browse/FLINK-4901 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-10-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 10/25/16 2:21 AM: - There is similar issue

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15603888#comment-15603888 ] Jark Wu commented on FLINK-4469: Agree. I will propose these to Calcite. > Add support for user defined

[jira] [Created] (FLINK-4900) Implement Docker image support

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4900: --- Summary: Implement Docker image support Key: FLINK-4900 URL: https://issues.apache.org/jira/browse/FLINK-4900 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4899) Implement DCOS package

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4899: --- Summary: Implement DCOS package Key: FLINK-4899 URL: https://issues.apache.org/jira/browse/FLINK-4899 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

2016-10-24 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-1984: Description: There are some users asking for an integration of Flink into Mesos. -There also is a

[jira] [Commented] (FLINK-4352) Implement new JobClient

2016-10-24 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15603536#comment-15603536 ] Eron Wright commented on FLINK-4352: - This maybe should be moved to be a subtask of FLINK-4897. >

[jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4898: --- Summary: Refactor HTTP handlers and Netty server/client Key: FLINK-4898 URL: https://issues.apache.org/jira/browse/FLINK-4898 Project: Flink Issue Type:

[jira] [Created] (FLINK-4897) Implement Dispatcher

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4897: --- Summary: Implement Dispatcher Key: FLINK-4897 URL: https://issues.apache.org/jira/browse/FLINK-4897 Project: Flink Issue Type: New Feature

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-10-24 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 @mxm - Please take a look when you get a chance? --- 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-3930) Implement Service-Level Authorization

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

[jira] [Commented] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15603198#comment-15603198 ] Ufuk Celebi commented on FLINK-4306: [~StephanEwen] Can I cherry pick this to the {{release-1.1}}

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84767836 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeType.java --- @@ -265,16 +265,6 @@ public boolean

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84768779 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java --- @@ -0,0 +1,343 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84768233 --- Diff: flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ProductFieldAccessor.java --- @@ -0,0 +1,75 @@ +/* + * Licensed to the

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84769097 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java --- @@ -0,0 +1,343 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84767248 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java --- @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84767067 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java --- @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84766789 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java --- @@ -264,6 +265,7 @@ public void getFlatFields(String

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84765869 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java --- @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84767443 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/FieldAccessor.java --- @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r84767676 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfoBase.java --- @@ -203,7 +206,34 @@ public void getFlatFields(String

[jira] [Created] (FLINK-4896) PageRank algorithm for directed graphs

2016-10-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4896: - Summary: PageRank algorithm for directed graphs Key: FLINK-4896 URL: https://issues.apache.org/jira/browse/FLINK-4896 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-10-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602830#comment-15602830 ] Fabian Hueske commented on FLINK-4469: -- Thanks for the comments [~ShaoxuanWang] and [~jark]. I

[jira] [Updated] (FLINK-4460) Side Outputs in Flink

2016-10-24 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-4460: Affects Version/s: 1.1.3 Labels: latearrivingevents sideoutput (was: )

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

2016-10-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4204. - Resolution: Implemented Implemented in c4f9f0d78d65a7ce7290820ae9fb2919c9116e57 > Clean up

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

2016-10-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4204: -- Fix Version/s: 1.2.0 > Clean up gelly-examples > --- > > Key:

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

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

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

2016-10-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2670 --- 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-4450) update storm version to 1.0.0

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

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

2016-10-24 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2510 @StephanEwen Do you have some time now? 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-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602443#comment-15602443 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

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

2016-10-24 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2439 I would like to merge this. But I think we need to change back the dependency exclusions in `flink-storm/pom.xml` to as they are in the current master. Can you do that? Then I will

[jira] [Closed] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

2016-10-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4824. - Resolution: Fixed Fixed in c4783c856a8ea71271d411fa8c4dc9c484f29ff0 > CliFrontend shows misleading error

[jira] [Updated] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

2016-10-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4824: -- Fix Version/s: 1.2.0 > CliFrontend shows misleading error message when main() method returns before >

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

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

[GitHub] flink pull request #2662: [FLINK-4824] [client] CliFrontend shows misleading...

2016-10-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2662 --- 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-2875) Add createRemoveEnvironment variant for HA

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2875. -- Resolution: Won't Fix > Add createRemoveEnvironment variant for HA >

[jira] [Closed] (FLINK-2969) FlinkYarnSessionCli with recovery enabled fails when killing TaskManager

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2969. -- Resolution: Invalid > FlinkYarnSessionCli with recovery enabled fails when killing TaskManager >

[jira] [Updated] (FLINK-4401) Add docs about ordering in streams

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4401: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-4463 > Add docs about ordering in

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

2016-10-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602184#comment-15602184 ] Fabian Hueske commented on FLINK-4832: -- [~jark] is right. A zero count is only necessary for

[jira] [Commented] (FLINK-4756) NullPointerException on submiting a job with StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster

2016-10-24 Thread Jose Maria Fuentes Lopez (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602121#comment-15602121 ] Jose Maria Fuentes Lopez commented on FLINK-4756: - Hi there! Do you have any news on this

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

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602113#comment-15602113 ] Jark Wu commented on FLINK-4832: I have tried to count elements in an empty table in MySQL. Without GROUP

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

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602064#comment-15602064 ] Robert Metzger commented on FLINK-4876: --- Thank you for working on this. I gave you "Contributor"

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

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4876: -- Assignee: Bram Vogelaar > Allow web interface to be bound to a specific ip/interface/inetHost >

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

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

[GitHub] flink pull request #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSou...

2016-10-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2678 --- 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 #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2671 --- 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-4787) Add REST API call for cancel-with-savepoints

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

[GitHub] flink issue #2626: [FLINK-4787] [runtime-web] Expose cancel-with-savepoint v...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2626 Looks like the tests are failing. I quickly scrolled over the changes. +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

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

2016-10-24 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4862. - Resolution: Fixed master: 45762162fe7c23fd921db1e0f826b2906bfe1dcd release-1.1:

[GitHub] flink issue #2654: [hotfix] [kafka] Fix RackAwareMode instantiation in Kafka...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2654 Nice fix, thank you +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

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

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

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

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4879. --- Resolution: Fixed Fix Version/s: (was: 1.1.4) 1.2.0 Resolved

[jira] [Commented] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602031#comment-15602031 ] Aljoscha Krettek commented on FLINK-4072: - I saw this problem:

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

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

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

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4876: -- Component/s: Webfrontend > Allow web interface to be bound to a specific ip/interface/inetHost

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

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2680 Thank you for opening a PR for fixing this. +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

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

2016-10-24 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84689078 --- 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 #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

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

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

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

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

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

[jira] [Closed] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4866. --- > Make Trigger.clear() Abstract to Enforce Implementation >

[GitHub] flink issue #2683: [FLINK-4888][metrics] instantiated job manager metrics mi...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2683 Thank you for opening a pull request. I agree that we should expose all numbers we show in the web interface as a metric as well. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

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

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

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

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

2016-10-24 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2671 Thanks for having a look @aljoscha. Thanks again for the PR @manuzhang. Merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[GitHub] flink pull request #2683: [FLINK-4888][metrics] instantiated job manager met...

2016-10-24 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2683#discussion_r84689406 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1828,6 +1828,33 @@ class JobManager(

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

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

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

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3674. --- > Add an interface for Time aware User Functions > --

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

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4852. --- > ClassCastException when assigning Watermarks with > TimeCharacteristic.ProcessingTime >

[jira] [Updated] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4888: -- Assignee: Philipp von dem Bussche > instantiated job manager metrics missing important job

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601991#comment-15601991 ] Robert Metzger commented on FLINK-4888: --- Thank you for working on this. I gave you "Contributor"

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601982#comment-15601982 ] Aljoscha Krettek commented on FLINK-2491: - What source are you using, [~Revy1313]? > Operators

[jira] [Assigned] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4894: -- Assignee: Ufuk Celebi > Don't block on buffer request after broadcastEvent >

[jira] [Created] (FLINK-4895) Drop support for Hadoop 1

2016-10-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4895: - Summary: Drop support for Hadoop 1 Key: FLINK-4895 URL: https://issues.apache.org/jira/browse/FLINK-4895 Project: Flink Issue Type: Task

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

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601955#comment-15601955 ] Aljoscha Krettek commented on FLINK-4832: - Counting {{0}} elements using a union with a dummy

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2487 Hi @haoch, thanks alot for this contribution. I recently started moving some of the streaming connectors of Flink to Apache Bahir, a community for extensions to Spark, Flink (and maybe

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

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

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

2016-10-24 Thread ex00
Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2650 Hello. I pushed new changes. --- 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] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table

2016-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601890#comment-15601890 ] 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-24 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2673 Thanks for looking into this @rmetzger. I'll check again on my setup. --- 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

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

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2673 I tried reproducing the issue reported by @fhueske. The only issue I got was `Caused by: org.codehaus.commons.compiler.CompileException: Line 8, Column 13: Class

  1   2   >