[
https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910834#comment-17910834
]
Alexander Fedulov commented on FLINK-37025:
---
[~dwysakowicz] we are currently f
[
https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-37025:
--
Fix Version/s: 1.20.2
(was: 1.20.1)
> Periodic SQL watermarks c
[
https://issues.apache.org/jira/browse/FLINK-36735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-36735:
--
Fix Version/s: 1.20.2
(was: 1.20.1)
> SupportsRowLevelUpdate gi
[
https://issues.apache.org/jira/browse/FLINK-36736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910828#comment-17910828
]
Alexander Fedulov commented on FLINK-36736:
---
[~jark] [~luoyuxia] since there a
[
https://issues.apache.org/jira/browse/FLINK-36736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-36736:
--
Fix Version/s: 1.20.2
(was: 1.20.1)
> DynamicTableSink.Context#
ryanvanhuuksloot commented on code in PR #25899:
URL: https://github.com/apache/flink/pull/25899#discussion_r1906115622
##
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.html:
##
@@ -26,6 +25,9 @@
Checkpoint Type:
snuyanzin commented on code in PR #25881:
URL: https://github.com/apache/flink/pull/25881#discussion_r1906158104
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SplitRemoteConditionFromJoinRule.java:
##
@@ -0,0 +1,133 @@
+/*
+ *
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1905955530
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ToTimestampLtzTypeStrategy.java:
##
@@ -20,22 +20,79 @@
import or
yiyutian1 commented on PR #25763:
URL: https://github.com/apache/flink/pull/25763#issuecomment-2576451292
Hi @davidradl, thank you for the thorough check! I appreciate it. I’ve
addressed your comments in the last commit.
Since the PR is functionally intact, thoroughly reviewed, and h
[
https://issues.apache.org/jira/browse/FLINK-37007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910849#comment-17910849
]
Sergey Nuyanzin commented on FLINK-37007:
-
Merged as
[d432dff3a9e2c55ecf6c0af89
[
https://issues.apache.org/jira/browse/FLINK-37007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37007.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> FLIP-494: Add missing createTable/create
github-actions[bot] commented on PR #3441:
URL: https://github.com/apache/flink-cdc/pull/3441#issuecomment-2576452162
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3441: [cdc-connector][oracle]Flink cdc
pipeline support oracle source
URL: https://github.com/apache/flink-cdc/pull/3441
--
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
snuyanzin commented on PR #25876:
URL: https://github.com/apache/flink/pull/25876#issuecomment-2576454953
@hanyuzheng7 can you please fill the PR form?
--
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 g
[
https://issues.apache.org/jira/browse/FLINK-36976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910850#comment-17910850
]
Sergey Nuyanzin commented on FLINK-36976:
-
Merged as
[98a36a744f1e004dfd4d1f502
[
https://issues.apache.org/jira/browse/FLINK-36976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36976.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Bump jackson to 2.18.2
> ---
[
https://issues.apache.org/jira/browse/FLINK-36620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36620:
---
Labels: pull-request-available (was: )
> Add support for the flink-home parameter to be set
lvyanquan commented on PR #3828:
URL: https://github.com/apache/flink-cdc/pull/3828#issuecomment-2574616519
@leonardBang @ruanhang1993 could you please help to trigger the CI?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Jzjsnow opened a new pull request, #3838:
URL: https://github.com/apache/flink-cdc/pull/3838
Currently, most of FlinkCDC's command line arguments are supported in the
format `--$KEY $VALUE` or `--$KEY=$VALUE`, e.g. --jar, but, except for flink
home, which only supports space spacing. Users
yuxiqian commented on code in PR #3605:
URL: https://github.com/apache/flink-cdc/pull/3605#discussion_r1905059679
##
README.md:
##
@@ -28,14 +28,25 @@ and elegance of data integration via YAML to describe the
data movement and tran
The Flink CDC prioritizes efficient end-to-en
fsk119 merged PR #25754:
URL: https://github.com/apache/flink/pull/25754
--
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
[
https://issues.apache.org/jira/browse/FLINK-36760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-36760.
-
Resolution: Implemented
Merged into master: 4a8b8c03e3aa2677fe5ab94a09ee8ae754785938
> Support
lvyanquan commented on PR #3605:
URL: https://github.com/apache/flink-cdc/pull/3605#issuecomment-2575052681
@leonardBang 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 specific comment
1996fanrui commented on code in PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#discussion_r1905322958
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java:
##
@@ -89,21 +89,41 @@ private static ConfigOptions.Opt
xuyangzhong opened a new pull request, #25910:
URL: https://github.com/apache/flink/pull/25910
## What is the purpose of the change
*Remove apis about ManagedTable*
## Brief change log
- *Remove apis about ManagedTable*
- *Adapt related codes and tests*
[
https://issues.apache.org/jira/browse/FLINK-36171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36171:
---
Labels: pull-request-available (was: )
> Remove APIs about ManagedTable
> -
[
https://issues.apache.org/jira/browse/FLINK-36070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-36070.
--
Fix Version/s: 2.0.0
Resolution: Done
master
ae7184bd222b086e7b94dc0986b863ca349f5867
4c94d53
[
https://issues.apache.org/jira/browse/FLINK-37021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-37021:
---
Summary: Implement fast checkpoint/rescaling for ForStKeyedStateBackend
(was: Implement fast rescal
JunRuiLee commented on PR #25804:
URL: https://github.com/apache/flink/pull/25804#issuecomment-2574939368
@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.
Zakelly commented on code in PR #25848:
URL: https://github.com/apache/flink/pull/25848#discussion_r1905255634
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMapAsync.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation
fredia closed pull request #25908: [FLINK-37021][state/forst] Implement fast
rescaling for ForStKeyedStateBackend
URL: https://github.com/apache/flink/pull/25908
--
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
fredia commented on PR #25908:
URL: https://github.com/apache/flink/pull/25908#issuecomment-2574954659
After the offline discussion, fast rescaling and fast checkpoint will be
implemented together, and this PR will be closed first.
--
This is an automated message from the Apache Git Servi
snuyanzin commented on code in PR #25874:
URL: https://github.com/apache/flink/pull/25874#discussion_r1905081855
##
flink-python/pyflink/table/expressions.py:
##
@@ -350,14 +350,21 @@ def temporal_overlaps(left_time_point,
def date_format(timestamp, format) -> Expression:
Zakelly commented on code in PR #25884:
URL: https://github.com/apache/flink/pull/25884#discussion_r1905093224
##
flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystemTest.java:
##
@@ -247,6 +273,9 @@ void testSstFileInC
yuxiqian commented on code in PR #3802:
URL: https://github.com/apache/flink-cdc/pull/3802#discussion_r1905043255
##
flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java:
##
Review Comment:
Maybe this cha
snuyanzin commented on code in PR #25874:
URL: https://github.com/apache/flink/pull/25874#discussion_r1905081855
##
flink-python/pyflink/table/expressions.py:
##
@@ -350,14 +350,21 @@ def temporal_overlaps(left_time_point,
def date_format(timestamp, format) -> Expression:
flinkbot commented on PR #25909:
URL: https://github.com/apache/flink/pull/25909#issuecomment-2574609124
## CI report:
* 469452c894228f6331857b14f0e9f6028e8d00d8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #25873:
URL: https://github.com/apache/flink/pull/25873#discussion_r1905083319
##
flink-python/pyflink/table/expressions.py:
##
@@ -350,14 +350,21 @@ def temporal_overlaps(left_time_point,
def date_format(timestamp, format) -> Expression:
yuxiqian commented on code in PR #3818:
URL: https://github.com/apache/flink-cdc/pull/3818#discussion_r1905076618
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/FlushEventAlignmen
snuyanzin commented on code in PR #25898:
URL: https://github.com/apache/flink/pull/25898#discussion_r1905102798
##
.github/workflows/nightly.yml:
##
@@ -39,23 +39,12 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_
snuyanzin commented on code in PR #25898:
URL: https://github.com/apache/flink/pull/25898#discussion_r1905107370
##
pom.xml:
##
@@ -124,7 +124,7 @@ under the License.
2.15.3
2.7.0
true
- 11
+ 17
Revie
[
https://issues.apache.org/jira/browse/FLINK-36999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
林健昌 updated FLINK-36999:
Description: When the source type is oracle and field type is nember and
the value is null, a null pointer excepti
amjidc created FLINK-37023:
--
Summary: JobManager rest API returns 500 error with
CancellationException
Key: FLINK-37023
URL: https://issues.apache.org/jira/browse/FLINK-37023
Project: Flink
Issue T
yuxiqian commented on PR #3839:
URL: https://github.com/apache/flink-cdc/pull/3839#issuecomment-2575080335
ping @leonardBang
--
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.
xuyangzhong commented on PR #25521:
URL: https://github.com/apache/flink/pull/25521#issuecomment-2575081969
@jbalchan You only removed the method `TableDescriptor#forManaged` without
adapting all the code that uses that method.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-37023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
amjidc updated FLINK-37023:
---
Description:
We have probes that call JobManager rest API regularly, and these API calls are
failing interm
[
https://issues.apache.org/jira/browse/FLINK-36033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-36033.
--
Fix Version/s: 2.0.0
Release Note:
In 2.0, we introduced adaptive execution for batch jobs. In th
flinkbot commented on PR #25910:
URL: https://github.com/apache/flink/pull/25910#issuecomment-2575069989
## CI report:
* c84f2eb5e1e484fb59b6fe662beb70c88ad5b92d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JunRuiLee merged PR #25804:
URL: https://github.com/apache/flink/pull/25804
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-37023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
amjidc updated FLINK-37023:
---
Summary: Rest API returns 500 error with CancellationException (was:
JobManager rest API returns 500 error
[
https://issues.apache.org/jira/browse/FLINK-37023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
amjidc updated FLINK-37023:
---
Description:
We have probes that call JobManager rest API regularly, and these API calls are
failing interm
[
https://issues.apache.org/jira/browse/FLINK-37023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
amjidc updated FLINK-37023:
---
Description:
We have probes that call JobManager rest API regularly, and these API calls are
failing interm
yuxiqian opened a new pull request, #3839:
URL: https://github.com/apache/flink-cdc/pull/3839
This PR contains some pretty trivial fixes on our GHA workflows:
* Changes PR stale cycle to 120d / 60d
Now, our `actions/stale` workflow closes inactive PRs with a 60 / 30 days
cycle,
SinBex commented on code in PR #25822:
URL: https://github.com/apache/flink/pull/25822#discussion_r1905324107
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/strategy/AdaptiveBroadcastJoinOptimizationStrategy.java:
##
@@ -0,0 +1,213 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-36033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-36033:
---
Release Note:
In 2.0, we introduced adaptive execution for batch jobs. In this mode, the
JobGraph w
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-36290:
--
Assignee: Ferenc Csaky
> OutOfMemoryError in connect test run
> -
lvyanquan commented on PR #3491:
URL: https://github.com/apache/flink-cdc/pull/3491#issuecomment-2574666177
Close this and trace in https://github.com/apache/flink-cdc/pull/3818 as
this pr rely on https://github.com/apache/flink-cdc/pull/3818 to fix some bugs
and https://github.com/apache/f
lvyanquan closed pull request #3491: [FLINK-35888][cdc-connector][paimon] Add
e2e test for PaimonDataSink.
URL: https://github.com/apache/flink-cdc/pull/3491
--
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 t
lvyanquan commented on PR #3605:
URL: https://github.com/apache/flink-cdc/pull/3605#issuecomment-2575000188
Maybe we can add this script guidance to
[quicklystart](https://github.com/apache/flink-cdc/tree/master/docs/content/docs/get-started/quickstart)
too.
--
This is an automated messa
dawidwys commented on code in PR #25907:
URL: https://github.com/apache/flink/pull/25907#discussion_r1905279516
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1045,6 +1054,7 @@ public void createTable(
boring-cyborg[bot] commented on PR #152:
URL:
https://github.com/apache/flink-connector-jdbc/pull/152#issuecomment-2575023062
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
JohnMa123 opened a new pull request, #152:
URL: https://github.com/apache/flink-connector-jdbc/pull/152
(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 unsu
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35137:
---
Labels: pull-request-available (was: )
> Release flink-connector-jdbc v3.2.0 for Flink 1.19
ferenc-csaky commented on PR #24931:
URL: https://github.com/apache/flink/pull/24931#issuecomment-2574891289
@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 comme
lvyanquan commented on code in PR #3605:
URL: https://github.com/apache/flink-cdc/pull/3605#discussion_r1905224775
##
tools/cdcup/cdcup.sh:
##
@@ -0,0 +1,76 @@
+#!/usr/bin/env bash
+
+# Do not continue after error
+set -e
+
+display_help() {
+ echo "Usage: ./cdcup.sh { init | u
yuxiqian commented on PR #3823:
URL: https://github.com/apache/flink-cdc/pull/3823#issuecomment-2574765066
@hiliuxg Seems there are some test cases in
`org.apache.flink.cdc.cli.CliFrontendTest` that needs to be updated.
--
This is an automated message from the Apache Git Service.
To respo
dawidwys commented on code in PR #25907:
URL: https://github.com/apache/flink/pull/25907#discussion_r1905149120
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1012,9 +1012,17 @@ public String qualifyDatabase(@Nullable
leonardBang merged PR #3832:
URL: https://github.com/apache/flink-cdc/pull/3832
--
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
hiliuxg commented on code in PR #3823:
URL: https://github.com/apache/flink-cdc/pull/3823#discussion_r1905171238
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java:
##
@@ -114,6 +122,22 @@ static CliExecutor createExecutor(CommandLine commandLine)
throws E
MartijnVisser commented on code in PR #25898:
URL: https://github.com/apache/flink/pull/25898#discussion_r1905181258
##
.github/workflows/nightly.yml:
##
@@ -39,23 +39,12 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACC
lvyanquan commented on code in PR #3668:
URL: https://github.com/apache/flink-cdc/pull/3668#discussion_r1905394070
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationI
lvyanquan commented on code in PR #3668:
URL: https://github.com/apache/flink-cdc/pull/3668#discussion_r1905394070
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationI
dyccode commented on code in PR #25711:
URL: https://github.com/apache/flink/pull/25711#discussion_r1905391448
##
flink-formats/flink-orc/pom.xml:
##
@@ -141,6 +149,34 @@ under the License.
org.slf4j
dyccode commented on code in PR #25711:
URL: https://github.com/apache/flink/pull/25711#discussion_r1905391448
##
flink-formats/flink-orc/pom.xml:
##
@@ -141,6 +149,34 @@ under the License.
org.slf4j
lvyanquan commented on code in PR #3668:
URL: https://github.com/apache/flink-cdc/pull/3668#discussion_r1905394070
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationI
lvyanquan commented on code in PR #3668:
URL: https://github.com/apache/flink-cdc/pull/3668#discussion_r1905394070
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlOnLineSchemaMigrationI
[
https://issues.apache.org/jira/browse/FLINK-36926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-36926:
---
Assignee: xuyang
> Introduce Window Join Operator with Async State API
> --
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906221025
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/FloorCeilCallGen.scala:
##
@@ -65,15 +65,17 @@ class FloorCeilCallGen
[
https://issues.apache.org/jira/browse/FLINK-36927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-36927:
---
Assignee: xuyang
> Introduce slicing & one stage Window Aggregate with Async State API
> --
lvyanquan commented on PR #3825:
URL: https://github.com/apache/flink-cdc/pull/3825#issuecomment-2576640103
Minor changes, @leonardBang could you help to check for it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/FLINK-36837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-36837:
---
Assignee: xuyang
> Introduce RowTimeDeduplicateFunction with Async State API
>
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906337467
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -588,34 +588,50 @@ private Stream ceilTest
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906337467
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -588,34 +588,50 @@ private Stream ceilTest
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906337467
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -588,34 +588,50 @@ private Stream ceilTest
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906337467
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -588,34 +588,50 @@ private Stream ceilTest
yuxiqian commented on code in PR #3698:
URL: https://github.com/apache/flink-cdc/pull/3698#discussion_r1906325845
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java:
##
@@ -108,83 +108,305 @@ public static TimestampData toTimestamp
[
https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910918#comment-17910918
]
RocMarshal commented on FLINK-33977:
[The more discussion detail could be viewed in
reswqa merged PR #25731:
URL: https://github.com/apache/flink/pull/25731
--
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
lsyldliu commented on code in PR #25904:
URL: https://github.com/apache/flink/pull/25904#discussion_r1906247714
##
docs/content.zh/docs/dev/table/materialized-table/statements.md:
##
@@ -233,8 +233,8 @@ CREATE MATERIALIZED TABLE my_materialized_table_full
'format' = 'js
lvyanquan commented on PR #3605:
URL: https://github.com/apache/flink-cdc/pull/3605#issuecomment-2576579703
Hi, @yuxiqian. could you check the CI failure?
--
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 t
jiefei30 commented on PR #25904:
URL: https://github.com/apache/flink/pull/25904#issuecomment-2576581678
@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.
[
https://issues.apache.org/jira/browse/FLINK-37010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910892#comment-17910892
]
Zakelly Lan commented on FLINK-37010:
-
merge 9720dcc into master
> Unify KeyedProce
yuxiqian commented on PR #3823:
URL: https://github.com/apache/flink-cdc/pull/3823#issuecomment-2576581962
`org.apache.flink.cdc.cli.CliFrontendTest#testGeneratingHelpMessage` and
`org.apache.flink.cdc.cli.CliFrontendTest#testNoArgument` is still failing,
presumably because `-D ` is so long
hackergin commented on code in PR #25880:
URL: https://github.com/apache/flink/pull/25880#discussion_r1906256374
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableAsQueryOperation.java:
##
@@ -0,0 +1,142 @
[
https://issues.apache.org/jira/browse/FLINK-37010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan closed FLINK-37010.
---
Fix Version/s: 2.0.0
Resolution: Fixed
> Unify KeyedProcessFunction and the async one
> -
ChaomingZhangCN opened a new pull request, #3840:
URL: https://github.com/apache/flink-cdc/pull/3840
Already have LoadingCache.
--
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 commen
linjianchang opened a new pull request, #3841:
URL: https://github.com/apache/flink-cdc/pull/3841
Fix the problem with the block splitter logic of Oracle CDC incremental
snapshot, causing the split slice to be too large.
**java api compare rowid result:**
--
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 uns
[
https://issues.apache.org/jira/browse/FLINK-36793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36793:
---
Labels: pull-request-available (was: )
> There is a problem with the block splitter logic o
leonardBang merged PR #3254:
URL: https://github.com/apache/flink-cdc/pull/3254
--
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
101 - 200 of 340 matches
Mail list logo
