gong commented on PR #3463:
URL: https://github.com/apache/flink-cdc/pull/3463#issuecomment-2227812297
https://issues.apache.org/jira/browse/FLINK-35151 is same problem.
@lvyanquan
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
gtk96 commented on code in PR #3464:
URL: https://github.com/apache/flink-cdc/pull/3464#discussion_r1677378327
##
docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md:
##
@@ -470,7 +470,6 @@ public class PostgresParallelSourceExample {
.slotName
yuxiqian commented on code in PR #3385:
URL: https://github.com/apache/flink-cdc/pull/3385#discussion_r1648562972
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java:
##
@
dylanhz commented on PR #24988:
URL: https://github.com/apache/flink/pull/24988#issuecomment-2227793600
@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-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35318:
---
Fix Version/s: 2.0.0
(was: 1.18.2)
> incorrect timezone handling for TIMESTAM
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865881#comment-17865881
]
Leonard Xu edited comment on FLINK-35318 at 7/15/24 6:33 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865881#comment-17865881
]
Leonard Xu commented on FLINK-35318:
master(1.20) via: 94c48f428bedcc07840d243ccf3f0
leonardBang commented on PR #24787:
URL: https://github.com/apache/flink/pull/24787#issuecomment-2227776190
@lshangq Would you like to also open PRs for `release-1.18` and
`release-1.19` branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
leonardBang merged PR #24787:
URL: https://github.com/apache/flink/pull/24787
--
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.a
ChengJie1053 commented on code in PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#discussion_r1677354475
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaSinkWriteMetrics.java
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35318:
---
Fix Version/s: 1.18.2
> incorrect timezone handling for TIMESTAMP_WITH_LOCAL_TIME_ZONE type during
[
https://issues.apache.org/jira/browse/FLINK-35318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35318:
---
Fix Version/s: 1.20.0
1.19.2
> incorrect timezone handling for TIMESTAMP_WITH_LOC
yuxiqian commented on code in PR #3464:
URL: https://github.com/apache/flink-cdc/pull/3464#discussion_r1677353585
##
docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md:
##
@@ -470,7 +470,6 @@ public class PostgresParallelSourceExample {
.slotN
yuxiqian commented on code in PR #3464:
URL: https://github.com/apache/flink-cdc/pull/3464#discussion_r1677353585
##
docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md:
##
@@ -470,7 +470,6 @@ public class PostgresParallelSourceExample {
.slotN
flinkbot commented on PR #25086:
URL: https://github.com/apache/flink/pull/25086#issuecomment-2227766095
## CI report:
* 9d93a7b35bc73b35d4678c2f1acaa2ace44e6e05 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuxiqian commented on code in PR #3471:
URL: https://github.com/apache/flink-cdc/pull/3471#discussion_r1677349369
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaSinkWriteMetrics.java:
##
[
https://issues.apache.org/jira/browse/FLINK-35836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35836:
---
Labels: pull-request-available (was: )
> Some S5 related ITCases failed in JDK17 due to ref
[
https://issues.apache.org/jira/browse/FLINK-35836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35836:
--
Assignee: Weijie Guo
> Some S5 related ITCases failed in JDK17 due to reflection issue
>
reswqa opened a new pull request, #25086:
URL: https://github.com/apache/flink/pull/25086
## What is the purpose of the change
*In JDK17, we cannot access a final field via reflection by default.
Following 2940c02c986e3d70708187091bf006806bb90dff, I have added
--add-opens=java.base/j
[
https://issues.apache.org/jira/browse/FLINK-35836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35836:
---
Description:
{code:java}
Jul 13 01:26:47 at
org.apache.flink.runtime.io.network.api.writer.
Weijie Guo created FLINK-35836:
--
Summary: Some S5 related ITCases failed in JDK17 due to reflection
issue
Key: FLINK-35836
URL: https://issues.apache.org/jira/browse/FLINK-35836
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35126.
--
Fix Version/s: kubernetes-operator-1.10.0
Resolution: Fixed
merged to main cb90b10c93241f9994ac
[
https://issues.apache.org/jira/browse/FLINK-35831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35831.
--
Fix Version/s: kubernetes-operator-1.10.0
Resolution: Fixed
merged to main 2b82a9343140515646f8
gyfora merged PR #850:
URL: https://github.com/apache/flink-kubernetes-operator/pull/850
--
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
gyfora merged PR #852:
URL: https://github.com/apache/flink-kubernetes-operator/pull/852
--
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
Jiabao-Sun commented on PR #37:
URL:
https://github.com/apache/flink-connector-mongodb/pull/37#issuecomment-2227728551
Thanks @yuxiqian for the review, fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865861#comment-17865861
]
Weijie Guo commented on FLINK-35095:
This is totally test code fault and I'll fix it
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35095:
---
Affects Version/s: 2.0.0
> ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI
> --
flinkbot commented on PR #25085:
URL: https://github.com/apache/flink/pull/25085#issuecomment-2227664487
## CI report:
* ea5fc857eca3752a256f86bc2435244591763623 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35095:
---
Labels: pull-request-available test-stability (was: test-stability)
> ExecutionEnvironmentI
reswqa opened a new pull request, #25085:
URL: https://github.com/apache/flink/pull/25085
## What is the purpose of the change
*The returned collection of `streamGraph.getStreamNodes` is un-ordered, so
we have to check every node to decide if it's the source node.*
## Brief
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35095:
--
Assignee: Weijie Guo
> ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI
> ---
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865857#comment-17865857
]
Weijie Guo commented on FLINK-35095:
Also failed on AZP:
https://dev.azure.com/apac
1996fanrui merged PR #133:
URL: https://github.com/apache/flink-connector-jdbc/pull/133
--
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.
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35835:
---
Affects Version/s: 2.0.0
> SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingF
[
https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35835:
---
Description:
{code:java}
Jul 14 03:03:44 03:03:44.957 [ERROR] Failures:
Jul 14 03:03:44 03:03:44.95
Weijie Guo created FLINK-35835:
--
Summary:
SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging
failed on AZP
Key: FLINK-35835
URL: https://issues.apache.org/jira/browse/FLINK-35835
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865835#comment-17865835
]
Weijie Guo commented on FLINK-18476:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865833#comment-17865833
]
Weijie Guo commented on FLINK-35810:
https://dev.azure.com/apache-flink/apache-flink
SML0127 commented on code in PR #3448:
URL: https://github.com/apache/flink-cdc/pull/3448#discussion_r1677153078
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest
yuxiqian opened a new pull request, #3473:
URL: https://github.com/apache/flink-cdc/pull/3473
This closes FLINK-35072.
Thanks to @qg-lin's great work, doris-flink-connector 1.6.2 has implemented
column type modification API, so Flink CDC could implement this ticket more
easily.
[
https://issues.apache.org/jira/browse/FLINK-35679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35679.
Resolution: Done
> [Release-1.20] Cross team testing
> -
>
>
zhaorongsheng commented on PR #25068:
URL: https://github.com/apache/flink/pull/25068#issuecomment-2227594705
> > @zhaorongsheng Could you also cherry pick this patch into release-1.20
branch?
>
> I've created the backport pr #25084 to catch up 1.20's rc1 building.
OK!
--
Th
yuxiqian commented on code in PR #37:
URL:
https://github.com/apache/flink-connector-mongodb/pull/37#discussion_r1677252405
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/testutils/MongoTestUtil.java:
##
@@ -90,4 +102,36 @@ public static void assert
[
https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863428#comment-17863428
]
Rui Fan edited comment on FLINK-35750 at 7/15/24 1:47 AM:
--
Merg
[
https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35750.
-
Resolution: Fixed
> The latency marker metrics aren't updated after failover
> -
1996fanrui merged PR #25037:
URL: https://github.com/apache/flink/pull/25037
--
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.ap
1996fanrui merged PR #25038:
URL: https://github.com/apache/flink/pull/25038
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-35834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865828#comment-17865828
]
yux commented on FLINK-35834:
-
+1, bumping doris connector to 1.6.2 should also resolve FLIN
LvYanquan created FLINK-35834:
-
Summary: Update Doris Dependency to 1.6.2 to use group commit.
Key: FLINK-35834
URL: https://issues.apache.org/jira/browse/FLINK-35834
Project: Flink
Issue Type: B
lincoln-lil commented on PR #25068:
URL: https://github.com/apache/flink/pull/25068#issuecomment-2227560843
> @zhaorongsheng Could you also cherry pick this patch into release-1.20
branch?
I've created the backport pr #25084 to catch up 1.20's rc1 building.
--
This is an automated
flinkbot commented on PR #25084:
URL: https://github.com/apache/flink/pull/25084#issuecomment-2227560549
## CI report:
* f4b99b07e6166f42604983b6604765c068e7bd76 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan Meissner updated FLINK-35833:
---
Description:
FLINK-28915 added support for remote job jar fetching (HTTPS, S3, etc) but
bro
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31922:
---
Labels: pull-request-available (was: )
> Port over Kinesis Client configurations for retry
karubian opened a new pull request, #150:
URL: https://github.com/apache/flink-connector-aws/pull/150
## Purpose of the change
Port over Kinesis Client configurations for retry and backoff
## Verifying this change
- *Added unit tests*
## Significant changes
*(Pl
[
https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan Meissner updated FLINK-35833:
---
Description:
FLINK-28915 added support for remote job jar fetching (HTTPS, S3, etc) but
bro
hdulay closed pull request #21436: [FLINK-30093] [formats] Protobuf Timestamp
Compile Error
URL: https://github.com/apache/flink/pull/21436
--
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 specif
gaborgsomogyi commented on PR #852:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/852#issuecomment-2227465613
Restarted the failed job, the change looks good.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
gaborgsomogyi commented on code in PR #850:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/850#discussion_r1677194834
##
docs/layouts/shortcodes/generated/dynamic_section.html:
##
@@ -22,15 +22,15 @@
kubernetes.operator.cluster.h
[
https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan Meissner updated FLINK-35833:
---
Description:
FLINK-28915 added support for remote job jar fetching (HTTPS, S3, etc) but
bro
[
https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan Meissner updated FLINK-35833:
---
Description:
FLINK-28915 added support for remote job jar fetching (HTTPS, S3, etc) but
bro
[
https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan Meissner updated FLINK-35833:
---
Description:
FLINK-28915 added support for remote job jar fetching (HTTPS, S3, etc) but
bro
[
https://issues.apache.org/jira/browse/FLINK-35833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dylan Meissner updated FLINK-35833:
---
Description:
FLINK-28915 added support for remote job jar fetching (HTTPS, S3, etc) but
bro
Dylan Meissner created FLINK-35833:
--
Summary: ArtifactFetchManager always requires writable filesystem
Key: FLINK-35833
URL: https://issues.apache.org/jira/browse/FLINK-35833
Project: Flink
dylanhz commented on PR #24972:
URL: https://github.com/apache/flink/pull/24972#issuecomment-2227414443
@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-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865787#comment-17865787
]
Yu Chen commented on FLINK-35832:
-
Hi [~yunta], Would you mind to help @ someone related
[
https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Chen updated FLINK-35832:
Summary: IFNULL returns incorrect result in Flink SQL (was: IFNULL returns
error result in Flink SQL)
>
Yu Chen created FLINK-35832:
---
Summary: IFNULL returns error result in Flink SQL
Key: FLINK-35832
URL: https://issues.apache.org/jira/browse/FLINK-35832
Project: Flink
Issue Type: Bug
Comp
SML0127 commented on code in PR #3448:
URL: https://github.com/apache/flink-cdc/pull/3448#discussion_r1677153078
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest
SML0127 commented on code in PR #3448:
URL: https://github.com/apache/flink-cdc/pull/3448#discussion_r1677153078
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssignerTest
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865776#comment-17865776
]
yuanfenghu commented on FLINK-35035:
[~ztison]
Thanks, I will look into FLIP in det
[
https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-35804:
Fix Version/s: 1.20.0
> Incorrect calc merge generate wrong plan about udtf+join+udf
> ---
[
https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee resolved FLINK-35804.
-
Assignee: roncenzhao
Resolution: Fixed
fixed in master: a021082fa062e364e1c296a8ac33315b91
lincoln-lil merged PR #25068:
URL: https://github.com/apache/flink/pull/25068
--
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.a
aplyusnin commented on PR #847:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/847#issuecomment-2227345617
Hi, @mxm @gyfora! I've finished the implementation. Could you review the
code and run workflows?
--
This is an automated message from the Apache Git Service.
To resp
eskabetxe commented on PR #3282:
URL: https://github.com/apache/flink-cdc/pull/3282#issuecomment-2227280892
@GOODBOY008 any chance to get this 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 go
[
https://issues.apache.org/jira/browse/FLINK-35831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35831:
---
Labels: pull-request-available (was: )
> Rotate job id on savepoint upgrade as well
> -
gyfora opened a new pull request, #852:
URL: https://github.com/apache/flink-kubernetes-operator/pull/852
## What is the purpose of the change
Job Ids can and should be rotated on savepoint redeployments as well. It is
only important to keep the jobId when we are relying on recovery f
Gyula Fora created FLINK-35831:
--
Summary: Rotate job id on savepoint upgrade as well
Key: FLINK-35831
URL: https://issues.apache.org/jira/browse/FLINK-35831
Project: Flink
Issue Type: Improvemen
79 matches
Mail list logo
