[jira] [Updated] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-26 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-22318: - Attachment: (was: image-2021-04-26-13-58-19-302.png) > Support RENAME column name for ALTER TABLE statement

[jira] [Updated] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-25 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-22318: - Attachment: image-2021-04-26-13-58-19-302.png > Support RENAME column name for ALTER TABLE statement >

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-26 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331781#comment-17331781 ] todd commented on FLINK-22318: -- Hi [~jark] mysql allows primary key column renaming，indexes and foreign

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-26 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331973#comment-17331973 ] todd commented on FLINK-22318: -- [~jark]  code review   > Support RENAME column name for ALTER TABLE

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-22 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329112#comment-17329112 ] todd commented on FLINK-22318: -- Hi [~jark], I'm interested in this issue, could you assign it to me? >

[jira] [Issue Comment Deleted] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-22 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-22318: - Comment: was deleted (was: Hi [~jark], I'm interested in this issue, could you assign it to me?) > Support

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-22 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329230#comment-17329230 ] todd commented on FLINK-22318: -- I think it should be done in two steps, the first step is to extend the SQL

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-22 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329224#comment-17329224 ] todd commented on FLINK-22318: -- Hi [~jark], I'm interested in this issue, could you assign it to me?     >

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-24 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331356#comment-17331356 ] todd commented on FLINK-22318: -- I think it should be done in two steps, the first step is to extend the SQL

[jira] [Issue Comment Deleted] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-24 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-22318: - Comment: was deleted (was: I think it should be done in two steps, the first step is to extend the SQL syntax,

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-25 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331559#comment-17331559 ] todd commented on FLINK-22318: -- [~jark]  I will try Mysql's grammar later, can you see the code related to

[jira] [Comment Edited] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-25 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331559#comment-17331559 ] todd edited comment on FLINK-22318 at 4/25/21, 3:28 PM: [~jark]  I will try

[jira] [Commented] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-27 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1751#comment-1751 ] todd commented on FLINK-22318: -- hi, [~jark] Through today’s discussion in Pr, i think there are two points

[jira] [Comment Edited] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2021-04-27 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1751#comment-1751 ] todd edited comment on FLINK-22318 at 4/27/21, 4:01 PM: hi, [~jark] Through

[jira] [Commented] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode

2021-04-14 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321854#comment-17321854 ] todd commented on FLINK-22279: -- Thank you very much, what you said is right. I did not pay attention to

[jira] [Closed] (FLINK-16325) A connection check is required, and it needs to be reopened when the JDBC connection is interrupted

2021-04-14 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-16325. Resolution: Invalid > A connection check is required, and it needs to be reopened when the JDBC > connection is

[jira] [Closed] (FLINK-22279) Upload the pipeline.classpaths file in yarn application mode

2021-04-14 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-22279. Resolution: Invalid > Upload the pipeline.classpaths file in yarn application mode >

[jira] [Created] (FLINK-22361) flink run -c not upload udf jar

2021-04-19 Thread todd (Jira)
todd created FLINK-22361: Summary: flink run -c not upload udf jar Key: FLINK-22361 URL: https://issues.apache.org/jira/browse/FLINK-22361 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

2021-04-19 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325462#comment-17325462 ] todd commented on FLINK-22361: -- yarn.ship-files is a parameter of version 1.12. In addition,

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

2021-04-20 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325567#comment-17325567 ] todd commented on FLINK-22361: -- Thank you very much, I can execute the program by using -yD

[jira] [Closed] (FLINK-22361) flink run -c not upload udf jar

2021-04-20 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-22361. Resolution: Invalid > flink run -c not upload udf jar > --- > > Key:

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-24 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403698#comment-17403698 ] todd commented on FLINK-23725: -- [~sewen]        The target part file already exists. If you restore from

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403457#comment-17403457 ] todd commented on FLINK-23725: -- [~Paul Lin]   I think the target file should be deleted first instead of

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403523#comment-17403523 ] todd commented on FLINK-23725: -- [~sewen]  CC > HadoopFsCommitter, file rename failure >

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403526#comment-17403526 ] todd commented on FLINK-23725: --  I think that would be a problem if two files are written by different

[jira] [Updated] (FLINK-23725) HadoopFsCommitter， Prompt for file rename failure

2021-08-14 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Component/s: FileSystems > HadoopFsCommitter， Prompt for file rename failure >

[jira] [Updated] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-14 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Summary: HadoopFsCommitter, file rename failure (was: HadoopFsCommitter， file rename failure) >

[jira] [Updated] (FLINK-23725) HadoopFsCommitter， file rename failure

2021-08-14 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Summary: HadoopFsCommitter， file rename failure (was: HadoopFsCommitter， Prompt for file rename failure) >

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-09-12 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413898#comment-17413898 ] todd commented on FLINK-23725: -- [~sewen]    Do you have time to read this question? > HadoopFsCommitter,

[jira] [Updated] (FLINK-23725) HadoopFsCommitter， Prompt for file rename failure

2021-08-11 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Description: When the HDFS file is written, if the part file exists, only false will be returned if the

[jira] [Created] (FLINK-23725) HadoopFsCommitter， Prompt for file rename failure

2021-08-11 Thread todd (Jira)
todd created FLINK-23725: Summary: HadoopFsCommitter， Prompt for file rename failure Key: FLINK-23725 URL: https://issues.apache.org/jira/browse/FLINK-23725 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-03 Thread todd (Jira)
todd created FLINK-25508: Summary: Flink Batch mode, cluster shutdown early. Key: FLINK-25508 URL: https://issues.apache.org/jira/browse/FLINK-25508 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-04 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468595#comment-17468595 ] todd commented on FLINK-25508: -- [~MartijnVisser]  I have not subscribed to the dev mailing list, can you

[jira] [Closed] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-10 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-25508. Resolution: Invalid > Flink Batch mode, cluster shutdown early. > - > >

[jira] [Reopened] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-10 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd reopened FLINK-25508: -- > Flink Batch mode, cluster shutdown early. > - > > Key:

[jira] [Closed] (FLINK-25508) Flink Batch mode, cluster shutdown early.

2022-01-10 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd closed FLINK-25508. Resolution: Won't Do > Flink Batch mode, cluster shutdown early. > - > >