[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=15335578#comment-15335578 ] ASF GitHub Bot commented on FLINK-3677: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2109#discussion_r67468955 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/FilesFilter.java --- @@ -0,0 +1,99 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] flink pull request #2119: [FLINK-3949] Add numSplitsProcessed (Streaming)

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2119 [FLINK-3949] Add numSplitsProcessed (Streaming) This PR is a small follow-up to #2090. The number of splits processed is now also measured for the Streaming API. This change was excluded from the or

[jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators

[ https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335604#comment-15335604 ] ASF GitHub Bot commented on FLINK-3949: --- GitHub user zentol opened a pull request:

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

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2102 Regarding 3.: I already have some code in a branch that introduces symbols instead of the "Integer hack" we are currently using, but I haven't finished it so far. I can solve this issue for you. --

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

[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335636#comment-15335636 ] ASF GitHub Bot commented on FLINK-4068: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #2120: [FLINK-4070] [tableApi] Support literals on left s...

GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2120 [FLINK-4070] [tableApi] Support literals on left side of binary expre… The Table API does not support literals on left side of expressions like `+,_,*,/,%,>,< `. Because there is already such meth

[jira] [Commented] (FLINK-4070) Support literals on left side of binary expressions

[ https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335660#comment-15335660 ] ASF GitHub Bot commented on FLINK-4070: --- GitHub user wuchong opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335668#comment-15335668 ] 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...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2102 @twalthr That sounds great ! Thank you . --- 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 en

[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 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 project does not have this feature enabled and wishes so, or if the fea

[GitHub] flink issue #2104: [FLINK-3649] [docs] Add documentation for DataSet minBy /...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2104 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 project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-3649) Document stable API methods maxBy/minBy

[ https://issues.apache.org/jira/browse/FLINK-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335693#comment-15335693 ] ASF GitHub Bot commented on FLINK-3649: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2107: [FLINK-4077] Register Pojo DataSet/DataStream as Table wi...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2107 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 project does not have this feature enabled and wishes so, or if the fea

[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=15335692#comment-15335692 ] ASF GitHub Bot commented on FLINK-3650: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression.

[ https://issues.apache.org/jira/browse/FLINK-4077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335694#comment-15335694 ] ASF GitHub Bot commented on FLINK-4077: --- Github user fhueske commented on the issue:

[GitHub] flink pull request #2107: [FLINK-4077] Register Pojo DataSet/DataStream as T...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2107 --- 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 #2104: [FLINK-3649] [docs] Add documentation for DataSet ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2104 --- 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-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=15335701#comment-15335701 ] ASF GitHub Bot commented on FLINK-3650: --- Github user asfgit closed the pull request

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

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1856 --- 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-3649) Document stable API methods maxBy/minBy

[ https://issues.apache.org/jira/browse/FLINK-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335702#comment-15335702 ] ASF GitHub Bot commented on FLINK-3649: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression.

[ https://issues.apache.org/jira/browse/FLINK-4077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335700#comment-15335700 ] ASF GitHub Bot commented on FLINK-4077: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression.

[ https://issues.apache.org/jira/browse/FLINK-4077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4077. Resolution: Fixed Fixed with efc344a4e2ef8ea3e0b1e4da621196e9afeb75cc > Register Pojo DataSet/DataS

[jira] [Closed] (FLINK-3649) Document stable API methods maxBy/minBy

[ https://issues.apache.org/jira/browse/FLINK-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3649. Resolution: Done Fix Version/s: 1.1.0 Done with 298c009202ebf0fcf14d747c68124447b06b796d > D

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

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3650. Resolution: Implemented Fix Version/s: 1.1.0 Implemented with 7cc69434a21e23c871d091b0ba83085

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

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335715#comment-15335715 ] ASF GitHub Bot commented on FLINK-3937: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335717#comment-15335717 ] ASF GitHub Bot commented on FLINK-3667: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2034: [FLINK-3937] Implemented -yid option to Flink cli ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2034 --- 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-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335716#comment-15335716 ] ASF GitHub Bot commented on FLINK-3937: --- Github user asfgit closed the pull request

[GitHub] flink pull request #1978: [FLINK-3667] refactor client communication

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1978 --- 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 #2085: [FLINK-3937] programmatic resuming of clusters

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2085 --- 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 issue #2034: [FLINK-3937] Implemented -yid option to Flink cli list, s...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2034 Merged. Thank you for your contribution! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

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

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335718#comment-15335718 ] ASF GitHub Bot commented on FLINK-3937: --- Github user mxm commented on the issue:

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

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2085 Merged. Thank you for your comments! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

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

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335720#comment-15335720 ] ASF GitHub Bot commented on FLINK-3937: --- Github user mxm commented on the issue:

[jira] [Closed] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently

[ https://issues.apache.org/jira/browse/FLINK-3863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3863. - Resolution: Fixed Fixed with 9e9842410a635d183a002d1f25a6f489ce9d6a2f > Yarn Cluster shut

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

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3937: -- Priority: Minor (was: Trivial) > Make flink cli list, savepoint, cancel and stop work o

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

[ https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3937. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed with 875d4d238567a0503941488eb4e7d03b3

[jira] [Commented] (FLINK-4079) YARN properties file used for per-job cluster

[ https://issues.apache.org/jira/browse/FLINK-4079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335730#comment-15335730 ] Maximilian Michels commented on FLINK-4079: --- Fixed for 1.1 with ec6d97528e8b21f1

[jira] [Updated] (FLINK-3667) Generalize client<->cluster communication

[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3667: -- Fix Version/s: 1.1.0 > Generalize client<->cluster communication > -

[jira] [Closed] (FLINK-3667) Generalize client<->cluster communication

[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3667. - Resolution: Fixed Implemented via f9b52a3114a2114e6846091acf3abb294a49615b and f4ac852275

[GitHub] flink pull request #2119: [FLINK-3949] Add numSplitsProcessed (Streaming)

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2119#discussion_r67479777 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -292,6 +294,7 @@ public

[jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators

[ https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335740#comment-15335740 ] ASF GitHub Bot commented on FLINK-3949: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #2119: [FLINK-3949] Add numSplitsProcessed (Streaming)

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2119#discussion_r67480983 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -292,6 +294,7 @@ public

[jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators

[ https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335751#comment-15335751 ] ASF GitHub Bot commented on FLINK-3949: --- Github user zentol commented on a diff in t

[jira] [Updated] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4022: -- Component/s: Streaming Connectors Kafka Connector > Partition discovery / regex

[GitHub] flink pull request #2119: [FLINK-3949] Add numSplitsProcessed (Streaming)

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2119#discussion_r67481133 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java --- @@ -292,6 +294,7 @@ public

[jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators

[ https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335752#comment-15335752 ] ASF GitHub Bot commented on FLINK-3949: --- Github user zentol commented on a diff in t

[GitHub] flink issue #2118: [FLINK-3977] InternalWindowFunctions implement OutputType...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2118 LGTM! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[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=15335763#comment-15335763 ] ASF GitHub Bot commented on FLINK-3977: --- Github user aljoscha commented on the issue

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

[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335777#comment-15335777 ] Chesnay Schepler commented on FLINK-3950: - later afaik > Add Meter Metric Type >

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

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2112 Yes the idea is introduce the histogram abstraction which allows us to use any histogram implementation. At the moment we don't have a need for an optimized implementation which might change in

[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=15335778#comment-15335778 ] ASF GitHub Bot commented on FLINK-3951: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2079: [FLINK-3907] [gelly] Directed Clustering Coefficient

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2079 Related testt failures: Failed tests: ``` LocalClusteringCoefficientTest.testRMatGraph:85 expected:<1767159616563> but was:<1752656732242> ``` --- If your project is set up for it,

[jira] [Commented] (FLINK-3907) Directed Clustering Coefficient

[ https://issues.apache.org/jira/browse/FLINK-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335785#comment-15335785 ] ASF GitHub Bot commented on FLINK-3907: --- Github user zentol commented on the issue:

[GitHub] flink pull request #2121: [FLINK-4075] ContinuousFileProcessingCheckpointITC...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2121 [FLINK-4075] ContinuousFileProcessingCheckpointITCase failed on Travis Fixes the stability of the test. You can merge this pull request into a Git repository by running: $ git pull https://github.

[GitHub] flink issue #2119: [FLINK-3949] Add numSplitsProcessed (Streaming)

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2119 Thanks for the update. +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 enabled a

[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=15335796#comment-15335796 ] ASF GitHub Bot commented on FLINK-4075: --- GitHub user kl0u opened a pull request:

[jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators

[ https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335797#comment-15335797 ] ASF GitHub Bot commented on FLINK-3949: --- Github user fhueske commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3924: --- Fix Version/s: 1.1.0 > Remove protobuf shading from Kinesis connector > --

[jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335820#comment-15335820 ] Vladislav Pernin commented on FLINK-4034: - [~rmetzger] In case of "dependency dive

[jira] [Comment Edited] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335820#comment-15335820 ] Vladislav Pernin edited comment on FLINK-4034 at 6/17/16 10:16 AM: -

[jira] [Commented] (FLINK-3641) Document registerCachedFile API call

[ https://issues.apache.org/jira/browse/FLINK-3641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335830#comment-15335830 ] ASF GitHub Bot commented on FLINK-3641: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #2122: [FLINK-3641] Add documentation for DataSet distrib...

GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2122 [FLINK-3641] Add documentation for DataSet distributed cache. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink docsDistCache Alte

[GitHub] flink pull request #2123: [FLINK-3904] GlobalConfiguration doesn't ensure co...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2123 [FLINK-3904] GlobalConfiguration doesn't ensure config has been loaded This PR contains two commits. The first commit simply checks whether `loadConfiguration(..)` has been called. The second commit add

[jira] [Commented] (FLINK-3904) GlobalConfiguration doesn't ensure config has been loaded

[ https://issues.apache.org/jira/browse/FLINK-3904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335852#comment-15335852 ] ASF GitHub Bot commented on FLINK-3904: --- GitHub user mxm opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3890. - Resolution: Fixed Fixed with f4ac852275da36ee33aa54ae9097293ccc981afa > Deprecate streami

[GitHub] flink pull request #2121: [FLINK-4075] ContinuousFileProcessingCheckpointITC...

Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/2121 --- 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 enable

[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=15335892#comment-15335892 ] ASF GitHub Bot commented on FLINK-4075: --- Github user kl0u closed the pull request at

[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=15335893#comment-15335893 ] Kostas Kloudas commented on FLINK-4075: --- I pushed a fix and closing this issue. Ple

[jira] [Closed] (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 closed FLINK-4075. - Resolution: Fixed > ContinuousFileProcessingCheckpointITCase failed on Travis > --

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

[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335894#comment-15335894 ] Maximilian Michels commented on FLINK-4009: --- Not pressing IMHO. > Scala Shell f

[jira] [Created] (FLINK-4085) Set Kinesis Consumer Agent to Flink

Robert Metzger created FLINK-4085: - Summary: Set Kinesis Consumer Agent to Flink Key: FLINK-4085 URL: https://issues.apache.org/jira/browse/FLINK-4085 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4056. -- Resolution: Fixed Fix Version/s: 1.0.4 1.1.0 Hopefully fixed in 07a7b73 (maste

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

[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335898#comment-15335898 ] Maximilian Michels commented on FLINK-4009: --- Fixing this in the meantime with a

[jira] [Updated] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3231: --- Component/s: Kinesis Connector > Handle Kinesis-side resharding in Kinesis streaming c

[jira] [Updated] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards

[ https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4018: --- Component/s: Kinesis Connector > Configurable idle time between getRecords requests to

[jira] [Updated] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor

[ https://issues.apache.org/jira/browse/FLINK-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4020: --- Component/s: Kinesis Connector > Remove shard list querying from Kinesis consumer cons

[jira] [Updated] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration

[ https://issues.apache.org/jira/browse/FLINK-3983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3983: --- Component/s: Streaming Connectors > Allow users to set any (relevant) configuration pa

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

[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335903#comment-15335903 ] Maximilian Michels commented on FLINK-4009: --- Fixed with 4d8cbec4ffca033f5602a532

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

[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4009. - Resolution: Fixed > Scala Shell fails to find library for inclusion in test >

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

[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4009: -- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-3454) > Scala Shell fai

[GitHub] flink issue #2088: [FLINK-3859] [table] Add BigDecimal/BigInteger support to...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2088 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 project does not have this feature enabled and wishes so, or if the fea

[GitHub] flink issue #2118: [FLINK-3977] InternalWindowFunctions implement OutputType...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2118 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 project does not have this feature enabled and wishes so, or if the fea

[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=15335929#comment-15335929 ] ASF GitHub Bot commented on FLINK-3977: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-3859) Add BigDecimal/BigInteger support to Table API

[ https://issues.apache.org/jira/browse/FLINK-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335927#comment-15335927 ] ASF GitHub Bot commented on FLINK-3859: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2119: [FLINK-3949] Add numSplitsProcessed (Streaming)

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2119 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 project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-3949) Collect Metrics in Runtime Operators

[ https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335937#comment-15335937 ] ASF GitHub Bot commented on FLINK-3949: --- Github user fhueske commented on the issue:

[GitHub] flink pull request #2124: [FLINK-3647] Change StreamSource to use Processing...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2124 [FLINK-3647] Change StreamSource to use Processing-Time Clock Service This PR changes the AutomaticWatermarkContext to user a pluggable processing time clock. This allows for better testability of

[jira] [Commented] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service

[ https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335950#comment-15335950 ] ASF GitHub Bot commented on FLINK-3647: --- GitHub user kl0u opened a pull request:

[jira] [Commented] (FLINK-3646) Use Processing-Time Clock in Window Assigners/Triggers

[ https://issues.apache.org/jira/browse/FLINK-3646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335951#comment-15335951 ] Kostas Kloudas commented on FLINK-3646: --- The solution to this in included in https:/

[GitHub] flink pull request #2125: [FLINK-3864] Yarn tests don't check for prohibited...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2125 [FLINK-3864] Yarn tests don't check for prohibited strings in log output You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-3864 Alter

[jira] [Commented] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335955#comment-15335955 ] ASF GitHub Bot commented on FLINK-3864: --- GitHub user mxm opened a pull request:

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

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2093 Some tests, such as `testLateness()` still fill the expected output in one block at the end of the test and not inline with the `processElement()`/`processWatermark()` calls. Some, such as `testDro

[GitHub] flink issue #2103: [FLINK-2733] Harden ZooKeeperLeaderElectionTest

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2103 Ran 10 Travis builds and couldn't reproduce the ZooKeeperLeaderElectionTest failure. Thus, I assume that this PR fixes/hardens the test case. Will merge it now. --- If your project is set up f

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

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

[jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335970#comment-15335970 ] ASF GitHub Bot commented on FLINK-2733: --- Github user tillrohrmann commented on the i

[jira] [Closed] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2733. Resolution: Fixed Fixed via 1a6bab3ef76805685044cf4521e32315169f9033 > ZooKeeperLeaderElectionTest.

[GitHub] flink pull request #2103: [FLINK-2733] Harden ZooKeeperLeaderElectionTest

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2103 --- 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-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335976#comment-15335976 ] ASF GitHub Bot commented on FLINK-2733: --- Github user asfgit closed the pull request

  1   2   >