anupamaggarwal commented on code in PR #24967:
URL: https://github.com/apache/flink/pull/24967#discussion_r1673409493
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/JsonUnquoteFunction.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed
gyfora commented on PR #847:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/847#issuecomment-163270
> Hi, @mxm, @gyfora. I rewrote the code for the processing rate
backpropagation. Unfortunately, backpropagation results depend on the vertices
order during backpropagation
twalthr commented on PR #24993:
URL: https://github.com/apache/flink/pull/24993#issuecomment-18
@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.
AHeise commented on PR #107:
URL:
https://github.com/apache/flink-connector-kafka/pull/107#issuecomment-142699
> > At this point, we just try to get the build green. You can check locally
by running `mvn verify`.
>
> checked, should be green now.
Retriggering CI.
--
Thi
[
https://issues.apache.org/jira/browse/FLINK-35004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864922#comment-17864922
]
Rui Fan commented on FLINK-35004:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
Rui Fan created FLINK-35810:
---
Summary:
AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails
Key: FLINK-35810
URL: https://issues.apache.org/jira/browse/FLINK-35810
Project: Flink
Zakelly closed pull request #25071: [AZP-Trigger] Fixing two issues about
checkpoint file-merging
URL: https://github.com/apache/flink/pull/25071
--
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
[
https://issues.apache.org/jira/browse/FLINK-33672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864917#comment-17864917
]
Zakelly Lan commented on FLINK-33672:
-
I haven't done any perf on this. :D
> Use Ma
lvyanquan commented on code in PR #3468:
URL: https://github.com/apache/flink-cdc/pull/3468#discussion_r1673449557
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerITCase.java:
##
@@ -335,6 +337,65 @@ void testTransform(ValuesDataSink.
Zakelly commented on PR #25066:
URL: https://github.com/apache/flink/pull/25066#issuecomment-088556
I have run the test with the last commit for 200 times. No failure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
yuxiqian commented on PR #3466:
URL: https://github.com/apache/flink-cdc/pull/3466#issuecomment-055928
Tested in my forked repo, and reviewer auto-assigning & PR progress tagging
features work as expected.
Looking forward to @GOODBOY008 @leonardBang's thoughts.
--
This is an au
anupamaggarwal commented on code in PR #24967:
URL: https://github.com/apache/flink/pull/24967#discussion_r1673409493
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/JsonUnquoteFunction.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed
kumar-mallikarjuna commented on code in PR #25027:
URL: https://github.com/apache/flink/pull/25027#discussion_r1673394381
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java:
##
@@ -85,7 +85,16 @@ public Collection getJobManage
aplyusnin commented on PR #847:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/847#issuecomment-003461
Hi, @mxm, @gyfora. I rewrote the code for the processing rate
backpropagation. Unfortunately, backpropagation results depend on the vertices
order during backpropagatio
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-20628:
---
Assignee: (was: RocMarshal)
> Port RabbitMQ Sources to FLIP-27 API
> --
JimmyZZZ commented on PR #107:
URL:
https://github.com/apache/flink-connector-kafka/pull/107#issuecomment-2221950554
> At this point, we just try to get the build green. You can check locally
by running `mvn verify`.
checked, should be green now.
--
This is an automated message f
JimmyZZZ opened a new pull request, #107:
URL: https://github.com/apache/flink-connector-kafka/pull/107
## What is the purpose of the change
Fix the bug for losing data during kafka cluster is unavailable for a while.
The related issue: https://issues.apache.org/jira/browse/FLINK-35
JimmyZZZ closed pull request #107: [FLINK-35749] Kafka sink component will lose
data when kafka cluster is unavailable for a while
URL: https://github.com/apache/flink-connector-kafka/pull/107
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/FLINK-35754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864884#comment-17864884
]
Feng Jin commented on FLINK-35754:
--
I submitted the backport pr [https://github.com/ap
flinkbot commented on PR #25073:
URL: https://github.com/apache/flink/pull/25073#issuecomment-2221901401
## CI report:
* db07a5a7d16ebb7a702c12e14fb45000950ca539 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on PR #25066:
URL: https://github.com/apache/flink/pull/25066#issuecomment-2221899392
I don't think the CI failure is related with file-merging. It happens when
file-merging is disabled. I'm investigating the potential file leak.
--
This is an automated message from the
superdiaodiao commented on PR #25053:
URL: https://github.com/apache/flink/pull/25053#issuecomment-2221897499
> Thanks for the review, @superdiaodiao. Updated the PR to fix the tests.
You're welcome! ^_^
I left some suggestion just now, please take a look.
--
This is an automated
superdiaodiao commented on code in PR #25053:
URL: https://github.com/apache/flink/pull/25053#discussion_r1673325921
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/BitLeftShiftFunction.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed t
superdiaodiao commented on code in PR #25053:
URL: https://github.com/apache/flink/pull/25053#discussion_r1673323514
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/BitLeftShiftFunction.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed t
superdiaodiao commented on code in PR #25053:
URL: https://github.com/apache/flink/pull/25053#discussion_r1673320514
##
docs/data/sql_functions_zh.yml:
##
@@ -302,7 +302,13 @@ arithmetic:
返回截取 integer2 位小数的数字。如果 numeric1 或 integer2 为 `NULL`，则返回 `NULL`。
如果 integer2
[
https://issues.apache.org/jira/browse/FLINK-35782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864877#comment-17864877
]
Yi Cai commented on FLINK-35782:
mysql-connector-j-8.0.33.jar is mysql jdbc driver, all
hackergin opened a new pull request, #25073:
URL: https://github.com/apache/flink/pull/25073
BP https://github.com/apache/flink/pull/25029
## What is the purpose of the change
*Fix unstable testMaterializedTableInFullMode test case*
## Brief change log
- *Fix
[
https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864874#comment-17864874
]
Zakelly Lan commented on FLINK-35803:
-
Merged into master via: 2cad54846510db63254c5
[
https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-35803.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> ResumeCheckpointManuallyITCase fails with check
[
https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-35803:
Fix Version/s: 2.0.0
> ResumeCheckpointManuallyITCase fails with checkpoint file merging
> ---
Zakelly merged PR #25070:
URL: https://github.com/apache/flink/pull/25070
--
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
Zakelly merged PR #25069:
URL: https://github.com/apache/flink/pull/25069
--
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
钟洋洋 created FLINK-35809:
---
Summary: Deploying Flink History Server and Flink SQL Gateway via
Flink Operator.
Key: FLINK-35809
URL: https://issues.apache.org/jira/browse/FLINK-35809
Project: Flink
Issue
Zakelly commented on PR #25071:
URL: https://github.com/apache/flink/pull/25071#issuecomment-2221864778
@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-35782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864865#comment-17864865
]
xuyang commented on FLINK-35782:
Hi, [~caiyi]. SqlGateway does not provide a driver by d
lvyanquan commented on PR #3466:
URL: https://github.com/apache/flink-cdc/pull/3466#issuecomment-2221829575
Further more, can you add approve label to help PR reviewing?
https://github.com/apache/seatunnel/blob/5bf6f7892a65ed26ef0bee3d6e21638bd7cab37b/.github/workflows/approve-label.yml#L4
[
https://issues.apache.org/jira/browse/FLINK-35754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864854#comment-17864854
]
dalongliu commented on FLINK-35754:
---
[~hackergin] Can you help backport it to release-
[
https://issues.apache.org/jira/browse/FLINK-35754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864853#comment-17864853
]
dalongliu commented on FLINK-35754:
---
Merged in master: d04c70fae033bb04ed7a3bb69832be5
lsyldliu merged PR #25029:
URL: https://github.com/apache/flink/pull/25029
--
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
yuxiqian commented on PR #3222:
URL: https://github.com/apache/flink-cdc/pull/3222#issuecomment-2221802936
Closing this for now since it has been implemented in
https://github.com/apache/doris-flink-connector/pull/408.
--
This is an automated message from the Apache Git Service.
To respon
yuxiqian closed pull request #3222: [FLINK-35090][cdc][doris] Add database
auto-creating support for Doris sink pipeline connector
URL: https://github.com/apache/flink-cdc/pull/3222
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
yuxiqian commented on PR #3215:
URL: https://github.com/apache/flink-cdc/pull/3215#issuecomment-2221802439
Since it has been implemented in
https://github.com/apache/doris-flink-connector/pull/408, I'll close it for now
and bump dependency version to address this after Doris Flink connector
yuxiqian closed pull request #3215: [FLINK-35072][cdc][doris] Support applying
compatible `AlterColumnTypeEvent` to Doris sink
URL: https://github.com/apache/flink-cdc/pull/3215
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
jnh5y commented on PR #25064:
URL: https://github.com/apache/flink/pull/25064#issuecomment-2221656321
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Lam updated FLINK-35808:
--
Description:
This issue is a follow-up to [this mailing list
discussion|https://lists.apache.org/thre
[
https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Lam updated FLINK-35808:
--
Description:
This issue is a follow-up to [this mailing list
discussion|https://lists.apache.org/thre
[
https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Lam updated FLINK-35808:
--
Description:
This issue is a follow-up to [this mailing list
discussion|https://lists.apache.org/thre
[
https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Lam updated FLINK-35808:
--
Description:
This issue is a follow-up to [this mailing list
discussion|https://lists.apache.org/thre
Kevin Lam created FLINK-35808:
-
Summary: Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be
overridable by user in KafkaSourceBuilder
Key: FLINK-35808
URL: https://issues.apache.org/jira/browse/FLINK-35808
klam-shop opened a new pull request, #108:
URL: https://github.com/apache/flink-connector-kafka/pull/108
Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG overridable by user in
`KafkaSourceBuilder`, in order to enable the Large Message use-case discussed
in this [mailing list
discussion]
boring-cyborg[bot] commented on PR #108:
URL:
https://github.com/apache/flink-connector-kafka/pull/108#issuecomment-2221254845
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-35706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergio Peña updated FLINK-35706:
Summary: FLIP-463: Schema Definition in CREATE TABLE AS Statement (was:
FLIP-463: Allow defining
[
https://issues.apache.org/jira/browse/FLINK-35706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergio Peña updated FLINK-35706:
Summary: FLIP-463: Allow defining partition keys and table distribution in
CREATE TABLE AS (CTAS)
[
https://issues.apache.org/jira/browse/FLINK-33672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864748#comment-17864748
]
Roman Khachatryan commented on FLINK-33672:
---
Nice optimization!
Do you have a
Zakelly commented on PR #25071:
URL: https://github.com/apache/flink/pull/25071#issuecomment-2220990688
Github action attempt 1 passed
https://github.com/Zakelly/flink/actions/runs/9875488506/attempts/1
--
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-34341:
---
Assignee: (was: Hong Liang Teoh)
> Implement DDB Streams Table API support
> --
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-34341:
---
Assignee: Hong Liang Teoh
> Implement DDB Streams Table API support
> -
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-34341:
---
Assignee: Abhi Gupta
> Implement DDB Streams Table API support
> --
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-34341:
Fix Version/s: aws-connector-4.4.0
> Implement DDB Streams Table API support
> ---
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-34341.
-
Resolution: Fixed
> Implement DDB Streams Table API support
> --
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864734#comment-17864734
]
Hong Liang Teoh commented on FLINK-34341:
-
merged commit
[{{7f3483c}}|https://
[
https://issues.apache.org/jira/browse/FLINK-32218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-32218.
-
Resolution: Fixed
> Implement support for parent/child shard ordering
>
[
https://issues.apache.org/jira/browse/FLINK-32218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-32218:
Fix Version/s: aws-connector-4.4.0
> Implement support for parent/child shard ordering
> -
[
https://issues.apache.org/jira/browse/FLINK-32218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864733#comment-17864733
]
Hong Liang Teoh commented on FLINK-32218:
-
merged commit
[{{c716ca4}}|https://
hlteoh37 merged PR #145:
URL: https://github.com/apache/flink-connector-aws/pull/145
--
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...@
Zakelly commented on code in PR #25066:
URL: https://github.com/apache/flink/pull/25066#discussion_r1672561489
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SnapshotFileMergingCompatibilityITCase.java:
##
@@ -249,48 +249,42 @@ private void verifyStateHandleTyp
Zakelly commented on code in PR #25066:
URL: https://github.com/apache/flink/pull/25066#discussion_r1672561489
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SnapshotFileMergingCompatibilityITCase.java:
##
@@ -249,48 +249,42 @@ private void verifyStateHandleTyp
pnowojski commented on code in PR #25028:
URL: https://github.com/apache/flink/pull/25028#discussion_r1672556173
##
flink-core/src/main/java/org/apache/flink/util/FileUtils.java:
##
@@ -138,17 +140,27 @@ public static String readFile(File file, String
charsetName) throws IOExce
Zakelly commented on PR #25070:
URL: https://github.com/apache/flink/pull/25070#issuecomment-2220887841
@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 PR #25070:
URL: https://github.com/apache/flink/pull/25070#issuecomment-2220887548
Unrelated CI error, re-running
--
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
[
https://issues.apache.org/jira/browse/FLINK-35754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864727#comment-17864727
]
Zakelly Lan commented on FLINK-35754:
-
https://dev.azure.com/apache-flink/apache-fli
z3d1k commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1672531161
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTrackerTest.java:
##
z3d1k commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1672531161
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTrackerTest.java:
##
z3d1k commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1672530653
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTrackerTest.java:
##
hlteoh37 commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1672530257
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTrackerTest.java:
###
z3d1k commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1672525373
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTracker.java:
##
@@
spena commented on code in PR #24993:
URL: https://github.com/apache/flink/pull/24993#discussion_r1672522012
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTableAs.java:
##
@@ -124,18 +124,6 @@ public void validate() throws SqlValidateExce
snuyanzin commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672519351
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala:
##
@@ -182,6 +186,58 @@ abstract class PlannerBase(
pnowojski commented on code in PR #25028:
URL: https://github.com/apache/flink/pull/25028#discussion_r1672494318
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamStateHandle.java:
##
@@ -38,6 +38,14 @@ public interface StreamStateHandle extends StateObject {
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864710#comment-17864710
]
Alexis Sarda-Espinosa commented on FLINK-25920:
---
We don't use transactions
hlteoh37 merged PR #147:
URL: https://github.com/apache/flink-connector-aws/pull/147
--
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...@
z3d1k commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1672449884
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxyTest.java:
##
@@ -41
zhangkunjie created FLINK-35807:
---
Summary: When restoring a task from a savepoint, tables that were
previously synchronized but later deleted still exist in a state
Key: FLINK-35807
URL: https://issues.apache.org/ji
jnh5y commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672433347
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala:
##
@@ -182,6 +186,58 @@ abstract class PlannerBase(
tr
snuyanzin commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672412991
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/ExecNodeMetadataUtil.java:
##
@@ -198,8 +205,9 @@ public static Class>
ret
snuyanzin commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672406225
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala:
##
@@ -182,6 +186,58 @@ abstract class PlannerBase(
spena commented on code in PR #24993:
URL: https://github.com/apache/flink/pull/24993#discussion_r1672397308
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDdlToOperationConverterTest.java:
##
@@ -856,18 +858,30 @@ public void testM
z3d1k commented on code in PR #145:
URL:
https://github.com/apache/flink-connector-aws/pull/145#discussion_r1670845570
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/enumerator/tracker/SplitTrackerTest.java:
##
jnh5y commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672366149
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java:
##
@@ -568,7 +568,7 @@ public Optional generat
jnh5y commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672364217
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/api/CompiledPlanITCase.java:
##
@@ -404,28 +404,13 @@ void testPersistedConfigOption() throws Exce
jnh5y commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672363121
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecCalc.java:
##
@@ -65,6 +76,29 @@ public BatchExecCalc(
fhueske commented on code in PR #24967:
URL: https://github.com/apache/flink/pull/24967#discussion_r1672309798
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java:
##
@@ -794,6 +796,218 @@ private static List jsonObj
mattayes commented on PR #25061:
URL: https://github.com/apache/flink/pull/25061#issuecomment-2220597610
Thanks @Samrat002!
--
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.
twalthr commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672278690
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSink.java:
##
@@ -33,19 +34,38 @@
import org.apache.flin
[
https://issues.apache.org/jira/browse/FLINK-35796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864668#comment-17864668
]
Martijn Visser commented on FLINK-35796:
[~arvid] Will you backport it also to t
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864666#comment-17864666
]
Arvid Heise edited comment on FLINK-25920 at 7/10/24 1:46 PM:
[
https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864666#comment-17864666
]
Arvid Heise commented on FLINK-25920:
-
Could you please verify that your transaction
jnh5y commented on code in PR #25064:
URL: https://github.com/apache/flink/pull/25064#discussion_r1672276028
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/ExecNodeMetadataUtil.java:
##
@@ -198,8 +205,9 @@ public static Class>
retriev
[
https://issues.apache.org/jira/browse/FLINK-35717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35717:
---
Labels: pull-request-available (was: )
> Allow DISTRIBUTED BY in CREATE TABLE AS (CTAS)
> -
twalthr commented on code in PR #24993:
URL: https://github.com/apache/flink/pull/24993#discussion_r1672253123
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTableAs.java:
##
@@ -124,18 +124,6 @@ public void validate() throws SqlValidateEx
1 - 100 of 702 matches
Mail list logo
