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.
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`
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)
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
[
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
>
[
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
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:
[
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
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,
[
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
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
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
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
[
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
[
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
[
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
[
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
[
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
[
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)
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:
[
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
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
[
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
[
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
[
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
[
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
[
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
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
[ 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
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
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
[
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
[
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
[
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
34 matches
Mail list logo