[jira] [Commented] (FLINK-6552) Side outputs don't allow differing output types

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

[GitHub] flink issue #3885: [FLINK-6552] Allow differing types for side outputs

2017-05-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3885 You're right. 😓 I'm fixing and then 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 fea

[GitHub] flink pull request #3034: [FLINK-5363] Fire timers when window state is curr...

2017-05-13 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/3034 --- 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 en

[jira] [Commented] (FLINK-5363) Fire timers when window state is currently empty

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009591#comment-16009591 ] ASF GitHub Bot commented on FLINK-5363: --- Github user aljoscha closed the pull reques

[GitHub] flink issue #3034: [FLINK-5363] Fire timers when window state is currently e...

2017-05-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3034 It could, but I think we don't want to do this change right now. --- 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

[jira] [Commented] (FLINK-5363) Fire timers when window state is currently empty

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

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009538#comment-16009538 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009544#comment-16009544 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009541#comment-16009541 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009539#comment-16009539 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009537#comment-16009537 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009535#comment-16009535 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009536#comment-16009536 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009542#comment-16009542 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009534#comment-16009534 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009543#comment-16009543 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009540#comment-16009540 ] ASF GitHub Bot commented on FLINK-6221: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368672 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java --- @@ -0,0 +1,192 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368588 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368667 --- Diff: flink-metrics/flink-metrics-prometheus/src/test/java/org/apache/flink/metrics/prometheus/PrometheusReporterTest.java --- @@ -0,0 +1,192 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368532 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368522 --- Diff: flink-metrics/flink-metrics-prometheus/pom.xml --- @@ -0,0 +1,128 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.o

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368638 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368696 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368510 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368563 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368530 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[GitHub] flink pull request #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3833#discussion_r116368561 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java --- @@ -0,0 +1,256 @@ +/*

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

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

[GitHub] flink issue #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3833 As it stands a metric can have at most 10 labels, and there aren't any current plans to extend this set; according to the docs that's still ok. If this does indeed become a problem we can add a switch

[jira] [Commented] (FLINK-6221) Add Prometheus support to metrics

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009520#comment-16009520 ] ASF GitHub Bot commented on FLINK-6221: --- Github user mbode commented on the issue:

[GitHub] flink issue #3833: [FLINK-6221] Add PrometheusReporter

2017-05-13 Thread mbode
Github user mbode commented on the issue: https://github.com/apache/flink/pull/3833 @hadronzoo I tried to keep it as general as possible by exporting all variables available to the metric group as labels. I am not sure if this might lead to [label overuse](https://prometheus.io/docs/

[jira] [Closed] (FLINK-6518) Migrate BlobServer configuration options

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6518. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 4d719118cee3a256722e2bacf276568d601f2b65 >

[jira] [Closed] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6397. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3: 36edac4b16993459de

[jira] [Closed] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6530. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3: 81d520bbf9bffb6e37

[jira] [Commented] (FLINK-6518) Migrate BlobServer configuration options

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

[jira] [Commented] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

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

[jira] [Commented] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

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

[GitHub] flink pull request #3865: [FLINK-6518] Port blobserver config parameters to ...

2017-05-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3865 --- 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 #3810: [FLINK-6397] MultipleProgramsTestBase does not res...

2017-05-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3810 --- 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 #3892: [FLINK-6530] Close response in DatadogHttpClient

2017-05-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3892 --- 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-6455) Yarn single-job JobManagers should not allow uploads of new jobs.

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009405#comment-16009405 ] Chesnay Schepler commented on FLINK-6455: - We can do this in 3 steps. 1) Make sur

[GitHub] flink pull request #3895: [FLINK-6544] [table] Expose State Backend Interfac...

2017-05-13 Thread kaibozhou
GitHub user kaibozhou opened a pull request: https://github.com/apache/flink/pull/3895 [FLINK-6544] [table] Expose State Backend Interface for UDAGG This PR partially solved "Expose State Backend Interface for UDAGG", support over aggregate and unbounded group aggregate. Th

[jira] [Commented] (FLINK-6544) Expose State Backend Interface for UDAGG

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009403#comment-16009403 ] ASF GitHub Bot commented on FLINK-6544: --- GitHub user kaibozhou opened a pull request

[jira] [Commented] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

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

[jira] [Commented] (FLINK-6541) Jar upload directory not created

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009398#comment-16009398 ] ASF GitHub Bot commented on FLINK-6541: --- GitHub user zentol opened a pull request:

[GitHub] flink issue #3892: [FLINK-6530] Close response in DatadogHttpClient

2017-05-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3892 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 pull request #3894: [FLINK-6541] Improve tmp dir setup in TM/WebMonito...

2017-05-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3894 [FLINK-6541] Improve tmp dir setup in TM/WebMonitor This PR contains 2 changes related to temporary directories. 1. The `WebRuntimeMonitor` now uses `mkdirs` instead of `mkdir` 2. The `Ta

[jira] [Commented] (FLINK-6544) Expose State Backend Interface for UDAGG

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009397#comment-16009397 ] ASF GitHub Bot commented on FLINK-6544: --- Github user kaibozhou closed the pull reque

[GitHub] flink pull request #3893: [FLINK-6544][table] Expose State Backend Interface...

2017-05-13 Thread kaibozhou
Github user kaibozhou closed the pull request at: https://github.com/apache/flink/pull/3893 --- 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 e

[GitHub] flink pull request #3893: [Flink-6544][table] Expose State Backend Interface...

2017-05-13 Thread kaibozhou
GitHub user kaibozhou opened a pull request: https://github.com/apache/flink/pull/3893 [Flink-6544][table] Expose State Backend Interface for UDAGG This PR partially solved "Expose State Backend Interface for UDAGG", support over aggregate and unbounded group aggregate. Th

[jira] [Updated] (FLINK-6541) Jar upload directory not created

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6541: Priority: Minor (was: Critical) > Jar upload directory not created > --

[jira] [Updated] (FLINK-6541) Jar upload directory not created

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6541: Affects Version/s: 1.4.0 1.3.0 > Jar upload directory not created > -

[jira] [Assigned] (FLINK-6541) Jar upload directory not created

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6541: --- Assignee: Chesnay Schepler > Jar upload directory not created > -

[jira] [Commented] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009387#comment-16009387 ] ASF GitHub Bot commented on FLINK-6530: --- Github user tedyu commented on the issue:

[GitHub] flink issue #3892: [FLINK-6530] Close response in DatadogHttpClient

2017-05-13 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/3892 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 feature

[jira] [Commented] (FLINK-6518) Migrate BlobServer configuration options

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

[GitHub] flink issue #3865: [FLINK-6518] Port blobserver config parameters to ConfigO...

2017-05-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3865 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-6397) MultipleProgramsTestBase does not reset ContextEnvironment

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

[jira] [Commented] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009383#comment-16009383 ] ASF GitHub Bot commented on FLINK-6530: --- GitHub user zentol opened a pull request:

[GitHub] flink issue #3810: [FLINK-6397] MultipleProgramsTestBase does not reset Cont...

2017-05-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3810 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] [Comment Edited] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009382#comment-16009382 ] Chesnay Schepler edited comment on FLINK-6530 at 5/13/17 3:45 PM: --

[GitHub] flink pull request #3892: [FLINK-6530] Close response in DatadogHttpClient

2017-05-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3892 [FLINK-6530] Close response in DatadogHttpClient You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6530_datadog_response Alternativel

[jira] [Commented] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009382#comment-16009382 ] Chesnay Schepler commented on FLINK-6530: - The response instance is created by exe

[jira] [Assigned] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey()

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6530: --- Assignee: Chesnay Schepler > Unclosed Response in DatadogHttpClient#validateApiKey()

[jira] [Commented] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009377#comment-16009377 ] Tzu-Li (Gordon) Tai commented on FLINK-2510: This doesn't seem relevant anymor

[jira] [Closed] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-2510. -- Resolution: Fixed > KafkaConnector should access partition metadata from master/cluster

[jira] [Commented] (FLINK-5966) Document Running Flink on Kubernetes

2017-05-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009364#comment-16009364 ] Greg Hogan commented on FLINK-5966: --- Has this been resolved with FLINK-6330? > Document

[jira] [Closed] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-4722. -- Resolution: Not A Problem > Consumer group concept not working properly with FlinkKafkaC

[jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009342#comment-16009342 ] Tzu-Li (Gordon) Tai commented on FLINK-4722: Closing this issue as it doesn't

[jira] [Commented] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009330#comment-16009330 ] Tzu-Li (Gordon) Tai commented on FLINK-5711: Hi [~mj2...@att.com], what extra

[jira] [Commented] (FLINK-6062) Re-read a Kafka topic at the reception of an event

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009323#comment-16009323 ] Tzu-Li (Gordon) Tai commented on FLINK-6062: The Kafka connector now allows se

[jira] [Comment Edited] (FLINK-5753) CEP timeout handler.

2017-05-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009284#comment-16009284 ] Kostas Kloudas edited comment on FLINK-5753 at 5/13/17 11:49 AM: ---

[jira] [Comment Edited] (FLINK-5753) CEP timeout handler.

2017-05-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009284#comment-16009284 ] Kostas Kloudas edited comment on FLINK-5753 at 5/13/17 11:48 AM: ---

[jira] [Commented] (FLINK-5753) CEP timeout handler.

2017-05-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009284#comment-16009284 ] Kostas Kloudas commented on FLINK-5753: --- Hi [~jurijuri]. Did you configure your wat

[jira] [Assigned] (FLINK-5753) CEP timeout handler.

2017-05-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-5753: - Assignee: Kostas Kloudas > CEP timeout handler. > > >

[jira] [Commented] (FLINK-6575) Disable all tests on Windows that use HDFS

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009278#comment-16009278 ] ASF GitHub Bot commented on FLINK-6575: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3891: [FLINK-6575] Disable tests on Windows that use HDF...

2017-05-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3891 [FLINK-6575] Disable tests on Windows that use HDFS This PR disables all tests on `Windows` that rely on `HDFS`. You can merge this pull request into a Git repository by running: $ git pull http

[jira] [Updated] (FLINK-6577) Expand supported types for ConfigOptions

2017-05-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6577: Priority: Trivial (was: Major) > Expand supported types for ConfigOptions > ---

[jira] [Created] (FLINK-6577) Expand supported types for ConfigOptions

2017-05-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6577: --- Summary: Expand supported types for ConfigOptions Key: FLINK-6577 URL: https://issues.apache.org/jira/browse/FLINK-6577 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-6576) Allow ConfigOptions to validate the configured value

2017-05-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6576: --- Summary: Allow ConfigOptions to validate the configured value Key: FLINK-6576 URL: https://issues.apache.org/jira/browse/FLINK-6576 Project: Flink Issu

[jira] [Created] (FLINK-6575) Disable all tests on Windows that use HDFS

2017-05-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6575: --- Summary: Disable all tests on Windows that use HDFS Key: FLINK-6575 URL: https://issues.apache.org/jira/browse/FLINK-6575 Project: Flink Issue Type: Im

[jira] [Resolved] (FLINK-6554) CompatibilityResult should contain a notCompatible() option

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6554. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for mas

[jira] [Resolved] (FLINK-6566) Narrow down interface for compatibility hook method in VersionedIOReadableWritable

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6566. Resolution: Fixed Assignee: Tzu-Li (Gordon) Tai Fix Version/s: 1.4.0

[jira] [Updated] (FLINK-6565) Improve error messages for state restore failures

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6565: --- Fix Version/s: 1.4.0 1.3.0 > Improve error messages for state resto

[jira] [Closed] (FLINK-6565) Improve error messages for state restore failures

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6565. -- > Improve error messages for state restore failures > --

[jira] [Commented] (FLINK-6565) Improve error messages for state restore failures

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009234#comment-16009234 ] Tzu-Li (Gordon) Tai commented on FLINK-6565: Fixed for master via c594af09767e

[jira] [Resolved] (FLINK-6565) Improve error messages for state restore failures

2017-05-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6565. Resolution: Fixed > Improve error messages for state restore failures >

[jira] [Commented] (FLINK-6565) Improve error messages for state restore failures

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

[jira] [Commented] (FLINK-6566) Narrow down interface for compatibility hook method in VersionedIOReadableWritable

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

[jira] [Commented] (FLINK-6554) CompatibilityResult should contain a notCompatible() option

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

[GitHub] flink pull request #3883: [FLINK-6566] [core] More restricted interface for ...

2017-05-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3883 --- 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 #3886: [FLINK-6554] [core] Make CompatibilityResult optio...

2017-05-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3886 --- 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 #3882: [FLINK-6565] Fail memory-backed state restores wit...

2017-05-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3882 --- 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-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009199#comment-16009199 ] ASF GitHub Bot commented on FLINK-6288: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3766: [FLINK-6288] fix FlinkKafkaProducer's custom Partitioner ...

2017-05-13 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3766 seems like the relevant commits are e6ec702 and 64af26e. Let me try to resolve this .. :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

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

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009195#comment-16009195 ] ASF GitHub Bot commented on FLINK-4022: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3746: [FLINK-4022] [kafka] Partition and topic discovery for Fl...

2017-05-13 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3746 Hi @haohui, unfortunately we might not be able to merge this for 1.3. The reason is that the feature requires a migration from partitionable list state to union list state, which currently can not b

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

2017-05-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16009191#comment-16009191 ] ASF GitHub Bot commented on FLINK-4022: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3746: [FLINK-4022] [kafka] Partition and topic discovery...

2017-05-13 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3746#discussion_r116352819 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -503,23

  1   2   >