[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256270551 ## File path:

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256270580 ## File path:

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256270609 ## File path:

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256270568 ## File path:

[GitHub] glaksh100 commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
glaksh100 commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-463086493 Thanks for taking a look @becketqin and @tweise. I think adding an interface that can extend to other connectors and

[GitHub] liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory removed messages

2019-02-12 Thread GitBox
liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory removed messages URL: https://github.com/apache/flink/pull/7257#issuecomment-463084487 @tillrohrmann Hi,are you available to help me to review this PR? Thanks! Look forwards to your reply.

[jira] [Updated] (FLINK-11590) Redundant spaces occur when the string true is generated using 'case when' grammar

2019-02-12 Thread dong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dong updated FLINK-11590: - Description: {code:java} case when conditionA then 'false' else 'true' end as field {code} When I execute

[jira] [Closed] (FLINK-10996) Enable state ttl in cep

2019-02-12 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi closed FLINK-10996. -- Resolution: Won't Fix > Enable state ttl in cep > --- > > Key:

[jira] [Commented] (FLINK-10996) Enable state ttl in cep

2019-02-12 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766862#comment-16766862 ] aitozi commented on FLINK-10996: [~tzulitai] I'm OK. And with the remind of [~dawidwys], may be his

[jira] [Created] (FLINK-11590) Redundant spaces occur when the string true is generated using 'case when' grammar

2019-02-12 Thread dong (JIRA)
dong created FLINK-11590: Summary: Redundant spaces occur when the string true is generated using 'case when' grammar Key: FLINK-11590 URL: https://issues.apache.org/jira/browse/FLINK-11590 Project: Flink

[jira] [Commented] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Nicholas Jiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766852#comment-16766852 ] Nicholas Jiang commented on FLINK-11562: [~jark]I have already applied contributor permission

[jira] [Commented] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread cellen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766842#comment-16766842 ] cellen commented on FLINK-11562: Hi [~jark],   Thank you. I will pull the request as soon as quickly.

[jira] [Commented] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766832#comment-16766832 ] Jark Wu commented on FLINK-11562: - Thank you [~Sunnyd]. [~cellen], I assigned this issue to me. You can

[jira] [Comment Edited] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766832#comment-16766832 ] Jark Wu edited comment on FLINK-11562 at 2/13/19 6:21 AM: -- Thank you [~Sunnyd].

[jira] [Assigned] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11562: --- Assignee: Jark Wu > Translate "Flink Operations" page into Chinese >

[jira] [Assigned] (FLINK-11563) Translate "Getting Help" page into Chinese

2019-02-12 Thread Huadong Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huadong Sun reassigned FLINK-11563: --- Assignee: Huadong Sun > Translate "Getting Help" page into Chinese >

[jira] [Commented] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Huadong Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766814#comment-16766814 ] Huadong Sun commented on FLINK-11562: - Hi [~jark],  I have not started the translation work for this

[jira] [Updated] (FLINK-11559) Translate "FAQ" page into Chinese

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11559: --- Labels: pull-request-available (was: ) > Translate "FAQ" page into Chinese >

[jira] [Assigned] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Huadong Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huadong Sun reassigned FLINK-11562: --- Assignee: (was: Huadong Sun) > Translate "Flink Operations" page into Chinese >

[jira] [Commented] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766807#comment-16766807 ] Jark Wu commented on FLINK-11562: - Hi [~cellen], please comment in English. The dev mailing list

[jira] [Assigned] (FLINK-11581) Add Chinese document contribution guideline

2019-02-12 Thread Forward Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Forward Xu reassigned FLINK-11581: -- Assignee: Forward Xu > Add Chinese document contribution guideline >

[jira] [Commented] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread cellen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766793#comment-16766793 ] cellen commented on FLINK-11562: hi,[~jark]

[GitHub] walterddr commented on issue #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

2019-02-12 Thread GitBox
walterddr commented on issue #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607#issuecomment-463067571 @twalthr @zentol could you kindly take another look on this PR?

[jira] [Assigned] (FLINK-11562) Translate "Flink Operations" page into Chinese

2019-02-12 Thread Huadong Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huadong Sun reassigned FLINK-11562: --- Assignee: Huadong Sun > Translate "Flink Operations" page into Chinese >

[jira] [Assigned] (FLINK-11330) Migrate Scala-macro generated serializers to use new serialization compatibility abstractions

2019-02-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-11330: --- Assignee: Igal Shilman > Migrate Scala-macro generated serializers to use

[jira] [Assigned] (FLINK-11588) Migrate CopyableValueSerializer to use new serialization compatibility abstractions

2019-02-12 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11588: Assignee: Congxian Qiu > Migrate CopyableValueSerializer to use new serialization

[jira] [Updated] (FLINK-11588) Migrate CopyableValueSerializer to use new serialization compatibility abstractions

2019-02-12 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11588: Description: This subtask covers migration of the {{CopyableValueSerializer}} to

[jira] [Updated] (FLINK-11088) Allow pre-install Kerberos authentication keytab discovery on YARN

2019-02-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Summary: Allow pre-install Kerberos authentication keytab discovery on YARN (was: Allow Pre-install

[jira] [Created] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

2019-02-12 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11589: - Summary: Introduce service provider pattern for user to dynamically load SecurityFactory classes Key: FLINK-11589 URL: https://issues.apache.org/jira/browse/FLINK-11589

[jira] [Created] (FLINK-11588) Migrate CopyableValueSerializer to use new serialization compatibility abstractions

2019-02-12 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11588: --- Summary: Migrate CopyableValueSerializer to use new serialization compatibility abstractions Key: FLINK-11588 URL: https://issues.apache.org/jira/browse/FLINK-11588

[jira] [Updated] (FLINK-11088) Allow Pre-install Kerberos Authentication Keytab discovery on YARN

2019-02-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11088: -- Summary: Allow Pre-install Kerberos Authentication Keytab discovery on YARN (was: Improve Kerberos

[jira] [Updated] (FLINK-11271) Improvement to Kerberos Security

2019-02-12 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11271: -- Summary: Improvement to Kerberos Security (was: Improve Kerberos Credential Distribution) >

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766727#comment-16766727 ] pj commented on FLINK-11484:  source code: {code:java} // code placeholder package com.blinktest.main;

[jira] [Issue Comment Deleted] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Comment: was deleted (was: source code:   !code.png! error file: !error.png!) > Blink

[jira] [Issue Comment Deleted] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Comment: was deleted (was: I don't know why Jira could not upload source code file and jar file. I have written an

[jira] [Issue Comment Deleted] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Comment: was deleted (was:  source code: {code:java} // code placeholder package com.blinktest.main; import

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Attachment: code.png > Blink java.util.concurrent.TimeoutException > --- >

[jira] [Comment Edited] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766702#comment-16766702 ] pj edited comment on FLINK-11484 at 2/13/19 3:17 AM: - I write a simple sample could

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Attachment: error.png > Blink java.util.concurrent.TimeoutException > --- >

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766724#comment-16766724 ] pj commented on FLINK-11484: I don't know why Jira could not upload source code file and jar file. I have

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766711#comment-16766711 ] pj commented on FLINK-11484: source code:   !code.png! error file: !error.png! > Blink

[jira] [Commented] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766702#comment-16766702 ] pj commented on FLINK-11484: I write a simple sample could reproduce the bug. The jar file: 

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Attachment: dashboard.png > Blink java.util.concurrent.TimeoutException >

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-02-12 Thread pj (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pj updated FLINK-11484: --- Attachment: image-2019-02-13-10-54-16-880.png > Blink java.util.concurrent.TimeoutException >

[jira] [Updated] (FLINK-11566) Translate "Powered by Flink" page into Chinese

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11566: --- Labels: pull-request-available (was: ) > Translate "Powered by Flink" page into Chinese >

[GitHub] klion26 commented on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store elements of ListState as multiple key-values in rocksdb

2019-02-12 Thread GitBox
klion26 commented on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store elements of ListState as multiple key-values in rocksdb URL: https://github.com/apache/flink/pull/7675#issuecomment-463032796 @FaxianZhao thank you for your contribution. I think you could use `git rebase` other

[jira] [Assigned] (FLINK-11581) Add Chinese document contribution guideline

2019-02-12 Thread Forward Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Forward Xu reassigned FLINK-11581: -- Assignee: (was: Forward Xu) > Add Chinese document contribution guideline >

[jira] [Assigned] (FLINK-11566) Translate "Powered by Flink" page into Chinese

2019-02-12 Thread Forward Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Forward Xu reassigned FLINK-11566: -- Assignee: Forward Xu > Translate "Powered by Flink" page into Chinese >

[jira] [Commented] (FLINK-10213) Task managers cache a negative DNS lookup of the blob server indefinitely

2019-02-12 Thread Joey Echeverria (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766600#comment-16766600 ] Joey Echeverria commented on FLINK-10213: - Hi [~dawidwys], Sorry for the delay responding. What

[jira] [Commented] (FLINK-11547) JsonMappingException in DynamoDBStreamsSchema

2019-02-12 Thread Devin Thomson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766572#comment-16766572 ] Devin Thomson commented on FLINK-11547: --- [~thw] sure! I'll send a PR sometime this week >

[GitHub] tillrohrmann opened a new pull request #7690: [FLINK-11587][tests] Port CoLocationConstraintITCase to new code base

2019-02-12 Thread GitBox
tillrohrmann opened a new pull request #7690: [FLINK-11587][tests] Port CoLocationConstraintITCase to new code base URL: https://github.com/apache/flink/pull/7690 ## What is the purpose of the change Port `CoLocationConstraintITCase` to new code base. This PR is based on

[GitHub] flinkbot commented on issue #7690: [FLINK-11587][tests] Port CoLocationConstraintITCase to new code base

2019-02-12 Thread GitBox
flinkbot commented on issue #7690: [FLINK-11587][tests] Port CoLocationConstraintITCase to new code base URL: https://github.com/apache/flink/pull/7690#issuecomment-462963378 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-11586) Check and port SlotSharingITCase to new code base

2019-02-12 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766522#comment-16766522 ] Gary Yao commented on FLINK-11586: -- Please take a look at FLINK-10610. > Check and port

[jira] [Updated] (FLINK-11586) Check and port SlotSharingITCase to new code base

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11586: --- Labels: pull-request-available (was: ) > Check and port SlotSharingITCase to new code base

[GitHub] flinkbot commented on issue #7689: [FLINK-11586][tests] Remove legacy SlotSharingITCase

2019-02-12 Thread GitBox
flinkbot commented on issue #7689: [FLINK-11586][tests] Remove legacy SlotSharingITCase URL: https://github.com/apache/flink/pull/7689#issuecomment-462952910 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Closed] (FLINK-11587) Check and port CoLocationConstraintITCase to new code base

2019-02-12 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-11587. Resolution: Duplicate Closing because I don't see a difference to FLINK-10610. Please re-open if I am

[GitHub] tillrohrmann opened a new pull request #7689: [FLINK-11586][tests] Remove legacy SlotSharingITCase

2019-02-12 Thread GitBox
tillrohrmann opened a new pull request #7689: [FLINK-11586][tests] Remove legacy SlotSharingITCase URL: https://github.com/apache/flink/pull/7689 ## What is the purpose of the change Remove legacy `SlotSharingITCase`. This PR is based on #7683. ## Brief change log

[jira] [Assigned] (FLINK-11586) Check and port SlotSharingITCase to new code base

2019-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11586: - Assignee: Till Rohrmann > Check and port SlotSharingITCase to new code base >

[jira] [Assigned] (FLINK-11587) Check and port CoLocationConstraintITCase to new code base

2019-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11587: - Assignee: Till Rohrmann > Check and port CoLocationConstraintITCase to new code base >

[GitHub] flinkbot commented on issue #7688: [FLINK-9816][network] add option to configure SSL engine provider for TM communication

2019-02-12 Thread GitBox
flinkbot commented on issue #7688: [FLINK-9816][network] add option to configure SSL engine provider for TM communication URL: https://github.com/apache/flink/pull/7688#issuecomment-462944271 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] NicoK closed pull request #6328: [FLINK-9816][network] add option to configure SSL engine provider for TM communication

2019-02-12 Thread GitBox
NicoK closed pull request #6328: [FLINK-9816][network] add option to configure SSL engine provider for TM communication URL: https://github.com/apache/flink/pull/6328 This is an automated message from the Apache Git

[GitHub] NicoK opened a new pull request #7688: [FLINK-9816][network] add option to configure SSL engine provider for TM communication

2019-02-12 Thread GitBox
NicoK opened a new pull request #7688: [FLINK-9816][network] add option to configure SSL engine provider for TM communication URL: https://github.com/apache/flink/pull/7688 ## What is the purpose of the change Netty has the ability to run with different `SSLEngine` implementations

[GitHub] rmetzger commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
rmetzger commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462943479 Thanks a lot :) There's a cool new feature coming up in the pipeline: Labeling of the PR progress.

[jira] [Created] (FLINK-11586) Check and port SlotSharingITCase to new code base

2019-02-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11586: - Summary: Check and port SlotSharingITCase to new code base Key: FLINK-11586 URL: https://issues.apache.org/jira/browse/FLINK-11586 Project: Flink Issue

[jira] [Created] (FLINK-11587) Check and port CoLocationConstraintITCase to new code base

2019-02-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11587: - Summary: Check and port CoLocationConstraintITCase to new code base Key: FLINK-11587 URL: https://issues.apache.org/jira/browse/FLINK-11587 Project: Flink

[GitHub] tillrohrmann closed pull request #7665: [FLINK-11551][rpc] Allow RpcEndpoint to execute asynchronous stop operations

2019-02-12 Thread GitBox
tillrohrmann closed pull request #7665: [FLINK-11551][rpc] Allow RpcEndpoint to execute asynchronous stop operations URL: https://github.com/apache/flink/pull/7665 This is an automated message from the Apache Git Service.

[jira] [Resolved] (FLINK-11551) Allow RpcEndpoints to execute asynchronous stop operations

2019-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11551. --- Resolution: Fixed Fixed via 3d200070c4404dbce61d80fcdda4509ece383937 > Allow RpcEndpoints

[GitHub] zentol commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once

2019-02-12 Thread GitBox
zentol commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once URL: https://github.com/apache/flink/pull/7682#discussion_r256139016 ## File path:

[GitHub] zentol commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once

2019-02-12 Thread GitBox
zentol commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once URL: https://github.com/apache/flink/pull/7682#discussion_r256139016 ## File path:

[GitHub] zentol commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once

2019-02-12 Thread GitBox
zentol commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once URL: https://github.com/apache/flink/pull/7682#discussion_r256138606 ## File path:

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256122460 ## File path:

[GitHub] tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462908960 @rmetzger the flinkbot is awesome! This is an automated

[GitHub] flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462574731 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462908617 @flinkbot approve consensus This is an automated

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256116846 ## File path:

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256117327 ## File path:

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r256117885 ## File path:

[GitHub] flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462574731 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462904724 @flinkbot approve description This is an automated

[GitHub] tweise removed a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise removed a comment on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462904441 * @flinkbot approve description This is an

[GitHub] tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-02-12 Thread GitBox
tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462904441 * @flinkbot approve description This is an automated

[jira] [Updated] (FLINK-11557) Translate "Downloads" page into Chinese.

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11557: --- Labels: pull-request-available (was: ) > Translate "Downloads" page into Chinese. >

[jira] [Closed] (FLINK-11574) Make StreamTask properly handle the DRAIN message.

2019-02-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-11574. -- Resolution: Invalid > Make StreamTask properly handle the DRAIN message. >

[jira] [Updated] (FLINK-11458) Ensure sinks commit side-effects when cancelling with savepoint.

2019-02-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-11458: --- Description: See https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=103090212

[jira] [Closed] (FLINK-11575) Let the JobManager send the SUSPEND and DRAIN messages

2019-02-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-11575. -- Resolution: Invalid > Let the JobManager send the SUSPEND and DRAIN messages >

[jira] [Closed] (FLINK-11573) Make StreamTask properly handle the SUSPEND message.

2019-02-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-11573. -- Resolution: Invalid > Make StreamTask properly handle the SUSPEND message. >

[jira] [Closed] (FLINK-11572) Add new types of CheckpointBarriers.

2019-02-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-11572. -- Resolution: Invalid > Add new types of CheckpointBarriers. >

[GitHub] tillrohrmann commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once

2019-02-12 Thread GitBox
tillrohrmann commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once URL: https://github.com/apache/flink/pull/7682#discussion_r256027272 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once

2019-02-12 Thread GitBox
tillrohrmann commented on a change in pull request #7682: [FLINK-11583][configuration] Support deprecated and fallback keys at once URL: https://github.com/apache/flink/pull/7682#discussion_r256027410 ## File path:

[jira] [Closed] (FLINK-11584) ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used

2019-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11584. Resolution: Fixed Fix Version/s: 1.8.0 1.7.3

[jira] [Reopened] (FLINK-11584) ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used

2019-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11584: -- > ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used >

[jira] [Closed] (FLINK-11584) ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used

2019-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11584. Resolution: Fixed master: 9839126b7d05eb4b6966e77e0893fb09b445803f 1.7:

[jira] [Updated] (FLINK-11584) ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used

2019-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11584: - Summary: ConfigDocsCompletenessITCase fails DescriptionBuilder#linebreak() is used

[GitHub] zentol merged pull request #7685: [FLINK-11584][docs] Add space in self-closing linebreak tag

2019-02-12 Thread GitBox
zentol merged pull request #7685: [FLINK-11584][docs] Add space in self-closing linebreak tag URL: https://github.com/apache/flink/pull/7685 This is an automated message from the Apache Git Service. To respond to the

[GitHub] tillrohrmann commented on issue #7665: [FLINK-11551][rpc] Allow RpcEndpoint to execute asynchronous stop operations

2019-02-12 Thread GitBox
tillrohrmann commented on issue #7665: [FLINK-11551][rpc] Allow RpcEndpoint to execute asynchronous stop operations URL: https://github.com/apache/flink/pull/7665#issuecomment-462792922 Thanks for the review @StefanRRichter. I've addressed your comments and pushed the changes. Merging

[GitHub] flinkbot commented on issue #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions

2019-02-12 Thread GitBox
flinkbot commented on issue #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions URL: https://github.com/apache/flink/pull/7687#issuecomment-462791945 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-11542) Missing configuration sections since 1.5 docs

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11542: --- Labels: pull-request-available (was: ) > Missing configuration sections since 1.5 docs >

[GitHub] zentol opened a new pull request #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions

2019-02-12 Thread GitBox
zentol opened a new pull request #7687: [FLINK-11542][config][docs] Extend memory configuration descriptions URL: https://github.com/apache/flink/pull/7687 Based on #7686. ## What is the purpose of the change Re-introduces lost advanced taskmanager memory

[GitHub] flinkbot commented on issue #7686: [FLINK-11585][docs] Fix prefix matching

2019-02-12 Thread GitBox
flinkbot commented on issue #7686: [FLINK-11585][docs] Fix prefix matching URL: https://github.com/apache/flink/pull/7686#issuecomment-462790707 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[jira] [Updated] (FLINK-11585) Prefix matching in ConfigDocsGenerator can result in wrong assignments

2019-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11585: --- Labels: pull-request-available (was: ) > Prefix matching in ConfigDocsGenerator can result

  1   2   >