flinkbot commented on PR #22731:
URL: https://github.com/apache/flink/pull/22731#issuecomment-1581895947
## CI report:
* dff7fb0beac948e36f9391a4158e0ab7e5b7defe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Aitozi opened a new pull request, #22731:
URL: https://github.com/apache/flink/pull/22731
cherry-pick for release-1.17
--
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
Jiang Xin created FLINK-32285:
-
Summary: Support multiple Flink versions in each Flink ML Java
library release
Key: FLINK-32285
URL: https://issues.apache.org/jira/browse/FLINK-32285
Project: Flink
reswqa closed pull request #52: [hotfix] Update connector version to 3.0.1 for
v3.0 branch.
URL: https://github.com/apache/flink-connector-pulsar/pull/52
--
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
reswqa opened a new pull request, #52:
URL: https://github.com/apache/flink-connector-pulsar/pull/52
As titile.
--
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-32284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linweijiang updated FLINK-32284:
Description:
This will happen no matter how much parallelism I set, and it will always be
in
[
https://issues.apache.org/jira/browse/FLINK-32284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linweijiang updated FLINK-32284:
Description:
This will happen no matter how much parallelism I set, and it will always be
in
[
https://issues.apache.org/jira/browse/FLINK-32284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linweijiang updated FLINK-32284:
Attachment: Checkpoint Details.png
> When using session windows, the state of slot 1 keeps
[
https://issues.apache.org/jira/browse/FLINK-32284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linweijiang updated FLINK-32284:
Attachment: Window Function Received Details.png
> When using session windows, the state of slot
linweijiang created FLINK-32284:
---
Summary: When using session windows, the state of slot 1 keeps
growing
Key: FLINK-32284
URL: https://issues.apache.org/jira/browse/FLINK-32284
Project: Flink
xintongsong commented on code in PR #22728:
URL: https://github.com/apache/flink/pull/22728#discussion_r1222376428
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/local/memory/MemoryTierFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ *
hanyuzheng7 commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1222401333
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -272,6 +281,61 @@ ANY,
Yuxin Tan created FLINK-32283:
-
Summary: Implement SortBufferAccumulator
Key: FLINK-32283
URL: https://issues.apache.org/jira/browse/FLINK-32283
Project: Flink
Issue Type: Sub-task
luoyuxia commented on code in PR #22620:
URL: https://github.com/apache/flink/pull/22620#discussion_r1200414609
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveLookupJoinITCase.java:
##
@@ -182,7 +182,7 @@ public void
bvarghese1 commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1222374966
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -272,6 +281,61 @@ ANY,
[
https://issues.apache.org/jira/browse/FLINK-32274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-32274.
-
Release Note: try to replace
`org.apache.kafka.common.serialization.StringSerializer` with
[
https://issues.apache.org/jira/browse/FLINK-32275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730070#comment-17730070
]
Hangxiang Yu edited comment on FLINK-32275 at 6/8/23 2:21 AM:
--
Thanks for
xintongsong commented on code in PR #22342:
URL: https://github.com/apache/flink/pull/22342#discussion_r1222361205
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageNettyServiceImpl.java:
##
@@ -0,0 +1,191 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729879#comment-17729879
]
Shengkai Fang edited comment on FLINK-32219 at 6/8/23 2:12 AM:
---
Merged
[
https://issues.apache.org/jira/browse/FLINK-32219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-32219.
-
Fix Version/s: 1.18.0
1.17.2
Resolution: Fixed
> SQL client hangs
fsk119 merged PR #22725:
URL: https://github.com/apache/flink/pull/22725
--
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:
Aitozi commented on PR #22398:
URL: https://github.com/apache/flink/pull/22398#issuecomment-1581773655
> @Aitozi Could you please backport it to 1.17. Thanks
Sure
--
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-32276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730339#comment-17730339
]
Jark Wu commented on FLINK-32276:
-
[~yesorno] it works as expected. Adding a condition for {{dim.age >
[
https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730338#comment-17730338
]
luoyuxia commented on FLINK-31774:
--
master: 77214f138cf759a3ee5466c9b2379e717227a0ae
1.17: todo
> Add
luoyuxia commented on PR #22398:
URL: https://github.com/apache/flink/pull/22398#issuecomment-1581769993
@Aitozi Could you please backport it to 1.17. 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
luoyuxia merged PR #22398:
URL: https://github.com/apache/flink/pull/22398
--
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:
[
https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-13400.
Resolution: Fixed
> Remove Hive and Hadoop dependencies from SQL Client
>
luoyuxia closed pull request #16532: [FLINK-13400]Remove Hive and Hadoop
dependencies from SQL Client
URL: https://github.com/apache/flink/pull/16532
--
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
[
https://issues.apache.org/jira/browse/FLINK-30660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730336#comment-17730336
]
luoyuxia edited comment on FLINK-30660 at 6/8/23 1:46 AM:
--
master:
luoyuxia commented on PR #16532:
URL: https://github.com/apache/flink/pull/16532#issuecomment-1581768372
Fix via #22690
--
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-30660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-30660.
--
Resolution: Fixed
master:
98f5500fea96213741aa300b4b9e76be588d867a
luoyuxia closed pull request #22690: [FLINK-30660][hive] add e2e test for hive
for hive3
URL: https://github.com/apache/flink/pull/22690
--
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
luoyuxia closed pull request #22704: Flink 30660 hive 3
URL: https://github.com/apache/flink/pull/22704
--
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:
luoyuxia closed pull request #22679: [FLINK-30660][hive] add e2e test for hive
URL: https://github.com/apache/flink/pull/22679
--
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.
Aitozi commented on PR #22398:
URL: https://github.com/apache/flink/pull/22398#issuecomment-1581748223
@luoyuxia ready for merge
--
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
hanyuzheng7 commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r1222314516
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayMaxFunction.java:
##
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the
morhidi commented on PR #613:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/613#issuecomment-1581701588
> > Thanks @morhidi . I think this metric is useful for monitoring the
autoscaler especially if automatic scaling is turned off.
> > However I think we need to add
bvarghese1 commented on code in PR #22730:
URL: https://github.com/apache/flink/pull/22730#discussion_r197725
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayMaxFunction.java:
##
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the
flinkbot commented on PR #22730:
URL: https://github.com/apache/flink/pull/22730#issuecomment-1581665262
## CI report:
* 6b5f07e12f176d4d67b425c23f697b11e73761f1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32257:
---
Labels: pull-request-available (was: )
> Add ARRAY_MIN support in SQL & Table API
>
hanyuzheng7 opened a new pull request, #22730:
URL: https://github.com/apache/flink/pull/22730
This is an implementation of ARRAY_MAX
The array_max() function concatenates get the maximum element from input
array.
The result matches the type of the elements. NULL elements are
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
The array_concat() function concatenates two arrays, creating an array that
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730312#comment-17730312
]
Hanyu Zheng commented on FLINK-31665:
-
Thanks for [~twalthr] the addition, I've done the change to
jiexray commented on PR #21410:
URL: https://github.com/apache/flink/pull/21410#issuecomment-1581609186
> Hi @jiexray I wonder whether you would like to continue working on this PR
or not
Thank you for you reminding. I have resolved all converasation, and I will
rebase my pr this
mas-chen commented on PR #31:
URL:
https://github.com/apache/flink-connector-kafka/pull/31#issuecomment-1581530114
Looks good aside from the CI error
--
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
RamanVerma commented on code in PR #22249:
URL: https://github.com/apache/flink/pull/22249#discussion_r1221963740
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/src/enumerate/NonSplittingRegexEnumeratorTest.java:
##
@@ -0,0 +1,247 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32260:
Description:
Implement the {{array_slice}} function to extract a subset of elements from an
[
https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32260:
Description:
Implement the {{array_slice}} function to extract a subset of elements from an
[
https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32260:
Description:
Implement the {{array_slice}} function to extract a subset of elements from an
[
https://issues.apache.org/jira/browse/FLINK-32263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32263:
Description:
Implement the elt function to extract the n-th input value from a list of
inputs.
[
https://issues.apache.org/jira/browse/FLINK-32262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32262:
Description:
Implement the {{map_entries}} method to transform a map into an array of
key-value
[
https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32261:
Description:
Description:
The current implementation of the {{map_union}} method in the Flink
[
https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32261:
Description:
Description:
The current implementation of the {{map_union}} method in the Flink
[
https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32261:
Description:
Description:
The current implementation of the {{map_union}} method in the Flink
JingGe merged PR #22729:
URL: https://github.com/apache/flink/pull/22729
--
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:
RamanVerma commented on code in PR #22249:
URL: https://github.com/apache/flink/pull/22249#discussion_r1221827919
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/enumerate/NonSplittingRegexEnumerator.java:
##
@@ -0,0 +1,90 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
The array_concat() function concatenates two arrays, creating an array that
[
https://issues.apache.org/jira/browse/FLINK-32264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32264:
Description:
FIELD Function
Description
The FIELD function returns the position of a value in a
[
https://issues.apache.org/jira/browse/FLINK-32264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32264:
Description:
FIELD Function
Description
The FIELD function returns the position of a value in
[
https://issues.apache.org/jira/browse/FLINK-32263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32263:
Description:
elt
elt(n, input1, input2, ...) - Returns the n-th input, e.g., returns input2 when
[
https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32261:
Description:
map_union(x(K, V)) -> map(K, V)#
Returns the union of all the input maps. If a key
[
https://issues.apache.org/jira/browse/FLINK-32262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32262:
Description:
map_entries
map_entries(map) - Returns an unordered array of all entries in the
[
https://issues.apache.org/jira/browse/FLINK-32262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32262:
Description:
map_entries
map_entries(map) - Returns an unordered array of all entries in the
[
https://issues.apache.org/jira/browse/FLINK-32261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32261:
Description:
map_union(x(K, V)) -> map(K, V)#
Returns the union of all the input maps. If a key
[
https://issues.apache.org/jira/browse/FLINK-32259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bonnie Varghese updated FLINK-32259:
Description:
Concatenates the elements of the array with a delimiter and optional string
[
https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32260:
Description:
slice(x, start, length) - Subsets array x starting from index start (array
indices
[
https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32260:
Description:
slice(x, start, length) - Subsets array x starting from index start (array
indices
[
https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32260:
Description:
slice(x, start, length) - Subsets array x starting from index start (array
indices
[
https://issues.apache.org/jira/browse/FLINK-32256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-32256:
Description:
This is an implementation of ARRAY_MAX
The array_max() function concatenates get
[
https://issues.apache.org/jira/browse/FLINK-32257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bonnie Varghese updated FLINK-32257:
Description:
Find the minimum among all elements in the array for which ordering is
[
https://issues.apache.org/jira/browse/FLINK-32257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bonnie Varghese updated FLINK-32257:
Description:
Find the minimum among all elements in the array for which ordering is
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
The array_concat() function concatenates two arrays, creating an array that
[
https://issues.apache.org/jira/browse/FLINK-31704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730162#comment-17730162
]
Aitozi commented on FLINK-31704:
thanks, will try it.
> Pulsar docs should be pulled from dedicated
[
https://issues.apache.org/jira/browse/FLINK-31704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730147#comment-17730147
]
Weijie Guo commented on FLINK-31704:
[~aitozi] The current master branch should no longer track
[
https://issues.apache.org/jira/browse/FLINK-31704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730147#comment-17730147
]
Weijie Guo edited comment on FLINK-31704 at 6/7/23 2:48 PM:
[~aitozi] The
morhidi commented on PR #613:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/613#issuecomment-1580981644
> Thanks @morhidi . I think this metric is useful for monitoring the
autoscaler especially if automatic scaling is turned off.
>
> However I think we need to add
[
https://issues.apache.org/jira/browse/FLINK-31781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31781:
---
Labels: pull-request-available (was: )
> Introduce contender ID into LeaderElectionService
zentol commented on code in PR #22601:
URL: https://github.com/apache/flink/pull/22601#discussion_r1221691661
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java:
##
@@ -247,7 +247,7 @@ private LeaderElection
zentol commented on code in PR #22601:
URL: https://github.com/apache/flink/pull/22601#discussion_r1221678062
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java:
##
@@ -27,29 +27,37 @@
public abstract class
[
https://issues.apache.org/jira/browse/FLINK-31704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730133#comment-17730133
]
Aitozi commented on FLINK-31704:
Hi [~Weijie Guo] [~dannycranmer] I have a CI failed with missing branch
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730132#comment-17730132
]
Timo Walther commented on FLINK-31665:
--
Thanks for the detailed investigation [~Sergey Nuyanzin]. I
zentol commented on code in PR #22404:
URL: https://github.com/apache/flink/pull/22404#discussion_r1221649459
##
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/TestingContender.java:
##
@@ -31,22 +31,17 @@ public class TestingContender extends
flinkbot commented on PR #22729:
URL: https://github.com/apache/flink/pull/22729#issuecomment-1580794375
## CI report:
* bd20d983248ec0810d66de56984c1cd8d07a8582 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Gyula Fora created FLINK-32282:
--
Summary: Use kubernetes-webhooks-framework instead of deprecated
admission control
Key: FLINK-32282
URL: https://issues.apache.org/jira/browse/FLINK-32282
Project: Flink
JingGe opened a new pull request, #22729:
URL: https://github.com/apache/flink/pull/22729
## What is the purpose of the change
fix the wrong Ververica Platform URL
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or
WenDing-Y commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-jdbc/pull/49#discussion_r1221555134
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/clickhouse/dialect/ClickHouseDialectTypeTest.java:
##
@@ -0,0 +1,41 @@
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730003#comment-17730003
]
Sergey Nuyanzin edited comment on FLINK-31665 at 6/7/23 12:49 PM:
--
To
reswqa commented on PR #21527:
URL: https://github.com/apache/flink/pull/21527#issuecomment-1580742874
@Mrart It seems that the e2e test case is failed, can you rebase on latest
`master` branch to see if it is fixed.
--
This is an automated message from the Apache Git Service.
To respond
1996fanrui commented on PR #22552:
URL: https://github.com/apache/flink/pull/22552#issuecomment-1580722779
Hi @reswqa , thanks a lot for your review.
> Have we manually submitted a job and verified this through `WebUI`?
Yes, I have tested on my Mac through WebUI.
--
1996fanrui commented on code in PR #22552:
URL: https://github.com/apache/flink/pull/22552#discussion_r1221512277
##
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/threadinfo/VertexThreadInfoTracker.java:
##
@@ -0,0 +1,569 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on code in PR #22552:
URL: https://github.com/apache/flink/pull/22552#discussion_r1221512024
##
flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/threadinfo/VertexThreadInfoTrackerTest.java:
##
@@ -159,106 +188,242 @@ public void
WenDing-Y commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-jdbc/pull/49#discussion_r1221509236
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/clickhouse/dialect/ClickHouseDialectTypeTest.java:
##
@@ -0,0 +1,41 @@
WenDing-Y commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-jdbc/pull/49#discussion_r1221506906
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/clickhouse/dialect/ClickHouseDialectTypeTest.java:
##
@@ -0,0 +1,41 @@
[
https://issues.apache.org/jira/browse/FLINK-32275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730095#comment-17730095
]
Weijie Guo commented on FLINK-32275:
[~masteryhx] Thanks for the quick reply! Let them talk to each
zentol commented on code in PR #22667:
URL: https://github.com/apache/flink/pull/22667#discussion_r1221473184
##
flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java:
##
@@ -41,16 +39,14 @@ public
[
https://issues.apache.org/jira/browse/FLINK-31833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-31833:
--
Description: Please see FLIP-315 for more detail:
[
https://issues.apache.org/jira/browse/FLINK-32277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-32277:
--
Summary: Introduce operator fusion codegen basic framework (was: Introduce
operator fusion codegen
[
https://issues.apache.org/jira/browse/FLINK-32281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-32281:
--
Summary: Enable two-phase HashAgg default when agg function support
adaptive local HashAgg (was:
dalongliu created FLINK-32281:
-
Summary: Enable two-phase agg default when agg function support
adaptive local hashagg
Key: FLINK-32281
URL: https://issues.apache.org/jira/browse/FLINK-32281
Project:
dalongliu created FLINK-32279:
-
Summary: Shuffle HashJoin support spill to disk when enable
operator fusion codegen
Key: FLINK-32279
URL: https://issues.apache.org/jira/browse/FLINK-32279
Project: Flink
1 - 100 of 173 matches
Mail list logo
