[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 enab

[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&focusedCommentId=15602047#comment-15602047 ] ASF GitHub Bot commented on FLINK-4862: --- Github user asfgit closed the pull request

[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-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&focusedCommentId=15602064#comment-15602064 ] Robert Metzger commented on FLINK-4876: --- Thank you for working on this. I gave you "

[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&focusedCommentId=15602113#comment-15602113 ] Jark Wu commented on FLINK-4832: I have tried to count elements in an empty table in MySQL

[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&focusedCommentId=15602121#comment-15602121 ] Jose Maria Fuentes Lopez commented on FLINK-4756: - Hi there! Do you have

[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&focusedCommentId=15602184#comment-15602184 ] Fabian Hueske commented on FLINK-4832: -- [~jark] is right. A zero count is only necess

[jira] [Closed] (FLINK-1127) Utility library

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-1127. -- Resolution: Won't Fix Obsolete > Utility library > --- > > Key: FLINK-1127

[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 strea

[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 > ---

[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 enab

[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&focusedCommentId=15602286#comment-15602286 ] ASF GitHub Bot commented on FLINK-4824: --- Github user asfgit closed the pull request

[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 > e

[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

[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 merge

[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&focusedCommentId=15602443#comment-15602443 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the iss

[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 doe

[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&focusedCommentId=15602438#comment-15602438 ] ASF GitHub Bot commented on FLINK-4450: --- Github user StephanEwen commented on the is

[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 enab

[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&focusedCommentId=15602505#comment-15602505 ] ASF GitHub Bot commented on FLINK-4204: --- Github user asfgit closed the pull request

[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: FLINK-

[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 gelly-examples

[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: ) Priority:

[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&focusedCommentId=15602830#comment-15602830 ] Fabian Hueske commented on FLINK-4469: -- Thanks for the comments [~ShaoxuanWang] and [

[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-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&focusedCommentId=15603092#comment-15603092 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15603087#comment-15603087 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15603090#comment-15603090 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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 field

[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&focusedCommentId=15603093#comment-15603093 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15603091#comment-15603091 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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 Softwa

[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 Softwa

[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&focusedCommentId=15603086#comment-15603086 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15603085#comment-15603085 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15603084#comment-15603084 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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 fieldExpres

[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&focusedCommentId=15603088#comment-15603088 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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&focusedCommentId=15603089#comment-15603089 ] ASF GitHub Bot commented on FLINK-3702: --- Github user fhueske commented on a diff in

[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 Softwa

[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 Softwa

[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 So

[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 Apach

[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 So

[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 hasDeterministicFieldOrde

[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&focusedCommentId=15603198#comment-15603198 ] Ufuk Celebi commented on FLINK-4306: [~StephanEwen] Can I cherry pick this to the {{re

[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&focusedCommentId=15603349#comment-15603349 ] ASF GitHub Bot commented on FLINK-3930: --- Github user vijikarthi commented on the iss

[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] [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 Components

[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: Sub-ta

[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&focusedCommentId=15603536#comment-15603536 ] Eron Wright commented on FLINK-4352: - This maybe should be moved to be a subtask of F

[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 p

[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 Reporter:

[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 R

[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&focusedCommentId=15603888#comment-15603888 ] Jark Wu commented on FLINK-4469: Agree. I will propose these to Calcite. > Add support fo

[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&focusedCommentId=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 10/25/16 2:21 AM: - There is

[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 Reporter

[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

[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 dupli

[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 ena

[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&focusedCommentId=15604032#comment-15604032 ] ASF GitHub Bot commented on FLINK-4886: --- Github user ch33hau commented on the issue:

[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&focusedCommentId=15604033#comment-15604033 ] ASF GitHub Bot commented on FLINK-4886: --- Github user ch33hau closed the pull request

[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&focusedCommentId=15604147#comment-15604147 ] Renkai Ge commented on FLINK-4883: -- I tried to use object to extend UDF, but I haven't go

[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. le

[jira] [Commented] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15604336#comment-15604336 ] Jark Wu commented on FLINK-4600: Hi [~miaoever] , do you still have a chance to implement

[jira] [Commented] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15604393#comment-15604393 ] Jark Wu commented on FLINK-3976: Ah! I have also encountered this issue a few months ago w

[jira] [Closed] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-3976. -- Resolution: Fixed fixed by FLINK-4590 > Alias fields of physical plan node to avoid name collision with Calcite

<    1   2