[
https://issues.apache.org/jira/browse/FLINK-36041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36041:
---
Fix Version/s: cdc-3.3.0
> Eliminate Calcite dependency during runtime
> ---
[
https://issues.apache.org/jira/browse/FLINK-36041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36041:
---
Affects Version/s: cdc-3.1.1
> Eliminate Calcite dependency during runtime
> ---
twalthr commented on code in PR #25195:
URL: https://github.com/apache/flink/pull/25195#discussion_r1714729815
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/internal/ShowCreateUtilTest.java:
##
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache Softw
lvyanquan closed pull request #3413: [FLINK-35586] shuffle Event of the same
bucket to the same subtask to avoid conflict.
URL: https://github.com/apache/flink-cdc/pull/3413
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-36040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873114#comment-17873114
]
Leonard Xu commented on FLINK-36040:
[~xuhaiLong] Thanks for your reporting, [~loser
[
https://issues.apache.org/jira/browse/FLINK-34876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34876:
--
Affects Version/s: cdc-3.1.0
> [Feature][Pipeline] Flink CDC pipeline transform supports UDF
> ---
[
https://issues.apache.org/jira/browse/FLINK-35297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35297:
--
Affects Version/s: cdc-3.1.1
> Add validation for option connect.timeout
> ---
[
https://issues.apache.org/jira/browse/FLINK-35297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873111#comment-17873111
]
Ruan Hang commented on FLINK-35297:
---
master: 80920aaa28608eb107ad61c071199032e6bd2777
[
https://issues.apache.org/jira/browse/FLINK-35648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873110#comment-17873110
]
Ruan Hang edited comment on FLINK-35648 at 8/13/24 6:21 AM:
[
https://issues.apache.org/jira/browse/FLINK-35648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873110#comment-17873110
]
Ruan Hang commented on FLINK-35648:
---
fix via master: 3441a1e2ab17f194bc27191819089153b
[
https://issues.apache.org/jira/browse/FLINK-35648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35648:
--
Affects Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> Pipeline job doesn't suppor
[
https://issues.apache.org/jira/browse/FLINK-35648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35648:
--
Affects Version/s: cdc-3.2.0
> Pipeline job doesn't support multiple routing
> ---
[
https://issues.apache.org/jira/browse/FLINK-35884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-35884:
--
Affects Version/s: cdc-3.1.1
cdc-3.1.0
> Pipeline MySQL connector supports sett
leonardBang merged PR #3534:
URL: https://github.com/apache/flink-cdc/pull/3534
--
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
leonardBang merged PR #3532:
URL: https://github.com/apache/flink-cdc/pull/3532
--
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
leonardBang merged PR #3531:
URL: https://github.com/apache/flink-cdc/pull/3531
--
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
leonardBang commented on PR #3531:
URL: https://github.com/apache/flink-cdc/pull/3531#issuecomment-2285389684
CI passed, merging...
--
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 co
[
https://issues.apache.org/jira/browse/FLINK-36040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873105#comment-17873105
]
xuhaiLong commented on FLINK-36040:
---
Without restarting, the new table will be filtere
[
https://issues.apache.org/jira/browse/FLINK-36042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuhaiLong updated FLINK-36042:
--
Summary: Newly added table captures are filtered (was: newly added tables
capture )
> Newly added ta
yuxiqian commented on code in PR #3535:
URL: https://github.com/apache/flink-cdc/pull/3535#discussion_r1714671662
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToElasticsearchE2eITCase.java:
##
@@ -0,0 +1,231 @@
+packa
yuxiqian commented on code in PR #3535:
URL: https://github.com/apache/flink-cdc/pull/3535#discussion_r1714682124
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java:
##
@@ -60,16 +60,16 @@
i
yuxiqian commented on code in PR #3535:
URL: https://github.com/apache/flink-cdc/pull/3535#discussion_r1714675091
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToElasticsearchE2eITCase.java:
##
@@ -0,0 +1,231 @@
+packa
yuxiqian commented on code in PR #3535:
URL: https://github.com/apache/flink-cdc/pull/3535#discussion_r1714673090
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToElasticsearchE2eITCase.java:
##
@@ -0,0 +1,231 @@
+packa
yuxiqian commented on code in PR #3535:
URL: https://github.com/apache/flink-cdc/pull/3535#discussion_r1714667705
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml:
##
@@ -113,6 +113,12 @@ limitations under the License.
${testcontainers.version}
JunRuiLee commented on PR #25110:
URL: https://github.com/apache/flink/pull/25110#issuecomment-2285319023
Squashed and rebased onto master.
--
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 spe
[
https://issues.apache.org/jira/browse/FLINK-35996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35996:
---
Labels: pull-request-available (was: )
> Add end-to-end tests for MySQL to Elasticsearch pi
yuxiqian commented on PR #3438:
URL: https://github.com/apache/flink-cdc/pull/3438#issuecomment-2285301752
Hi @proletarians, you may want to create individual branches for each PR to
avoid mixing different changes together.
--
This is an automated message from the Apache Git Service.
To r
JunRuiLee commented on PR #25110:
URL: https://github.com/apache/flink/pull/25110#issuecomment-2285291007
Thanks @zhuzhurk , I've updated this pr accordingly, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
yuxiqian commented on PR #3533:
URL: https://github.com/apache/flink-cdc/pull/3533#issuecomment-2285284084
Backported in #3534
--
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
zhuzhurk commented on code in PR #25110:
URL: https://github.com/apache/flink/pull/25110#discussion_r1714627722
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java:
##
@@ -137,6 +137,9 @@ public class StreamGraph implements Pipeline {
[
https://issues.apache.org/jira/browse/FLINK-36042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873091#comment-17873091
]
xuhaiLong commented on FLINK-36042:
---
Restarting may cause this problem [mysql cdc pipe
xuhaiLong created FLINK-36042:
-
Summary: newly added tables capture
Key: FLINK-36042
URL: https://issues.apache.org/jira/browse/FLINK-36042
Project: Flink
Issue Type: Bug
Components: F
leonardBang commented on PR #3533:
URL: https://github.com/apache/flink-cdc/pull/3533#issuecomment-2285279535
@yux Would you like to open a PR for release-3.2 branch ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
yux created FLINK-36041:
---
Summary: Eliminate Calcite dependency during runtime
Key: FLINK-36041
URL: https://issues.apache.org/jira/browse/FLINK-36041
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-26840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-26840.
---
Resolution: Fixed
Fixed in master: 227e61d2e010ec8123dcda78675f18deadf7df1b
> [minor refactor] Add
[
https://issues.apache.org/jira/browse/FLINK-26840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-26840:
---
Assignee: lincoln lee
> [minor refactor] Add a general TopNBufferCacheRemovalListener for t
lincoln-lil merged PR #19220:
URL: https://github.com/apache/flink/pull/19220
--
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
lincoln-lil commented on PR #19220:
URL: https://github.com/apache/flink/pull/19220#issuecomment-2285267885
@xuyangzhong Thank you for reviewing this! Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
yuxiqian commented on PR #3533:
URL: https://github.com/apache/flink-cdc/pull/3533#issuecomment-2285267798
@leonardBang @aiwenmo 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
yuxiqian opened a new pull request, #3533:
URL: https://github.com/apache/flink-cdc/pull/3533
Occasionally, CDC composer ITcase will fail when running test cases
consecutively, with the following error message:
```
Caused by: java.lang.IllegalStateException: Trying to access closed
[
https://issues.apache.org/jira/browse/FLINK-35863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873084#comment-17873084
]
Weijie Guo edited comment on FLINK-35863 at 8/13/24 3:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873084#comment-17873084
]
Weijie Guo edited comment on FLINK-35863 at 8/13/24 3:18 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35863.
Resolution: Fixed
This was resolved via rollback java doc plugin version. But we should also find
[
https://issues.apache.org/jira/browse/FLINK-36040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuhaiLong updated FLINK-36040:
--
Description:
CDC Pipeline dynamically adds tables, use this
[pr-3411|https://github.com/apache/flink-
xuhaiLong created FLINK-36040:
-
Summary: mysql cdc pipeline recover error from ck
Key: FLINK-36040
URL: https://issues.apache.org/jira/browse/FLINK-36040
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873083#comment-17873083
]
xuyang commented on FLINK-36004:
Hi, [~xccui] Can you provide the plans(LogicalNode Plan
[
https://issues.apache.org/jira/browse/FLINK-35908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35908:
---
Priority: Minor (was: Blocker)
> Flink log can not output method name and line number.
> -
[
https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873081#comment-17873081
]
Weijie Guo commented on FLINK-34513:
https://dev.azure.com/apache-flink/apache-flink
yuxiqian commented on PR #3503:
URL: https://github.com/apache/flink-cdc/pull/3503#issuecomment-2285257879
Addressed by #3339.
--
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
yuxiqian closed pull request #3503: [hotfix][doris] DorisMetadataApplier fails
to reject unsupported schema change events
URL: https://github.com/apache/flink-cdc/pull/3503
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
yuxiqian commented on PR #3468:
URL: https://github.com/apache/flink-cdc/pull/3468#issuecomment-2285253781
Rebased with `master` and cleaned up metadata column definitions for a bit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
spoon-lz commented on PR #25192:
URL: https://github.com/apache/flink/pull/25192#issuecomment-2285230778
@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-36039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-36039:
---
Assignee: RocMarshal
> Support clean historical event handler records in autoscaler jdbc plugin
> -
RocMarshal created FLINK-36039:
--
Summary: Support clean historical event handler records in
autoscaler jdbc plugin
Key: FLINK-36039
URL: https://issues.apache.org/jira/browse/FLINK-36039
Project: Flink
github-actions[bot] commented on PR #3332:
URL: https://github.com/apache/flink-cdc/pull/3332#issuecomment-2285099283
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
[
https://issues.apache.org/jira/browse/FLINK-35592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35592:
---
Labels: pull-request-available (was: )
> MysqlDebeziumTimeConverter miss timezone convert t
github-actions[bot] commented on PR #3413:
URL: https://github.com/apache/flink-cdc/pull/3413#issuecomment-2285099267
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
all-cloudz commented on PR #23563:
URL: https://github.com/apache/flink/pull/23563#issuecomment-2285084835
@sn-12-3 Yes it's ok to merge now.
--
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 s
SamBarker commented on PR #863:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/863#issuecomment-2284966789
I can't reproduce the build failure with either JDK 17 or 21 locally from
the previous workflow run. I do see a lot of errors logged locally as well as
in the failed ru
flinkbot commented on PR #25195:
URL: https://github.com/apache/flink/pull/25195#issuecomment-2284964140
## CI report:
* d6122386c64cd2c0a5c8e074ea76258291686cf0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36038:
---
Labels: pull-request-available (was: )
> SHOW CREATE VIEW returns invalid query
> -
snuyanzin opened a new pull request, #25195:
URL: https://github.com/apache/flink/pull/25195
## What is the purpose of the change
1. `COMMENT` in `SHOW CREATE VIEW` should be before the query to satisfy
`CREATE VIEW` syntax [1]
2. Make output of `SHOW CREATE VIEW` be simila
Sergey Nuyanzin created FLINK-36038:
---
Summary: SHOW CREATE VIEW returns invalid query
Key: FLINK-36038
URL: https://issues.apache.org/jira/browse/FLINK-36038
Project: Flink
Issue Type: Bug
SamBarker commented on code in PR #863:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/863#discussion_r1714368003
##
pom.xml:
##
@@ -78,7 +78,7 @@ under the License.
4.8.3
1.1.1
-6.11.0
+6.13.2
Review Comment:
Thanks for t
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714363213
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/ProgressiveTimestampsAndWatermarks.java:
##
@@ -273,6 +322,16 @@ void emitPer
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714325988
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714324713
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the
klam-shop commented on PR #109:
URL:
https://github.com/apache/flink-connector-kafka/pull/109#issuecomment-2284775581
> I'm still working on running these tests locally, as the container setup
does not work out of the box with podman. I have podman available but not
docker.
Tested `
flinkbot commented on PR #25194:
URL: https://github.com/apache/flink/pull/25194#issuecomment-2284736907
## CI report:
* fd247820f0649a91e621c64ca264c0737254edc3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
DanRoscigno opened a new pull request, #25194:
URL: https://github.com/apache/flink/pull/25194
small grammar
## 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 avoi
vahmed-hamdy commented on PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#issuecomment-2284706925
Thanks @robg-eb ,
@hlteoh37 could you please take a look
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
19priyadhingra commented on PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2284565004
@hlteoh37 how can we merge this now?
--
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
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714079425
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/WatermarkAssignerOperator.java:
##
@@ -162,13 +172,14 @@ public
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714073708
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Ap
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714073708
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Ap
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714070225
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Ap
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714060955
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Ap
pnowojski commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1714052393
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/ProgressiveTimestampsAndWatermarks.java:
##
@@ -273,6 +322,16 @@ void emitPeriod
mateczagany opened a new pull request, #864:
URL: https://github.com/apache/flink-kubernetes-operator/pull/864
## What is the purpose of the change
Suspended `savepoint` upgrade-mode Flink jobs submitted with Operator
version 1.9 won't restore from the proper savepoint unless this fix
[
https://issues.apache.org/jira/browse/FLINK-36037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36037:
---
Labels: pull-request-available (was: )
> Add compability for 1.9 last savepoint info on upg
Mate Czagany created FLINK-36037:
Summary: Add compability for 1.9 last savepoint info on
upgrade/recovery
Key: FLINK-36037
URL: https://issues.apache.org/jira/browse/FLINK-36037
Project: Flink
lincoln-lil commented on PR #25163:
URL: https://github.com/apache/flink/pull/25163#issuecomment-2284178223
@dylanhz LGTM! Could you rebase the master to resolve the conflicts?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
lincoln-lil commented on code in PR #25163:
URL: https://github.com/apache/flink/pull/25163#discussion_r1713915870
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/EltFunction.java:
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-35987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872952#comment-17872952
]
lincoln lee commented on FLINK-35987:
-
[~dylanhz] I'm ok with current implementation
xuzifu666 closed pull request #24842: [FLINK-35453][core] StreamReader Charset
fix with UTF8 in core files
URL: https://github.com/apache/flink/pull/24842
--
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-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35985:
--
Assignee: MOBIN
> SUBSTRING function not available in transform rules
> -
[
https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872941#comment-17872941
]
Leonard Xu commented on FLINK-35985:
+1, assigned to you [~MOBIN]
> SUBSTRING func
gaborgsomogyi commented on code in PR #24914:
URL: https://github.com/apache/flink/pull/24914#discussion_r1713838756
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/utils/TestBucketWriter.java:
##
@@ -0,0 +1,160 @@
+/*
+ * Licensed to
lincoln-lil merged PR #25193:
URL: https://github.com/apache/flink/pull/25193
--
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
PatrickRen opened a new pull request, #3532:
URL: https://github.com/apache/flink-cdc/pull/3532
This pull request updates documentation configurations on release-3.2 branch
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
PatrickRen opened a new pull request, #3531:
URL: https://github.com/apache/flink-cdc/pull/3531
This pull request bumps the version on master to 3.3-SNAPSHOT, as branch
release-3.2 has been cut out
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
[
https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872902#comment-17872902
]
yux commented on FLINK-35985:
-
Thanks [~MOBIN]'s suggestion! +1 for providing both functions
X-czh commented on PR #23998:
URL: https://github.com/apache/flink/pull/23998#issuecomment-2283698504
@becketqin Kindly remind～
--
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
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1713535597
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1713522527
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the
rkhachatryan commented on code in PR #25167:
URL: https://github.com/apache/flink/pull/25167#discussion_r1713535597
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/ProgressBlockingRelativeClock.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872861#comment-17872861
]
Maximilian Michels commented on FLINK-36018:
Yes, that’s fine with me 👍
> S
[
https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872859#comment-17872859
]
Gyula Fora commented on FLINK-36018:
[~mxm] or simply `autoscaler.scale-down.interva
[
https://issues.apache.org/jira/browse/FLINK-28622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872855#comment-17872855
]
Ammu Parvathy commented on FLINK-28622:
---
[~norris3n] Analysing through the issue,
csviri commented on code in PR #863:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/863#discussion_r1713512645
##
pom.xml:
##
@@ -78,7 +78,7 @@ under the License.
4.8.3
1.1.1
-6.11.0
+6.13.2
Review Comment:
Note that NOTIC
1 - 100 of 145 matches
Mail list logo
