shiyiky commented on code in PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#discussion_r1654671986
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java:
##
Revie
xuyangzhong opened a new pull request, #24984:
URL: https://github.com/apache/flink/pull/24984
## What is the purpose of the change
*Add doc for syntax DESCRIBE JOB *
## Brief change log
- *add doc for en and zh*
## Verifying this change
This pr is no need
xuyangzhong commented on code in PR #24984:
URL: https://github.com/apache/flink/pull/24984#discussion_r1654746594
##
docs/content/docs/dev/table/sql/describe.md:
##
@@ -26,25 +26,25 @@ under the License.
# DESCRIBE Statements
-DESCRIBE statements are used to describe the s
flinkbot commented on PR #24984:
URL: https://github.com/apache/flink/pull/24984#issuecomment-2191596027
## CI report:
* 9cdced1ce814bc30f779f7c8f55c1ea0b75fcaf6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
whhe commented on code in PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#discussion_r1654752149
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java:
##
@@ -324,11
shiyiky commented on code in PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#discussion_r1654774127
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java:
##
@@ -324
whhe commented on PR #3432:
URL: https://github.com/apache/flink-cdc/pull/3432#issuecomment-2191654815
Thanks for the update, now we know the blocking is caused by two reasons:
1. We did not deal with empty queue.
2. The BinaryLogClient is missing LifecycleListener, or more specificall
lsyldliu opened a new pull request, #24985:
URL: https://github.com/apache/flink/pull/24985
[BP-1.20] [FLINK-35691][table] Fix unexpected behavior of repeated suspend
and resume materialized table
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #24985:
URL: https://github.com/apache/flink/pull/24985#issuecomment-2191682344
## CI report:
* 40bac18a7c025e54ff6c7438b8982d6b76c9597c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu merged PR #24978:
URL: https://github.com/apache/flink/pull/24978
--
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.apac
gliter commented on PR #24986:
URL: https://github.com/apache/flink/pull/24986#issuecomment-2191702558
I would prefer the code be structured a bit differently, mainly by not
creating ArrayList just to be passed as parameter and return stream instead in
`addSplitsForPath` but it have to be
flinkbot commented on PR #24986:
URL: https://github.com/apache/flink/pull/24986#issuecomment-2191696248
## CI report:
* 5cc83326c8958e4795b9d77d11d0c2793ad7366c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gliter opened a new pull request, #24986:
URL: https://github.com/apache/flink/pull/24986
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
gliter commented on PR #24986:
URL: https://github.com/apache/flink/pull/24986#issuecomment-2194649007
@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.
T
loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1657064426
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java
RocMarshal commented on PR #24229:
URL: https://github.com/apache/flink/pull/24229#issuecomment-2194703794
@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
XComp commented on PR #24910:
URL: https://github.com/apache/flink/pull/24910#issuecomment-2194727428
[CI
failure](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60525&view=logs&j=52b61abe-a3cc-5bde-cc35-1bbe89bb7df5&t=54421a62-0c80-5aad-3319-094ff69180bb&l=10037)
du
XComp commented on PR #24910:
URL: https://github.com/apache/flink/pull/24910#issuecomment-2194727822
@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.
To
ztison commented on code in PR #24911:
URL: https://github.com/apache/flink/pull/24911#discussion_r1657013866
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -214,402 +60,49 @@ void reportRestoredCheckpoint(RestoredCheckpoint
empathy87 commented on PR #24991:
URL: https://github.com/apache/flink/pull/24991#issuecomment-2197002034
@Stephen0421, could you, please, look at this issue
https://issues.apache.org/jira/projects/FLINK/issues/FLINK-35698
It seems to be connected to your work. There is a problem Parquet
XComp commented on PR #24912:
URL: https://github.com/apache/flink/pull/24912#issuecomment-2197023625
I addressed the last two comments and rebased the branch to most-recent
version of parent PR #24911 . That way we also have the CI debug commit included
--
This is an automated message fr
jeyhunkarimov closed pull request #24995: [WIP] [FLINK-] [core] WIP
Watermarking
URL: https://github.com/apache/flink/pull/24995
--
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
jeyhunkarimov opened a new pull request, #24995:
URL: https://github.com/apache/flink/pull/24995
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring t
flinkbot commented on PR #24995:
URL: https://github.com/apache/flink/pull/24995#issuecomment-2197770924
## CI report:
* b739e000f1ad7e9ce6f1dcbb3fbd2bfb27016083 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuxiqian commented on code in PR #3430:
URL: https://github.com/apache/flink-cdc/pull/3430#discussion_r1659427878
##
docs/content/docs/developer-guide/contribute-to-flink-cdc.md:
##
@@ -82,3 +83,56 @@ not need a long description.
3. Are the Documentation Updated?
If the pull
yuxiqian commented on code in PR #3430:
URL: https://github.com/apache/flink-cdc/pull/3430#discussion_r1659416389
##
README.md:
##
@@ -27,7 +27,15 @@ full database synchronization, sharding table
synchronization, schema evolution


was successful. I'm gonna go ahead and prepare this
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2205212666
Great, thanks @XComp, @HuangXingBo for the help 👍
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
HuangZhenQiu opened a new pull request, #25012:
URL: https://github.com/apache/flink/pull/25012
## What is the purpose of the change
1. Add Table Lineage Vertex into transformation in planner. The final
LineageGraph is generated from transformation and put into StreamGraph. The
lineage g
flinkbot commented on PR #25012:
URL: https://github.com/apache/flink/pull/25012#issuecomment-2205241298
## CI report:
* ac8b90883eb1bf69b8b0b8bc3611c346ab0f2fc6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gtk96 commented on PR #3324:
URL: https://github.com/apache/flink-cdc/pull/3324#issuecomment-2205263171
cc @leonardBang @ruanhang1993
--
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 specifi
gtk96 commented on code in PR #3030:
URL: https://github.com/apache/flink-cdc/pull/3030#discussion_r1663652660
##
docs/content/connectors/mongodb-cdc(ZH).md:
##
@@ -285,6 +285,13 @@ upstart 流需要一个唯一的密钥,所以我们必须声明 `_id` 作为
是否在快照结束后关闭空闲的 Reader。 此特性需要 flink 版本大于等于 1.14 并且
'ex
gtk96 commented on code in PR #3030:
URL: https://github.com/apache/flink-cdc/pull/3030#discussion_r1663653505
##
docs/content/connectors/mysql-cdc(ZH).md:
##
@@ -202,6 +202,13 @@ Flink SQL> SELECT * FROM orders;
Integer
表快照的块大小(行数),读取表的快照时,捕获的表被拆分为多个块。
showuon commented on PR #24852:
URL: https://github.com/apache/flink/pull/24852#issuecomment-2205288373
@XComp , please help have another look when available. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
XComp commented on PR #24912:
URL: https://github.com/apache/flink/pull/24912#issuecomment-2205289738
The [CI
failure](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=60613)
doesn't seem to be related to this PR. I created FLINK-35748 to cover
mateczagany opened a new pull request, #750:
URL: https://github.com/apache/flink-web/pull/750
(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,
DNCBA opened a new pull request, #25013:
URL: https://github.com/apache/flink/pull/25013
### What is the purpose of the change
-
[FLINK-35747][yarn]Fix ccustomer ‘rest.bind-address' config overwrite by code
### Brief change log
-
[FLINK-35747][yarn]Fix ccust
flinkbot commented on PR #25013:
URL: https://github.com/apache/flink/pull/25013#issuecomment-2205560236
## CI report:
* 4934d88d595f3bd6afc517156608c6206fc4d855 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora merged PR #750:
URL: https://github.com/apache/flink-web/pull/750
--
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.apache
paulh86 commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2205851900
Any updates?
--
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 com
xuyangzhong closed pull request #24241: [FLINK-34315][table-planner]
Temporarily force disabling window join, window rank and window deduplicate
optimization when using session window tvf
URL: https://github.com/apache/flink/pull/24241
--
This is an automated message from the Apache Git Serv
XComp merged PR #24911:
URL: https://github.com/apache/flink/pull/24911
--
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.apache.
whhe commented on PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#issuecomment-2205953828
> Hi, @whhe Thx for the contribution. Would you mind fixing the failed CI
action before the next review ?
Hi @RocMarshal, the CI failure is fixed now. PTAL
--
This is an
XComp commented on PR #24912:
URL: https://github.com/apache/flink/pull/24912#issuecomment-2205962967
Rebased to `master`after base PR #24911 was 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
dawidwys commented on code in PR #749:
URL: https://github.com/apache/flink-web/pull/749#discussion_r1664119375
##
docs/data/additional_components.yml:
##
@@ -33,12 +39,6 @@ flink-shaded-17.0:
source_release_asc_url:
"https://downloads.apache.org/flink/flink-shaded-17.0/flin
liuyongvs opened a new pull request, #25014:
URL: https://github.com/apache/flink/pull/25014
## What is the purpose of the change
A bit reasoning for the change
The reason is that since 1.28.0 (
[CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core
to
jnh5y opened a new pull request, #25015:
URL: https://github.com/apache/flink/pull/25015
## What is the purpose of the change
When FLINK-34268 was initially implemented, FLINK-3367 and FLINK-33805 had
not landed.
## Brief change log
Given that, there were exclusions hard
morazow opened a new pull request, #25016:
URL: https://github.com/apache/flink/pull/25016
## What is the purpose of the change
Integrates Python Wheels build into the GitHub Actions (GHA) nightly
workflow for 1.18 releases.
## Brief change log
- Adds Python Wheels GHA w
morazow opened a new pull request, #25017:
URL: https://github.com/apache/flink/pull/25017
## What is the purpose of the change
Integrates Python Wheels build into the GitHub Actions (GHA) nightly
workflow for 1.19 releases.
## Brief change log
- Adds Python Wheels GHA w
morazow opened a new pull request, #25018:
URL: https://github.com/apache/flink/pull/25018
## What is the purpose of the change
Integrates Python Wheels build into the GitHub Actions (GHA) nightly
workflow for 1.20 releases.
## Brief change log
- Adds Python Wheels GHA w
601 - 700 of 53001 matches
Mail list logo