leosanqing commented on PR #109:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/109#issuecomment-2320267238
Thanks for your advices，and I fixed this. Has anybody can review my code?
> Thank you for your patch! I am not an official maintainer. Your changes
look reas
[
https://issues.apache.org/jira/browse/FLINK-27758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-27758.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> [JUnit5 Migration] Module: flink-table-r
[
https://issues.apache.org/jira/browse/FLINK-27758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877975#comment-17877975
]
Sergey Nuyanzin commented on FLINK-27758:
-
Merged as
[d57b89db6b2e177d131ce2376
snuyanzin merged PR #19811:
URL: https://github.com/apache/flink/pull/19811
--
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
snuyanzin commented on PR #19811:
URL: https://github.com/apache/flink/pull/19811#issuecomment-2320184795
thanks a lot for taking a look
--
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 speci
flinkbot commented on PR #25271:
URL: https://github.com/apache/flink/pull/25271#issuecomment-2320184043
## CI report:
* 105309763cef18fe72945f6469b3139a5a476361 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mk233 opened a new pull request, #25271:
URL: https://github.com/apache/flink/pull/25271
In this version, state backend should be populated using state.backend.type
instead of state.backend
## What is the purpose of the change
*(For example: This pull request makes task
gyfora commented on PR #874:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/874#issuecomment-2320147397
cc @anupamaggarwal
--
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 spec
flinkbot commented on PR #25270:
URL: https://github.com/apache/flink/pull/25270#issuecomment-2320005935
## CI report:
* ed7ee247dd7772ebff76f0ac89ef396053e3ac5d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36185:
---
Labels: pull-request-available (was: )
> Remove RuntimeContext#getExecutionConfig
> ---
JunRuiLee opened a new pull request, #25270:
URL: https://github.com/apache/flink/pull/25270
## What is the purpose of the change
Remove RuntimeContext#getExecutionConfig
## Brief change log
Remove RuntimeContext#getExecutionConfig
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-36186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877960#comment-17877960
]
Yue Ma commented on FLINK-36186:
I found that rocksdb does not have the JNI method for D
mayuehappy commented on PR #25263:
URL: https://github.com/apache/flink/pull/25263#issuecomment-2319986175
@rkhachatryan @StefanRRichter I've updated the PR , can you help merge it
after the CI pass ?
--
This is an automated message from the Apache Git Service.
To respond to the message,
Yue Ma created FLINK-36186:
--
Summary: Speed up RocksDB close during manual compaction
Key: FLINK-36186
URL: https://issues.apache.org/jira/browse/FLINK-36186
Project: Flink
Issue Type: Bug
liuml07 commented on PR #105:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/105#issuecomment-2319962869
```
Error: Failed to execute goal
org.apache.maven.plugins:maven-compiler-plugin:3.8.0:testCompile
(default-testCompile) on project flink-connector-elasticsearch-
beryllw commented on PR #3581:
URL: https://github.com/apache/flink-cdc/pull/3581#issuecomment-2319957847
Green ci(https://github.com/beryllw/flink-cdc/pull/4 ) @leonardBang cc
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
[
https://issues.apache.org/jira/browse/FLINK-36184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-36184.
---
Fix Version/s: cdc-3.2.0
Resolution: Fixed
master(3.3-SNAPSHOT): 06fc9395693a78318bc3b42b7608
[
https://issues.apache.org/jira/browse/FLINK-36184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reassigned FLINK-36184:
-
Assignee: yux
> Transform Operator swallows schema changes from tables not present in
> transf
wenbingshen commented on PR #95:
URL:
https://github.com/apache/flink-connector-pulsar/pull/95#issuecomment-2319942657
@syhily @tisonkun PTAL. Thanks.
--
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-36184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36184:
---
Labels: pull-request-available (was: )
> Transform Operator swallows schema changes from ta
ruanhang1993 merged PR #3591:
URL: https://github.com/apache/flink-cdc/pull/3591
--
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...@flin
ruanhang1993 merged PR #3589:
URL: https://github.com/apache/flink-cdc/pull/3589
--
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...@flin
lexluo09 commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2319861227
@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.
lexluo09 commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2319862696
@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.
lexluo09 closed pull request #25257: [FLINK-36149][state] Make the
RocksdbCompactFilter parameters take effect directly at the statebackend level
URL: https://github.com/apache/flink/pull/25257
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
lexluo09 commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2319823261
> The CI failed. Would you mind fixing this?
> The CI failed. Would you mind fixing this?
ok
--
This is an automated message from the Apache Git Service.
To respon
Zakelly commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2319755282
The CI failed. Would you mind fixing this?
--
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
Junrui Li created FLINK-36185:
-
Summary: Remove RuntimeContext#getExecutionConfig
Key: FLINK-36185
URL: https://issues.apache.org/jira/browse/FLINK-36185
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #25269:
URL: https://github.com/apache/flink/pull/25269#issuecomment-2319731838
## CI report:
* 5718983eaade3fc400c09d72c1b61b06c63799fc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877950#comment-17877950
]
Zakelly Lan commented on FLINK-36117:
-
Merged into master via 0cf73d973a0c8be4a76c5d
[
https://issues.apache.org/jira/browse/FLINK-36117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36117.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Implement AsyncKeyedStateBackend for RocksDBKeye
JunRuiLee opened a new pull request, #25269:
URL: https://github.com/apache/flink/pull/25269
## What is the purpose of the change
[FLINK-33678][streaming-java] Remove StateBackend related public API.
## Verifying this change
This change is a trivial rework
Zakelly merged PR #25233:
URL: https://github.com/apache/flink/pull/25233
--
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.apach
yux created FLINK-36184:
---
Summary: Transform Operator swallows schema changes from tables
not present in transform rules
Key: FLINK-36184
URL: https://issues.apache.org/jira/browse/FLINK-36184
Project: Flink
yux created FLINK-36183:
---
Summary: Lenient mode doesn't work with route blocks
Key: FLINK-36183
URL: https://issues.apache.org/jira/browse/FLINK-36183
Project: Flink
Issue Type: Bug
Component
[
https://issues.apache.org/jira/browse/FLINK-36170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-36170:
---
Assignee: Siddharth R
> Bump assertj-core version
> -
>
> K
1996fanrui merged PR #876:
URL: https://github.com/apache/flink-kubernetes-operator/pull/876
--
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-unsu
[
https://issues.apache.org/jira/browse/FLINK-36170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-36170.
-
Fix Version/s: kubernetes-operator-1.10.0
Resolution: Fixed
Merged to main(1.10.0) via: 2ee9f20c3
1996fanrui commented on PR #876:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/876#issuecomment-2319667055
> @1996fanrui it's okay to merge these types of straightforward changes
immediately 👍
Thanks for the reminder, merging~
--
This is an automated message from t
kissycn commented on PR #3433:
URL: https://github.com/apache/flink-cdc/pull/3433#issuecomment-2319623637
> Does it only support jdbc-mysql? Can the jdbc be extended to a general
sink connector?
Yes. current was supported jdbc mysql sink. Jdbc sink is a general sink
connector, it eas
[
https://issues.apache.org/jira/browse/FLINK-36181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877883#comment-17877883
]
Sergey Nuyanzin edited comment on FLINK-36181 at 8/29/24 8:41 PM:
[
https://issues.apache.org/jira/browse/FLINK-36181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877883#comment-17877883
]
Sergey Nuyanzin commented on FLINK-36181:
-
[~martijnvisser] out of curiosity: do
[
https://issues.apache.org/jira/browse/FLINK-36182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
EMERSON WANG updated FLINK-36182:
-
Description:
PyFlink SQL job was running in the AWS EKS cluster. When the task manager pods
wer
EMERSON WANG created FLINK-36182:
Summary: PyFlink SQL Job Got IllegalStateException During Task
Manager Shutdown
Key: FLINK-36182
URL: https://issues.apache.org/jira/browse/FLINK-36182
Project: Flink
Martijn Visser created FLINK-36181:
--
Summary: Drop support for Java 8 and use Java 17 by default
Key: FLINK-36181
URL: https://issues.apache.org/jira/browse/FLINK-36181
Project: Flink
Issue
XComp commented on code in PR #25261:
URL: https://github.com/apache/flink/pull/25261#discussion_r1736734100
##
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala:
##
@@ -70,7 +71,7 @@ class AllWindowedStream[T, W <: Window](javaStr
hlteoh37 commented on code in PR #151:
URL:
https://github.com/apache/flink-connector-aws/pull/151#discussion_r1736097740
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java:
##
StefanRRichter commented on code in PR #25263:
URL: https://github.com/apache/flink/pull/25263#discussion_r1736431329
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOperationUtils.java:
##
@@ -119,14 +122,18 @@ pu
[
https://issues.apache.org/jira/browse/FLINK-36168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-36168.
---
Fix Version/s: 2.0.0
Resolution: Fixed
master:
[7cff1da89cbd4f35b12c61a3e109db4a5568
[
https://issues.apache.org/jira/browse/FLINK-36168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-36168:
-
Assignee: Zdenek Tison
> AdaptiveSchedulerTest doesn't follow the production lifecycle
XComp merged PR #25260:
URL: https://github.com/apache/flink/pull/25260
--
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.
XComp commented on PR #25260:
URL: https://github.com/apache/flink/pull/25260#issuecomment-2318107222
Thanks for the fix, @ztison . It looks good to me 👍
--
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
[
https://issues.apache.org/jira/browse/FLINK-36116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-36116:
---
Fix Version/s: 2.0.0
> Javadocs aren't visible anymore for Flink 1.17 and above
> --
[
https://issues.apache.org/jira/browse/FLINK-36116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877721#comment-17877721
]
Martijn Visser commented on FLINK-36116:
Fixed in apache/flink:master 2ca359a140
MartijnVisser merged PR #25265:
URL: https://github.com/apache/flink/pull/25265
--
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
wenbingshen opened a new pull request, #95:
URL: https://github.com/apache/flink-connector-pulsar/pull/95
## Purpose of the change
When restoring from the state, the unconsumed messages of the batch will be
lost.
we should return the next batch index single message for current
[
https://issues.apache.org/jira/browse/FLINK-36180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36180:
---
Labels: pull-request-available (was: )
> Flink pulsar connector when restoring from the sta
flinkbot commented on PR #25268:
URL: https://github.com/apache/flink/pull/25268#issuecomment-2317678872
## CI report:
* bb10b50052d4608b36d7126614f5eb3cf0e3426c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #25268:
URL: https://github.com/apache/flink/pull/25268#issuecomment-2317670755
cc @ferenc-csaky
--
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
gaborgsomogyi commented on PR #25268:
URL: https://github.com/apache/flink/pull/25268#issuecomment-2317670306
This is 1.20 backport of https://github.com/apache/flink/pull/25262
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
gaborgsomogyi opened a new pull request, #25268:
URL: https://github.com/apache/flink/pull/25268
## What is the purpose of the change
Some of the places we still have
`checkpointing-with-parts-of-the-graph-finished-beta` link instead of
`checkpointing-with-parts-of-the-graph-finished
rkhachatryan commented on PR #25263:
URL: https://github.com/apache/flink/pull/25263#issuecomment-2317664479
@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
Wenbing Shen created FLINK-36180:
Summary: Flink pulsar connector when restoring from the state, the
unconsumed messages of the first batch will be lost
Key: FLINK-36180
URL: https://issues.apache.org/jira/browse/
[
https://issues.apache.org/jira/browse/FLINK-36176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36176:
---
Labels: pull-request-available (was: )
> Remove support for ancient Kafka versions
> --
boring-cyborg[bot] commented on PR #115:
URL:
https://github.com/apache/flink-connector-kafka/pull/115#issuecomment-2317623921
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
AHeise opened a new pull request, #115:
URL: https://github.com/apache/flink-connector-kafka/pull/115
Warp up FLINK-19152 by also removing all related producer code.
Move FlinkKafkaProducerBase.getPropertiesFromBrokerList to a new test
utility class as this method is used by some test
[
https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-35988.
---
Resolution: Fixed
Fixed in master: d9931c8af05d0f1f721be9fe920690fe122507ad
> Reduce the number of
lincoln-lil merged PR #25159:
URL: https://github.com/apache/flink/pull/25159
--
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
lexluo09 commented on PR #25257:
URL: https://github.com/apache/flink/pull/25257#issuecomment-2317580430
> And BTW, you should run `mvn package -Dgenerate-config-docs -pl flink-docs
-am -nsu -DskipTests -Pskip-webui-build` if you add/change the configurations.
Please check the instructions
[
https://issues.apache.org/jira/browse/FLINK-36179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36179:
---
Labels: pull-request-available (was: )
> Bump log4j version
> --
>
>
r-sidd opened a new pull request, #877:
URL: https://github.com/apache/flink-kubernetes-operator/pull/877
Bumping **log4j** to the latest version (2.23.1) - this will remediate a lot
of vulnerabilities in dependant packages.
**Package details:**
https://mvnrepository.com/artif
Siddharth R created FLINK-36179:
---
Summary: Bump log4j version
Key: FLINK-36179
URL: https://issues.apache.org/jira/browse/FLINK-36179
Project: Flink
Issue Type: Improvement
Components
pnowojski merged PR #25245:
URL: https://github.com/apache/flink/pull/25245
--
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
lvyanquan commented on code in PR #3569:
URL: https://github.com/apache/flink-cdc/pull/3569#discussion_r1736054979
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java:
lvyanquan commented on code in PR #3569:
URL: https://github.com/apache/flink-cdc/pull/3569#discussion_r1736053118
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java:
gyfora commented on PR #876:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/876#issuecomment-2317390266
@1996fanrui it's okay to merge these types of straightforward changes
immediately 👍
--
This is an automated message from the Apache Git Service.
To respond to the messa
gaborgsomogyi commented on PR #25262:
URL: https://github.com/apache/flink/pull/25262#issuecomment-2317386747
Some unrelated issues:
```
08:48:23.638 [ERROR] Failed to execute goal
com.github.eirslett:frontend-maven-plugin:1.12.1:install-node-and-npm (install
node and npm) on project
snuyanzin commented on code in PR #19811:
URL: https://github.com/apache/flink/pull/19811#discussion_r1736030307
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/hashtable/BinaryHashTableTest.java:
##
@@ -56,7 +57,7 @@
import static org.assertj.co
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36178:
---
Labels: pull-request-available (was: )
> Parse CREATE TABLE LIKE to CreateTableEvent corre
lvyanquan opened a new pull request, #3590:
URL: https://github.com/apache/flink-cdc/pull/3590
Support parsing SQL like following:
```
CREATE TABLE `user_log_copy` LIKE `user_log`
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
r-sidd commented on PR #876:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/876#issuecomment-2317324783
> Thanks @r-sidd for the contribution!
>
> LGTM.
>
> I will merge it if no objection within 24 hours.
Sure, thank you 🙂
--
This is an automated messa
gaborgsomogyi commented on PR #25262:
URL: https://github.com/apache/flink/pull/25262#issuecomment-2317275532
Backport to 1.20 makes sense.
--
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-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Summary: Parse CREATE TABLE LIKE to CreateTableEvent correctly. (was:
Parse CREATE TABLE LIKE to Cre
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877657#comment-17877657
]
LvYanquan commented on FLINK-36178:
---
I'm willing to fix this.
> Parse CREATE TABLE LI
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Component/s: Flink CDC
> Parse CREATE TABLE LIKE to CreateTableEvent
> --
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Labels: (was: cdc)
> Parse CREATE TABLE LIKE to CreateTableEvent
>
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Description: Currently, {{CREATE TABLE `user_log_copy_2` LIKE `user_log`
SQL is not correctly parsed,
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Labels: cdc (was: )
> Parse CREATE TABLE LIKE to CreateTableEvent
>
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Affects Version/s: cdc-3.2.0
> Parse CREATE TABLE LIKE to CreateTableEvent
>
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Fix Version/s: cdc-3.2.0
> Parse CREATE TABLE LIKE to CreateTableEvent
>
[
https://issues.apache.org/jira/browse/FLINK-36178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-36178:
--
Summary: Parse CREATE TABLE LIKE to CreateTableEvent (was: Parse CREATE
TABLE LIKE to CreateTableEve
LvYanquan created FLINK-36178:
-
Summary: Parse CREATE TABLE LIKE to CreateTableEvent
Key: FLINK-36178
URL: https://issues.apache.org/jira/browse/FLINK-36178
Project: Flink
Issue Type: Improvement
MartijnVisser commented on PR #25265:
URL: https://github.com/apache/flink/pull/25265#issuecomment-2317223285
@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 comm
gaborgsomogyi commented on PR #25267:
URL: https://github.com/apache/flink/pull/25267#issuecomment-2317206099
cc @gyfora
--
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
gaborgsomogyi commented on PR #25262:
URL: https://github.com/apache/flink/pull/25262#issuecomment-2317197421
Though not really sure how severe it is to add backports. We can do if we
think so...
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
gaborgsomogyi commented on PR #25262:
URL: https://github.com/apache/flink/pull/25262#issuecomment-2317195551
I think this is there for quite some time.
--
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
JunRuiLee commented on PR #25256:
URL: https://github.com/apache/flink/pull/25256#issuecomment-2317180646
@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.
loserwang1024 commented on code in PR #3588:
URL: https://github.com/apache/flink-cdc/pull/3588#discussion_r1735899156
##
flink-cdc-cli/src/test/resources/definitions/pipeline-definition-minimized.yaml:
##
Review Comment:
Test YamlPipelineDefinitionParserTest.YamlPipelineDe
gaborgsomogyi commented on code in PR #25267:
URL: https://github.com/apache/flink/pull/25267#discussion_r1735888342
##
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/SavepointWriterUidModificationITCase.java:
##
@@ -184,21 +214,57 @@ private
gaborgsomogyi commented on code in PR #25267:
URL: https://github.com/apache/flink/pull/25267#discussion_r1735896005
##
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/input/KeyedStateInputFormatTest.java:
##
@@ -213,7 +213,7 @@ private List r
1 - 100 of 148 matches
Mail list logo
