[jira] [Commented] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876403#comment-17876403 ] Feng Jin commented on FLINK-36131: -- {color:#00}[~Shixiaolin] What version of the Ka

[jira] [Commented] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876402#comment-17876402 ] Feng Jin commented on FLINK-36131: -- !截屏2024-08-24 14.01.51.png!   {color:#00}{col

[jira] [Updated] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jin updated FLINK-36131: - Attachment: 截屏2024-08-24 14.01.51.png > FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display

Re: [PR] [FLINK-23598] [core] Fix a bug that caused position to be updated twice when writing a string to a byte array [flink]

2024-08-23 Thread via GitHub
all-cloudz commented on PR #23563: URL: https://github.com/apache/flink/pull/23563#issuecomment-2308142995 I added code to move the position in the same way as the existing DataOutputSerializer code and ran the test. The following error occurred, which was due to moving the position multipl

Re: [PR] [FLINK-14068] Removes org.apache.flink.api.common.time.Time [flink]

2024-08-23 Thread via GitHub
XComp commented on PR #25250: URL: https://github.com/apache/flink/pull/25250#issuecomment-2308140923 ``` $ find . -name "*.java" | xargs sed -i 's/import org.apache.flink.api.common.time.Time;/import java.time.Duration;/g' ``` -- This is an automated message from the Apache Git Ser

Re: [PR] [FLINK-36148][pipeline-connector][mysql] Add custom parser for CreateTableEvent [flink-cdc]

2024-08-23 Thread via GitHub
lvyanquan commented on PR #3570: URL: https://github.com/apache/flink-cdc/pull/3570#issuecomment-2308030485 A follow up of https://github.com/apache/flink-cdc/pull/3560. @leonardBang PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please l

[jira] [Updated] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36148: --- Labels: pull-request-available (was: ) > Support parsing DDL to new CreateTableEvent in bin

[PR] [FLINK-36148][pipeline-connector][mysql] Add custom parser for CreateTableEvent [flink-cdc]

2024-08-23 Thread via GitHub
lvyanquan opened a new pull request, #3570: URL: https://github.com/apache/flink-cdc/pull/3570 Support parsing table creation ddl and creating CreateTableEvent in Binlog reading phase. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

2024-08-23 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876398#comment-17876398 ] LvYanquan commented on FLINK-36148: --- I'm willing to fix this. > Support parsing DDL t

[jira] [Created] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase.

2024-08-23 Thread LvYanquan (Jira)
LvYanquan created FLINK-36148: - Summary: Support parsing DDL to new CreateTableEvent in binlog reading phase. Key: FLINK-36148 URL: https://issues.apache.org/jira/browse/FLINK-36148 Project: Flink

Re: [PR] [FLINK-26943][table] Add the built-in function DATE_ADD [flink]

2024-08-23 Thread via GitHub
superdiaodiao commented on code in PR #24988: URL: https://github.com/apache/flink/pull/24988#discussion_r1729656998 ## docs/data/sql_functions.yml: ## @@ -653,6 +653,16 @@ temporal: CURRENT_WATERMARK(ts) IS NULL OR ts > CURRENT_WATERMARK(ts) ``` + - sq

Re: [PR] [FLINK-14068] Removes org.apache.flink.api.common.time.Time [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25250: URL: https://github.com/apache/flink/pull/25250#issuecomment-2307865783 ## CI report: * d646f5bc38200904b5c520bcd7c54164b8619c83 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-14068) Use Java's Duration instead of Flink's Time

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14068: --- Labels: 2.0-related pull-request-available (was: 2.0-related) > Use Java's Duration instead

[PR] [FLINK-14068] Removes Time classes [flink]

2024-08-23 Thread via GitHub
XComp opened a new pull request, #25250: URL: https://github.com/apache/flink/pull/25250 ## What is the purpose of the change Removes deprecated `Time` classes as part of the 2.0 efforts. ## Brief change log * Removes APIs related to `org.apache.flink.api.common.time.Tim

Re: [PR] [FLINK-36147][runtime] Removes deprecated location field [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25249: URL: https://github.com/apache/flink/pull/25249#issuecomment-2307795014 ## CI report: * 33a169e843cf685e72b15230011519bef457db96 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-14068) Use Java's Duration instead of Flink's Time

2024-08-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-14068: - Assignee: Matthias Pohl > Use Java's Duration instead of Flink's Time > ---

[PR] [FLINK-36147][runtime] Removes deprecated location field [flink]

2024-08-23 Thread via GitHub
XComp opened a new pull request, #25249: URL: https://github.com/apache/flink/pull/25249 ## What is the purpose of the change Removes deprecated field "location". It was replaced by the "endpoint" field in 1.19. ## Verifying this change This change is a trivial rework /

[jira] [Updated] (FLINK-36147) Removes deprecated location field

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36147: --- Labels: pull-request-available (was: ) > Removes deprecated location field > --

[jira] [Created] (FLINK-36147) Removes deprecated location field

2024-08-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36147: - Summary: Removes deprecated location field Key: FLINK-36147 URL: https://issues.apache.org/jira/browse/FLINK-36147 Project: Flink Issue Type: Technical Deb

[jira] [Assigned] (FLINK-32688) Remove deprecated exception history fields

2024-08-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-32688: - Assignee: Matthias Pohl > Remove deprecated exception history fields >

Re: [PR] [FLINK-32688][runtime] Removes deprecated JobExceptionsInfo. [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25248: URL: https://github.com/apache/flink/pull/25248#issuecomment-2307767888 ## CI report: * 036741f3c912393289cff1d213c6e690629b212f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-32688][runtime] Removes deprecated JobExceptionsInfo. [flink]

2024-08-23 Thread via GitHub
XComp opened a new pull request, #25248: URL: https://github.com/apache/flink/pull/25248 ## What is the purpose of the change Removes deprecated class `JobExceptionsInfo` as part of the 2.0 changes. ## Verifying this change This change is a trivial rework / code cleanup w

[jira] [Updated] (FLINK-32688) Remove deprecated exception history fields

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32688: --- Labels: 2.0-related pull-request-available (was: 2.0-related) > Remove deprecated exception

Re: [PR] [FLINK-35709][Table SQL / API] Allow defining a schema in REPLACE TABLE AS (RTAS) [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25247: URL: https://github.com/apache/flink/pull/25247#issuecomment-2307651013 ## CI report: * a3b134c444aaa07e0cd513db2b3bdd9d218865d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35708][Table SQL / API] Allow defining a schema in REPLACE TABLE AS (RTAS) [flink]

2024-08-23 Thread via GitHub
spena commented on PR #25237: URL: https://github.com/apache/flink/pull/25237#issuecomment-2307613670 Closing this and replace this PR for https://github.com/apache/flink/pull/25247 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] [FLINK-35708][Table SQL / API] Allow defining a schema in REPLACE TABLE AS (RTAS) [flink]

2024-08-23 Thread via GitHub
spena closed pull request #25237: [FLINK-35708][Table SQL / API] Allow defining a schema in REPLACE TABLE AS (RTAS) URL: https://github.com/apache/flink/pull/25237 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Updated] (FLINK-35709) Allow reordering source column names in CTAS / RTAS

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35709: --- Labels: pull-request-available (was: ) > Allow reordering source column names in CTAS / RTA

[PR] [FLINK-35709][Table SQL / API] Allow defining a schema in REPLACE TABLE AS (RTAS) [flink]

2024-08-23 Thread via GitHub
spena opened a new pull request, #25247: URL: https://github.com/apache/flink/pull/25247 ## What is the purpose of the change Allow defining new columns and/or overriding source column types in the CREATE clause on RTAS statements. Syntax supported: ``` CREATE OR REPLACE

[jira] [Created] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

2024-08-23 Thread Jira
Kim Gräsman created FLINK-36146: --- Summary: NoSuchElement exception from SingleThreadFetcherManager Key: FLINK-36146 URL: https://issues.apache.org/jira/browse/FLINK-36146 Project: Flink Issue T

[jira] [Created] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

2024-08-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-36145: -- Summary: Change JobSpec.flinkStateSnapshotReference to snapshotReference Key: FLINK-36145 URL: https://issues.apache.org/jira/browse/FLINK-36145 Project: Flink

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

2024-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876296#comment-17876296 ] Gyula Fora commented on FLINK-36145: What do you think [~mateczagany] ? > Change Jo

[jira] [Commented] (FLINK-36138) KinesisStreamsSource.build() should have helpful null errors

2024-08-23 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876287#comment-17876287 ] Ahmed Hamdy commented on FLINK-36138: - This sounds like a good addition for debuggin

[jira] [Closed] (FLINK-35482) ParquetInt64TimestampReaderTest unit tests fail due to system timezone

2024-08-23 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-35482. Resolution: Fixed [{{4faf096}}|https://github.com/apache/flink/commit/4faf0966766e3734792f80ed66e5

Re: [PR] [BP-1.19][FLINK-35482] ParquetInt64TimestampReaderTest unit tests fail due to system timezone [flink]

2024-08-23 Thread via GitHub
ferenc-csaky merged PR #25240: URL: https://github.com/apache/flink/pull/25240 -- 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 comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

Re: [PR] [BP-1.20][FLINK-35482] ParquetInt64TimestampReaderTest unit tests fail due to system timezone [flink]

2024-08-23 Thread via GitHub
ferenc-csaky merged PR #25241: URL: https://github.com/apache/flink/pull/25241 -- 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 comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

Re: [PR] [FLINK-35482] ParquetInt64TimestampReaderTest unit tests fail due to system timezone [flink]

2024-08-23 Thread via GitHub
ferenc-csaky merged PR #25239: URL: https://github.com/apache/flink/pull/25239 -- 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 comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

Re: [PR] [BP-1.20][FLINK-35482] ParquetInt64TimestampReaderTest unit tests fail due to system timezone [flink]

2024-08-23 Thread via GitHub
ferenc-csaky commented on PR #25241: URL: https://github.com/apache/flink/pull/25241#issuecomment-2307215916 Backport of https://github.com/apache/flink/pull/25239 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [BP-1.19][FLINK-35482] ParquetInt64TimestampReaderTest unit tests fail due to system timezone [flink]

2024-08-23 Thread via GitHub
ferenc-csaky commented on PR #25240: URL: https://github.com/apache/flink/pull/25240#issuecomment-2307215472 Backport of https://github.com/apache/flink/pull/25239 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-34440][formats][protobuf-confluent] Protobuf confluent dynamic format [flink]

2024-08-23 Thread via GitHub
dmariassy commented on PR #25114: URL: https://github.com/apache/flink/pull/25114#issuecomment-2307175349 @rmetzger , do you think you could provide feedback? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] REVERT (1.20 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25246: URL: https://github.com/apache/flink/pull/25246#issuecomment-2307058742 ## CI report: * 829a0d5710b9915a3065b889d812bfe22c6f5412 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] REVERT (1.19 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25245: URL: https://github.com/apache/flink/pull/25245#issuecomment-2307049472 ## CI report: * 9094d88a8328797fb574d1e36cc79c1ce9ac65c6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] (1.19 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]

2024-08-23 Thread via GitHub
pnowojski commented on code in PR #25223: URL: https://github.com/apache/flink/pull/25223#discussion_r1728928197 ## pom.xml: ## @@ -2355,6 +2355,10 @@ under the License. @org.apache.flink.annotation.Experimental

Re: [PR] [FLINK-36124][filesystem][s3]Make S3RecoverableFsDataOutputStream.sync not to close the stream [flink]

2024-08-23 Thread via GitHub
gaborgsomogyi commented on PR #25231: URL: https://github.com/apache/flink/pull/25231#issuecomment-2307004974 @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 comm

Re: [PR] [FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType [flink-cdc]

2024-08-23 Thread via GitHub
SML0127 commented on PR #3529: URL: https://github.com/apache/flink-cdc/pull/3529#issuecomment-2306962421 > @ruanhang1993 PTAL > > some cheks was timed out https://private-user-images.githubusercontent.com/13589283/356863255-4861dfeb-7013-4f21-9f53-badae0b39b9a.png?jwt=eyJhbGciOiJIUzI1

[jira] [Resolved] (FLINK-36096) Add synchronous interfaces for State V2 API.

2024-08-23 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36096. - Fix Version/s: 2.0.0 Resolution: Fixed > Add synchronous interfaces for State V2 API. > -

[jira] [Commented] (FLINK-36096) Add synchronous interfaces for State V2 API.

2024-08-23 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876232#comment-17876232 ] Zakelly Lan commented on FLINK-36096: - Merged into master via 825ed857efbb11a45032eb

[jira] [Updated] (FLINK-36139) ClassCastException when checkpointing AggregateFunction that implements ResultTypeQueryable interface

2024-08-23 Thread Vladislav Keda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Keda updated FLINK-36139: --- Summary: ClassCastException when checkpointing AggregateFunction that implements ResultTypeQ

Re: [PR] [FLINK-36096] Add synchronous interfaces for State V2 API. [flink]

2024-08-23 Thread via GitHub
Zakelly commented on PR #25221: URL: https://github.com/apache/flink/pull/25221#issuecomment-2306829173 Merged. -- 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 comment. To unsubscri

Re: [PR] [FLINK-36096] Add synchronous interfaces for State V2 API. [flink]

2024-08-23 Thread via GitHub
Zakelly closed pull request #25221: [FLINK-36096] Add synchronous interfaces for State V2 API. URL: https://github.com/apache/flink/pull/25221 -- 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 spe

[jira] [Commented] (FLINK-36139) ClassCastException when checkpointing AggregateFunction

2024-08-23 Thread Vladislav Keda (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876231#comment-17876231 ] Vladislav Keda commented on FLINK-36139: It seems that problem happens because o

[jira] [Commented] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2024-08-23 Thread Ammu Parvathy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876228#comment-17876228 ] Ammu Parvathy commented on FLINK-24494: --- [~mahen] I can see a similar issue FLINK-

[jira] [Commented] (FLINK-33129) Can't create RowDataToAvroConverter for LocalZonedTimestampType logical type

2024-08-23 Thread Ammu Parvathy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876226#comment-17876226 ] Ammu Parvathy commented on FLINK-33129: --- I can see the missing switch clause menti

Re: [PR] [FLINK-36124][filesystem][s3]Make S3RecoverableFsDataOutputStream.sync not to close the stream [flink]

2024-08-23 Thread via GitHub
gaborgsomogyi commented on PR #25231: URL: https://github.com/apache/flink/pull/25231#issuecomment-2306744305 Just resolved the conflict. -- 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 speci

[jira] [Comment Edited] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876218#comment-17876218 ] zhongyuandong edited comment on FLINK-36141 at 8/23/24 9:54 AM: --

Re: [PR] [FLINK-34467] bump flink version to 1.20.0 [flink-connector-kafka]

2024-08-23 Thread via GitHub
AHeise commented on PR #111: URL: https://github.com/apache/flink-connector-kafka/pull/111#issuecomment-2306726495 > hope the community can support Flink version 1.16 due to the issue [FLINK-28303](https://issues.apache.org/jira/browse/FLINK-28303). I don't think this is related to t

Re: [PR] [FLINK-36115][pipeline-connector][mysql] add scan.incremental.newly-added-table.enabled option [flink-cdc]

2024-08-23 Thread via GitHub
zhongyuandong commented on code in PR #3560: URL: https://github.com/apache/flink-cdc/pull/3560#discussion_r1728568326 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory

[jira] [Comment Edited] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876218#comment-17876218 ] zhongyuandong edited comment on FLINK-36141 at 8/23/24 9:49 AM: --

[jira] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141 ] zhongyuandong deleted comment on FLINK-36141: --- was (Author: JIRAUSER306741): Is flink-cdc 3.4.0 only supported? When will it be used?[~kunni]  > [mysql]Set the scanNewlyAddedTableEnabled i

[jira] [Comment Edited] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876215#comment-17876215 ] zhongyuandong edited comment on FLINK-36141 at 8/23/24 9:42 AM: --

[jira] [Commented] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876218#comment-17876218 ] zhongyuandong commented on FLINK-36141: --- [~kunni] Is flink-cdc 3.4.0 only supporte

[jira] [Updated] (FLINK-35584) Support Java 21 in flink-docker

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35584: --- Labels: pull-request-available (was: ) > Support Java 21 in flink-docker >

Re: [PR] [FLINK-36119] Conditionally interfaces for StateFuture [flink]

2024-08-23 Thread via GitHub
flinkbot commented on PR #25244: URL: https://github.com/apache/flink/pull/25244#issuecomment-2306709535 ## CI report: * cbf01a2d20076de2728315e127116f3d89073b85 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36119) Conditional branchings APIs under `StateFuture`

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36119: --- Labels: pull-request-available (was: ) > Conditional branchings APIs under `StateFuture` >

[PR] [FLINK-36119] Conditionally interfaces for StateFuture [flink]

2024-08-23 Thread via GitHub
Zakelly opened a new pull request, #25244: URL: https://github.com/apache/flink/pull/25244 ## What is the purpose of the change As described in FLIP-455, this PR provides some interface for conditional branchings under `StateFuture` ## Brief change log - Add interface i

[jira] [Commented] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876215#comment-17876215 ] zhongyuandong commented on FLINK-36141: --- Is flink-cdc 3.4.0 only supported? When w

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
RocMarshal commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728680918 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java: ## @@ -104,6 +135,49 @@ public

Re: [PR] [FLINK-34467] bump flink version to 1.20.0 [flink-connector-kafka]

2024-08-23 Thread via GitHub
taiziwang commented on PR #111: URL: https://github.com/apache/flink-connector-kafka/pull/111#issuecomment-2306667250 hope the community can support Flink version 1.16 due to the issue FLINK-28303. -- This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Updated] (FLINK-36143) Sink ES occurred "version conflict"

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36143: --- Labels: pull-request-available (was: ) > Sink ES occurred "version conflict" >

Re: [PR] [FLINK-36143][ES6][ES7] Intro retry-on-conflict param to resolve Sink ES occurred "version conflict" [flink-connector-elasticsearch]

2024-08-23 Thread via GitHub
boring-cyborg[bot] commented on PR #109: URL: https://github.com/apache/flink-connector-elasticsearch/pull/109#issuecomment-2306651224 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) --

[jira] [Commented] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread mumu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876205#comment-17876205 ] mumu commented on FLINK-36131: -- [~hackergin]  Thank you for your reply. I searched for 'Cu

[jira] [Updated] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread mumu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mumu updated FLINK-36131: - Attachment: image-2024-08-23-16-42-27-450.png > FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display

[jira] [Updated] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore

2024-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35444: --- Labels: pull-request-available (was: ) > Paimon Pipeline Connector support changing column

[PR] [FLINK-35444][pipeline-connector][paimon] Paimon Pipeline Connector support changing column names to lowercase for Hive metastore [flink-cdc]

2024-08-23 Thread via GitHub
kyzheng196 opened a new pull request, #3569: URL: https://github.com/apache/flink-cdc/pull/3569 Hive metastore Require column names to be lowercase, but field names from upstream tables may not meet the requirements. I've transferred the columnname into lowercase and tested the case with

[jira] [Closed] (FLINK-36144) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread mumu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mumu closed FLINK-36144. Resolution: Duplicate > FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data > --

Re: [PR] [FLINK-36115][pipeline-connector][mysql] add scan.incremental.newly-added-table.enabled option [flink-cdc]

2024-08-23 Thread via GitHub
zhongyuandong commented on code in PR #3560: URL: https://github.com/apache/flink-cdc/pull/3560#discussion_r1728568326 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory

[jira] [Created] (FLINK-36144) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-23 Thread mumu (Jira)
mumu created FLINK-36144: Summary: FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data Key: FLINK-36144 URL: https://issues.apache.org/jira/browse/FLINK-36144 Project: Flink Issue

Re: [PR] [FLINK-36115][pipeline-connector][mysql] add scan.incremental.newly-added-table.enabled option [flink-cdc]

2024-08-23 Thread via GitHub
zhongyuandong commented on code in PR #3560: URL: https://github.com/apache/flink-cdc/pull/3560#discussion_r1728568326 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory

[jira] [Closed] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

2024-08-23 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-27146. Resolution: Fixed [{{a451edd}}|https://github.com/apache/flink/commit/a451edd33894092e43505bb8c497

[jira] [Commented] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876200#comment-17876200 ] LvYanquan commented on FLINK-36141: --- Thanks for reporting this, fixed in https://gith

Re: [PR] [FLINK-27146] [Filesystem] Migrate to Junit5 [flink]

2024-08-23 Thread via GitHub
ferenc-csaky merged PR #22789: URL: https://github.com/apache/flink/pull/22789 -- 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 comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

[jira] [Assigned] (FLINK-35890) Select only the increment but still enter the SNAPSHOT,lead

2024-08-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35890: -- Assignee: sanqingleo > Select only the increment but still enter the SNAPSHOT,lead > ---

[jira] [Created] (FLINK-36143) Sink ES occurred "version conflict"

2024-08-23 Thread sanqingleo (Jira)
sanqingleo created FLINK-36143: -- Summary: Sink ES occurred "version conflict" Key: FLINK-36143 URL: https://issues.apache.org/jira/browse/FLINK-36143 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table

2024-08-23 Thread zhongyuandong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhongyuandong updated FLINK-36141: -- Summary: [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic cap

[jira] [Updated] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

2024-08-23 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-27146: - Fix Version/s: 2.0.0 > [JUnit5 Migration] Module: flink-filesystems > --

Re: [PR] [FLINK-35266][snapshot] Add E2E tests for FlinkStateSnapshot [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
gyfora commented on PR #862: URL: https://github.com/apache/flink-kubernetes-operator/pull/862#issuecomment-2306481491 This PR needs to be updated since a recent change on main -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-33803) Add observedGeneration to Operator's status spec

2024-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876196#comment-17876196 ] Gyula Fora commented on FLINK-33803: a10fb4501011be4e88fb6164156e3b9e8527950e > Add

[jira] [Closed] (FLINK-36110) Periodic save points trigger continuously

2024-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36110. -- Resolution: Fixed merged to main 0ef627edf001b56aac7d57ea8839546d7ed87681 > Periodic save points trig

Re: [PR] [FLINK-36110][snapshot] Store periodic snapshot trigger timestamps in memory [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
gyfora merged PR #868: URL: https://github.com/apache/flink-kubernetes-operator/pull/868 -- 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 comment. To unsubscribe, e-mail: issues-unsubscr

Re: [PR] [FLINK-33803] Remove deprecated `lastReconciledSpec` meta generation in favour of `observedGeneration` [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
gyfora merged PR #834: URL: https://github.com/apache/flink-kubernetes-operator/pull/834 -- 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 comment. To unsubscribe, e-mail: issues-unsubscr

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
RocMarshal commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728491235 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java: ## @@ -104,6 +135,49 @@ public

[jira] [Assigned] (FLINK-36140) Log a warning when pods are terminated by kubernetes

2024-08-23 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36140: - Assignee: Clara Xiong > Log a warning when pods are terminated by kubernetes >

Re: [PR] [FLINK-36140] Log a warning when pods are terminated by kubernetes [flink]

2024-08-23 Thread via GitHub
gaborgsomogyi commented on PR #25242: URL: https://github.com/apache/flink/pull/25242#issuecomment-2306470908 Unless there are further comments I'm intended to merge this on Monday. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[jira] [Resolved] (FLINK-36129) Autoscaler is compatible with Flink 1.20

2024-08-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36129. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed Merged to main(1.10.0) via: * b26a0f

Re: [PR] [FLINK-36129][autoscaler] Autoscaler is compatible with Flink 1.20 [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
1996fanrui merged PR #869: URL: https://github.com/apache/flink-kubernetes-operator/pull/869 -- 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 comment. To unsubscribe, e-mail: issues-unsu

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
1996fanrui commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728499330 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcEventInteractor.java: ## @@ -152,4 +153,29 @@ protected Lis

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
RocMarshal commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728490124 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcEventInteractor.java: ## @@ -152,4 +153,29 @@ protected Lis

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
RocMarshal commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728491235 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java: ## @@ -104,6 +135,49 @@ public

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
1996fanrui commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728486535 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java: ## @@ -104,6 +135,49 @@ public

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
1996fanrui commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728486535 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java: ## @@ -104,6 +135,49 @@ public

Re: [PR] [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler [flink-kubernetes-operator]

2024-08-23 Thread via GitHub
1996fanrui commented on code in PR #865: URL: https://github.com/apache/flink-kubernetes-operator/pull/865#discussion_r1728485175 ## flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java: ## @@ -104,6 +135,49 @@ public

  1   2   >