Re: [PR] Show correct float metric value on flink UI. [flink]

2024-04-20 Thread via GitHub
luocan17 commented on PR #24693: URL: https://github.com/apache/flink/pull/24693#issuecomment-2067912716 @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 comment.

Re: [PR] Show correct float metric value on flink UI. [flink]

2024-04-20 Thread via GitHub
flinkbot commented on PR #24693: URL: https://github.com/apache/flink/pull/24693#issuecomment-2067879789 ## CI report: * 0c152dc813def8df2ae89d56c4f4900be0325b63 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] Show correct float metric value show on flink UI. [flink]

2024-04-20 Thread via GitHub
luocan17 opened a new pull request, #24693: URL: https://github.com/apache/flink/pull/24693 ## What is the purpose of the change This PR makes flink ui show float metric value correctly. Before this PR: (`outPoolUsage` always 0 or 1)

[jira] [Created] (FLINK-35183) Expose FlinkMinorVersion as metric for applications in operator

2024-04-20 Thread Jira
Márton Balassi created FLINK-35183: -- Summary: Expose FlinkMinorVersion as metric for applications in operator Key: FLINK-35183 URL: https://issues.apache.org/jira/browse/FLINK-35183 Project: Flink

[jira] [Updated] (FLINK-32315) Support local file upload in K8s mode

2024-04-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-32315: --- Fix Version/s: 1.20.0 > Support local file upload in K8s mode >

[jira] [Closed] (FLINK-32315) Support local file upload in K8s mode

2024-04-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-32315. -- Resolution: Fixed

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-04-20 Thread via GitHub
mbalassi merged PR #24303: URL: https://github.com/apache/flink/pull/24303 -- 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:

[jira] [Resolved] (FLINK-28048) Introduce Source API alternative to FiniteTestSource

2024-04-20 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-28048. -- Fix Version/s: 1.20.0 Resolution: Implemented > Introduce Source API alternative to

Re: [PR] [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source [flink-connector-jdbc]

2024-04-20 Thread via GitHub
RocMarshal closed pull request #117: [FLINK-33463][Connector/JDBC] Support the implementation of dynamic source tables based on the new source URL: https://github.com/apache/flink-connector-jdbc/pull/117 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector

2024-04-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35182: --- Labels: pull-request-available (was: ) > Bump org.apache.commons:commons-compress from

[jira] [Created] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector

2024-04-20 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35182: --- Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector Key: FLINK-35182 URL: https://issues.apache.org/jira/browse/FLINK-35182

Re: [PR] [hotfix] Polish ci concurrency group [flink-cdc]

2024-04-20 Thread via GitHub
GOODBOY008 commented on PR #3241: URL: https://github.com/apache/flink-cdc/pull/3241#issuecomment-2067678410 @leonardBang @Jiabao-Sun PTAL -- 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

[PR] [hotfix] Polish ci concurrency group [flink-cdc]

2024-04-20 Thread via GitHub
GOODBOY008 opened a new pull request, #3241: URL: https://github.com/apache/flink-cdc/pull/3241 Changes: - Avoid canceling ci in branch. ![1713620429122](https://github.com/apache/flink-cdc/assets/13617900/a3def071-5ac1-47ac-9ff0-453ac68f68eb) -- This is an automated message

[jira] [Closed] (FLINK-35181) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong closed FLINK-35181. --- Resolution: Fixed > Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for

[jira] [Updated] (FLINK-35181) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35181: Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink

[jira] [Updated] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35181: Fix Version/s: (was: rabbitmq-3.1.0) > CLONE - Bump

[jira] [Updated] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35181: Labels: (was: pull-request-available) > CLONE - Bump

[jira] [Updated] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35181: Description: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink

[jira] [Updated] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35181: Component/s: Connectors / ElasticSearch (was: Connectors/ RabbitMQ)

[jira] [Created] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector

2024-04-20 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35181: --- Summary: CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector Key: FLINK-35181 URL:

[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

2024-04-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35173: --- Labels: CDC pull-request-available (was: CDC) > Debezium for Mysql connector Custom Time

[PR] Draft : [FLINK-35173] Debezium for Mysql connector Custom Time Serializer [flink-cdc]

2024-04-20 Thread via GitHub
czy006 opened a new pull request, #3240: URL: https://github.com/apache/flink-cdc/pull/3240 Currently, Flink CDC Time encounters time type errors (including DateTime, Time, Date, TimeStamp) when using MySQL Connector (JsonDebeziumDeserializationSchema) as deserialization, and the converted

[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

2024-04-20 Thread ZhengYu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhengYu Chen updated FLINK-35173: - Summary: Debezium for Mysql connector Custom Time Serializer (was: Debezium Custom Time

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python thread mode

2024-04-20 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Summary: Instant in row doesn't convert to correct type in python thread mode (was: Instant in row

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

2024-04-20 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Description: {code:java} from pyflink.datastream import StreamExecutionEnvironment from pyflink.common

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

2024-04-20 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Description: {code:java} from pyflink.datastream import StreamExecutionEnvironment from pyflink.common

[jira] [Updated] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

2024-04-20 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Yuan updated FLINK-35180: - Description: use  ``` from pyflink.datastream import StreamExecutionEnvironment from pyflink.common

[jira] [Created] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode

2024-04-20 Thread Wei Yuan (Jira)
Wei Yuan created FLINK-35180: Summary: Instant in row doesn't convert to correct type in python process mode Key: FLINK-35180 URL: https://issues.apache.org/jira/browse/FLINK-35180 Project: Flink

[jira] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

2024-04-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33463 ] RocMarshal deleted comment on FLINK-33463: was (Author: rocmarshal): The ticket is mainly to do the three items: 1. Support the implementation of dynamic source/factories tables based on the

[jira] [Created] (FLINK-35179) add postgres pipeline data sink connector

2024-04-20 Thread melin (Jira)
melin created FLINK-35179: - Summary: add postgres pipeline data sink connector Key: FLINK-35179 URL: https://issues.apache.org/jira/browse/FLINK-35179 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

2024-04-20 Thread elon_X (Jira)
elon_X created FLINK-35178: -- Summary: Checkpoint CLAIM mode does not fully control snapshot ownership Key: FLINK-35178 URL: https://issues.apache.org/jira/browse/FLINK-35178 Project: Flink Issue

[jira] [Updated] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks

2024-04-20 Thread elon_X (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35160: --- Attachment: image-2024-04-20-14-43-36-939.png Description: After receiving feedback from the business

[jira] [Updated] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks

2024-04-20 Thread elon_X (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] elon_X updated FLINK-35160: --- Attachment: (was: image-2024-04-18-21-00-04-532.png) > Support for Thread Dump provides a convenient

[jira] [Commented] (FLINK-35144) Support various sources sync for FlinkCDC in one pipeline

2024-04-20 Thread melin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839198#comment-17839198 ] melin commented on FLINK-35144: --- Yes, the business system database consists of multiple database