[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

2019-02-15 Thread GitBox
alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r257450797 ## File path:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

2019-02-15 Thread GitBox
alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r257450797 ## File path:

[jira] [Comment Edited] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

2019-02-15 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770027#comment-16770027 ] shengjk1 edited comment on FLINK-11608 at 2/16/19 6:58 AM: --- hi [~jark]   I

[jira] [Commented] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

2019-02-15 Thread shengjk1 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770027#comment-16770027 ] shengjk1 commented on FLINK-11608: -- hi [~jark]   I want to know when and where I can create a PR for

[jira] [Updated] (FLINK-10718) Use IO executor in RpcService for message serialization

2019-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10718: --- Labels: pull-request-available (was: ) > Use IO executor in RpcService for message

[GitHub] flinkbot commented on issue #7718: [FLINK-10718] Use IO executor in RpcService for message serialization

2019-02-15 Thread GitBox
flinkbot commented on issue #7718: [FLINK-10718] Use IO executor in RpcService for message serialization URL: https://github.com/apache/flink/pull/7718#issuecomment-464293892 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] yanghua opened a new pull request #7718: [FLINK-10718] Use IO executor in RpcService for message serialization

2019-02-15 Thread GitBox
yanghua opened a new pull request #7718: [FLINK-10718] Use IO executor in RpcService for message serialization URL: https://github.com/apache/flink/pull/7718 ## What is the purpose of the change *This pull request introduced an IO Executor in RpcServer for message serialization*

[jira] [Assigned] (FLINK-11634) Translate "State Backends" page into Chinese

2019-02-15 Thread hanfei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hanfei reassigned FLINK-11634: -- Assignee: hanfei (was: Congxian Qiu) > Translate "State Backends" page into Chinese >

[jira] [Created] (FLINK-11638) Translate "Savepoints" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11638: Summary: Translate "Savepoints" page into Chinese Key: FLINK-11638 URL: https://issues.apache.org/jira/browse/FLINK-11638 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

2019-02-15 Thread xulinjie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1677#comment-1677 ] xulinjie commented on FLINK-11561: -- Hi Congxian Qiu,Whether there is time for development, and whether

[jira] [Assigned] (FLINK-11567) Translate "How to Review a Pull Request" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11567: Assignee: xulinjie (was: Congxian Qiu) > Translate "How to Review a Pull Request" page

[jira] [Created] (FLINK-11637) Translate "Checkpoints" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11637: Summary: Translate "Checkpoints" page into Chinese Key: FLINK-11637 URL: https://issues.apache.org/jira/browse/FLINK-11637 Project: Flink Issue Type:

[jira] [Created] (FLINK-11636) Translate "State Schema Evolution" into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11636: Summary: Translate "State Schema Evolution" into Chinese Key: FLINK-11636 URL: https://issues.apache.org/jira/browse/FLINK-11636 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11529) Support Chinese Documents for Apache Flink

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11529: Assignee: Jark Wu (was: Congxian Qiu) > Support Chinese Documents for Apache Flink >

[jira] [Created] (FLINK-11635) Translate "Checkpointing" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11635: Summary: Translate "Checkpointing" page into Chinese Key: FLINK-11635 URL: https://issues.apache.org/jira/browse/FLINK-11635 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11529) Support Chinese Documents for Apache Flink

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11529: Assignee: Congxian Qiu (was: Jark Wu) > Support Chinese Documents for Apache Flink >

[jira] [Created] (FLINK-11634) Translate "State Backends" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11634: Summary: Translate "State Backends" page into Chinese Key: FLINK-11634 URL: https://issues.apache.org/jira/browse/FLINK-11634 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11633) Translate "Working with State" into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-11633: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-11529 > Translate "Working with

[jira] [Created] (FLINK-11633) Translate "Working with State" into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11633: Summary: Translate "Working with State" into Chinese Key: FLINK-11633 URL: https://issues.apache.org/jira/browse/FLINK-11633 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-11554) Translate the "Community & Project Info" page into Chinese

2019-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11554: --- Labels: pull-request-available (was: ) > Translate the "Community & Project Info" page

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

2019-02-15 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_r257442067 ## File path:

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

2019-02-15 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_r257442067 ## File path:

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

2019-02-15 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_r257441163 ## File path:

[jira] [Assigned] (FLINK-10319) Too many requestPartitionState would crash JM

2019-02-15 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-10319: Assignee: (was: TisonKun) > Too many requestPartitionState would crash JM >

[jira] [Closed] (FLINK-10319) Too many requestPartitionState would crash JM

2019-02-15 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-10319. Resolution: Won't Do Assignee: TisonKun Release Note: Cannot reach a consensus > Too many

[GitHub] TisonKun closed pull request #6680: [FLINK-10319] [runtime] Many requestPartitionState messages overwhelm JM

2019-02-15 Thread GitBox
TisonKun closed pull request #6680: [FLINK-10319] [runtime] Many requestPartitionState messages overwhelm JM URL: https://github.com/apache/flink/pull/6680 This is an automated message from the Apache Git Service. To

[GitHub] TisonKun closed pull request #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd…

2019-02-15 Thread GitBox
TisonKun closed pull request #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd… URL: https://github.com/apache/flink/pull/7184 This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-11616) Flink official document has an error

2019-02-15 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769921#comment-16769921 ] vinoyang commented on FLINK-11616: -- Hi [~linjie] The HTML page of flink official website is built from

[jira] [Commented] (FLINK-11454) Support MergedStream operation

2019-02-15 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769779#comment-16769779 ] Rong Rong commented on FLINK-11454: --- Initial thought was to use the

[GitHub] ealtamir commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2019-02-15 Thread GitBox
ealtamir commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#issuecomment-464223539 Hi, when could we expect to see this commit in a stable release?

[GitHub] flinkbot edited a comment on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer

2019-02-15 Thread GitBox
flinkbot edited a comment on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer URL: https://github.com/apache/flink/pull/7655#issuecomment-461015963 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-11454) Support MergedStream operation

2019-02-15 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11454: -- Description: Following SlicedStream, the mergedStream operator merges results from sliced stream and

[jira] [Updated] (FLINK-11454) Support MergedStream operation

2019-02-15 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11454: -- Description: {{Following SlicedStream, the mergedStream operator merges results from sliced stream

[jira] [Created] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

2019-02-15 Thread Alex (JIRA)
Alex created FLINK-11632: Summary: Make TaskManager automatic bind address picking more explicit (by default) and more configurable Key: FLINK-11632 URL: https://issues.apache.org/jira/browse/FLINK-11632

[GitHub] azagrebin commented on a change in pull request #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition

2019-02-15 Thread GitBox
azagrebin commented on a change in pull request #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition URL: https://github.com/apache/flink/pull/7549#discussion_r257322977 ## File path:

[GitHub] azagrebin commented on a change in pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface

2019-02-15 Thread GitBox
azagrebin commented on a change in pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface URL: https://github.com/apache/flink/pull/7704#discussion_r257317570 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257260840 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257262311 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257306932 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257291059 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257240524 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257317087 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257275386 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257290665 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257245495 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257239909 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257244537 ## File path:

[GitHub] azagrebin commented on a change in pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface

2019-02-15 Thread GitBox
azagrebin commented on a change in pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface URL: https://github.com/apache/flink/pull/7704#discussion_r257261776 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257290245 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257305966 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257260881 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257314300 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257266148 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257281559 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257259780 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257286355 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257244431 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257239628 ## File path: flink-connectors/flink-connector-pubsub/pom.xml

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257250885 ## File path:

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257238629 ## File path: docs/dev/connectors/pubsub.md ## @@

[GitHub] rmetzger commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-464120309 One thing to consider in the long run: Apache Beam / Google Cloud Dataflow's PubSub

[GitHub] zhijiangW commented on issue #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode

2019-02-15 Thread GitBox
zhijiangW commented on issue #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-464116492 @pnowojski , both `RecordWriter` and `BroadcastRecordWriter` are involved in broadcast

[GitHub] flinkbot commented on issue #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

2019-02-15 Thread GitBox
flinkbot commented on issue #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717#issuecomment-464113787 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

2019-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11533: --- Labels: pull-request-available (was: ) > Retrieve job class name from JAR manifest in

[GitHub] uce opened a new pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

2019-02-15 Thread GitBox
uce opened a new pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717 ## What is the purpose of the change This PR allows users to point the `StandaloneJobClusterEntryPoint` to a JAR file instead

[GitHub] tillrohrmann commented on a change in pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase

2019-02-15 Thread GitBox
tillrohrmann commented on a change in pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase URL: https://github.com/apache/flink/pull/7709#discussion_r257294117 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase

2019-02-15 Thread GitBox
tillrohrmann commented on a change in pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase URL: https://github.com/apache/flink/pull/7709#discussion_r257295700 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase

2019-02-15 Thread GitBox
tillrohrmann commented on a change in pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase URL: https://github.com/apache/flink/pull/7709#discussion_r257294680 ## File path:

[jira] [Created] (FLINK-11631) TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis

2019-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11631: - Summary: TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis Key: FLINK-11631 URL: https://issues.apache.org/jira/browse/FLINK-11631

[GitHub] tillrohrmann opened a new pull request #7716: [FLINK-11629][rpc] Stop AkkaRpcActor immediately after onStop future has been completed

2019-02-15 Thread GitBox
tillrohrmann opened a new pull request #7716: [FLINK-11629][rpc] Stop AkkaRpcActor immediately after onStop future has been completed URL: https://github.com/apache/flink/pull/7716 ## What is the purpose of the change The AkkaRcpActor should stop itself immediately after the onStop

[jira] [Updated] (FLINK-11629) Stop AkkaRpcActor immediately after onStop has finished

2019-02-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11629: --- Labels: pull-request-available (was: ) > Stop AkkaRpcActor immediately after onStop has

[jira] [Created] (FLINK-11630) TaskExecutor does not wait for Task termination when terminating itself

2019-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11630: - Summary: TaskExecutor does not wait for Task termination when terminating itself Key: FLINK-11630 URL: https://issues.apache.org/jira/browse/FLINK-11630 Project:

[GitHub] flinkbot commented on issue #7716: [FLINK-11629][rpc] Stop AkkaRpcActor immediately after onStop future has been completed

2019-02-15 Thread GitBox
flinkbot commented on issue #7716: [FLINK-11629][rpc] Stop AkkaRpcActor immediately after onStop future has been completed URL: https://github.com/apache/flink/pull/7716#issuecomment-464097384 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Created] (FLINK-11629) Stop AkkaRpcActor immediately after onStop has finished

2019-02-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11629: - Summary: Stop AkkaRpcActor immediately after onStop has finished Key: FLINK-11629 URL: https://issues.apache.org/jira/browse/FLINK-11629 Project: Flink

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257217609 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257263753 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257260190 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257217842 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257262581 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257262866 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257265651 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

2019-02-15 Thread GitBox
StefanRRichter commented on a change in pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#discussion_r257268389 ## File path:

[GitHub] tzulitai edited a comment on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer

2019-02-15 Thread GitBox
tzulitai edited a comment on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer URL: https://github.com/apache/flink/pull/7655#issuecomment-464073707 LGTM  (I'm assuming that this has also been tested with Scala 2.12) Please also remember to update the

[GitHub] zentol commented on issue #7715: Iluvex dev branch

2019-02-15 Thread GitBox
zentol commented on issue #7715: Iluvex dev branch URL: https://github.com/apache/flink/pull/7715#issuecomment-464063857 Please update the PR title. This is an automated message from the Apache Git Service. To respond to the

[GitHub] tzulitai edited a comment on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer

2019-02-15 Thread GitBox
tzulitai edited a comment on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer URL: https://github.com/apache/flink/pull/7655#issuecomment-464073707 LGTM  (I'm assuming that this has also been tested with Scala 2.12) Please also remember to update the

[GitHub] tzulitai commented on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer

2019-02-15 Thread GitBox
tzulitai commented on issue #7655: [FLINK-11539] Add TypeSerializerSnapshot for TraversableSerializer URL: https://github.com/apache/flink/pull/7655#issuecomment-464073707 LGTM  (I'm assuming that this has also been tested with Scala 2.12)

[GitHub] rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r256496252 ## File path:

[GitHub] flinkbot commented on issue #7715: Iluvex dev branch

2019-02-15 Thread GitBox
flinkbot commented on issue #7715: Iluvex dev branch URL: https://github.com/apache/flink/pull/7715#issuecomment-464062188 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 use this comment to

[GitHub] luvex opened a new pull request #7715: Iluvex dev branch

2019-02-15 Thread GitBox
luvex opened a new pull request #7715: Iluvex dev branch URL: https://github.com/apache/flink/pull/7715 ## What is the purpose of the change This pull request completes the Chinese translation of batch examples page from official document. ## Brief change log

[jira] [Resolved] (FLINK-11596) Check & port ResourceManagerTest to new code base

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

[GitHub] asfgit closed pull request #7698: [FLINK-11596][test] Remove legacy ResourceManagerTest

2019-02-15 Thread GitBox
asfgit closed pull request #7698: [FLINK-11596][test] Remove legacy ResourceManagerTest URL: https://github.com/apache/flink/pull/7698 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] rmetzger commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
rmetzger commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-464054883 Great! I will then do the following: 1. I do a pass over the code, commenting on

[jira] [Commented] (FLINK-11609) Translate the "Running Flink on Windows" page into Chinese

2019-02-15 Thread xulinjie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769320#comment-16769320 ] xulinjie commented on FLINK-11609: -- Hi,Jark Wu,thank you for your reply. I will wait for FLINK-11530 to

[GitHub] wuchong commented on issue #7714: [FLINK-11609] [docs] Translate the "Running Flink on Windows" page in…

2019-02-15 Thread GitBox
wuchong commented on issue #7714: [FLINK-11609] [docs] Translate the "Running Flink on Windows" page in… URL: https://github.com/apache/flink/pull/7714#issuecomment-464049630 Hi @ash-ali , thank you for your effort. But I'm sorry that we should hold this for a while. Because we

[jira] [Updated] (FLINK-11609) Translate the "Running Flink on Windows" page into Chinese

2019-02-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11609: Description: The page url is

[jira] [Commented] (FLINK-11609) Translate the "Running Flink on Windows" page into Chinese

2019-02-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769300#comment-16769300 ] Jark Wu commented on FLINK-11609: - Hi [~linjie], thank you for your effort. But I'm sorry we should hold

[jira] [Comment Edited] (FLINK-11609) Translate the "Running Flink on Windows" page into Chinese

2019-02-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769300#comment-16769300 ] Jark Wu edited comment on FLINK-11609 at 2/15/19 1:15 PM: -- Hi [~linjie], thank

[GitHub] Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-02-15 Thread GitBox
Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-464045292 Hi @rmetzger We are still eager to get the code in the flink repository, especially

[jira] [Closed] (FLINK-11424) DatadogHttpReporter throws ConcurrentModificationException if gauge throws exception or returns a non-numeric value

2019-02-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11424. Resolution: Fixed > DatadogHttpReporter throws ConcurrentModificationException if gauge

[jira] [Closed] (FLINK-11424) org.apache.flink.metrics.datadog.DatadogHttpReporter#report remove will throw exception

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

  1   2   >