[jira] [Commented] (FLINK-3951) Add Histogram Metric Type

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335470#comment-15335470 ] ASF GitHub Bot commented on FLINK-3951: --- Github user zentol commented on the issue:

[GitHub] flink issue #2112: [FLINK-3951] Add histogram metric type

2016-06-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2112 So we don't want to tie ourselves to DropWizard histograms, but the only way for users to use a histogram right now _without implementing one themselves (something that is too much work for us apparen

[jira] [Assigned] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

2016-06-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4075: - Assignee: Kostas Kloudas > ContinuousFileProcessingCheckpointITCase failed on Travis > --

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334748#comment-15334748 ] ASF GitHub Bot commented on FLINK-3650: --- Github user fhueske commented on the issue:

[GitHub] flink issue #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/1856 Thanks for the update @ramkrish86. PR is good 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 t

[GitHub] flink issue #2108: [FLINK-4027] Flush FlinkKafkaProducer on checkpoints

2016-06-16 Thread eliaslevy
Github user eliaslevy commented on the issue: https://github.com/apache/flink/pull/2108 👍 --- 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 fea

[jira] [Commented] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334636#comment-15334636 ] ASF GitHub Bot commented on FLINK-4027: --- Github user eliaslevy commented on the issu

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

2016-06-16 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2109 Fixed my PR according to the review. --- 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 enabl

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334570#comment-15334570 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API

2016-06-16 Thread Robert Thorman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334509#comment-15334509 ] Robert Thorman commented on FLINK-3319: --- Is this as simple as duplicating the AndFil

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

2016-06-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334325#comment-15334325 ] Ufuk Celebi commented on FLINK-4075: Another instance https://s3.amazonaws.com/archiv

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334195#comment-15334195 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on the iss

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334190#comment-15334190 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on a diff

[GitHub] flink issue #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/1856 @fhueske - Pushed with latest updates. Pls review. Thank you for guiding me through this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67385885 --- Diff: flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala --- @@ -0,0 +1,233 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4040: -- Component/s: YARN Client > Same env.java.opts is applied for TM , JM and ZK > --

[jira] [Commented] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

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

[GitHub] flink pull request #2118: [FLINK-3977] InternalWindowFunctions implement Out...

2016-06-16 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2118 [FLINK-3977] InternalWindowFunctions implement OutputTypeConfigurable and forward calls to wrapped functions. - [X] General - The pull request references the related JIRA issue ("[FLINK-XXX] J

[jira] [Commented] (FLINK-3827) Flink modules include unused dependencies

2016-06-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334076#comment-15334076 ] Till Rohrmann commented on FLINK-3827: -- I don't really know what the status of this i

[jira] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-06-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4084: Summary: Add configDir parameter to CliFrontend and flink shell script Key: FLINK-4084 URL: https://issues.apache.org/jira/browse/FLINK-4084 Project: Flink

[jira] [Assigned] (FLINK-3942) Add support for INTERSECT

2016-06-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-3942: -- Assignee: Jark Wu > Add support for INTERSECT > - > > Key: FLIN

[jira] [Commented] (FLINK-3942) Add support for INTERSECT

2016-06-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334042#comment-15334042 ] Jark Wu commented on FLINK-3942: I can try to work on it if nobody else is already work on

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333992#comment-15333992 ] ASF GitHub Bot commented on FLINK-3839: --- Github user thormanrd commented on the issu

[GitHub] flink issue #2114: FLINK-3839 Added the extraction of jar files from a URL s...

2016-06-16 Thread thormanrd
Github user thormanrd commented on the issue: https://github.com/apache/flink/pull/2114 Corrected the typo. Gotta add FLINK to my dictionary. --- 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 hav

[jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333991#comment-15333991 ] ASF GitHub Bot commented on FLINK-4068: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2102: [FLINK-4068] [tableAPI] Move constant computations out of...

2016-06-16 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2102 After introducing `RexExecutor` which make `ReduceExpressionRules` taking effect , many errors occurred. 1. The `cannot translate call AS($t0, $t1)` is a Calcite bug I think, and I create

[jira] [Resolved] (FLINK-3332) Provide an exactly-once Cassandra connector

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

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

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

[jira] [Resolved] (FLINK-3311) Add a connector for streaming data into Cassandra

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

[GitHub] flink pull request #1771: [FLINK-3311/FLINK-3332] Add Cassandra connector

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

[GitHub] flink pull request #2041: [FLINK-3317] [cep] Introduce timeout handler to CE...

2016-06-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2041 --- 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-3317) Add timeout handler to CEP operator

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

[jira] [Closed] (FLINK-3317) Add timeout handler to CEP operator

2016-06-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3317. Resolution: Fixed Added via 57ef6c315ee7aa467d922dd4d1213dfd8bc74fb0 > Add timeout handler to CEP o

[jira] [Commented] (FLINK-3317) Add timeout handler to CEP operator

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

[GitHub] flink issue #2041: [FLINK-3317] [cep] Introduce timeout handler to CEP opera...

2016-06-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2041 Will be merging this PR. --- 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 wi

[jira] [Commented] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

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

[GitHub] flink issue #2085: [FLINK-3937] programmatic resuming of clusters

2016-06-16 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2085 I tried your code again on my testing machine and everything that didn't work at my last tests is now fixed. I also quickly scanned the newly added commits. I think the pull request is g

[jira] [Commented] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333870#comment-15333870 ] ASF GitHub Bot commented on FLINK-4083: --- GitHub user StefanRRichter opened a pull re

[GitHub] flink pull request #2117: [FLINK-4083] [java,DataSet] Introduce closure clea...

2016-06-16 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2117 [FLINK-4083] [java,DataSet] Introduce closure cleaning in Join.where(… Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333861#comment-15333861 ] ASF GitHub Bot commented on FLINK-3650: --- Github user fhueske commented on the issue:

[jira] [Assigned] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

2016-06-16 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-4019: -- Assignee: Tzu-Li (Gordon) Tai > Expose approximateArrivalTimestamp through the

[jira] [Commented] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

2016-06-16 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333858#comment-15333858 ] Tzu-Li (Gordon) Tai commented on FLINK-4019: Ok. I'll add this then along with

[GitHub] flink issue #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/1856 Hi @ramkrish86, PR looks quite good now. I had only a few minor comments. After those are fixed, the PR should be good to merge. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67350850 --- Diff: flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala --- @@ -0,0 +1,233 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67349578 --- Diff: flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala --- @@ -0,0 +1,233 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67349089 --- Diff: flink-scala/src/test/scala/org/apache/flink/api/operator/SelectByFunctionTest.scala --- @@ -0,0 +1,233 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

2016-06-16 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333824#comment-15333824 ] Gyula Fora commented on FLINK-4038: --- Should I open a discussion thread on the mailing li

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67345907 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/SelectByMaxFunction.scala --- @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

2016-06-16 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333822#comment-15333822 ] Gyula Fora commented on FLINK-4038: --- I feel that these issues are rather easy to solve o

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[jira] [Assigned] (FLINK-4067) Add version header to savepoints

2016-06-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4067: -- Assignee: Ufuk Celebi > Add version header to savepoints > > >

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67346072 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/SelectByMinFunction.scala --- @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67345503 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala --- @@ -356,6 +357,40 @@ class GroupedDataSet[T: ClassTag]( }

[GitHub] flink pull request #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r67345484 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala --- @@ -356,6 +357,40 @@ class GroupedDataSet[T: ClassTag]( }

[jira] [Commented] (FLINK-4078) Use ClosureCleaner for CoGroup where

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333789#comment-15333789 ] ASF GitHub Bot commented on FLINK-4078: --- GitHub user StefanRRichter opened a pull re

[GitHub] flink pull request #2116: [FLINK-4078] [java, DataSet] Introduce missing cal...

2016-06-16 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2116 [FLINK-4078] [java, DataSet] Introduce missing calls to closure cleaner Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into c

[GitHub] flink issue #2114: FLINT-3839 Added the extraction of jar files from a URL s...

2016-06-16 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2114 Thank you for your contribution. There is a typo in the pull request title. its important that its correct so that our jira picks up the pull request. Please also check out our contribution guide

[jira] [Commented] (FLINK-3924) Remove protobuf shading from Kinesis connector

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333752#comment-15333752 ] Robert Metzger commented on FLINK-3924: --- I'm assigning this to myself > Remove prot

[jira] [Assigned] (FLINK-3924) Remove protobuf shading from Kinesis connector

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3924: - Assignee: Robert Metzger > Remove protobuf shading from Kinesis connector > -

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

2016-06-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333749#comment-15333749 ] ASF GitHub Bot commented on FLINK-3714: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2093: [FLINK-3714] Add Support for "Allowed Lateness"

2016-06-16 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2093 Could you please update the tests to add elements to `expectedOutput` in line with the `processElement` and `processWatermark` calls on the test harness. In the existing tests I did this and it make

[jira] [Updated] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

2016-06-16 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4083: -- Description: When specifying a key selector in the where or equalTo clause of a Join, the closu

[jira] [Commented] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

2016-06-16 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333747#comment-15333747 ] Stefan Richter commented on FLINK-4083: --- Same problem. > Use ClosureCleaner for Joi

[jira] [Issue Comment Deleted] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

2016-06-16 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4083: -- Comment: was deleted (was: Same problem.) > Use ClosureCleaner for Join where and equalTo > ---

[jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

2016-06-16 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4083: - Summary: Use ClosureCleaner for Join where and equalTo Key: FLINK-4083 URL: https://issues.apache.org/jira/browse/FLINK-4083 Project: Flink Issue Type: Bug

[GitHub] flink pull request #2115: [FLINK-4017] [py] Add Aggregation support to Pytho...

2016-06-16 Thread GEOFBOT
GitHub user GEOFBOT opened a pull request: https://github.com/apache/flink/pull/2115 [FLINK-4017] [py] Add Aggregation support to Python API Adds Aggregation support in the Python API accessible through `.aggregate()` and `.agg_and()`. (I was unable to use `.and()` in Python becaus

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

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

[jira] [Comment Edited] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333740#comment-15333740 ] Robert Metzger edited comment on FLINK-4038 at 6/16/16 1:12 PM:

[GitHub] flink pull request #2093: [FLINK-3714] Add Support for "Allowed Lateness"

2016-06-16 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2093#discussion_r67339362 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java --- @@ -917,6 +929,465 @@ public

[jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333740#comment-15333740 ] Robert Metzger commented on FLINK-4038: --- Can you work on FLINK-4038 - FLINK-4040 unt

[jira] [Commented] (FLINK-3714) Add Support for "Allowed Lateness"

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

[jira] [Updated] (FLINK-3967) Provide RethinkDB Sink for Flink

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3967: -- Fix Version/s: (was: 1.1.0) > Provide RethinkDB Sink for Flink > ---

[GitHub] flink pull request #2114: FLINT-3839 Added the extraction of jar files from ...

2016-06-16 Thread thormanrd
GitHub user thormanrd opened a pull request: https://github.com/apache/flink/pull/2114 FLINT-3839 Added the extraction of jar files from a URL spec that is … Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consi

[jira] [Commented] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333712#comment-15333712 ] Robert Metzger commented on FLINK-3890: --- This will be addressed by https://github.co

[jira] [Updated] (FLINK-3875) Add a TableSink for Elasticsearch

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3875: -- Fix Version/s: (was: 1.1.0) > Add a TableSink for Elasticsearch > --

[jira] [Updated] (FLINK-3873) Add a Kafka TableSink with Avro serialization

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3873: -- Fix Version/s: (was: 1.1.0) > Add a Kafka TableSink with Avro serialization > --

[jira] [Updated] (FLINK-3874) Add a Kafka TableSink with JSON serialization

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3874: -- Fix Version/s: (was: 1.1.0) > Add a Kafka TableSink with JSON serialization > --

[jira] [Commented] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333708#comment-15333708 ] Robert Metzger commented on FLINK-4019: --- I think its okay to keep these two things s

[jira] [Commented] (FLINK-4009) Scala Shell fails to find library for inclusion in test

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333705#comment-15333705 ] Robert Metzger commented on FLINK-4009: --- Do we want to include this into the 1.1. re

[jira] [Commented] (FLINK-3995) Properly Structure Test Utils and Dependencies

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333701#comment-15333701 ] Robert Metzger commented on FLINK-3995: --- There is a pull request for this one, with

[jira] [Commented] (FLINK-4082) Add Setting for LargeRecordHandler

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

[jira] [Commented] (FLINK-3951) Add Histogram Metric Type

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

[GitHub] flink issue #2112: [FLINK-3951] Add histogram metric type

2016-06-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2112 We decided to add the histogram metric, because users requested this feature. The important thing is that the histograms are not used by the runtime per default, because they indeed don't come f

[jira] [Commented] (FLINK-3395) Polishing the web UI

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333700#comment-15333700 ] Robert Metzger commented on FLINK-3395: --- The PR opened by Stephan has the wrong issu

[GitHub] flink pull request #2113: [FLINK-4082] Add Setting for enabling/disabling La...

2016-06-16 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/2113 [FLINK-4082] Add Setting for enabling/disabling LargeRecordHandler By default this is set to disabled because there are known issues when users specify a custom TypeInformation. R: @til

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333692#comment-15333692 ] Robert Metzger commented on FLINK-3950: --- [~Zentol] is this in the scope of the 1.1 r

[jira] [Updated] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3933: -- Component/s: Streaming Connectors > Add an auto-type-extracting DeserializationSchema >

[jira] [Resolved] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3933. --- Resolution: Fixed This has been merged in https://github.com/apache/flink/commit/92e1c82cc545

[jira] [Created] (FLINK-4082) Add Setting for LargeRecordHandler

2016-06-16 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4082: --- Summary: Add Setting for LargeRecordHandler Key: FLINK-4082 URL: https://issues.apache.org/jira/browse/FLINK-4082 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-3895) Remove Docs for Program Packaging via Plans

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3895: -- Fix Version/s: (was: 1.1.0) > Remove Docs for Program Packaging via Plans >

[jira] [Updated] (FLINK-3871) Add Kafka TableSource with Avro serialization

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3871: -- Fix Version/s: (was: 1.1.0) > Add Kafka TableSource with Avro serialization > --

[jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

2016-06-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333683#comment-15333683 ] Ufuk Celebi commented on FLINK-4021: No, cleared the fix version. > Problem of settin

[jira] [Updated] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

2016-06-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4021: --- Fix Version/s: (was: 1.1.0) > Problem of setting autoread for netty channel when more tasks sharin

[jira] [Updated] (FLINK-3894) Remove Program Packaging via Plans

2016-06-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3894: -- Fix Version/s: (was: 1.1.0) > Remove Program Packaging via Plans > -

  1   2   3   >