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

[ 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

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

[ 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] [Assigned] (FLINK-3942) Add support for INTERSECT

[ 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] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

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] [Commented] (FLINK-3827) Flink modules include unused dependencies

[ 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

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

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-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

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

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

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

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

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

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

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

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

[ 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

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

[ 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-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ 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-3319) Add or operator to CEP's pattern API

[ 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-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ 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

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

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-4027) FlinkKafkaProducer09 sink can lose messages

[ 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 #2108: [FLINK-4027] Flush FlinkKafkaProducer on checkpoints

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

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

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

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

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

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

[ 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-3951) Add Histogram Metric Type

[ 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

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

<    1   2   3