hackergin opened a new pull request, #24777:
URL: https://github.com/apache/flink/pull/24777
## What is the purpose of the change
*Support drop materialized table syntax and execution in continuous refresh
mode*
## Brief change log
- *Support parser drop materializ
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
request|https://github.com/apache/flink-kubernetes-operator/pull/
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845887#comment-17845887
]
ouyangwulin commented on FLINK-35337:
-
[~Leonard]， Our production environment has be
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
request|https://github.com/apache/flink-kubernetes-operator/pull/
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35337:
Component/s: Flink CDC
> Keep up with the latest version of tikv client
>
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35337:
---
Labels: pull-request-available (was: )
> Keep up with the latest version of tikv client
> -
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Affects Version/s: 1.8.0
> Enable FS Plugins as non-root
> -
>
Rasmus Thygesen created FLINK-35338:
---
Summary: Enable FS Plugins as non-root
Key: FLINK-35338
URL: https://issues.apache.org/jira/browse/FLINK-35338
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35336:
--
Summary: SQL failed to restore from savepoint after change in
default-parallelism (was: SQL failed to
ouyangwulin created FLINK-35337:
---
Summary: Keep up with the latest version of tikv client
Key: FLINK-35337
URL: https://issues.apache.org/jira/browse/FLINK-35337
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35336:
--
Description:
After bumping 'table.exec.resource.default-parallelism' from 1 to 4, I am
observing the
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598298446
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-35109:
---
Assignee: Hang Ruan (was: Fabian Paul)
> Add support for Flink 1.20-SNAPSHOT in Flink Kafk
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845883#comment-17845883
]
Fabian Paul commented on FLINK-35109:
-
[~ruanhang1993] sure always happy to take som
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2107243083
> Thanks for your contribution @superdiaodiao , I left some comments
>
> also ci is failed and i tend to think it is related to your changes in
python code, could you please h
snuyanzin commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598263115
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the A
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598262984
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/UrlFunctionsITCase.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Ap
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598262631
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/UrlFunctionsITCase.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Ap
snuyanzin commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2107229466
Thanks for your contribution @superdiaodiao ,
I left some comments
also ci is failed and i tend to think it is related to your changes in
python code, could you please have a l
Keith Lee created FLINK-35336:
-
Summary: SQL failed to restore from savepoint after change in
default-parallelismFlink/Flink:User
Key: FLINK-35336
URL: https://issues.apache.org/jira/browse/FLINK-35336
Pr
snuyanzin commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598253206
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/UrlFunctionsITCase.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache
snuyanzin commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598251586
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/UrlFunctionsITCase.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598248764
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to t
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598243697
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to t
gyfora commented on code in PR #24754:
URL: https://github.com/apache/flink/pull/24754#discussion_r1598242464
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java:
##
@@ -228,6 +230,14 @@ public void setTimeCharacteristic(TimeCharacteristic
snuyanzin commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598239270
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the A
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598238010
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlEncodeFunction.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to t
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598236936
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to t
snuyanzin commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1598224511
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the A
Ryan Skraba created FLINK-35335:
---
Summary: StateCheckpointedITCase failed fatally with 127 exit code
Key: FLINK-35335
URL: https://issues.apache.org/jira/browse/FLINK-35335
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-20400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20400:
---
Labels: pull-request-available (was: )
> Migrate test_streaming_sql.sh
> --
flinkbot commented on PR #24776:
URL: https://github.com/apache/flink/pull/24776#issuecomment-2107163410
## CI report:
* f54fe0b1c50f9c105f9f4dbcca44c0565dec3dd6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on code in PR #24766:
URL: https://github.com/apache/flink/pull/24766#discussion_r1598208386
##
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -292,4 +292,25 @@ The final checkpoint would be triggered immediately after
all operators ha
fredia commented on code in PR #24766:
URL: https://github.com/apache/flink/pull/24766#discussion_r1598207483
##
docs/content.zh/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -250,5 +250,20 @@ StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutio
morazow opened a new pull request, #24776:
URL: https://github.com/apache/flink/pull/24776
## What is the purpose of the change
Migrate `test_streaming_sql.sh` bash based end-to-end tests to docker based
FlinkContainers framework.
## Brief change log
- Add Java ITCase us
fredia commented on code in PR #24762:
URL: https://github.com/apache/flink/pull/24762#discussion_r1598169714
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -600,15 +612,24 @@ public void restoreStateHand
[
https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35149:
---
Fix Version/s: cdc-3.2.0
(was: 3.1.0)
> Fix DataSinkTranslator#sinkTo ignorin
[
https://issues.apache.org/jira/browse/FLINK-35149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35149:
---
Affects Version/s: cdc-3.1.0
> Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not
> T
[
https://issues.apache.org/jira/browse/FLINK-35320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35320:
---
Fix Version/s: rabbitmq-3.1.0
(was: 3.1.0)
> RabbitMQ Source fails to consume
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35071:
---
Fix Version/s: cdc-3.2.0
(was: 3.1.0)
> Remove dependency on flink-shaded fro
[
https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35259:
---
Fix Version/s: cdc-3.1.0
(was: 3.1.0)
> FlinkCDC Pipeline transform can't dea
[
https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35259:
---
Affects Version/s: cdc-3.1.0
(was: 3.1.0)
> FlinkCDC Pipeline transform c
[
https://issues.apache.org/jira/browse/FLINK-35235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35235:
---
Affects Version/s: cdc-3.1.0
(was: 3.1.0)
> Fix missing dependencies in t
[
https://issues.apache.org/jira/browse/FLINK-35235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35235:
---
Fix Version/s: cdc-3.1.0
(was: cdc-3.2.0)
> Fix missing dependencies in the u
[
https://issues.apache.org/jira/browse/FLINK-35235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35235:
---
Fix Version/s: cdc-3.2.0
(was: 3.1.0)
> Fix missing dependencies in the uber
[
https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35274:
---
Component/s: Flink CDC
> Occasional failure issue with Flink CDC Db2 UT
> --
[
https://issues.apache.org/jira/browse/FLINK-35274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35274:
---
Fix Version/s: cdc-3.2.0
(was: 3.1.0)
> Occasional failure issue with Flink C
snuyanzin commented on PR #19797:
URL: https://github.com/apache/flink/pull/19797#issuecomment-2107084694
There is no response from the author, so I addressed feedback (the initial
author is still in git history)
@xuyangzhong could you please have a look once again?
--
This is an a
[
https://issues.apache.org/jira/browse/FLINK-34661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34661.
---
Fix Version/s: 1.20.0
Resolution: Done
4e6b42046adbe2f337460d2e50f1fee12cff21a5
> TaskExecutor suppo
zhuzhurk merged PR #24582:
URL: https://github.com/apache/flink/pull/24582
--
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
leonardBang commented on code in PR #739:
URL: https://github.com/apache/flink-web/pull/739#discussion_r1598146351
##
docs/content/posts/2024-MM-DD-release-cdc-3.1.0.md:
##
@@ -0,0 +1,67 @@
+---
+title: "Apache Flink CDC 3.1.0 Release Announcement"
+date: "2024-MM-DDT08:00:00.0
Simon Lee created FLINK-35334:
-
Summary: Code generation: init method exceeds 64 KB when there is
a long array field with Table API
Key: FLINK-35334
URL: https://issues.apache.org/jira/browse/FLINK-35334
Martijn Visser created FLINK-35333:
--
Summary: JdbcXaSinkTestBase fails in weekly Flink JDBC Connector
tests
Key: FLINK-35333
URL: https://issues.apache.org/jira/browse/FLINK-35333
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34108:
--
Assignee: chesterxu
> Add URL_ENCODE and URL_DECODE function
> --
1996fanrui commented on code in PR #24613:
URL: https://github.com/apache/flink/pull/24613#discussion_r1598105369
##
flink-core/src/test/java/org/apache/flink/types/BasicTypeInfoTest.java:
##
@@ -51,24 +49,24 @@ public class BasicTypeInfoTest extends TestLogger {
};
Zakelly commented on code in PR #24762:
URL: https://github.com/apache/flink/pull/24762#discussion_r1598038977
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -600,15 +612,24 @@ public void restoreStateHan
flinkbot commented on PR #24775:
URL: https://github.com/apache/flink/pull/24775#issuecomment-2106898008
## CI report:
* c8706db11eff30149877f6fffad57df225d96129 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35332:
---
Labels: pull-request-available (was: )
> Manually setting rest.bind-address does not work f
paul8263 opened a new pull request, #24775:
URL: https://github.com/apache/flink/pull/24775
…ress of the Yarn NodeManager in order to support dual network environment
## What is the purpose of the change
Removed setting rest.address to the actual IP address of the Yarn
Yao Zhang created FLINK-35332:
-
Summary: Manually setting rest.bind-address does not work for
Flink running on Hadoop Yarn dual network environment
Key: FLINK-35332
URL: https://issues.apache.org/jira/browse/FLINK-353
jeyhunkarimov commented on PR #24725:
URL: https://github.com/apache/flink/pull/24725#issuecomment-2106877715
> Hello @jeyhunkarimov, have you completed this pull request？I'd like to
review it. BTW, you should add the introduction of this pr.
Hi @WencongLiu the PR is theorethically re
nicusX commented on PR #122:
URL:
https://github.com/apache/flink-connector-aws/pull/122#issuecomment-2106854494
@z3d1k I addressed most of the comments. But I am not sure how to implement
the IT, in particular for a *format* using an external registry.
Any reference or example I can fol
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-35302.
---
Resolution: Fixed
36b1d2a on master
> Flink REST server throws exception on unknown fields
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-35302.
-
> Flink REST server throws exception on unknown fields in RequestBody
>
gaborgsomogyi merged PR #24759:
URL: https://github.com/apache/flink/pull/24759
--
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
snuyanzin commented on PR #24659:
URL: https://github.com/apache/flink/pull/24659#issuecomment-2106819423
@empathy87 please let me know once backports are ready, then we can merge
all of them
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
WencongLiu commented on PR #24725:
URL: https://github.com/apache/flink/pull/24725#issuecomment-2106812606
Hello @jeyhunkarimov, have you completed this pull request？I'd like to
review it. BTW, you should complete the introduction of this pr.
--
This is an automated message from the Apach
GOODBOY008 commented on PR #3317:
URL: https://github.com/apache/flink-cdc/pull/3317#issuecomment-2106801248
Is this pr will be merged after release vote passed?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
101 - 168 of 168 matches
Mail list logo
