[jira] [Updated] (FLINK-32548) Make watermark alignment ready for production use

2023-07-30 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32548: Release Note: The watermark alignment is ready for production since Flink-1.18, which completed a series o

[jira] [Updated] (FLINK-32548) Make watermark alignment ready for production use

2023-07-30 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32548: Release Note: The watermark alignment is ready for production since Flink-1.18, which fixed a series of bu

[GitHub] [flink] lindong28 commented on a diff in pull request #22931: [FLINK-32514] Support configuring checkpointing interval during process backlog

2023-07-30 Thread via GitHub
lindong28 commented on code in PR #22931: URL: https://github.com/apache/flink/pull/22931#discussion_r1278817765 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java: ## @@ -180,8 +186,25 @@ public class CheckpointCoordinator { /** A

[jira] [Commented] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-07-30 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749035#comment-17749035 ] He Wang commented on FLINK-32714: - Hi  [~yangs] , sorry for the late reply. I have submi

[jira] [Updated] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32714: --- Labels: pull-request-available (was: ) > JDBC: Add dialect for OceanBase database > ---

[jira] [Commented] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-07-30 Thread yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749009#comment-17749009 ] yang commented on FLINK-32714: -- Can assgin the issue to me? > JDBC: Add dialect for OceanB

[GitHub] [flink] FangYongs commented on a diff in pull request #23087: [FLINK-32665][format] Support reading null value for csv format

2023-07-30 Thread via GitHub
FangYongs commented on code in PR #23087: URL: https://github.com/apache/flink/pull/23087#discussion_r1278734685 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvToRowDataConverters.java: ## @@ -185,48 +187,57 @@ private CsvToRowDataConverter createConver

[jira] [Created] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-07-30 Thread He Wang (Jira)
He Wang created FLINK-32714: --- Summary: JDBC: Add dialect for OceanBase database Key: FLINK-32714 URL: https://issues.apache.org/jira/browse/FLINK-32714 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-32704) Supports spilling to disk when feedback channel memory buffer is full

2023-07-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32704: --- Labels: pull-request-available (was: ) > Supports spilling to disk when feedback channel me

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

2023-07-30 Thread via GitHub
jiangxin369 opened a new pull request, #248: URL: https://github.com/apache/flink-ml/pull/248 ## What is the purpose of the change Supports spilling to disk when feedback channel memory buffer is full. ## Brief change log - Adds config to allow user to s

[jira] [Commented] (FLINK-32697) When using JDBC to insert data into the oracle database, an error will be reported if the target field is lowercase,

2023-07-30 Thread sunyanyong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748990#comment-17748990 ] sunyanyong commented on FLINK-32697: [~martijnvisser] I am very happy to fix this bu

[GitHub] [flink] flinkbot commented on pull request #23055: historgram

2023-07-30 Thread via GitHub
flinkbot commented on PR #23055: URL: https://github.com/apache/flink/pull/23055#issuecomment-1657296118 ## CI report: * eb5f10170f3518bcc891afa1cbc208b70d0377b4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-32713) Cascade deprecation to non-private methods that reference SourceFunction

2023-07-30 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32713: - Summary: Cascade deprecation to non-private methods that reference SourceFunction Key: FLINK-32713 URL: https://issues.apache.org/jira/browse/FLINK-32713 Pr

[jira] [Commented] (FLINK-32700) Support job drain for Savepoint upgrade mode jobs in Flink Operator

2023-07-30 Thread Talat Uyarer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748908#comment-17748908 ] Talat Uyarer commented on FLINK-32700: -- Our customers are ok to lose data if The jo

[jira] [Updated] (FLINK-32691) Make it possible to use builtin functions without catalog/db set

2023-07-30 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-32691: - Description: # Relative to https://issues.apache.org/jira/browse/FLINK-32584, function lookup fails wit