[jira] [Commented] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309206#comment-17309206 ] zhuxiaoshang commented on FLINK-21702: -- [~jark]，yes i'm working on this issue > Support option

[jira] [Commented] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300429#comment-17300429 ] zhuxiaoshang commented on FLINK-21702: -- [~fsk119] [~jark] plz assign to me. > Support option

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300427#comment-17300427 ] zhuxiaoshang commented on FLINK-21466: -- [~fsk119] [~jark] plz assign to me. > Make "embedded"

[jira] [Closed] (FLINK-21461) FileNotFoundException when sink to hive

[ https://issues.apache.org/jira/browse/FLINK-21461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxiaoshang closed FLINK-21461. Resolution: Not A Problem > FileNotFoundException when sink to hive >

[jira] [Commented] (FLINK-21461) FileNotFoundException when sink to hive

[ https://issues.apache.org/jira/browse/FLINK-21461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289623#comment-17289623 ] zhuxiaoshang commented on FLINK-21461: -- our legacy spark compaction program cause this. Not a

[jira] [Created] (FLINK-21461) FileNotFoundException when sink to hive

zhuxiaoshang created FLINK-21461: Summary: FileNotFoundException when sink to hive Key: FLINK-21461 URL: https://issues.apache.org/jira/browse/FLINK-21461 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278512#comment-17278512 ] zhuxiaoshang edited comment on FLINK-21250 at 2/4/21, 3:42 AM: --- latest

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278512#comment-17278512 ] zhuxiaoshang commented on FLINK-21250: -- latest progress, we find the checkpoint id is cyclic, from

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxiaoshang updated FLINK-21250: - Attachment: image-2021-02-04-11-33-09-549.png > Failure to finalize checkpoint due to >

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278495#comment-17278495 ] zhuxiaoshang commented on FLINK-21250: -- [~trohrmann] [~roman_khachatryan],Could you offer some

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278490#comment-17278490 ] zhuxiaoshang commented on FLINK-21250: -- [~trohrmann],it's not convenient to open debug log in

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277927#comment-17277927 ] zhuxiaoshang edited comment on FLINK-21250 at 2/3/21, 11:40 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277927#comment-17277927 ] zhuxiaoshang edited comment on FLINK-21250 at 2/3/21, 11:38 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277927#comment-17277927 ] zhuxiaoshang commented on FLINK-21250: -- [~trohrmann] [~hauler] Thx for your reply.These jobs have

[jira] [Commented] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax

[ https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263227#comment-17263227 ] zhuxiaoshang commented on FLINK-20937: -- [~jark] i want to take it. > Drop table can fails, when i

[jira] [Commented] (FLINK-20851) flink datagen produce NULL value

[ https://issues.apache.org/jira/browse/FLINK-20851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17259528#comment-17259528 ] zhuxiaoshang commented on FLINK-20851: -- [~appleyuchi] [~hailong wang] I reproduce the problem when

[jira] [Commented] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

[ https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256298#comment-17256298 ] zhuxiaoshang commented on FLINK-20348: -- [~jark]，I want to have a try. > Make

[jira] [Commented] (FLINK-20771) Hive partition is not added when there is a lot of data

[ https://issues.apache.org/jira/browse/FLINK-20771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254876#comment-17254876 ] zhuxiaoshang commented on FLINK-20771: -- Hi [~hehuiyuan],this is dumplicated to 

[jira] [Commented] (FLINK-20747) max 函数冲突报ClassCastException异常

[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254138#comment-17254138 ] zhuxiaoshang commented on FLINK-20747: -- Hi [~zengjinbo],you should use English in JIRA,could you

[jira] [Closed] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxiaoshang closed FLINK-20671. Resolution: Not A Problem > Partition doesn't commit until the end of partition >

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252696#comment-17252696 ] zhuxiaoshang commented on FLINK-20671: -- Thanks for your [~lzljs3620320] patient explanation. I'll

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252661#comment-17252661 ] zhuxiaoshang commented on FLINK-20671: -- If use file compaction, don't have this problem. If not use

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252463#comment-17252463 ] zhuxiaoshang commented on FLINK-20671: -- [~lzljs3620320],please take a look. > Partition doesn't

[jira] [Comment Edited] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251570#comment-17251570 ] zhuxiaoshang edited comment on FLINK-20671 at 12/18/20, 8:00 AM: -

[jira] [Comment Edited] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251570#comment-17251570 ] zhuxiaoshang edited comment on FLINK-20671 at 12/18/20, 7:51 AM: -

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251570#comment-17251570 ] zhuxiaoshang commented on FLINK-20671: -- Maybe the reason is bucket is always active until no data

[jira] [Created] (FLINK-20671) Partition doesn't commit until the end of partition

zhuxiaoshang created FLINK-20671: Summary: Partition doesn't commit until the end of partition Key: FLINK-20671 URL: https://issues.apache.org/jira/browse/FLINK-20671 Project: Flink Issue

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251524#comment-17251524 ] zhuxiaoshang commented on FLINK-20665: -- [~lzljs3620320],yes you are write,if it has been compacted,

[jira] [Comment Edited] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251486#comment-17251486 ] zhuxiaoshang edited comment on FLINK-20665 at 12/18/20, 3:55 AM: -

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251486#comment-17251486 ] zhuxiaoshang commented on FLINK-20665: -- [~lzljs3620320],I'd like to do this job. BTW,I find that if

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251476#comment-17251476 ] zhuxiaoshang commented on FLINK-20665: -- When the file is big,it will be rename directly.So when

[jira] [Created] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

zhuxiaoshang created FLINK-20665: Summary: FileNotFoundException when restore from latest Checkpoint Key: FLINK-20665 URL: https://issues.apache.org/jira/browse/FLINK-20665 Project: Flink

[jira] [Commented] (FLINK-20504) NPE when writing to hive and fail over happened

[ https://issues.apache.org/jira/browse/FLINK-20504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247848#comment-17247848 ] zhuxiaoshang commented on FLINK-20504: -- [~lirui] 2.3.4 > NPE when writing to hive and fail over

[jira] [Commented] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246999#comment-17246999 ] zhuxiaoshang commented on FLINK-20552: -- Maybe OutputFormatSinkFunction should implements 

[jira] [Created] (FLINK-20544) ConcurrentModificationException when writing to hive and fail over happened

zhuxiaoshang created FLINK-20544: Summary: ConcurrentModificationException when writing to hive and fail over happened Key: FLINK-20544 URL: https://issues.apache.org/jira/browse/FLINK-20544 Project:

[jira] [Created] (FLINK-20538) sink.rolling-policy.file-size does not work in filesystem connector

zhuxiaoshang created FLINK-20538: Summary: sink.rolling-policy.file-size does not work in filesystem connector Key: FLINK-20538 URL: https://issues.apache.org/jira/browse/FLINK-20538 Project: Flink

[jira] [Commented] (FLINK-19345) In Table File Sink, introduce streaming sink compaction

[ https://issues.apache.org/jira/browse/FLINK-19345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245183#comment-17245183 ] zhuxiaoshang commented on FLINK-19345: -- HI [~lzljs3620320],when the `auto-compaction` is open,the

[jira] [Commented] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON

[ https://issues.apache.org/jira/browse/FLINK-20470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244976#comment-17244976 ] zhuxiaoshang commented on FLINK-20470: -- [~jark],The legacy  JsonRowDeserializationSchema also has

[jira] [Created] (FLINK-20504) NPE when writing to hive and fail over happened

zhuxiaoshang created FLINK-20504: Summary: NPE when writing to hive and fail over happened Key: FLINK-20504 URL: https://issues.apache.org/jira/browse/FLINK-20504 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON

[ https://issues.apache.org/jira/browse/FLINK-20470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243659#comment-17243659 ] zhuxiaoshang commented on FLINK-20470: -- Hi [~jark],I want to take this. > MissingNode can't be