[jira] [Updated] (FLINK-35895) flink parquet vectorized reader should use readNextFilteredRowGroup() instead of readNextRowGroup()

[ https://issues.apache.org/jira/browse/FLINK-35895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-35895: - Description: reader.readNextRowGroup() should be changed to reader.readNextFilteredRowGroup(); https://

[jira] [Created] (FLINK-35895) flink parquet vectorized reader should use readNextFilteredRowGroup() instead of readNextRowGroup()

Kai Chen created FLINK-35895: Summary: flink parquet vectorized reader should use readNextFilteredRowGroup() instead of readNextRowGroup() Key: FLINK-35895 URL: https://issues.apache.org/jira/browse/FLINK-35895

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621456#comment-17621456 ] Kai Chen commented on FLINK-23074: -- [~luoyuxia] After this change, the version of org

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619951#comment-17619951 ] Kai Chen commented on FLINK-23074: -- I found that this commit(ce7481ae20cf6b4a32568df1d

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23074: - Attachment: screenshot-6.png > There is a class conflict between flink-connector-hive and flink-parquet

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23074: - Attachment: screenshot-5.png > There is a class conflict between flink-connector-hive and flink-parquet

[jira] [Comment Edited] (FLINK-27823) Standalone Job continously restart by illegal checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink

[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601100#comment-17601100 ] Kai Chen edited comment on FLINK-27823 at 9/7/22 2:01 AM: -- Hi [

[jira] [Commented] (FLINK-27823) Standalone Job continously restart by illegal checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink

[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601100#comment-17601100 ] Kai Chen commented on FLINK-27823: -- Hi [~suheng.cloud].We met this problem, too. Have

[jira] [Commented] (FLINK-29005) Parquet row type reader should not return null value when some child fields is null

[ https://issues.apache.org/jira/browse/FLINK-29005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580550#comment-17580550 ] Kai Chen commented on FLINK-29005: -- hi [~lsy] Could you assign this to me? > Parquet r

[jira] [Updated] (FLINK-21193) Migrate Flink Docs to Hugo

[ https://issues.apache.org/jira/browse/FLINK-21193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-21193: - Attachment: (was: screenshot-1.png) > Migrate Flink Docs to Hugo > --- > >

[jira] [Issue Comment Deleted] (FLINK-21193) Migrate Flink Docs to Hugo

[ https://issues.apache.org/jira/browse/FLINK-21193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-21193: - Comment: was deleted (was: hi [~sjwiesman]. Was it conflict with https://issues.apache.org/jira/browse/

[jira] [Comment Edited] (FLINK-21193) Migrate Flink Docs to Hugo

[ https://issues.apache.org/jira/browse/FLINK-21193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412469#comment-17412469 ] Kai Chen edited comment on FLINK-21193 at 9/9/21, 10:02 AM:

[jira] [Commented] (FLINK-21193) Migrate Flink Docs to Hugo

[ https://issues.apache.org/jira/browse/FLINK-21193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412469#comment-17412469 ] Kai Chen commented on FLINK-21193: -- hi [~sjwiesman]. Was it conflict with https://issu

[jira] [Updated] (FLINK-21193) Migrate Flink Docs to Hugo

[ https://issues.apache.org/jira/browse/FLINK-21193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-21193: - Attachment: screenshot-1.png > Migrate Flink Docs to Hugo > --- > >

[jira] [Closed] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen closed FLINK-23449. Resolution: Not A Problem > YarnTaskExecutorRunner does not contains MapReduce classes >

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392851#comment-17392851 ] Kai Chen commented on FLINK-23449: -- [~gaborgsomogyi] I agree with that. The PR can be c

[jira] [Comment Edited] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392680#comment-17392680 ] Kai Chen edited comment on FLINK-23449 at 8/4/21, 3:10 AM: --- [~

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392680#comment-17392680 ] Kai Chen commented on FLINK-23449: -- [~gaborgsomogyi] [~trohrmann] I'm not stick to code

[jira] [Comment Edited] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391381#comment-17391381 ] Kai Chen edited comment on FLINK-23449 at 8/2/21, 6:47 AM: --- [~

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391381#comment-17391381 ] Kai Chen commented on FLINK-23449: -- [~arvid] I checked https://issues.apache.org/jira/b

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391351#comment-17391351 ] Kai Chen commented on FLINK-23449: -- [~jiechen] I updated and now we can configure with

[jira] [Updated] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23449: - Component/s: Connectors / Hive > YarnTaskExecutorRunner does not contains MapReduce classes > -

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17387033#comment-17387033 ] Kai Chen commented on FLINK-23449: -- [~fly_in_gis] [~trohrmann] Could you review this pa

[jira] [Updated] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23449: - Description: I followed instructions described in [https://ci.apache.org/projects/flink/flink-docs-rele

[jira] [Updated] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23449: - Description: I followed instructions described in [https://ci.apache.org/projects/flink/flink-docs-rele

[jira] [Updated] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-23449: - Description: I followed instructions described in [https://ci.apache.org/projects/flink/flink-docs-rele

[jira] [Created] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

Kai Chen created FLINK-23449: Summary: YarnTaskExecutorRunner does not contains MapReduce classes Key: FLINK-23449 URL: https://issues.apache.org/jira/browse/FLINK-23449 Project: Flink Issue Ty

[jira] [Commented] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218185#comment-17218185 ] Kai Chen commented on FLINK-18811: -- I'm looking forward someone could help review the c

[jira] [Commented] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213757#comment-17213757 ] Kai Chen commented on FLINK-18196: -- hi [~pnowojski] [~roman_khachatryan] ，it's true tha

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Description: I met this Exception when a hard disk was damaged: !flink_disk_error.png! I checked the c

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Description: I met this Exception when a hard disk was damaged: !flink_disk_error.png! I checked the c

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Description: I met this Exception when a hard disk was damaged: !flink_disk_error.png! I checked the c

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Description: I met this Exception when a hard disk was damaged: !flink_disk_error.png! I checked the c

[jira] [Commented] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172907#comment-17172907 ] Kai Chen commented on FLINK-18196: -- Another report: [http://apache-flink.147419.n8.nab

[jira] [Commented] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171875#comment-17171875 ] Kai Chen commented on FLINK-18785: -- hi [~trohrmann] . Updated jobmanager.log `jobmanage

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Attachment: jobmanager.log.attemp2-13 > flink goes into dead lock leader election when restoring from a

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Attachment: flink_savepoint_path_do_not_exits.jpg > flink goes into dead lock leader election when resto

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Attachment: (was: jobmanager.log.attemp2) > flink goes into dead lock leader election when restoring

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Description: I met this Exception when a disk was damaged: !flink_disk_error.png! I think, if a disk i

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Attachment: jobmanager.log.attemp1 > flink goes into dead lock leader election when restoring from a do-

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Attachment: (was: jobmanager.log.attemp1) > flink goes into dead lock leader election when restoring

[jira] [Commented] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171389#comment-17171389 ] Kai Chen commented on FLINK-18785: -- add jobmanager.log of 2 attempts. yarn-2.7.2 > fl

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Environment: flink on yarn flink-1.10.x jdk8 flink-conf.yaml yarn.application-attempts: 2 (or just de

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Attachment: jobmanager.log.attemp2 jobmanager.log.attemp1 > flink goes into dead lock le

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Attachment: (was: jobmanager.log.attemp2) > if a disk is damaged, taskmanager should choose another

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Attachment: jobmanager.log.attemp2 jobmanager.log.attemp1 > if a disk is damaged, taskma

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Attachment: (was: jobmanager.log.attemp1) > if a disk is damaged, taskmanager should choose another

[jira] [Comment Edited] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171367#comment-17171367 ] Kai Chen edited comment on FLINK-18811 at 8/5/20, 9:24 AM: --- I

[jira] [Comment Edited] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171367#comment-17171367 ] Kai Chen edited comment on FLINK-18811 at 8/5/20, 9:22 AM: --- I

[jira] [Commented] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171367#comment-17171367 ] Kai Chen commented on FLINK-18811: -- I made some test today, and the change below looks

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Environment: flink on yarn flink-1.10.x jdk8 flink-conf.yaml yarn.application-attempts: 2 (or just de

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Description: flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/sa

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Description: flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/sa

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Description: flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/sa

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Description: flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/sa

[jira] [Comment Edited] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171299#comment-17171299 ] Kai Chen edited comment on FLINK-18785 at 8/5/20, 7:01 AM: --- I

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Description: flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/sa

[jira] [Comment Edited] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171299#comment-17171299 ] Kai Chen edited comment on FLINK-18785 at 8/5/20, 6:59 AM: --- I

[jira] [Commented] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171299#comment-17171299 ] Kai Chen commented on FLINK-18785: -- I found that flink job will normally exit if I set 

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Environment: flink on yarn flink-1.10.x jdk8 yarn.application-attempts: 2 was: flink on yarn flink

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Component/s: Runtime / Coordination > flink goes into dead lock leader election when restoring from a do

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Component/s: (was: Table SQL / Runtime) Runtime / Network > if a disk is damaged, t

[jira] [Created] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

Kai Chen created FLINK-18811: Summary: if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again Key: FLINK-18811

[jira] [Created] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

Kai Chen created FLINK-18785: Summary: flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path Key: FLINK-18785 URL: https://issues.apache.org/jira/browse/FLINK-18785

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18196: - Description: I meet checkpoint NPE when executing wordcount example: java.lang.Exception: Could not per

[jira] [Created] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

Kai Chen created FLINK-18196: Summary: flink throws `NullPointerException` when executeCheckpointing Key: FLINK-18196 URL: https://issues.apache.org/jira/browse/FLINK-18196 Project: Flink Issue

[jira] [Updated] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-17133: - Component/s: (was: Connectors / Kafka) > Support CsvParser Features for CSV format via SQL DDL > ---

[jira] [Created] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

Kai Chen created FLINK-17133: Summary: Support CsvParser Features for CSV format via SQL DDL Key: FLINK-17133 URL: https://issues.apache.org/jira/browse/FLINK-17133 Project: Flink Issue Type: New

[jira] [Created] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL

Kai Chen created FLINK-17116: Summary: support UsernamePasswordCredentials for elasticsearch sink via SQL DDL Key: FLINK-17116 URL: https://issues.apache.org/jira/browse/FLINK-17116 Project: Flink

[jira] [Commented] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773957#comment-16773957 ] Kai Chen commented on FLINK-11708: -- FLINK-11137 meets the same problem. Looks like this

[jira] [Comment Edited] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773934#comment-16773934 ] Kai Chen edited comment on FLINK-11708 at 2/21/19 10:52 AM:

[jira] [Comment Edited] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773934#comment-16773934 ] Kai Chen edited comment on FLINK-11708 at 2/21/19 10:52 AM:

[jira] [Commented] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773934#comment-16773934 ] Kai Chen commented on FLINK-11708: -- Hi Till Rohrmann, I have upload taskmanager.log to

[jira] [Updated] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-11708: - Attachment: taskmanager.log > There is a big chance that a taskExecutor starts another RegistrationTimeo

[jira] [Updated] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-11708: - Description: Currently *TaskExecutor.start()* method starts by connecting to the ResourceManager and en

[jira] [Updated] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

[ https://issues.apache.org/jira/browse/FLINK-11708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-11708: - Description: Currently *TaskExecutor.start()* method starts by connecting to the ResourceManager and en

[jira] [Created] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

Kai Chen created FLINK-11708: Summary: There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM Key: FLINK-11708 URL: https://issues.apache.org/jira/browse/FLINK