[jira] [Updated] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

[ https://issues.apache.org/jira/browse/FLINK-35291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-35291: -- Description: We are doing performance testing on Flink cdc 3.0 and found through the arthas profile t

[jira] [Updated] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

[ https://issues.apache.org/jira/browse/FLINK-35291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-35291: -- Attachment: a96b54e6-7736-434b-bd40-0a7a59300375.png 25ff4084-b7b5-488a-8665-cfb5062b7e

[jira] [Updated] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

[ https://issues.apache.org/jira/browse/FLINK-35291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-35291: -- Description: We are doing performance testing on Flink cdc 3.0 and found through the arthas profile t

[jira] [Updated] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

[ https://issues.apache.org/jira/browse/FLINK-35291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-35291: -- Description: We are doing performance testing on Flink cdc 3.0 and found through the arthas profile t

[jira] [Created] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

LiuZeshan created FLINK-35291: - Summary: Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme Key: FLINK-35291 URL: https://issues.apache.org/jira/browse/FLINK-35291 Proj

[jira] [Comment Edited] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725853#comment-17725853 ] LiuZeshan edited comment on FLINK-32139 at 5/24/23 3:27 PM:

[jira] [Comment Edited] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725853#comment-17725853 ] LiuZeshan edited comment on FLINK-32139 at 5/24/23 3:25 PM:

[jira] [Commented] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725853#comment-17725853 ] LiuZeshan commented on FLINK-32139: --- By adding logs to HBase, the root cause of unexpe

[jira] [Updated] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-32139: -- Attachment: image-2023-05-24-23-16-59-508.png > Data accidentally deleted and not deleted when upsert

[jira] [Updated] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-32139: -- Attachment: aa.log > Data accidentally deleted and not deleted when upsert sink to hbase > ---

[jira] [Updated] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-32139: -- Attachment: image-2023-05-24-23-07-23-978.png > Data accidentally deleted and not deleted when upsert

[jira] [Commented] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724739#comment-17724739 ] LiuZeshan commented on FLINK-32139: --- [~liyu] Would you also help to take a look at thi

[jira] [Commented] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17724543#comment-17724543 ] LiuZeshan commented on FLINK-32139: --- [~ferenc-csaky] [~martijnvisser] Could you help t

[jira] [Closed] (FLINK-32140) Data accidentally deleted and not deleted when upsert sink to hbase

[ https://issues.apache.org/jira/browse/FLINK-32140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan closed FLINK-32140. - Resolution: Duplicate > Data accidentally deleted and not deleted when upsert sink to hbase > --

[jira] [Created] (FLINK-32140) Data accidentally deleted and not deleted when upsert sink to hbase

LiuZeshan created FLINK-32140: - Summary: Data accidentally deleted and not deleted when upsert sink to hbase Key: FLINK-32140 URL: https://issues.apache.org/jira/browse/FLINK-32140 Project: Flink

[jira] [Created] (FLINK-32139) Data accidentally deleted and not deleted when upsert sink to hbase

LiuZeshan created FLINK-32139: - Summary: Data accidentally deleted and not deleted when upsert sink to hbase Key: FLINK-32139 URL: https://issues.apache.org/jira/browse/FLINK-32139 Project: Flink

[jira] [Updated] (FLINK-31557) Metric viewUpdater and reporter task in a SingleThreadScheduledExecutor lead to inaccurate PerSecond related metrics

[ https://issues.apache.org/jira/browse/FLINK-31557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-31557: -- Description: Currently, metric viewUpdater and reporterTask share the same SingleThreadScheduledExecu

[jira] [Updated] (FLINK-31557) Metric viewUpdater and reporter task in a SingleThreadScheduledExecutor lead to inaccurate PerSecond related metrics

[ https://issues.apache.org/jira/browse/FLINK-31557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-31557: -- Description: Currently, metric viewUpdater and reporterTask share the same SingleThreadScheduledExecu

[jira] [Created] (FLINK-31557) Metric viewUpdater and reporter task in a SingleThreadScheduledExecutor lead to inaccurate PerSecond related metrics

LiuZeshan created FLINK-31557: - Summary: Metric viewUpdater and reporter task in a SingleThreadScheduledExecutor lead to inaccurate PerSecond related metrics Key: FLINK-31557 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604870#comment-17604870 ] LiuZeshan commented on FLINK-29306: --- [~rudi.kershaw] would you please to have a look ?

[jira] [Updated] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-29306: -- Description: The following shell command always make FLINK_DIST_COUNT=1 ([config.sh|https://github.co

[jira] [Created] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

LiuZeshan created FLINK-29306: - Summary: fail to check multiple flink-dist*.jar for config.sh Key: FLINK-29306 URL: https://issues.apache.org/jira/browse/FLINK-29306 Project: Flink Issue Type: Bu

[jira] [Comment Edited] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458865#comment-17458865 ] LiuZeshan edited comment on FLINK-18112 at 12/14/21, 2:33 AM:

[jira] [Commented] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458865#comment-17458865 ] LiuZeshan commented on FLINK-18112: --- Hi [~trohrmann] ，thank you very much for you kind

[jira] [Updated] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-18112: -- Attachment: image-2021-12-14-10-30-26-486.png > Approximate Task-Local Recovery -- Milestone One > ---

[jira] [Commented] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453849#comment-17453849 ] LiuZeshan commented on FLINK-18112: --- [~ym]  Thanks very much for the ticket. We are ve

[jira] [Updated] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-18112: -- Attachment: image-2021-12-06-16-39-21-604.png > Approximate Task-Local Recovery -- Milestone One > ---

[jira] [Updated] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-24212: -- Description: >From FLINK-18971，we can mount kerberos krb5 conf file to pod with path >/etc/krb5.conf，

[jira] [Updated] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-24212: -- Priority: Minor (was: Major) > kerberos krb5.conf file is mounted as empty directory, not the expecte

[jira] [Updated] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-24212: -- Summary: kerberos krb5.conf file is mounted as empty directory, not the expected file (was: kerberos

[jira] [Commented] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory for customer file name

[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411864#comment-17411864 ] LiuZeshan commented on FLINK-24212: --- Could you [~karmagyz] [~xtsong] have a look at th

[jira] [Created] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory for customer file name

LiuZeshan created FLINK-24212: - Summary: kerberos krb5.conf file is mounted as empty directory for customer file name Key: FLINK-24212 URL: https://issues.apache.org/jira/browse/FLINK-24212 Project: Flink