[jira] [Created] (FLINK-10949) When use flink-1.6.2's intervalJoin funtion, the thread is stucked in rockdb's seek for too long time

2018-11-20 Thread Liu (JIRA)
Liu created FLINK-10949: --- Summary: When use flink-1.6.2's intervalJoin funtion, the thread is stucked in rockdb's seek for too long time Key: FLINK-10949 URL: https://issues.apache.org/jira/browse/FLINK-10949 P

[jira] [Updated] (FLINK-10949) When use flink-1.6.2's intervalJoin funtion, the thread is stucked in rockdb's seek for too long time

2018-11-20 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-10949: Description: 0down vote [favorite|https://stackoverflow.com/questions/53393775/when-use-flink-1-6-2s-intervaljoin

[jira] [Updated] (FLINK-10949) When use flink-1.6.2's intervalJoin funtion, the thread is stucked in rockdb's seek for too long time

2018-11-20 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-10949: Description: 0down vote [favorite|https://stackoverflow.com/questions/53393775/when-use-flink-1-6-2s-intervaljoin

[jira] [Created] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

2018-12-02 Thread Liu (JIRA)
Liu created FLINK-11050: --- Summary: When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound Key: FLINK-11050 URL: https://issues.apache.org/jira/browse/FLINK-11050 Project: Fli

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

2018-12-02 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11050: Description:     When IntervalJoin, it is very slow to get left or right buffer's entries. Because we have to sca

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

2018-12-02 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11050: Description:     When IntervalJoin, it is very slow to get left or right buffer's entries. Because we have to sca

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

2018-12-03 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11050: Fix Version/s: (was: 1.7.1) > When IntervalJoin, get left or right buffer's entries more quickly by > assigni

[jira] [Created] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread liu (Jira)
liu created FLINK-20230: --- Summary: PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException Key: FLINK-20230 URL: https://issues.apache.org/jira/browse/FLINK-20230 Project: Flink Issu

[jira] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liu updated FLINK-20230: Environment: TABLE DDL: CREATE TABLE IF NOT EXISTS test1 ( uid string, truename string, dt string ) ROW FORM

[jira] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-18 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liu updated FLINK-20230: Description: if table has PARTITIONED, USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS NULL, AND IT WILL THROW F

[jira] [Created] (FLINK-20238) flink-sql-connector-elasticsearch does not support Elasticsearch auth

2020-11-19 Thread liu (Jira)
liu created FLINK-20238: --- Summary: flink-sql-connector-elasticsearch does not support Elasticsearch auth Key: FLINK-20238 URL: https://issues.apache.org/jira/browse/FLINK-20238 Project: Flink Issue T

[jira] [Updated] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-19 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liu updated FLINK-20230: Description: table  USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS NULL, AND IT WILL THROW  FileNotFoundExceptio

[jira] [Updated] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-19 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liu updated FLINK-20230: Summary: INSERT INTO EMPTY VALUES, THROW FileNotFoundException (was: PARTITIONED TABLE, INSERT INTO EMPTY VALUE

[jira] [Created] (FLINK-20330) Flink connector has error in support hive external tables (hbase or es)

2020-11-24 Thread liu (Jira)
liu created FLINK-20330: --- Summary: Flink connector has error in support hive external tables (hbase or es) Key: FLINK-20330 URL: https://issues.apache.org/jira/browse/FLINK-20330 Project: Flink Issue

[jira] [Created] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-25 Thread Liu (Jira)
Liu created FLINK-19409: --- Summary: The comment for getValue has wrong code in class ListView Key: FLINK-19409 URL: https://issues.apache.org/jira/browse/FLINK-19409 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-19409: Description: The comment for getValue is as following currently: {code:java} *    @Override  *    public Long get

[jira] [Commented] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202519#comment-17202519 ] Liu commented on FLINK-19409: - [~jark] I would like to fix it. Can you assign this ticket to

[jira] [Commented] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-27 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202936#comment-17202936 ] Liu commented on FLINK-19409: - Hi, [~jark]. Please review the code. Thank you. > The commen

[jira] [Created] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-14 Thread Liu (Jira)
Liu created FLINK-18959: --- Summary: Fail to archiveExecutionGraph because job is not finished when dispatcher close Key: FLINK-18959 URL: https://issues.apache.org/jira/browse/FLINK-18959 Project: Flink

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18959: Description: When job is cancelled, we expect to see it in flink's history server. But I can not see my job after

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18959: Description: When job is cancelled, we expect to see it in flink's history server. But I can not see my job after

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18959: Attachment: flink-debug-log > Fail to archiveExecutionGraph because job is not finished when dispatcher > close >

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177706#comment-17177706 ] Liu commented on FLINK-18959: - Thank you, [~rmetzger] .The job is per-job and is running on

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-15 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178414#comment-17178414 ] Liu commented on FLINK-18959: - Thank you, [~trohrmann]. I have the same confusion with you.

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-16 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18959: Description: When job is cancelled, we expect to see it in flink's history server. But I can not see my job after

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-21 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181706#comment-17181706 ] Liu commented on FLINK-18959: - Hi, [~trohrmann]. The problem has been raised for some time.

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-24 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183137#comment-17183137 ] Liu commented on FLINK-18959: - [~trohrmann], thanks for your advice. I just try to revert th

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-24 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183683#comment-17183683 ] Liu commented on FLINK-18959: - Thanks for the reply, [~trohrmann] and [~aljoscha]. After rev

[jira] [Comment Edited] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-09-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717 ] Liu edited comment on FLINK-18959 at 9/2/20, 12:34 AM: --- Hi, [~troh

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-09-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717 ] Liu commented on FLINK-18959: - Hi, [~trohrmann] and [~aljoscha]. If we just revert the {{Min

[jira] [Comment Edited] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-09-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1717#comment-1717 ] Liu edited comment on FLINK-18959 at 9/2/20, 12:36 AM: --- Hi, [~troh

[jira] [Created] (FLINK-17446) Blink supports cube and window together in group by

2020-04-28 Thread Liu (Jira)
Liu created FLINK-17446: --- Summary: Blink supports cube and window together in group by Key: FLINK-17446 URL: https://issues.apache.org/jira/browse/FLINK-17446 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-17446) Blink supports cube and window together in group by

2020-04-28 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-17446: Description:       Blink planner supports CUBE. CUBE can be used together with a field but not window. For exampl

[jira] [Created] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-17 Thread Liu (Jira)
Liu created FLINK-18625: --- Summary: Maintain redundant taskmanagers to speed up failover Key: FLINK-18625 URL: https://issues.apache.org/jira/browse/FLINK-18625 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-17 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18625: Description: When flink job fails because of killed taskmanagers, it will request new containers when restarting.

[jira] [Comment Edited] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-19 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160856#comment-17160856 ] Liu edited comment on FLINK-18625 at 7/20/20, 2:43 AM: --- Thanks for

[jira] [Commented] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-19 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160856#comment-17160856 ] Liu commented on FLINK-18625: - Thanks for [~xintongsong] 's reply.  The following is my cons

[jira] [Comment Edited] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-19 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160856#comment-17160856 ] Liu edited comment on FLINK-18625 at 7/20/20, 2:46 AM: --- Thanks for

[jira] [Commented] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-19 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160901#comment-17160901 ] Liu commented on FLINK-18625: - Yes, I can do it. Please assign this feature to me. Thank you

[jira] [Updated] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-22 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-18625: Description: When flink job fails because of killed taskmanagers, it will request new containers when restarting.

[jira] [Commented] (FLINK-18760) Redundant task managers should be released when there's no job running in session cluster

2020-07-29 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167666#comment-17167666 ] Liu commented on FLINK-18760: - Thanks for report this case, [~xintongsong]. I will fix it la

[jira] [Commented] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2023-07-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742338#comment-17742338 ] Liu commented on FLINK-19249: - [~ym] [~zjwang] [~pnowojski] [~xtsong] Any progress on this i

[jira] [Created] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

2023-05-19 Thread Liu (Jira)
Liu created FLINK-32133: --- Summary: Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers Key: FLINK-32133 URL: https://issues.apache.org/jira/browse/FLINK-32133 Project

[jira] [Commented] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

2023-05-19 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724268#comment-17724268 ] Liu commented on FLINK-32133: - A related issue is https://issues.apache.org/jira/browse/FLIN

[jira] [Commented] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

2023-05-22 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724829#comment-17724829 ] Liu commented on FLINK-32133: - [~huwh] Thanks for the detail analysis. Although the problem

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-05-22 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725186#comment-17725186 ] Liu commented on FLINK-30629: - [~Weijie Guo] [~Sergey Nuyanzin]  I will have a look.  > Cli

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-05-29 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727062#comment-17727062 ] Liu commented on FLINK-30629: - [~Sergey Nuyanzin] I have tried multi times but can not repro

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-06-02 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17728714#comment-17728714 ] Liu commented on FLINK-30629: - [~Sergey Nuyanzin] Thanks. From the log, we can see the logs

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-06-08 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730783#comment-17730783 ] Liu commented on FLINK-30629: - [~Sergey Nuyanzin] Fixed. Please review the code. Thanks. >

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-06-09 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730942#comment-17730942 ] Liu commented on FLINK-30629: - Rebased. Thanks. > ClientHeartbeatTest.testJobRunningIfClien

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-11 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675533#comment-17675533 ] Liu commented on FLINK-30629: - [~xtsong] Thanks. I would fix it as soon as possible. > Clie

[jira] [Updated] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-30629: Attachment: ClientHeartbeatTestLog.txt > ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable > -

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675921#comment-17675921 ] Liu commented on FLINK-30629: - [~xtsong] I have reproduced the failure locally and upload th

[jira] [Comment Edited] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675921#comment-17675921 ] Liu edited comment on FLINK-30629 at 1/12/23 10:10 AM: --- [~xtsong]

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-15 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677179#comment-17677179 ] Liu commented on FLINK-30629: - [~xtsong] Have a look at the code? Thanks. > ClientHeartbeat

[jira] [Commented] (FLINK-30773) Add API for rescaling of jobs based on per-vertex parallelism overrides

2023-04-27 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717449#comment-17717449 ] Liu commented on FLINK-30773: - [~mxm] The rescaling api is useful in many situations such as

[jira] [Comment Edited] (FLINK-30773) Add API for rescaling of jobs based on per-vertex parallelism overrides

2023-04-27 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717449#comment-17717449 ] Liu edited comment on FLINK-30773 at 4/28/23 6:43 AM: -- [~mxm] The r

[jira] [Created] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

2023-05-06 Thread Liu (Jira)
Liu created FLINK-32023: --- Summary: execution.buffer-timeout cannot be set to -1 ms Key: FLINK-32023 URL: https://issues.apache.org/jira/browse/FLINK-32023 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

2023-05-07 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720395#comment-17720395 ] Liu commented on FLINK-32023: - [~wanglijie] [~fanrui] Thanks for the reply. I would to fix i

[jira] [Updated] (FLINK-23203) Program cannot parse the parameter value with special characters

2021-07-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-23203: Attachment: image-2021-07-01-18-56-24-263.png > Program cannot parse the parameter value with special characters >

[jira] [Commented] (FLINK-23203) Program cannot parse the parameter value with special characters

2021-07-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372631#comment-17372631 ] Liu commented on FLINK-23203: - Hi, I have checked the case but not reproduce. Maybe you can

[jira] [Created] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

2021-07-07 Thread Liu (Jira)
Liu created FLINK-23300: --- Summary: Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager Key: FLINK-23300 URL: https://issues.apache.org/jira/browse/FLINK-23300 Project: Flink

[jira] [Commented] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

2021-07-07 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376985#comment-17376985 ] Liu commented on FLINK-23300: - Thanks, [~Thesharing]. I will focus on the issues you mention

[jira] [Closed] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

2021-07-07 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu closed FLINK-23300. --- Resolution: Duplicate > Job fails very slow because of no notifyAllocationFailure for > DeclarativeSlotManager > --

[jira] [Commented] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

2021-07-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379070#comment-17379070 ] Liu commented on FLINK-23216: - I have met the same problem  [FLINK-23300|https://issues.apac

[jira] [Commented] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

2021-07-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379117#comment-17379117 ] Liu commented on FLINK-23216: - Thanks, [~trohrmann] The basic idea is as you said before. Wh

[jira] [Comment Edited] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

2021-07-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379117#comment-17379117 ] Liu edited comment on FLINK-23216 at 7/12/21, 10:46 AM: Thanks,

[jira] [Created] (FLINK-20762) Remove unused checkpointStorage path after job finished

2020-12-24 Thread Liu (Jira)
Liu created FLINK-20762: --- Summary: Remove unused checkpointStorage path after job finished Key: FLINK-20762 URL: https://issues.apache.org/jira/browse/FLINK-20762 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-20762) Remove unused checkpointStorage path after job finished

2020-12-24 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-20762: Description:     Current checkpoint structure is as following: {code:java} /user-defined-checkpoint-dir |

[jira] [Commented] (FLINK-20762) Remove unused checkpointStorage path after job finished

2020-12-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254936#comment-17254936 ] Liu commented on FLINK-20762: - [~yunta] Thank you for your information. I have read the FLIN

[jira] [Closed] (FLINK-20762) Remove unused checkpointStorage path after job finished

2020-12-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu closed FLINK-20762. --- Resolution: Duplicate > Remove unused checkpointStorage path after job finished > --

[jira] [Created] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-06 Thread Liu (Jira)
Liu created FLINK-20872: --- Summary: Job resume from history savepoint when failover if checkpoint is disabled Key: FLINK-20872 URL: https://issues.apache.org/jira/browse/FLINK-20872 Project: Flink Issu

[jira] [Updated] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-20872: Affects Version/s: (was: 1.11.0) 1.10.0 > Job resume from history savepoint when failov

[jira] [Commented] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-07 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260408#comment-17260408 ] Liu commented on FLINK-20872: - [~yunta] Thank you. For you questions: 1.  Yes. The job is c

[jira] [Commented] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

2021-01-07 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260893#comment-17260893 ] Liu commented on FLINK-20872: - [~yunta] Since it is designed to be this, I am ok with it. Ma

[jira] [Created] (FLINK-22453) Can not stop job when not ust "-m" option

2021-04-25 Thread Liu (Jira)
Liu created FLINK-22453: --- Summary: Can not stop job when not ust "-m" option Key: FLINK-22453 URL: https://issues.apache.org/jira/browse/FLINK-22453 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-22453) Can not stop job when not ust "-m" option

2021-04-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-22453: Description: flink version: 1.12.2 yarn version : 3.1.1 (hdp 3.1.5) h3. Starting a Flink Session on YARN when i

[jira] [Updated] (FLINK-22453) Can not stop job when not ust "-m" option

2021-04-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-22453: Description: flink version: 1.12.2 yarn version : 3.1.1 (hdp 3.1.5) h3. Starting a Flink Session on YARN when i

[jira] [Updated] (FLINK-22453) Can not stop job when do not use "-m" option arg

2021-04-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-22453: Summary: Can not stop job when do not use "-m" option arg (was: Can not stop job when do not use "-m" option)

[jira] [Updated] (FLINK-22453) Can not stop job when do not use "-m" option

2021-04-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-22453: Summary: Can not stop job when do not use "-m" option (was: Can not stop job when not ust "-m" option) > Can no

[jira] [Commented] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-05-16 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345827#comment-17345827 ] liu commented on FLINK-22540: - For user-define-function,I want to know how to create functio

[jira] [Comment Edited] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-05-16 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345827#comment-17345827 ] liu edited comment on FLINK-22540 at 5/17/21, 2:21 AM: --- For user-d

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2021-05-16 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345851#comment-17345851 ] liu commented on FLINK-19973: - When use flink-sql-client , how to set  {{execution.target to

[jira] [Commented] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-05-18 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346753#comment-17346753 ] liu commented on FLINK-22540: - Hi,[~jark], I understand about "make the construtor arguments

[jira] [Commented] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-05-19 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347443#comment-17347443 ] liu commented on FLINK-22540: - Thanks a lot [~jark],I got it. > Remove YAML environment fil

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

2020-02-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17037105#comment-17037105 ] Liu commented on FLINK-16030: - Sorry for late reply. For quick fix, I send ping message to s

[jira] [Created] (FLINK-16229) testCompressionOnRelativePath() fails due to Files.createDirectory() in macOS

2020-02-21 Thread Liu (Jira)
Liu created FLINK-16229: --- Summary: testCompressionOnRelativePath() fails due to Files.createDirectory() in macOS Key: FLINK-16229 URL: https://issues.apache.org/jira/browse/FLINK-16229 Project: Flink

[jira] [Updated] (FLINK-16229) testCompressionOnRelativePath() fails due to Files.createDirectory() in macOS

2020-02-21 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-16229: Description:       I am using flink 1.10.0. In macOS, cd flink/flink-core  and execute "mvn -Dtest=org.apache.fli

[jira] [Updated] (FLINK-16229) testCompressionOnRelativePath() fails due to Files.createDirectory() in macOS

2020-02-21 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-16229: Description:       I am using flink 1.10.0. In macOS, cd flink/flink-core  and execute "mvn -Dtest=org.apache.fli

[jira] [Created] (FLINK-14981) web frontend support dynamic adjustment of the log level

2019-11-27 Thread liu (Jira)
liu created FLINK-14981: --- Summary: web frontend support dynamic adjustment of the log level Key: FLINK-14981 URL: https://issues.apache.org/jira/browse/FLINK-14981 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms

2018-12-24 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11215: Description: Sometimes, job will fail after 5 minutes because register fail at resource manager. !https://wiki.c

[jira] [Updated] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms

2018-12-24 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11215: Description: Sometimes, job will fail after 5 minutes because register fail at resource manager. !https://wiki.c

[jira] [Updated] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms

2018-12-24 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11215: Description: Sometimes, job will fail after 5 minutes because register fail at resource manager. !https://wiki.c

[jira] [Created] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms

2018-12-24 Thread Liu (JIRA)
Liu created FLINK-11215: --- Summary: TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 30ms Key: FLINK-11215 URL: https://issues.apache.org/jira/browse/FLINK-11215 P

[jira] [Commented] (FLINK-11215) TaskExecutor RegistrationTimeoutException within the specified maximum registration duration 300000ms

2018-12-24 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16728607#comment-16728607 ] Liu commented on FLINK-11215: - Yes, the problem is the same. Thank you for your reply. > Ta

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

2021-09-10 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413464#comment-17413464 ] Liu commented on FLINK-23969: - [~syhily] I have written E2E test just like KafkaSourceE2ECas

[jira] [Commented] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-09-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413715#comment-17413715 ] Liu commented on FLINK-23821: - Hi, [~hxbks2ks]. I have read the loopback mode and find that

[jira] [Comment Edited] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-09-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413715#comment-17413715 ] Liu edited comment on FLINK-23821 at 9/12/21, 2:29 PM: --- Hi, [~hxbk

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

2021-09-13 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414505#comment-17414505 ] Liu commented on FLINK-23969: - Hello, [~arvid] and [~syhily] . Could you review my code? Tha

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

2021-09-13 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414682#comment-17414682 ] Liu commented on FLINK-23969: - [~syhily] I have reviewed your code. The additional  Shared a

  1   2   3   4   5   6   7   8   9   10   >