Au-Miner opened a new pull request, #25789:
URL: https://github.com/apache/flink/pull/25789
## What is the purpose of the change
Introduce GroupTableAggFunction in GroupTableAggregate with async state api.
## Brief change log
- *Introduce GroupTableAggFunction in GroupT
Au-Miner closed pull request #25789: [FLINK-36881][table] Introduce
GroupTableAggFunction in GroupTableAggregate with Async State API
URL: https://github.com/apache/flink/pull/25789
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-31880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929393#comment-17929393
]
Kurt Ostfeld commented on FLINK-31880:
--
[~dsaisharath] One of the project leads sai
gyfora opened a new pull request, #775:
URL: https://github.com/apache/flink-web/pull/775
(no comment)
--
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-mai
MOBIN-F commented on code in PR #3791:
URL: https://github.com/apache/flink-cdc/pull/3791#discussion_r1966507311
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java:
weigphf opened a new pull request, #3930:
URL: https://github.com/apache/flink-cdc/pull/3930
[…tion](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-37369?filter=allissues)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-37369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37369:
---
Labels: pull-request-available (was: )
> Flink CDC OceanBase Connector Throws Exception for
morozov opened a new pull request, #3929:
URL: https://github.com/apache/flink-cdc/pull/3929
There are two problems in the code:
1. The table name passed to `to_regclass()` isn't quoted, so the upper-case
letters get lower-cased.
2. The column names used in snapshot queries aren't quot
flinkbot commented on PR #26193:
URL: https://github.com/apache/flink/pull/26193#issuecomment-2676136976
## CI report:
* bf6ffb43b61d7a9c43c080c7ce995db0426bf004 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929332#comment-17929332
]
caixiaowei commented on FLINK-37369:
Looks like the TableSchemaBuilder used in Ocean
[
https://issues.apache.org/jira/browse/FLINK-37369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caixiaowei updated FLINK-37369:
---
Language: java
> Flink CDC OceanBase Connector Throws Exception for Column DEFAULT VALUE
> CURRENT_
slfan1989 opened a new pull request, #26193:
URL: https://github.com/apache/flink/pull/26193
## What is the purpose of the change
I noticed a small issue while reading the code. The entire unit test is
written using JUnit 5 syntax, but this class uses JUnit 4 import. I think w
[
https://issues.apache.org/jira/browse/FLINK-37371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37371:
---
Labels: pull-request-available (was: )
> Postgres CDC incremental source fails to handle up
morozov closed pull request #3552: [FLINK-36086] Set isSnapshotCompleted only
immediately after snapshot
URL: https://github.com/apache/flink-cdc/pull/3552
--
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
Sergei Morozov created FLINK-37371:
--
Summary: Postgres CDC incremental source fails to handle
upper-case table and column names
Key: FLINK-37371
URL: https://issues.apache.org/jira/browse/FLINK-37371
15 matches
Mail list logo
