luoyuxia commented on code in PR #22977:
URL: https://github.com/apache/flink/pull/22977#discussion_r1263367999
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPropertiesUtil.java:
##
@@ -79,6 +80,11 @@ public static Map
serializeCatalogTab
[
https://issues.apache.org/jira/browse/FLINK-32020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-32020.
---
Resolution: Fixed
> Enable Dynamic Partition Discovery by Default in Kafka Source based on
[
https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-31953.
---
Resolution: Fixed
> FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source
[
https://issues.apache.org/jira/browse/FLINK-32020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743029#comment-17743029
]
Qingsheng Ren commented on FLINK-32020:
---
Merged to main: 811716c5155e82fa3bfc47ced
PatrickRen closed pull request #40: [FLINK-32020] Enable Dynamic Partition
Discovery by Default in Kafka Source based on FLIP-288
URL: https://github.com/apache/flink-connector-kafka/pull/40
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
jiaoqingbo commented on PR #22992:
URL: https://github.com/apache/flink/pull/22992#issuecomment-1635348356
My modification does not seem to be related to the CI error ，please cc
@wanglijie95
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743010#comment-17743010
]
Dong Lin commented on FLINK-32335:
--
Merged to apache/flink-ml master branch 892fb4714c6
[
https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-32335.
--
Resolution: Fixed
> Fix the Flink ML unittest failure
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743009#comment-17743009
]
Yunhong Zheng commented on FLINK-32579:
---
Hi, [~jasonliangyc] . I got it.
For ques
[
https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-32335:
Assignee: Jiang Xin
> Fix the Flink ML unittest failure
> -
>
>
lindong28 merged PR #247:
URL: https://github.com/apache/flink-ml/pull/247
--
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
lindong28 commented on PR #247:
URL: https://github.com/apache/flink-ml/pull/247#issuecomment-1635252080
Thanks for the PR. LGTM.
--
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
Guozhen Yang created FLINK-32590:
Summary: Fail to read flink parquet filesystem table stored in
hive metastore service.
Key: FLINK-32590
URL: https://issues.apache.org/jira/browse/FLINK-32590
Project
flinkbot commented on PR #22994:
URL: https://github.com/apache/flink/pull/22994#issuecomment-1635219756
## CI report:
* c7abe7f02a916120208e6f9b80513bf6b6385b9a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32354:
---
Labels: pull-request-available (was: )
> Support to execute the call procedure operation
>
luoyuxia opened a new pull request, #22994:
URL: https://github.com/apache/flink/pull/22994
## 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 avoid re-transferring them o
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263236647
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalogOptions.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263235270
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalogOptions.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263235270
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalogOptions.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263235270
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalogOptions.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263233465
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/constants/AWSGlueConfigConstants.java:
##
@@ -0,0 +1,48 @@
+/*
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263232863
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/constants/AWSGlueConfigConstants.java:
##
@@ -0,0 +1,48 @@
+/*
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1263232863
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/constants/AWSGlueConfigConstants.java:
##
@@ -0,0 +1,48 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-28743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee resolved FLINK-28743.
-
Resolution: Fixed
fixed in master: 8829b5e60a71b871462d1d2bb849c926b0de9b80
> Support validatin
lincoln-lil merged PR #22981:
URL: https://github.com/apache/flink/pull/22981
--
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
jiaoqingbo commented on PR #22992:
URL: https://github.com/apache/flink/pull/22992#issuecomment-1635163141
@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-32481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32481.
--
Resolution: Fixed
master:
e5324c085f627df2f8e452b0aec3264fe0c6f6f6
> Support type inference for proc
luoyuxia merged PR #22904:
URL: https://github.com/apache/flink/pull/22904
--
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
luoyuxia commented on PR #22904:
URL: https://github.com/apache/flink/pull/22904#issuecomment-1635130068
@LadyForest Thanks for reviewing. 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
[
https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc closed FLINK-32587.
Resolution: Cannot Reproduce
> The results returned from the CDC sql query are null or the value w
[
https://issues.apache.org/jira/browse/FLINK-31830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742968#comment-17742968
]
Sergey Nuyanzin commented on FLINK-31830:
-
Thanks for the very detailed investig
[
https://issues.apache.org/jira/browse/FLINK-32585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-32585.
-
Resolution: Fixed
master via d7a3b3847dc5c680b32d1997d448b7dac44e529c
> Filter javax.xml.bind:jaxb-api
tisonkun merged PR #22989:
URL: https://github.com/apache/flink/pull/22989
--
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
tisonkun commented on PR #22989:
URL: https://github.com/apache/flink/pull/22989#issuecomment-1634654818
Emm..I think I should merge it now so that the SNAPSHOT can be updated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
tisonkun commented on PR #22989:
URL: https://github.com/apache/flink/pull/22989#issuecomment-1634653552
I'm going to merge this patch tomorrow and check if the Pulsar connector can
pass with this patch.
--
This is an automated message from the Apache Git Service.
To respond to the messag
flinkbot commented on PR #22993:
URL: https://github.com/apache/flink/pull/22993#issuecomment-1634603561
## CI report:
* c1ebb259b21f391fb12eae4d1dd2647e1dd90350 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #22993:
URL: https://github.com/apache/flink/pull/22993
Bumps [okio](https://github.com/square/okio) from 1.17.2 to 3.4.0.
Changelog
Sourced from https://github.com/square/okio/blob/master/CHANGELOG.md";>okio's
changelog.
Version 3.
[
https://issues.apache.org/jira/browse/FLINK-32589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742887#comment-17742887
]
Gyula Fora commented on FLINK-32589:
I think this would be a good improvement but we
[
https://issues.apache.org/jira/browse/FLINK-32589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742886#comment-17742886
]
Gyula Fora commented on FLINK-32589:
So just to be clear, do you suggest adding a ne
[
https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-32420:
---
Release Note:
This performance improvement would be good to mention in the release blog post
[
https://issues.apache.org/jira/browse/FLINK-32589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742865#comment-17742865
]
Maximilian Michels commented on FLINK-32589:
We handle this in our applicati
XComp commented on code in PR #22987:
URL: https://github.com/apache/flink/pull/22987#discussion_r1262773979
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java:
##
@@ -501,6 +501,22 @@ private CompletableFuture
submitRequest(
}
gyfora merged PR #630:
URL: https://github.com/apache/flink-kubernetes-operator/pull/630
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742849#comment-17742849
]
Rui Fan commented on FLINK-32420:
-
Thanks [~pnowojski] for update the performance change
[
https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742846#comment-17742846
]
Piotr Nowojski commented on FLINK-32420:
Yeah... no need for further comments :)
[
https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-32420:
---
Attachment: Screenshot 2023-07-13 at 17.19.11.png
Screenshot 2023-07-13 at 17
[
https://issues.apache.org/jira/browse/FLINK-32589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742840#comment-17742840
]
Gyula Fora commented on FLINK-32589:
I think this is not necessarily something that
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1262718932
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java:
##
@@ -0,0 +1,1188 @@
+/*
+ * Licensed to the
wanglijie95 commented on code in PR #22861:
URL: https://github.com/apache/flink/pull/22861#discussion_r1262696361
##
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputGateDeploymentDescriptor.java:
##
@@ -139,53 +139,67 @@ public IndexRange getConsumedSubpart
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742834#comment-17742834
]
jasonliangyc edited comment on FLINK-32579 at 7/13/23 3:09 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742834#comment-17742834
]
jasonliangyc edited comment on FLINK-32579 at 7/13/23 3:06 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742834#comment-17742834
]
jasonliangyc edited comment on FLINK-32579 at 7/13/23 3:05 PM:
---
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1262700429
##
flink-catalog-aws/flink-catalog-aws-glue/pom.xml:
##
@@ -0,0 +1,125 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/200
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742834#comment-17742834
]
jasonliangyc commented on FLINK-32579:
--
Hi [~337361...@qq.com]. Yes, I'm using the
akalash commented on code in PR #22761:
URL: https://github.com/apache/flink/pull/22761#discussion_r1262673283
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java:
##
@@ -65,7 +65,7 @@ public abstract class BufferWriting
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc updated FLINK-32579:
-
Attachment: test_case.sql
> The filter criteria on the lookup table of Lookup join has no effect
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc updated FLINK-32579:
-
Attachment: image-2023-07-13-22-43-45-957.png
> The filter criteria on the lookup table of Looku
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc updated FLINK-32579:
-
Attachment: image-2023-07-13-22-43-24-213.png
> The filter criteria on the lookup table of Looku
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1262663157
##
flink-catalog-aws/flink-catalog-aws-glue/pom.xml:
##
@@ -0,0 +1,125 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/200
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc updated FLINK-32579:
-
Attachment: image-2023-07-13-22-38-16-709.png
> The filter criteria on the lookup table of Looku
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jasonliangyc updated FLINK-32579:
-
Attachment: image-2023-07-13-22-35-35-696.png
> The filter criteria on the lookup table of Looku
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1262655614
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/operator/GlueFunctionOperator.java:
##
@@ -0,0 +1,277 @@
+/*
+
Maximilian Michels created FLINK-32589:
--
Summary: Carry over parallelism overrides to prevent users from
clearing them on updates
Key: FLINK-32589
URL: https://issues.apache.org/jira/browse/FLINK-32589
XComp commented on PR #22988:
URL: https://github.com/apache/flink/pull/22988#issuecomment-1634351279
(sorry for not approving the PR before merging :innocent: )
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-32157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32157.
---
Fix Version/s: 1.18.0
Resolution: Fixed
master: f37d41cf557e9acd113a063dbee442a3a92bf
XComp merged PR #22988:
URL: https://github.com/apache/flink/pull/22988
--
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 #22010:
URL: https://github.com/apache/flink/pull/22010#issuecomment-1634336399
> In https://github.com/apache/flink/pull/21971 we added
SequenceGeneratorTest, I think we can add the corresponding test method in
https://github.com/apache/flink/pull/21971
I'm not
luoyuxia commented on code in PR #22939:
URL: https://github.com/apache/flink/pull/22939#discussion_r1262460439
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -380,7 +380,28 @@ public Optional
getTable(ObjectIdentifie
liuyongvs commented on PR #22745:
URL: https://github.com/apache/flink/pull/22745#issuecomment-1634235602
Hi @snuyanzin do you have 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 go to the spec
XComp commented on PR #22984:
URL: https://github.com/apache/flink/pull/22984#issuecomment-1634211308
Yup, I agree. I feel like it makes sense to summarize everything in a FLIP.
I created
[FLIP-335](https://cwiki.apache.org/confluence/display/FLINK/FLIP-335%3A+removing+flink's+time+classes)
zentol commented on PR #22984:
URL: https://github.com/apache/flink/pull/22984#issuecomment-1634202032
> I assumed the [discussion mentioned in
FLINK-14068](https://lists.apache.org/thread/76yywnwf3lk8qn4dby0vz7yoqx7f7pkj)
and [FLINK-14068](https://issues.apache.org/jira/browse/FLINK-14068)
fredia commented on PR #22890:
URL: https://github.com/apache/flink/pull/22890#issuecomment-1634170838
@AlexYinHan Thanks for the review and suggestion, I have addressed your
comments. It could be very nice if you could take another look.
--
This is an automated message from the Apache G
fredia commented on code in PR #22890:
URL: https://github.com/apache/flink/pull/22890#discussion_r1262496038
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageWorkerView.java:
##
@@ -75,4 +77,14 @@ CheckpointStreamFactory resolveCheckpointStorageLoc
fredia commented on code in PR #22890:
URL: https://github.com/apache/flink/pull/22890#discussion_r1262494966
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsMergingCheckpointStorageAccess.java:
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Softwa
lsyldliu commented on code in PR #22966:
URL: https://github.com/apache/flink/pull/22966#discussion_r1262402227
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/batch/runtimefilter/BatchPhysicalGlobalRuntimeFilterBuilder.java:
#
Limookiplimo opened a new pull request, #663:
URL: https://github.com/apache/flink-web/pull/663
Updated grammar on the markdown to improve clarity and accuracy. Added the
preposition "with" after "work well" and changed "each of" to "with each of"
for consistency.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-32049.
-
Fix Version/s: 1.18.0
1.17.2
Assignee: Rui Fan (was: Qingsheng Ren)
R
[
https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742758#comment-17742758
]
Rui Fan commented on FLINK-32049:
-
Hi [~Sergey Nuyanzin][~renqs], thanks for the reporti
[
https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742689#comment-17742689
]
Rui Fan edited comment on FLINK-32049 at 7/13/23 10:27 AM:
---
Me
1996fanrui merged PR #22991:
URL: https://github.com/apache/flink/pull/22991
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
1996fanrui commented on PR #22991:
URL: https://github.com/apache/flink/pull/22991#issuecomment-1633970439
Thanks for the review, 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 spec
luoyuxia commented on PR #22904:
URL: https://github.com/apache/flink/pull/22904#issuecomment-1633962951
@LadyForest Thanks for your reviewing. I have addressed your comment in this
[commit](https://github.com/apache/flink/pull/22904/commits/35a62a159cd1fa45aaa250218f013cd43d8d31d1).
--
T
darenwkt commented on code in PR #620:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/620#discussion_r1262342704
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -129,26 +144,56 @@ publi
luoyuxia commented on code in PR #22904:
URL: https://github.com/apache/flink/pull/22904#discussion_r1262339392
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java:
##
@@ -133,10 +149,19 @@ private static class DefaultAnn
PatrickRen commented on code in PR #22924:
URL: https://github.com/apache/flink/pull/22924#discussion_r1262307415
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/api/EnvironmentTest.java:
##
@@ -25,14 +25,22 @@
import org.apache.flink.streaming.api.envir
Jiang Xin created FLINK-32588:
-
Summary: Flink ML unittest BoundedPerRoundStreamIterationITCase
failed
Key: FLINK-32588
URL: https://issues.apache.org/jira/browse/FLINK-32588
Project: Flink
Issu
LadyForest commented on code in PR #22904:
URL: https://github.com/apache/flink/pull/22904#discussion_r1262153293
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java:
##
@@ -146,6 +171,15 @@ private static T defaultAsNul
[
https://issues.apache.org/jira/browse/FLINK-32481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32481:
---
Labels: pull-request-available (was: )
> Support type inference for procedure
> ---
LadyForest commented on code in PR #22904:
URL: https://github.com/apache/flink/pull/22904#discussion_r1259336884
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java:
##
@@ -577,6 +839,18 @@ static TestSpec forT
jasonliangyc created FLINK-32587:
Summary: The results returned from the CDC sql query are null or
the value was changed unexpectly
Key: FLINK-32587
URL: https://issues.apache.org/jira/browse/FLINK-32587
PatrickRen commented on code in PR #22869:
URL: https://github.com/apache/flink/pull/22869#discussion_r1262279404
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterDatabaseOperation.java:
##
@@ -70,10 +69,13 @@ public String asSummarySt
flinkbot commented on PR #22992:
URL: https://github.com/apache/flink/pull/22992#issuecomment-1633890956
## CI report:
* 72e8439ce49f3ebfe275a653d6ed41b6977de0ee UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742730#comment-17742730
]
Lijie Wang commented on FLINK-32586:
Thanks your proposal, make sense to me, assigne
[
https://issues.apache.org/jira/browse/FLINK-32586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-32586:
--
Assignee: xingbe
> Enable input locality in SimpleExecutionSlotAllocator
> --
[
https://issues.apache.org/jira/browse/FLINK-32577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-32577:
--
Description:
This issue is a sub-issue of FLINK-18356.
was:This issue is a sub-issue
jiaoqingbo opened a new pull request, #22992:
URL: https://github.com/apache/flink/pull/22992
## 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 avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742728#comment-17742728
]
Yunhong Zheng commented on FLINK-32579:
---
Hi [~jasonliangyc] . Are you using Flink
[
https://issues.apache.org/jira/browse/FLINK-32579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-32579:
--
Attachment: image-2023-07-13-17-19-26-972.png
> The filter criteria on the lookup table of Loo
xingbe created FLINK-32586:
--
Summary: Enable input locality in SimpleExecutionSlotAllocator
Key: FLINK-32586
URL: https://issues.apache.org/jira/browse/FLINK-32586
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742689#comment-17742689
]
Rui Fan commented on FLINK-32049:
-
Merged via:
bc4c21e47040360aab5bcb0f2c18b907b60e7838
1 - 100 of 104 matches
Mail list logo
