[jira] [Updated] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiangjiguang0719 updated FLINK-29271: - Description: I have done a test to compare byte array and bytebuffer,  40% performance i

[jira] [Commented] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603303#comment-17603303 ] jiangjiguang0719 commented on FLINK-29271: -- please assign me the issue, I will

[jira] [Created] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
jiangjiguang0719 created FLINK-29271: Summary: Change to byte array from bytebuffer to improve performance when reading parquet file Key: FLINK-29271 URL: https://issues.apache.org/jira/browse/FLINK-29271

[jira] [Commented] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata fo

2021-02-04 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279252#comment-17279252 ] jiangjiguang0719 commented on FLINK-21250: -- I got it, and [~trohrmann] you can

[jira] [Commented] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata fo

2021-02-04 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278784#comment-17278784 ] jiangjiguang0719 commented on FLINK-21250: -- [~roman_khachatryan]   Of course th

[jira] [Commented] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata fo

2021-02-04 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278738#comment-17278738 ] jiangjiguang0719 commented on FLINK-21250: -- [~trohrmann]  My solution is:  Exte

[jira] [Commented] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata fo

2021-02-04 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278727#comment-17278727 ] jiangjiguang0719 commented on FLINK-21250: -- [~trohrmann] I am not using HA serv

[jira] [Comment Edited] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metada

2021-02-04 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278718#comment-17278718 ] jiangjiguang0719 edited comment on FLINK-21250 at 2/4/21, 9:48 AM: ---

[jira] [Commented] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata fo

2021-02-04 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278718#comment-17278718 ] jiangjiguang0719 commented on FLINK-21250: -- I have got it !!! My test scenario

[jira] [Commented] (FLINK-21250) Failure to finalize checkpoint due to org.apache.hadoop.fs.FileAlreadyExistsException: /user/flink/checkpoints/9e36ed4ec2f6685f836e5ee5395f5f2e/chk-11096/_metadata fo

2021-02-03 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278630#comment-17278630 ] jiangjiguang0719 commented on FLINK-21250: -- I have reproduced this problem，When