[GitHub] sunjincheng121 commented on a change in pull request #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes.

2019-02-19 Thread GitBox
sunjincheng121 commented on a change in pull request #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes. URL: https://github.com/apache/flink/pull/7664#discussion_r258366533 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/expr

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

2019-02-19 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772725#comment-16772725 ] Hequn Cheng commented on FLINK-11067: - Hi, [~twalthr] Thank you for your reply. I li

[GitHub] tzulitai commented on issue #7732: [FLINK-9803] Drop canEqual() from TypeSerializer

2019-02-19 Thread GitBox
tzulitai commented on issue #7732: [FLINK-9803] Drop canEqual() from TypeSerializer URL: https://github.com/apache/flink/pull/7732#issuecomment-465453420 LGTM đź‘Ť This is an automated message from the Apache Git Service. To re

[GitHub] yanghua commented on issue #7375: [FLINK-11175][docs][table] Fix the sample code describing the Processing tim…

2019-02-19 Thread GitBox
yanghua commented on issue #7375: [FLINK-11175][docs][table] Fix the sample code describing the Processing tim… URL: https://github.com/apache/flink/pull/7375#issuecomment-465451717 cc @fhueske This is an automated message f

[jira] [Updated] (FLINK-11655) Remove `Serializable` interface from `CallAsync`

2019-02-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11655: --- Labels: pull-request-available (was: ) > Remove `Serializable` interface from `CallAsync` >

[GitHub] flinkbot commented on issue #7760: [FLINK-11655][core] Remove Serializable from CallAsync

2019-02-19 Thread GitBox
flinkbot commented on issue #7760: [FLINK-11655][core] Remove Serializable from CallAsync URL: https://github.com/apache/flink/pull/7760#issuecomment-465451394 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] libenchao opened a new pull request #7760: [FLINK-11655][core] Remove Serializable from CallAsync

2019-02-19 Thread GitBox
libenchao opened a new pull request #7760: [FLINK-11655][core] Remove Serializable from CallAsync URL: https://github.com/apache/flink/pull/7760 ## What is the purpose of the change *This pull request removes `Serializable` interface from `CallAsync`, since both `CallAsync`

[jira] [Commented] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

2019-02-19 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772694#comment-16772694 ] Yun Tang commented on FLINK-11662: -- [~framst] we already have some discussion about thi

[GitHub] tzulitai closed pull request #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs

2019-02-19 Thread GitBox
tzulitai closed pull request #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs URL: https://github.com/apache/flink/pull/7759 This is an automated message fr

[GitHub] tzulitai opened a new pull request #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs

2019-02-19 Thread GitBox
tzulitai opened a new pull request #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs URL: https://github.com/apache/flink/pull/7759 ## What is the purpose of the change This PR mainly solves FLINK-11485 (migrate `Pojo

[GitHub] zhijiangW edited a comment on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition

2019-02-19 Thread GitBox
zhijiangW edited a comment on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition URL: https://github.com/apache/flink/pull/7549#issuecomment-465448282 @azagrebin , I renamed the classes of `NetworkResultPartition` and `ResultPartition` as we c

[GitHub] zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition

2019-02-19 Thread GitBox
zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition URL: https://github.com/apache/flink/pull/7549#issuecomment-465448282 @azagrebin , I renamed the classes of `NetworkResultPartition` and `ResultPartition` as we confirme

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-02-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772679#comment-16772679 ] Kurt Young commented on FLINK-11421: [~fan_li_ya] I'm aware of this information. But

[jira] [Commented] (FLINK-10897) Support POJO state schema evolution

2019-02-19 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772678#comment-16772678 ] Tzu-Li (Gordon) Tai commented on FLINK-10897: - Hi [~kisimple], I'm sorry but

[GitHub] yanghua commented on issue #7750: [FLINK-11639] Provide readSequenceFile for Hadoop new API

2019-02-19 Thread GitBox
yanghua commented on issue #7750: [FLINK-11639] Provide readSequenceFile for Hadoop new API URL: https://github.com/apache/flink/pull/7750#issuecomment-465446384 @fhueske Can you review this PR? Thanks. This is an automated

[GitHub] flinkbot edited a comment on issue #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs

2019-02-19 Thread GitBox
flinkbot edited a comment on issue #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs URL: https://github.com/apache/flink/pull/7759#issuecomment-465441144 Thanks a lot for your contribution to the Apache Flink project. I'm t

[jira] [Updated] (FLINK-11485) Migrate PojoSerializer to use new serialization compatibility abstractions

2019-02-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11485: --- Labels: pull-request-available (was: ) > Migrate PojoSerializer to use new serialization co

[GitHub] tzulitai opened a new pull request #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs

2019-02-19 Thread GitBox
tzulitai opened a new pull request #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs URL: https://github.com/apache/flink/pull/7759 ## What is the purpose of the change This PR mainly solves FLINK-11485 (migrate `Pojo

[GitHub] flinkbot commented on issue #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs

2019-02-19 Thread GitBox
flinkbot commented on issue #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs URL: https://github.com/apache/flink/pull/7759#issuecomment-465441144 Thanks a lot for your contribution to the Apache Flink project. I'm the @fl

[GitHub] tzulitai commented on issue #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs

2019-02-19 Thread GitBox
tzulitai commented on issue #7759: [FLINK-11485][FLINK-10897] POJO state schema evolution / migrate PojoSerializer to use new compatibility APIs URL: https://github.com/apache/flink/pull/7759#issuecomment-465441244 @flinkbot attention @igalshilman @aljoscha

[jira] [Commented] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

2019-02-19 Thread madong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772651#comment-16772651 ] madong commented on FLINK-11662: [~klion26] thanks for the infomation. I have read the d

[jira] [Updated] (FLINK-11666) Add Amazon Kinesis Data Analytics to poweredby.zh.md for Chinese

2019-02-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11666: --- Labels: pull-request-available (was: ) > Add Amazon Kinesis Data Analytics to poweredby.zh.

[jira] [Commented] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772620#comment-16772620 ] TisonKun commented on FLINK-11665: -- If there a "Released locks" before "Removed job gra

[jira] [Commented] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread Bashar Abdul Jawad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772603#comment-16772603 ] Bashar Abdul Jawad commented on FLINK-11665: [~Tison] I do, this happens rig

[jira] [Comment Edited] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772600#comment-16772600 ] TisonKun edited comment on FLINK-11665 at 2/20/19 4:02 AM: --- Do

[jira] [Commented] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772600#comment-16772600 ] TisonKun commented on FLINK-11665: -- Do you see a log {{Released locks of job graph 1d24

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

2019-02-19 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772585#comment-16772585 ] Liya Fan commented on FLINK-11421: -- Hi Kurt Young, thank you so much for your attention

[jira] [Assigned] (FLINK-11666) Add Amazon Kinesis Data Analytics to poweredby.zh.md for Chinese

2019-02-19 Thread Forward Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Forward Xu reassigned FLINK-11666: -- Assignee: Forward Xu > Add Amazon Kinesis Data Analytics to poweredby.zh.md for Chinese > ---

[jira] [Updated] (FLINK-11666) Add Amazon Kinesis Data Analytics to poweredby.zh.md for Chinese

2019-02-19 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-11666: Summary: Add Amazon Kinesis Data Analytics to poweredby.zh.md for Chinese (was: Add Amazon Kinesis Data A

[jira] [Created] (FLINK-11666) Add Amazon Kinesis Data Analytics to poweredby.md for Chinese

2019-02-19 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11666: --- Summary: Add Amazon Kinesis Data Analytics to poweredby.md for Chinese Key: FLINK-11666 URL: https://issues.apache.org/jira/browse/FLINK-11666 Project: Flink Issue Ty

[jira] [Updated] (FLINK-11655) Remove `Serializable` interface from `CallAsync`

2019-02-19 Thread Benchao Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-11655: --- Description:   `RunAsync` and `CallAsync` are akka messages which are used only locally, so we don

[jira] [Commented] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

2019-02-19 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772545#comment-16772545 ] Congxian Qiu commented on FLINK-11662: -- Hi [~framst] , I think there are some other

[jira] [Commented] (FLINK-11655) runnable field should be transient in RunAsync from RPC messages

2019-02-19 Thread Benchao Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772548#comment-16772548 ] Benchao Li commented on FLINK-11655: Thank you for your advise [~till.rohrmann] > r

[GitHub] klion26 commented on issue #7758: blink first commit

2019-02-19 Thread GitBox
klion26 commented on issue #7758: blink first commit URL: https://github.com/apache/flink/pull/7758#issuecomment-465393296 hi, @lionxu I think this pr is not needed, could you please close it. This is an automated message from

[GitHub] lionxu opened a new pull request #7758: blink first commit

2019-02-19 Thread GitBox
lionxu opened a new pull request #7758: blink first commit URL: https://github.com/apache/flink/pull/7758 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-tran

[GitHub] flinkbot commented on issue #7758: blink first commit

2019-02-19 Thread GitBox
flinkbot commented on issue #7758: blink first commit URL: https://github.com/apache/flink/pull/7758#issuecomment-465390486 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 tra

[jira] [Assigned] (FLINK-10902) Jobmanager in HA setup communicates the ip address instead of hostnames

2019-02-19 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10902: Assignee: vinoyang > Jobmanager in HA setup communicates the ip address instead of hostnames > --

[jira] [Updated] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread Bashar Abdul Jawad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bashar Abdul Jawad updated FLINK-11665: --- Description: We recently have seen the following issue with Flink 1.5.5: Given Flin

[jira] [Updated] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread Bashar Abdul Jawad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bashar Abdul Jawad updated FLINK-11665: --- Description: We recently have seen the following issue with Flink 1.5.5: Given Flin

[jira] [Updated] (FLINK-11665) Flink fails to remove a JobGraph from ZK even though it reports it did

2019-02-19 Thread Bashar Abdul Jawad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bashar Abdul Jawad updated FLINK-11665: --- Summary: Flink fails to remove a JobGraph from ZK even though it reports it did (wa

[jira] [Updated] (FLINK-11665) Flink fails to remove JobGraph from ZK even though it reports it did

2019-02-19 Thread Bashar Abdul Jawad (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bashar Abdul Jawad updated FLINK-11665: --- Summary: Flink fails to remove JobGraph from ZK even though it reports it did (was:

[jira] [Created] (FLINK-11665) Flink failing to remove a JobGraph from ZK even though it reports it did

2019-02-19 Thread Bashar Abdul Jawad (JIRA)
Bashar Abdul Jawad created FLINK-11665: -- Summary: Flink failing to remove a JobGraph from ZK even though it reports it did Key: FLINK-11665 URL: https://issues.apache.org/jira/browse/FLINK-11665

[jira] [Commented] (FLINK-11552) Akka association issues in 1.7.x

2019-02-19 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772273#comment-16772273 ] William Cummings commented on FLINK-11552: -- Did some more testing, everything l

[GitHub] zentol closed pull request #7727: blink first commit

2019-02-19 Thread GitBox
zentol closed pull request #7727: blink first commit URL: https://github.com/apache/flink/pull/7727 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL abo

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

2019-02-19 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_r258189783 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

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

2019-02-19 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_r258189464 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

[jira] [Commented] (FLINK-11552) Akka association issues in 1.7.x

2019-02-19 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772245#comment-16772245 ] William Cummings commented on FLINK-11552: -- After reading through those two tic

[GitHub] flinkbot commented on issue #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

2019-02-19 Thread GitBox
flinkbot commented on issue #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#issuecomment-465249955 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

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

2019-02-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11630: --- Labels: pull-request-available (was: ) > TaskExecutor does not wait for Task termination wh

[GitHub] kisimple opened a new pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

2019-02-19 Thread GitBox
kisimple opened a new pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757 ## What is the purpose of the change Currently, the `TaskExecutor` does not properly wait for the termi

[jira] [Commented] (FLINK-11552) Akka association issues in 1.7.x

2019-02-19 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772172#comment-16772172 ] William Cummings commented on FLINK-11552: -- This is a "standalone" cluster on t

[jira] [Updated] (FLINK-11458) Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

2019-02-19 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: --- Fix Version/s: (was: 1.8.0) > Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34) > -

[jira] [Updated] (FLINK-11458) Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

2019-02-19 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: --- Affects Version/s: (was: 1.8.0) > Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34) > -

[jira] [Updated] (FLINK-11664) Pass leadership information by LeaderAddressAndId

2019-02-19 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11664: - Description: We already have {{LeaderAddressAndId}} class, and the existing {{LeaderRetrievalListener#n

[jira] [Updated] (FLINK-11664) Pass leadership information by LeaderAddressAndId

2019-02-19 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11664: - Description: We already have {{LeaderAddressAndId}} class, and the existing {{LeaderRetrievalListener#n

[jira] [Created] (FLINK-11664) Pass leadership information by LeaderAddressAndId

2019-02-19 Thread TisonKun (JIRA)
TisonKun created FLINK-11664: Summary: Pass leadership information by LeaderAddressAndId Key: FLINK-11664 URL: https://issues.apache.org/jira/browse/FLINK-11664 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-11552) Akka association issues in 1.7.x

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772136#comment-16772136 ] Till Rohrmann commented on FLINK-11552: --- Hi [~wcummings], are you running Flink on

[jira] [Updated] (FLINK-10902) Jobmanager in HA setup communicates the ip address instead of hostnames

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10902: -- Component/s: REST > Jobmanager in HA setup communicates the ip address instead of hostnames >

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

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11632: - Assignee: Alex (was: Till Rohrmann) > Make TaskManager automatic bind address picking

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

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11632: - Assignee: Till Rohrmann > Make TaskManager automatic bind address picking more explicit

[jira] [Assigned] (FLINK-11541) Heavy deployment E2E test failed on Travis

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11541: - Assignee: Stefan Richter > Heavy deployment E2E test failed on Travis > ---

[GitHub] TisonKun commented on issue #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd…

2019-02-19 Thread GitBox
TisonKun commented on issue #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd… URL: https://github.com/apache/flink/pull/7184#issuecomment-465221202 Alright. I would file a JIRA in soon. This is an

[jira] [Updated] (FLINK-11375) Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11375: -- Priority: Critical (was: Major) > Concurrent modification to slot pool due to SlotSharingMana

[jira] [Updated] (FLINK-10941) Slots prematurely released which still contain unconsumed data

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10941: -- Component/s: Distributed Coordination > Slots prematurely released which still contain unconsu

[GitHub] tillrohrmann commented on issue #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

2019-02-19 Thread GitBox
tillrohrmann commented on issue #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#issuecomment-465220293 Thanks for the update @HuangZhenQiu. I'll give it another pass now. --

[GitHub] tillrohrmann commented on issue #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd…

2019-02-19 Thread GitBox
tillrohrmann commented on issue #7184: [hotfix] Remove unused class OneTimeLeaderListenerFuture and LeaderAd… URL: https://github.com/apache/flink/pull/7184#issuecomment-465219862 Sorry for my late response @TisonKun. I think it would make sense to group the leader address and the id toget

[jira] [Commented] (FLINK-11655) runnable field should be transient in RunAsync from RPC messages

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772108#comment-16772108 ] Till Rohrmann commented on FLINK-11655: --- Good catch [~libenchao]. I think we shoul

[jira] [Updated] (FLINK-11375) Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11375: -- Component/s: Distributed Coordination > Concurrent modification to slot pool due to SlotSharin

[jira] [Updated] (FLINK-11655) runnable field should be transient in RunAsync from RPC messages

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11655: -- Component/s: (was: Core) Distributed Coordination > runnable field should

[jira] [Updated] (FLINK-11655) runnable field should be transient in RunAsync from RPC messages

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11655: -- Priority: Minor (was: Critical) > runnable field should be transient in RunAsync from RPC mes

[jira] [Resolved] (FLINK-11601) Remove legacy JobManagerGateway

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11601. --- Resolution: Fixed Fixed via 394afeabf5f7779d6621ccf529d7c3df6cc0b09d > Remove legacy JobMan

[jira] [Resolved] (FLINK-11600) Remove legacy JobListeningContext

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11600. --- Resolution: Fixed Fixed via e4a50403d46d3bd0b4b708651757cc50786eef75 > Remove legacy JobLis

[GitHub] flinkbot edited a comment on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
flinkbot edited a comment on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465194674 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465214296 Changes look good to me đź‘Ť once Travis is green. --

[GitHub] StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465214011 @flinkbot approve all This is

[jira] [Resolved] (FLINK-11598) Remove legacy JobSubmissionClientActor

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11598. --- Resolution: Fixed Fixed via 99667f1c5cb0127d5bc7c90b7e6fcf8595d03e76 > Remove legacy JobSub

[jira] [Resolved] (FLINK-11599) Remove legacy JobClientActor

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11599. --- Resolution: Fixed Fixed via 8e0546eaf1c449bd3b131299005856d6e98c1310 > Remove legacy JobCli

[GitHub] asfgit closed pull request #7741: [FLINK-11601] Remove legacy JobManagerGateway

2019-02-19 Thread GitBox
asfgit closed pull request #7741: [FLINK-11601] Remove legacy JobManagerGateway URL: https://github.com/apache/flink/pull/7741 This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] asfgit closed pull request #7739: [FLINK-11600] Remove legacy JobListeningContext

2019-02-19 Thread GitBox
asfgit closed pull request #7739: [FLINK-11600] Remove legacy JobListeningContext URL: https://github.com/apache/flink/pull/7739 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] asfgit closed pull request #7743: [FLINK-11652] Remove legacy JobClient

2019-02-19 Thread GitBox
asfgit closed pull request #7743: [FLINK-11652] Remove legacy JobClient URL: https://github.com/apache/flink/pull/7743 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub

[GitHub] asfgit closed pull request #7738: [FLINK-11598] Remove legacy JobSubmissionClientActor

2019-02-19 Thread GitBox
asfgit closed pull request #7738: [FLINK-11598] Remove legacy JobSubmissionClientActor URL: https://github.com/apache/flink/pull/7738 This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] asfgit closed pull request #7740: [FLINK-11599] Remove legacy JobClientActor

2019-02-19 Thread GitBox
asfgit closed pull request #7740: [FLINK-11599] Remove legacy JobClientActor URL: https://github.com/apache/flink/pull/7740 This is an automated message from the Apache Git Service. To respond to the message, please log on Gi

[jira] [Resolved] (FLINK-11652) Remove legacy JobClient

2019-02-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11652. --- Resolution: Fixed Fixed via d30957a419ab276f2c5937d8ab2d8887b176704c > Remove legacy JobCli

[GitHub] flinkbot commented on issue #7756: [FLINK-11357] Make ExecutionGraph#suspend terminate ExecutionGraph atomically

2019-02-19 Thread GitBox
flinkbot commented on issue #7756: [FLINK-11357] Make ExecutionGraph#suspend terminate ExecutionGraph atomically URL: https://github.com/apache/flink/pull/7756#issuecomment-465204812 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] tillrohrmann opened a new pull request #7756: [FLINK-11357] Make ExecutionGraph#suspend terminate ExecutionGraph atomically

2019-02-19 Thread GitBox
tillrohrmann opened a new pull request #7756: [FLINK-11357] Make ExecutionGraph#suspend terminate ExecutionGraph atomically URL: https://github.com/apache/flink/pull/7756 ## What is the purpose of the change This commit makes the suspend call transition the ExecutionGraph atomically

[GitHub] StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465198177 @flinkbot attention @StefanRRichter -

[GitHub] flinkbot edited a comment on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
flinkbot edited a comment on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465194674 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465198036 @flinkbot approve consensus T

[GitHub] StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
StefanRRichter commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465197874 @flinkbot approve description

[GitHub] flinkbot commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
flinkbot commented on issue #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755#issuecomment-465194674 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commun

[jira] [Updated] (FLINK-11663) Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11663: --- Labels: pull-request-available (was: ) > Remove control flow break point from Execution#rel

[GitHub] tillrohrmann opened a new pull request #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread GitBox
tillrohrmann opened a new pull request #7755: [FLINK-11663] Remove control flow break point from Execution#releaseAssignedResource URL: https://github.com/apache/flink/pull/7755 ## What is the purpose of the change Since LogicalSlot#releaseSlot returns a future which is always comple

[jira] [Commented] (FLINK-11552) Akka association issues in 1.7.x

2019-02-19 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772044#comment-16772044 ] William Cummings commented on FLINK-11552: -- More verbose logs around the except

[jira] [Commented] (FLINK-11320) Support user callback in Kafka sink

2019-02-19 Thread Aleksandr Salatich (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772020#comment-16772020 ] Aleksandr Salatich commented on FLINK-11320: [~allenxwang] is it actual task

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

2019-02-19 Thread GitBox
carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r258087305 ## File path: flink-state-backends/flink-stateb

[GitHub] flinkbot commented on issue #7754: [FLINK-11530] [docs] Support multiple languages for the docs framework

2019-02-19 Thread GitBox
flinkbot commented on issue #7754: [FLINK-11530] [docs] Support multiple languages for the docs framework URL: https://github.com/apache/flink/pull/7754#issuecomment-465170230 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-11530) Support multiple languages for the framework of flink docs

2019-02-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11530: --- Labels: pull-request-available (was: ) > Support multiple languages for the framework of fl

[GitHub] wuchong opened a new pull request #7754: [FLINK-11530] [docs] Support multiple languages for the docs framework

2019-02-19 Thread GitBox
wuchong opened a new pull request #7754: [FLINK-11530] [docs] Support multiple languages for the docs framework URL: https://github.com/apache/flink/pull/7754 ## What is the purpose of the change This PR integrate the `jekyll-mulitple-language` plugin for flink docs to s

[jira] [Created] (FLINK-11663) Remove control flow break point from Execution#releaseAssignedResource

2019-02-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11663: - Summary: Remove control flow break point from Execution#releaseAssignedResource Key: FLINK-11663 URL: https://issues.apache.org/jira/browse/FLINK-11663 Project: Fli

[GitHub] Myasuka commented on issue #7586: [FLINK-10912][rocksdb] Configurable RocksDBStateBackend options

2019-02-19 Thread GitBox
Myasuka commented on issue #7586: [FLINK-10912][rocksdb] Configurable RocksDBStateBackend options URL: https://github.com/apache/flink/pull/7586#issuecomment-465163197 1. I introduce `UserConfiguredOptionsFactory` because when `configure` the state backend, we cannot get the `ClassLoader`

  1   2   3   >