[GitHub] [flink] HuangZhenQiu commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration

HuangZhenQiu commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-496370553 @rmetzger @tillrohrmann I was blocked by setting up the secured MiniDFSCluster in integration tests, so took a

[GitHub] [flink] flinkbot commented on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side

flinkbot commented on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side URL: https://github.com/apache/flink/pull/8556#issuecomment-496368873 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12171) The network buffer memory size should not be checked against the heap size on the TM side

[ https://issues.apache.org/jira/browse/FLINK-12171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12171: --- Labels: pull-request-available (was: ) > The network buffer memory size should not be

[GitHub] [flink] gaoyunhaii opened a new pull request #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side

gaoyunhaii opened a new pull request #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side URL: https://github.com/apache/flink/pull/8556 ## What is the purpose of the change This pull request fixes the bug that limits the network buffer

[GitHub] [flink] leesf commented on a change in pull request #8543: [FLINK-12101] Race condition when concurrently running uploaded jars via REST

leesf commented on a change in pull request #8543: [FLINK-12101] Race condition when concurrently running uploaded jars via REST URL: https://github.com/apache/flink/pull/8543#discussion_r287931889 ## File path:

[GitHub] [flink] liyafan82 commented on issue #8511: [FLINK-12319][Library/CEP]Change the logic of releasing node from recursive to non-recursive

liyafan82 commented on issue #8511: [FLINK-12319][Library/CEP]Change the logic of releasing node from recursive to non-recursive URL: https://github.com/apache/flink/pull/8511#issuecomment-496361993 Hi @tillrohrmann , would you please take a look at this issue? I think it deserves to be

[GitHub] [flink] xuefuz commented on a change in pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file

xuefuz commented on a change in pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file URL: https://github.com/apache/flink/pull/8541#discussion_r287926431 ## File path:

[jira] [Commented] (FLINK-12171) The network buffer memory size should not be checked against the heap size on the TM side

[ https://issues.apache.org/jira/browse/FLINK-12171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849304#comment-16849304 ] Yun Gao commented on FLINK-12171: - After further analyze this problem, now I think we do not need to

[GitHub] [flink] lirui-apache commented on a change in pull request #8522: [FLINK-12572][hive]Implement TableSource and InputFormat to read Hive tables

lirui-apache commented on a change in pull request #8522: [FLINK-12572][hive]Implement TableSource and InputFormat to read Hive tables URL: https://github.com/apache/flink/pull/8522#discussion_r287919214 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file

xuefuz commented on a change in pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file URL: https://github.com/apache/flink/pull/8541#discussion_r287918350 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode

godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode URL: https://github.com/apache/flink/pull/8520#discussion_r287917681 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode

godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode URL: https://github.com/apache/flink/pull/8520#discussion_r287917681 ## File path:

[GitHub] [flink] sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287917746 ## File path:

[GitHub] [flink] sunhaibotb commented on issue #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

sunhaibotb commented on issue #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#issuecomment-496350510 Thanks for the reviews @tillrohrmann . I have update the code, please review it again.

[GitHub] [flink] sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287915194 ## File path:

[GitHub] [flink] sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287915194 ## File path:

[jira] [Created] (FLINK-12638) Expose max parallelism via the REST API and via the Web UI

Sean Bollin created FLINK-12638: --- Summary: Expose max parallelism via the REST API and via the Web UI Key: FLINK-12638 URL: https://issues.apache.org/jira/browse/FLINK-12638 Project: Flink

[GitHub] [flink] sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

sunhaibotb commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287915194 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode

godfreyhe commented on a change in pull request #8520: [FLINK-12600] [table-planner-blink] Introduce planner rules to do deterministic rewriting on RelNode URL: https://github.com/apache/flink/pull/8520#discussion_r287914800 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8527: [FLINK-12610] [table-planner-blink] Introduce planner rules about aggregate

godfreyhe commented on a change in pull request #8527: [FLINK-12610] [table-planner-blink] Introduce planner rules about aggregate URL: https://github.com/apache/flink/pull/8527#discussion_r287913290 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8527: [FLINK-12610] [table-planner-blink] Introduce planner rules about aggregate

godfreyhe commented on a change in pull request #8527: [FLINK-12610] [table-planner-blink] Introduce planner rules about aggregate URL: https://github.com/apache/flink/pull/8527#discussion_r287912472 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file

xuefuz commented on a change in pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file URL: https://github.com/apache/flink/pull/8541#discussion_r287912450 ## File path:

[GitHub] [flink] sunhaibotb commented on a change in pull request #8476: [FLINK-12490][network] Introduce Input and NetworkInput interfaces

sunhaibotb commented on a change in pull request #8476: [FLINK-12490][network] Introduce Input and NetworkInput interfaces URL: https://github.com/apache/flink/pull/8476#discussion_r287910131 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287909365 ## File path:

[GitHub] [flink] xuefuz commented on issue #8553: [FLINK-12418][hive] Add input/output format and SerDeLib information when creating Hive table in HiveCatalog

xuefuz commented on issue #8553: [FLINK-12418][hive] Add input/output format and SerDeLib information when creating Hive table in HiveCatalog URL: https://github.com/apache/flink/pull/8553#issuecomment-496340490 LGTM. This

[GitHub] [flink] tweise commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord

tweise commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord URL: https://github.com/apache/flink/pull/8535#issuecomment-496340207 @aljoscha glad to see this change, we may be interested to use the headers with 0.11

[GitHub] [flink] zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287909399 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287909365 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287908868 ## File path:

[GitHub] [flink] Xpray commented on issue #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

Xpray commented on issue #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#issuecomment-496338752 @GJL please have a look at this. This is an

[jira] [Comment Edited] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849259#comment-16849259 ] Mike Kaplinskiy edited comment on FLINK-12620 at 5/28/19 12:38 AM: ---

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849259#comment-16849259 ] Mike Kaplinskiy commented on FLINK-12620: - Sure, here's an example deadlock that I see,

[jira] [Updated] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Kaplinskiy updated FLINK-12620: Attachment: jstack_snippet.txt > Deadlock in task deserialization >

[GitHub] [flink] azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r287807783 ## File path: docs/dev/stream/state/state.md ##

[GitHub] [flink] azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r287804877 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r287878198 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r287809610 ## File path: docs/dev/stream/state/state.md ##

[GitHub] [flink] azagrebin commented on issue #8485: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API

azagrebin commented on issue #8485: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API URL: https://github.com/apache/flink/pull/8485#issuecomment-496287266 True, thanks for noticing it @zhijiangW, it was not an intent. I will change it to create group only once.

[jira] [Commented] (FLINK-10121) Introduce methods to remove registered operator states

[ https://issues.apache.org/jira/browse/FLINK-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849087#comment-16849087 ] aitozi commented on FLINK-10121: Hi,[~srichter] Is this still ongoing work ? I think it's a valuable

[jira] [Commented] (FLINK-10098) Programmatically select timer storage backend

[ https://issues.apache.org/jira/browse/FLINK-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849082#comment-16849082 ] aitozi commented on FLINK-10098: I will work on this issue to solve the problem > Programmatically

[jira] [Assigned] (FLINK-10098) Programmatically select timer storage backend

[ https://issues.apache.org/jira/browse/FLINK-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi reassigned FLINK-10098: -- Assignee: aitozi > Programmatically select timer storage backend >

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:53 PM: - [~gjy], from

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849080#comment-16849080 ] lamber-ken commented on FLINK-12302: So, when the unexcepted scene happens, it displays wrong

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: image-2019-05-28-00-50-13-500.png > Fixed the wrong finalStatus of yarn application

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:47 PM: - [~gjy], from

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

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jeremy huang reassigned FLINK-11634: Assignee: jeremy huang > Translate "State Backends" page into Chinese >

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:43 PM: - [~gjy], from

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:42 PM: - [~gjy], from

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:34 PM: - [~gjy], from

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken commented on FLINK-12302: [~gjy], from another side, we can analysis this issue only from

[GitHub] [flink] Aitozi commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on issue #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-496260983 Have added the three metric for the credit based mode, please take a look when you

[GitHub] [flink] flinkbot edited a comment on issue #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

flinkbot edited a comment on issue #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer URL: https://github.com/apache/flink/pull/8517#issuecomment-495066880 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] jgrier commented on issue #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

jgrier commented on issue #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer URL: https://github.com/apache/flink/pull/8517#issuecomment-496260766 @flinkbot approve all This is an automated

[GitHub] [flink] jgrier commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

jgrier commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer URL: https://github.com/apache/flink/pull/8517#discussion_r287840233 ## File path:

[GitHub] [flink] jgrier commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

jgrier commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer URL: https://github.com/apache/flink/pull/8517#discussion_r287840412 ## File path:

[jira] [Updated] (FLINK-12637) Add floatingBufferUsage and exclusiveBufferUsage for credit based mode

[ https://issues.apache.org/jira/browse/FLINK-12637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi updated FLINK-12637: --- Description: Described [here|https://github.com/apache/flink/pull/8455#issuecomment-496077999] (was:

[jira] [Created] (FLINK-12637) Add floatingBufferUsage and exclusiveBufferUsage for credit based mode

aitozi created FLINK-12637: -- Summary: Add floatingBufferUsage and exclusiveBufferUsage for credit based mode Key: FLINK-12637 URL: https://issues.apache.org/jira/browse/FLINK-12637 Project: Flink

[jira] [Issue Comment Deleted] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Comment: was deleted (was: [~gjy], hi, can you show me your +flink-conf.yaml+ file? thanks) >

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849038#comment-16849038 ] lamber-ken commented on FLINK-12302: [~gjy], here my env files. 1,test jars --> [^test.jar]

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: jobmanager-1.log > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: jobmanager-2.log > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: flink-conf.yaml > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: jobmanager-1.log) > Fixed the wrong finalStatus of yarn application when

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: test.jar > Fixed the wrong finalStatus of yarn application when application finished >

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: flink-conf.yaml) > Fixed the wrong finalStatus of yarn application when

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: jobmanager-2.log) > Fixed the wrong finalStatus of yarn application when

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: test.jar) > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: test.jar jobmanager-2.log jobmanager-1.log

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: test.jar) > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: test.jar > Fixed the wrong finalStatus of yarn application when application finished >

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849010#comment-16849010 ] lamber-ken commented on FLINK-12302: [~gjy], hi, can you show me your +flink-conf.yaml+ file? thanks

[GitHub] [flink] zhijiangW commented on issue #8485: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API

zhijiangW commented on issue #8485: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API URL: https://github.com/apache/flink/pull/8485#issuecomment-496231763 Thanks for the replies @zentol . But in this PR `parentGroup.addGroup("Network")` is called twice in

[GitHub] [flink] flinkbot commented on issue #8555: [FLINK-12254][table-common] More preparation for using the new type system

flinkbot commented on issue #8555: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8555#issuecomment-496231212 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] twalthr opened a new pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system

twalthr opened a new pull request #8555: [FLINK-12254][table-common] More preparation for using the new type system URL: https://github.com/apache/flink/pull/8555 ## What is the purpose of the change This PR contains another set of utility classes for enabling the new type system.

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848987#comment-16848987 ] Gary Yao commented on FLINK-12302: -- [~lamber-ken] Thanks for your example. However, I am still not able

[GitHub] [flink] 1u0 commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking

1u0 commented on a change in pull request #8467: [FLINK-12535][network] Make CheckpointBarrierHandler non-blocking URL: https://github.com/apache/flink/pull/8467#discussion_r287809858 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/AvailabilityListener.java

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-12302: - Attachment: jobmanager-05-27.log > Fixed the wrong finalStatus of yarn application when application

[GitHub] [flink] zentol commented on a change in pull request #8545: [FLINK-12520] Support to provide fully-qualified domain host name in TaskManagerMetricGroup

zentol commented on a change in pull request #8545: [FLINK-12520] Support to provide fully-qualified domain host name in TaskManagerMetricGroup URL: https://github.com/apache/flink/pull/8545#discussion_r287806538 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8545: [FLINK-12520] Support to provide fully-qualified domain host name in TaskManagerMetricGroup

zentol commented on a change in pull request #8545: [FLINK-12520] Support to provide fully-qualified domain host name in TaskManagerMetricGroup URL: https://github.com/apache/flink/pull/8545#discussion_r287806538 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8545: [FLINK-12520] Support to provide fully-qualified domain host name in TaskManagerMetricGroup

zentol commented on a change in pull request #8545: [FLINK-12520] Support to provide fully-qualified domain host name in TaskManagerMetricGroup URL: https://github.com/apache/flink/pull/8545#discussion_r287806224 ## File path:

[jira] [Updated] (FLINK-11283) Add keyed CoProcessFunction that allows accessing key

[ https://issues.apache.org/jira/browse/FLINK-11283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11283: - Issue Type: New Feature (was: Improvement) > Add keyed CoProcessFunction that allows

[GitHub] [flink] pnowojski commented on issue #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

pnowojski commented on issue #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#issuecomment-496224208 LGTM % renaming, one question and if Chesney is fine with extending the testing

[GitHub] [flink] twalthr commented on a change in pull request #8548: [FLINK-6962] [table] Add a create table SQL DDL

twalthr commented on a change in pull request #8548: [FLINK-6962] [table] Add a create table SQL DDL URL: https://github.com/apache/flink/pull/8548#discussion_r287803308 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -0,0

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r287803156 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

pnowojski commented on a change in pull request #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#discussion_r287802609 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r287802261 ## File path:

[jira] [Commented] (FLINK-12611) Make time indicator nullable in blink

[ https://issues.apache.org/jira/browse/FLINK-12611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848956#comment-16848956 ] Timo Walther commented on FLINK-12611: -- Running aggregates like {{SELECT MAX(X)}} should not

[GitHub] [flink] aljoscha closed pull request #7470: [FLINK-11283] Accessing the key when processing connected keyed stream

aljoscha closed pull request #7470: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/7470 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] aljoscha commented on issue #7470: [FLINK-11283] Accessing the key when processing connected keyed stream

aljoscha commented on issue #7470: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/7470#issuecomment-496221694 Thanks a lot for staying on this issue for long, @yanghua. I merged it finally. 

[GitHub] [flink] aljoscha commented on issue #8538: [FLINK-11283] Accessing the key when processing connected keyed stream

aljoscha commented on issue #8538: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/8538#issuecomment-496221456 Merged This is an automated message from the

[jira] [Closed] (FLINK-11283) Add keyed CoProcessFunction that allows accessing key

[ https://issues.apache.org/jira/browse/FLINK-11283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11283. Resolution: Implemented Fix Version/s: 1.9.0 Implemented on master in

[GitHub] [flink] 1u0 commented on issue #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation

1u0 commented on issue #8495: [FLINK-12556][e2e] Extend some end-to-end tests to run with custom (input) File System implementation URL: https://github.com/apache/flink/pull/8495#issuecomment-496221499 Timings of the tests, from the CI logs: ``` [PASS] 'Running Kerberized YARN on

[jira] [Updated] (FLINK-11373) CliFrontend cuts off reason for error messages

[ https://issues.apache.org/jira/browse/FLINK-11373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11373: - Component/s: (was: Deployment / Scripts) Command Line Client >

[GitHub] [flink] aljoscha closed pull request #8538: [FLINK-11283] Accessing the key when processing connected keyed stream

aljoscha closed pull request #8538: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/8538 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r287799750 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/PartitionInfo.java

[GitHub] [flink] aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord

aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord URL: https://github.com/apache/flink/pull/8535#issuecomment-496219121 Also, @tweise or @jgrier is this feature relevant for you? Maybe you also have some comments/input?

[GitHub] [flink] asfgit closed pull request #8510: [FLINK-12254][table] Update cast() and TypeLiteralExpression to new type system

asfgit closed pull request #8510: [FLINK-12254][table] Update cast() and TypeLiteralExpression to new type system URL: https://github.com/apache/flink/pull/8510 This is an automated message from the Apache Git Service. To

[GitHub] [flink] zentol commented on issue #8485: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API

zentol commented on issue #8485: [FLINK-12555] Introduce an encapsulated metric group layout for shuffle API URL: https://github.com/apache/flink/pull/8485#issuecomment-496213298 > And if we think there are no concerns for creating one metric group twice There are concerns; it

[GitHub] [flink] zentol commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zentol commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287788958 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zentol commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287786958 ## File path:

  1   2   3   >