[jira] [Created] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

Kostas Kloudas created FLINK-4126: - Summary: Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection Key: FLINK-4126 URL: https://issues.apache.org/jira/browse/FLINK-4126 Project: Flink

[jira] [Commented] (FLINK-3943) Add support for EXCEPT (set minus)

[ https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352499#comment-15352499 ] ASF GitHub Bot commented on FLINK-3943: --- Github user wuchong commented on a diff in the pull

[GitHub] flink pull request #2169: [FLINK-3943] Add support for EXCEPT operator

Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2169#discussion_r68704013 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala --- @@ -236,6 +236,32 @@ case class

[jira] [Commented] (FLINK-3943) Add support for EXCEPT (set minus)

[ https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352459#comment-15352459 ] ASF GitHub Bot commented on FLINK-3943: --- Github user mushketyk commented on a diff in the pull

[GitHub] flink pull request #2169: [FLINK-3943] Add support for EXCEPT operator

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2169#discussion_r68706865 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala --- @@ -236,6 +236,32 @@ case class Aggregate(

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352549#comment-15352549 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chobeat commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chobeat commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r68713373 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,287 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

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

[GitHub] flink pull request #2156: [FLINK-4113] [runtime] Always copy first value in ...

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

[GitHub] flink issue #2171: FLINK-3319 Added the or function to the CEP pattern

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2171 Thanks for cleaning up the PR @thormanrd. Could we also try to get rid of the merge commits? We actually always rebase in the Flink community and never merge branches. Furthermore, it

[GitHub] flink pull request #2166: [FLINK-4099] Fix CliFrontendYarnAddressConfigurati...

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

[jira] [Resolved] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4099. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in

[jira] [Commented] (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:comment-tabpanel=15352638#comment-15352638 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68722233 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68726797 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardDiscoverer.java ---

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68728603 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1727,6 +1764,160 @@ class JobManager( //

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352695#comment-15352695 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352697#comment-15352697 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352737#comment-15352737 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352572#comment-15352572 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chobeat commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chobeat commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r68715364 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,287 @@ +/* + * Licensed to

[GitHub] flink pull request #2156: [FLINK-4113] [runtime] Always copy first value in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2156#discussion_r68718332 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedAllReduceDriver.java --- @@ -89,7 +89,7 @@ public void

[jira] [Commented] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352593#comment-15352593 ] ASF GitHub Bot commented on FLINK-4113: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Updated] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner

[ https://issues.apache.org/jira/browse/FLINK-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4114: -- Component/s: YARN Client Issue Type: Improvement (was: Bug) > Need a way to manage

[jira] [Assigned] (FLINK-4110) Provide testing skeleton in quickstarts

[ https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4110: - Assignee: Robert Metzger > Provide testing skeleton in quickstarts >

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68728510 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -2325,55 +2326,65 @@ object TaskManager {

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352715#comment-15352715 ] ASF GitHub Bot commented on FLINK-1550: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2131 I'm done with my first full review. I'll test the code tomorrow. Let me know if you need help addressing my comments. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68729523 --- Diff: flink-core/src/main/java/org/apache/flink/metrics/MetricRegistry.java --- @@ -30,6 +30,7 @@ import org.slf4j.Logger; import

[jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration

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

[GitHub] flink issue #2168: [FLINK-3964] add hint to job submission timeout exception...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2168 Thanks for the feedback. Savepoint related errors should be forwarded to the client independently of timeouts (except maybe when the savepoint takes too long). So that should be fixed in a follow-up.

[jira] [Commented] (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:comment-tabpanel=15352540#comment-15352540 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in the pull

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

[jira] [Commented] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

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

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68726906 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -149,6 +154,16 @@ class JobManager( var

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352678#comment-15352678 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352679#comment-15352679 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68726957 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -204,6 +219,12 @@ class JobManager(

[jira] [Commented] (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:comment-tabpanel=15352676#comment-15352676 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68729084 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1082,6 +1110,13 @@ class JobManager(

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352704#comment-15352704 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (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:comment-tabpanel=15352738#comment-15352738 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68731283 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68731349 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68731503 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1082,6 +1110,13 @@ class JobManager(

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68731488 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

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

[GitHub] flink issue #2156: [FLINK-4113] [runtime] Always copy first value in Chained...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2156 @greghogan the tests looks good. Thanks for your work :-) The failing test cases are unrelated. Will merge this PR. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352650#comment-15352650 ] Aljoscha Krettek commented on FLINK-3710: - It might be solvable by fiddling with the ScalaDoc

[jira] [Commented] (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:comment-tabpanel=15352705#comment-15352705 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink issue #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2146 Good fixes @zentol. I had some minor comments which we should address before merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

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

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68729588 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1727,6 +1764,160 @@ class JobManager( //

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

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4085: - Assignee: Robert Metzger > Set Kinesis Consumer Agent to Flink >

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352714#comment-15352714 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68730716 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[jira] [Commented] (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:comment-tabpanel=15352733#comment-15352733 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #2150: [FLINK-3580] [table] Reintroduce Date/Time and imp...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2150#discussion_r68730731 --- Diff: docs/apis/table.md --- @@ -775,6 +775,8 @@ column names and function names follow Java identifier syntax. Expressions speci If working

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352734#comment-15352734 ] ASF GitHub Bot commented on FLINK-3580: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68711841 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[jira] [Resolved] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4113. -- Resolution: Fixed Fixed via a6feea32a328f3f3216960298d6c8a5d3f30a234 > Always copy first value

[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=15352616#comment-15352616 ] ASF GitHub Bot commented on FLINK-3319: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #2171: FLINK-3319 Added the or function to the CEP patter...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2171#discussion_r68719946 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java --- @@ -424,87 +423,71 @@ public Integer select(Map

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68727843 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[jira] [Commented] (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:comment-tabpanel=15352692#comment-15352692 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r68729145 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68731685 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352743#comment-15352743 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352739#comment-15352739 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352750#comment-15352750 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352749#comment-15352749 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68732049 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1727,6 +1764,160 @@ class JobManager( //

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352756#comment-15352756 ] ASF GitHub Bot commented on FLINK-4062: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352755#comment-15352755 ] ASF GitHub Bot commented on FLINK-4062: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68732268 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352754#comment-15352754 ] ASF GitHub Bot commented on FLINK-4062: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68733223 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1082,6 +1110,13 @@ class JobManager(

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352789#comment-15352789 ] ASF GitHub Bot commented on FLINK-3580: --- Github user twalthr commented on a diff in the pull

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352844#comment-15352844 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352841#comment-15352841 ] ASF GitHub Bot commented on FLINK-1550: --- Github user tillrohrmann commented on a diff in the pull

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352840#comment-15352840 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68741918 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendRunTest.java --- @@ -100,15 +100,22 @@ public void testRun() { }

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352847#comment-15352847 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2175: [FLINK-4085][Kinesis] Set Flink-specific user agen...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2175 [FLINK-4085][Kinesis] Set Flink-specific user agent I was asked by Amazon to set a Flink specific user agent when accessing the AWS APIs. I've set an agent for the consumer, for the producer I

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

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

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352859#comment-15352859 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68731943 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68732942 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-4062) Update Windowing Documentation

[ https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352764#comment-15352764 ] ASF GitHub Bot commented on FLINK-4062: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-1550) Show JVM Metrics for JobManager

[ https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352765#comment-15352765 ] ASF GitHub Bot commented on FLINK-1550: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68741402 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

[GitHub] flink pull request #2146: [FLINK-1550/FLINK-4057] Add JobManager Metrics

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2146#discussion_r68741425 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1727,6 +1764,160 @@ class JobManager( //

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352854#comment-15352854 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68742191 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352856#comment-15352856 ] ASF GitHub Bot commented on FLINK-4084: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68742325 --- Diff: flink-dist/src/main/flink-bin/bin/flink --- @@ -17,20 +17,41 @@ # limitations under the License.

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352857#comment-15352857 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in the pull

[GitHub] flink pull request #2149: [FLINK-4084] Add configDir parameter to CliFronten...

Github user alkagin commented on a diff in the pull request: https://github.com/apache/flink/pull/2149#discussion_r68742339 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendRunTest.java --- @@ -100,15 +100,22 @@ public void testRun() {

[GitHub] flink pull request #2154: [FLINK-4062] Update Windowing Documentation

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2154#discussion_r68743505 --- Diff: docs/apis/streaming/windows.md --- @@ -24,1023 +24,593 @@ specific language governing permissions and limitations under the License. -->

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

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352871#comment-15352871 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on a diff in the pull

  1   2   3   >