[GitHub] flink issue #3861: [Flink-6352] Support to use timestamp to set the initial ...

2017-05-13 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3861 Hi @zjureel, could you rebase your commits for the issue on the latest master? Otherwise I cannot review the PR like this. --- If your project is set up for it, you can reply to this email and

[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 @zjureel could you rebase the PR on the latest master? Otherwise I cannot review the PR like this. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

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

[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

[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 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=16009195#comment-16009195 ] ASF GitHub Bot commented on FLINK-4022: --- 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-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 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

[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

[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

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

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

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

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

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

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

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

[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

[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

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

[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

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

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

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

[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

[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

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

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

[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_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_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=16009540#comment-16009540 ] 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=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=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=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

[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

[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

  1   2   >