[GitHub] [flink] Aitozi closed pull request #19786: [FLINK-24713][Runtime/Coordination] Postpone resourceManager serving …

2022-05-28 Thread GitBox
Aitozi closed pull request #19786: [FLINK-24713][Runtime/Coordination] Postpone resourceManager serving … URL: https://github.com/apache/flink/pull/19786 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] flinkbot commented on pull request #19840: [FLINK-24713] Support the initial delay for SlotManager to waiting fo…

2022-05-28 Thread GitBox
flinkbot commented on PR #19840: URL: https://github.com/apache/flink/pull/19840#issuecomment-1140382750 ## CI report: * 38bf7a8b283a7f033f7e0ca38cd8ca032fe496ca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Aitozi commented on pull request #19786: [FLINK-24713][Runtime/Coordination] Postpone resourceManager serving …

2022-05-28 Thread GitBox
Aitozi commented on PR #19786: URL: https://github.com/apache/flink/pull/19786#issuecomment-1140382387 Closed in favor of https://github.com/apache/flink/pull/19840 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] Aitozi opened a new pull request, #19840: [FLINK-24713] Support the initial delay for SlotManager to waiting fo…

2022-05-28 Thread GitBox
Aitozi opened a new pull request, #19840: URL: https://github.com/apache/flink/pull/19840 …r taskManager to register ## What is the purpose of the change This PR is another solution to solve the problem of request the extra worker after JobManager failover. After the

[jira] [Updated] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-05-28 Thread Jiangfei Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangfei Liu updated FLINK-27828: - Attachment: Snipaste_2022-05-25_19-52-11.png > FlinkKafkaProducer VS KafkaSink >

[jira] [Created] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-05-28 Thread Jiangfei Liu (Jira)
Jiangfei Liu created FLINK-27828: Summary: FlinkKafkaProducer VS KafkaSink Key: FLINK-27828 URL: https://issues.apache.org/jira/browse/FLINK-27828 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-27593) Parquet/Orc format reader optimization

2022-05-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543551#comment-17543551 ] Jing Ge commented on FLINK-27593: - [~lsy] would you please describe what are the issues and what should

[jira] [Commented] (FLINK-27822) Translate the doc of checkpoint/savepoint guarantees

2022-05-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543550#comment-17543550 ] Jing Ge commented on FLINK-27822: - Thanks [~Feifan Wang], ticket has been assigned to you. You might

[jira] [Assigned] (FLINK-27822) Translate the doc of checkpoint/savepoint guarantees

2022-05-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-27822: --- Assignee: Feifan Wang > Translate the doc of checkpoint/savepoint guarantees >

[jira] [Assigned] (FLINK-27668) Document dynamic operator configuration

2022-05-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27668: -- Assignee: Nicholas Jiang > Document dynamic operator configuration >

[jira] [Commented] (FLINK-27822) Translate the doc of checkpoint/savepoint guarantees

2022-05-28 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543505#comment-17543505 ] Feifan Wang commented on FLINK-27822: - Hi [~fanrui] , I am a Chinese speaker and be glad to do this

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-28 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543488#comment-17543488 ] Feifan Wang commented on FLINK-27734: - Hi [~Zsigner] , I updated the pr with modify eslint

[jira] [Updated] (FLINK-26179) Support periodic savepointing in the operator

2022-05-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26179: --- Parent: (was: FLINK-25963) Issue Type: New Feature (was: Sub-task) > Support periodic

[jira] [Updated] (FLINK-26179) Support periodic savepointing in the operator

2022-05-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26179: --- Description: Automatic triggering of savepoints is a commonly requested feature. (was: Automatic

[jira] [Updated] (FLINK-26179) Support periodic savepointing in the operator

2022-05-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26179: --- Fix Version/s: kubernetes-operator-1.1.0 (was: kubernetes-operator-0.1.0) >

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

2022-05-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543484#comment-17543484 ] Gyula Fora commented on FLINK-26179: While user's could theoretically cron/schedule the manual

[jira] [Reopened] (FLINK-26179) Support periodic savepointing in the operator

2022-05-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reopened FLINK-26179: Assignee: Gyula Fora Re-openning this ticket as basically all current production users

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

2022-05-28 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543480#comment-17543480 ] Feifan Wang commented on FLINK-27734: - Hi [~Zsigner] , I tried changing "===" to "==", but there is

[jira] [Commented] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

2022-05-28 Thread Andreas Hailu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543479#comment-17543479 ] Andreas Hailu commented on FLINK-27827: --- If this is something that the community finds useful, I'm

[jira] [Created] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

2022-05-28 Thread Andreas Hailu (Jira)
Andreas Hailu created FLINK-27827: - Summary: StreamExecutionEnvironment method supporting explicit Boundedness Key: FLINK-27827 URL: https://issues.apache.org/jira/browse/FLINK-27827 Project: Flink

[GitHub] [flink] 1996fanrui commented on pull request #19839: [FLINK-27825][docs] Update the doc of aligned checkpoint timeout

2022-05-28 Thread GitBox
1996fanrui commented on PR #19839: URL: https://github.com/apache/flink/pull/19839#issuecomment-1140279938 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] 1996fanrui commented on pull request #19838: [hotfix][network] Fix the typo about subpartition

2022-05-28 Thread GitBox
1996fanrui commented on PR #19838: URL: https://github.com/apache/flink/pull/19838#issuecomment-1140271032 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-27826) Support machine learning training for very high dimesional models

2022-05-28 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-27826: -- Description: There is limited support for training high dimensional machine learning models

[jira] [Updated] (FLINK-27826) Support machine learning training for very high dimesional models

2022-05-28 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-27826: -- Description: There is limited support for training high dimensional machine learning models

[jira] [Updated] (FLINK-27826) Support machine learning training for very high dimesional models

2022-05-28 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-27826: -- Summary: Support machine learning training for very high dimesional models (was: Support

[jira] [Created] (FLINK-27826) Support machine learning training for high dimesional models

2022-05-28 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27826: - Summary: Support machine learning training for high dimesional models Key: FLINK-27826 URL: https://issues.apache.org/jira/browse/FLINK-27826 Project: Flink

[GitHub] [flink-table-store] JingsongLi commented on pull request #142: [FLINK-27814] Add an abstraction layer for connectors to read and write row data instead of key-values

2022-05-28 Thread GitBox
JingsongLi commented on PR #142: URL: https://github.com/apache/flink-table-store/pull/142#issuecomment-1140251177 I think the first thing we can do is: We can start with a design document in PR comments which gives a general description of the APIs that the Hive connector needs to use.

[GitHub] [flink-table-store] JingsongLi commented on pull request #142: [FLINK-27814] Add an abstraction layer for connectors to read and write row data instead of key-values

2022-05-28 Thread GitBox
JingsongLi commented on PR #142: URL: https://github.com/apache/flink-table-store/pull/142#issuecomment-1140250702 Thanks @tsreaper for the contribution. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] flinkbot commented on pull request #19839: [FLINK-27825][docs] Update the doc of aligned checkpoint timeout

2022-05-28 Thread GitBox
flinkbot commented on PR #19839: URL: https://github.com/apache/flink/pull/19839#issuecomment-1140227893 ## CI report: * b3537b67138f8db6d8501fd56c4c892da8f4ce98 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27825) Update the doc of aligned checkpoint timeout

2022-05-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27825: --- Labels: pull-request-available (was: ) > Update the doc of aligned checkpoint timeout >

[GitHub] [flink] 1996fanrui opened a new pull request, #19839: [FLINK-27825][docs] Update the doc of aligned checkpoint timeout

2022-05-28 Thread GitBox
1996fanrui opened a new pull request, #19839: URL: https://github.com/apache/flink/pull/19839 ## What is the purpose of the change Update the doc of aligned checkpoint timeout. ## Brief change log Update the doc of aligned checkpoint timeout. ## Verifying this

[jira] [Created] (FLINK-27825) Update the doc of aligned checkpoint timeout

2022-05-28 Thread fanrui (Jira)
fanrui created FLINK-27825: -- Summary: Update the doc of aligned checkpoint timeout Key: FLINK-27825 URL: https://issues.apache.org/jira/browse/FLINK-27825 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #19838: [hotfix][network] Fix the typo about subpartition

2022-05-28 Thread GitBox
flinkbot commented on PR #19838: URL: https://github.com/apache/flink/pull/19838#issuecomment-1140220924 ## CI report: * c485ba2af7e2d57513a850c24f3b11fbf1e60a2f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] 1996fanrui opened a new pull request, #19838: [hotfix][network] Fix the typo about subpartition

2022-05-28 Thread GitBox
1996fanrui opened a new pull request, #19838: URL: https://github.com/apache/flink/pull/19838 ## What is the purpose of the change Fix the typo about subpartition ## Brief change log Fix the typo about subpartition ## Verifying this change This change is a

[jira] [Created] (FLINK-27824) Implement Pyflink KeyedSchema

2022-05-28 Thread Zixuan Rao (Jira)
Zixuan Rao created FLINK-27824: -- Summary: Implement Pyflink KeyedSchema Key: FLINK-27824 URL: https://issues.apache.org/jira/browse/FLINK-27824 Project: Flink Issue Type: Improvement

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Description: Hi, community When I build up a standalone job to read from kafka topic and sink

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Attachment: image-2022-05-28-15-35-02-186.png > Standalone Job continously restart by illegal

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Attachment: image-2022-05-28-15-35-23-708.png > Standalone Job continously restart by illegal

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Attachment: image-2022-05-28-15-35-09-874.png > Standalone Job continously restart by illegal

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Description: Hi, community When I build up a standalone job to read from kafka topic and sink

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Attachment: image-2022-05-28-15-34-46-698.png > Standalone Job continously restart by illegal

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Attachment: image-2022-05-28-15-34-23-397.png > Standalone Job continously restart by illegal

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Attachment: image-2022-05-28-15-33-04-632.png > Standalone Job continously restart by illegal

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

2022-05-28 Thread suheng.cloud (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] suheng.cloud updated FLINK-27823: - Description: Hi, community When I build up a standalone job to read from kafka topic and sink

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

2022-05-28 Thread suheng.cloud (Jira)
suheng.cloud created FLINK-27823: Summary: Standalone Job continously restart by illegal checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink Key: FLINK-27823 URL: