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

HuangZhenQiu commented on issue #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#issuecomment-493729416 @tillrohrmann As this branch haven't been synced with Master for a while, I will create another

[jira] [Created] (FLINK-12551) elasticsearch6 connector print log error

xiongkun created FLINK-12551: Summary: elasticsearch6 connector print log error Key: FLINK-12551 URL: https://issues.apache.org/jira/browse/FLINK-12551 Project: Flink Issue Type: Bug

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

HuangZhenQiu commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r285362730 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8477: [FLINK-12241][hive] Support function related operations in GenericHiveMetastoreCatalog

bowenli86 commented on issue #8477: [FLINK-12241][hive] Support function related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8477#issuecomment-493695815 cc @xuefuz @lirui-apache This

[jira] [Updated] (FLINK-12550) hostnames with a dot never receive local input splits

[ https://issues.apache.org/jira/browse/FLINK-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12550: --- Labels: pull-request-available (was: ) > hostnames with a dot never receive local input

[GitHub] [flink] flinkbot commented on issue #8478: [FLINK-12550] fix local input split assignment for hostnames containing a dot (".")

flinkbot commented on issue #8478: [FLINK-12550] fix local input split assignment for hostnames containing a dot (".") URL: https://github.com/apache/flink/pull/8478#issuecomment-493695413 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] felse opened a new pull request #8478: [FLINK-12550] fix local input split assignment for hostnames containing a dot (".")

felse opened a new pull request #8478: [FLINK-12550] fix local input split assignment for hostnames containing a dot (".") URL: https://github.com/apache/flink/pull/8478 ## What is the purpose of the change LocatableInputSplitAssigner does not assign input splits locally if the

[jira] [Created] (FLINK-12550) hostnames with a dot never receive local input splits

Felix seibert created FLINK-12550: - Summary: hostnames with a dot never receive local input splits Key: FLINK-12550 URL: https://issues.apache.org/jira/browse/FLINK-12550 Project: Flink

[jira] [Commented] (FLINK-7883) Make savepoints atomic with respect to state and side effects

[ https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843189#comment-16843189 ] Vahid Hashemian commented on FLINK-7883: We are also very interested in this enhancement that

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

azagrebin 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-493680887 @kisimple could you rebase on latest master and squash empty commits? it seems there has

[GitHub] [flink] azagrebin commented on issue #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on issue #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#issuecomment-493680455 Thanks for the reviews @zentol @zhijiangW , I addressed the comments

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285343015 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285342718 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285342471 ## File path:

[GitHub] [flink] mr-cloud commented on issue #8464: [hotfix] fix typos.

mr-cloud commented on issue #8464: [hotfix] fix typos. URL: https://github.com/apache/flink/pull/8464#issuecomment-493675884 This is my first trying to contribute. I'd like to know why my PR has not been accepted yet, and how 's it going now? What else do I need to do to finish this task

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285341747 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285341674 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285341508 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285341508 ## File path:

[jira] [Closed] (FLINK-12519) Introduce planner rules about semi/anti join

[ https://issues.apache.org/jira/browse/FLINK-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12519. -- Resolution: Implemented Fix Version/s: 1.9.0 merged in 1.9.0:

[GitHub] [flink] KurtYoung merged pull request #8450: [FLINK-12519] [table-planner-blink] Introduce planner rules about semi/anti join

KurtYoung merged pull request #8450: [FLINK-12519] [table-planner-blink] Introduce planner rules about semi/anti join URL: https://github.com/apache/flink/pull/8450 This is an automated message from the Apache Git Service.

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285340688 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285340619 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285340366 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

azagrebin commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r285339824 ## File path:

[jira] [Closed] (FLINK-12424) Supports dag (multiple-sinks query) optimization

[ https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12424. -- Resolution: Implemented Fix Version/s: 1.9.0 merge in 1.9.0:

[GitHub] [flink] KurtYoung merged pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

KurtYoung merged pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-6263) Leader error in Kafka producer on leader change (broker restart/failrue)

[ https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843135#comment-16843135 ] Truong Duc Kien commented on FLINK-6263: I think this is a duplicate of

[GitHub] [flink] lamber-ken commented on issue #8265: [FLINK-12302][runtime] Fixed the wrong finalStatus of yarn application when application finished

lamber-ken commented on issue #8265: [FLINK-12302][runtime] Fixed the wrong finalStatus of yarn application when application finished URL: https://github.com/apache/flink/pull/8265#issuecomment-493664892 hi, I given detail steps to reproduc this problem @GJL,