[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740032#comment-17740032
]
Sergey Nuyanzin commented on FLINK-32539:
-
[ https://issues.apache.org/jira/browse/FLINK-32539 ]
Hanyu Zheng deleted comment on FLINK-32539:
-
was (Author: JIRAUSER300701):
so we need run this two statement on local?
{noformat}
mvn clean install -DskipTests
mvn verify -pl
snuyanzin commented on PR #20006:
URL: https://github.com/apache/flink/pull/20006#issuecomment-1621059659
Friendly reminder: before merging please be sure it passes ci
it seems this PR merged is the reason of a blocker issue
https://issues.apache.org/jira/browse/FLINK-32539
--
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740029#comment-17740029
]
Hanyu Zheng commented on FLINK-32539:
-
so we need run this two statement on local?
{noformat}
mvn
flinkbot commented on PR #22956:
URL: https://github.com/apache/flink/pull/22956#issuecomment-1621055568
## CI report:
* 7ae444f8d718b92e8c81627e4473c30e2811f5b8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252558140
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252558140
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
snuyanzin commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1621047910
looks like because of this https://issues.apache.org/jira/browse/FLINK-32539
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740027#comment-17740027
]
Sergey Nuyanzin commented on FLINK-32539:
-
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740028#comment-17740028
]
Sergey Nuyanzin commented on FLINK-32539:
-
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32539:
Description:
blocker since now it fails on every build
to reproduce jdk 8 is required
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32539:
---
Labels: pull-request-available test-stability (was: test-stability)
> Archunit violations
snuyanzin opened a new pull request, #22956:
URL: https://github.com/apache/flink/pull/22956
## What is the purpose of the change
The PR updates violations after changes done at
https://github.com/apache/flink/pull/20006
## Verifying this change
This
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32539:
Labels: test-stability (was: )
> Archunit violations started to fail in test_misc
>
Sergey Nuyanzin created FLINK-32539:
---
Summary: Archunit violations started to fail in test_misc
Key: FLINK-32539
URL: https://issues.apache.org/jira/browse/FLINK-32539
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32539:
Description:
blocker since now it fails on every build
to reproduce jdk 8 is required
liuyongvs commented on PR #22745:
URL: https://github.com/apache/flink/pull/22745#issuecomment-1621043422
hi @snuyanzin will it be merged now?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
hanyuzheng7 commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1621039450
@snuyanzin , do you know why test_ci misc report error?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-32402:
--
Assignee: Fang Yong
> FLIP-294: Support Customized Catalog Modification Listener
>
flinkbot commented on PR #22955:
URL: https://github.com/apache/flink/pull/22955#issuecomment-1621034716
## CI report:
* 512b8fbc98dbfdb91ee9fdac16514a0cd2ef1f8b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hanyuzheng7 commented on PR #22922:
URL: https://github.com/apache/flink/pull/22922#issuecomment-1621034276
@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
dianfu commented on PR #22955:
URL: https://github.com/apache/flink/pull/22955#issuecomment-1621034175
cc @zentol
--
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-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740024#comment-17740024
]
Yun Gao commented on FLINK-32455:
-
Thanks [~tzulitai] for the quick fix!
For the formal fix, I think
[
https://issues.apache.org/jira/browse/FLINK-32536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32536:
---
Labels: pull-request-available (was: )
> Python tests fail with Arrow DirectBuffer
dianfu opened a new pull request, #22955:
URL: https://github.com/apache/flink/pull/22955
## What is the purpose of the change
*This pull request adds `--add-opens=java.base/java.nio=ALL-UNNAMED
--add-opens=java.base/sun.nio.ch=ALL-UNNAMED` to java opts to allow
DirectByteBuffer
elkhand commented on code in PR #22816:
URL: https://github.com/apache/flink/pull/22816#discussion_r1252538100
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ExecutorImpl.java:
##
@@ -577,4 +593,29 @@ private void closeSession() throws
elkhand commented on code in PR #22816:
URL: https://github.com/apache/flink/pull/22816#discussion_r1252537263
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ExecutorImpl.java:
##
@@ -577,4 +593,29 @@ private void closeSession() throws
[
https://issues.apache.org/jira/browse/FLINK-32480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740022#comment-17740022
]
Viktor Feklin commented on FLINK-32480:
---
[~masteryhx] , please read description carefully -
elkhand commented on code in PR #22816:
URL: https://github.com/apache/flink/pull/22816#discussion_r1252528630
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java:
##
@@ -411,30 +413,31 @@ private static Request createRequest(
String
elkhand commented on code in PR #22816:
URL: https://github.com/apache/flink/pull/22816#discussion_r1252526586
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/HttpHeader.java:
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
[
https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740021#comment-17740021
]
Sergey Nuyanzin commented on FLINK-30719:
-
i submitted a PR enabling configuration of number of
[
https://issues.apache.org/jira/browse/FLINK-32459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-32459.
--
Resolution: Done
master(1.18) via4bc408b9750fb402523f1a7955a5b23d5c99011e.
> Force set the
reswqa merged PR #22933:
URL: https://github.com/apache/flink/pull/22933
--
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:
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252516691
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
hackergin commented on PR #22937:
URL: https://github.com/apache/flink/pull/22937#issuecomment-1620987697
@ferenc-csaky Thanks for the great suggestion, I update the code.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot commented on PR #22954:
URL: https://github.com/apache/flink/pull/22954#issuecomment-1620985629
## CI report:
* 736db13b75cff5ad19a4bd298dcaa2556044b7a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22953:
URL: https://github.com/apache/flink/pull/22953#issuecomment-1620980189
## CI report:
* e0e4fb991483868df9693a71194f10028ec823c7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LoveHeat commented on PR #22806:
URL: https://github.com/apache/flink/pull/22806#issuecomment-1620979223
1.16 : https://github.com/apache/flink/pull/22953
1.17: https://github.com/apache/flink/pull/22954
done @1996fanrui
--
This is an automated message from the Apache Git Service.
LoveHeat opened a new pull request, #22954:
URL: https://github.com/apache/flink/pull/22954
backport to 1.17, see
[Flink-32362](https://issues.apache.org/jira/browse/FLINK-32362)
## What is the purpose of the change
*(For example: This pull request makes task
LoveHeat opened a new pull request, #22953:
URL: https://github.com/apache/flink/pull/22953
backport to 1.16, see
[Flink-32362](https://issues.apache.org/jira/browse/FLINK-32362)
## What is the purpose of the change
*(For example: This pull request makes task
hanyuzheng7 commented on PR #22842:
URL: https://github.com/apache/flink/pull/22842#issuecomment-1620966114
@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
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252368976
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
1996fanrui commented on PR #22806:
URL: https://github.com/apache/flink/pull/22806#issuecomment-1620955453
Hi @LoveHeat , thanks for the fix.
Could you help backport this PR to release-1.16 and release-1.17? It's
better to wait until all CIs pass before merging.
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740011#comment-17740011
]
Weihua Hu commented on FLINK-32513:
---
Thanks [~vladislav.keda] reporting this. Could you provide the
[
https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruibin Xing closed FLINK-32520.
---
Resolution: Cannot Reproduce
> FlinkDeployment recovered states from an obsolete savepoint when
[
https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740009#comment-17740009
]
Ruibin Xing commented on FLINK-32520:
-
[~gyfora] Sorry, after reviewing, it turns out that the
[
https://issues.apache.org/jira/browse/FLINK-32257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740007#comment-17740007
]
Jacky Lau edited comment on FLINK-32257 at 7/5/23 2:46 AM:
---
hi [~dwysakowicz]
[
https://issues.apache.org/jira/browse/FLINK-32257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740007#comment-17740007
]
Jacky Lau commented on FLINK-32257:
---
hi [~dwysakowicz] , the array_max return type has fixed and
[
https://issues.apache.org/jira/browse/FLINK-32257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740005#comment-17740005
]
Jacky Lau commented on FLINK-32257:
---
hi [~hanyuzheng] MAP_ENTRIES i have already supported and merged
[
https://issues.apache.org/jira/browse/FLINK-31639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31639:
--
Summary: Introduce tiered storage memory manager (was: Introduce tiered
store memory manager)
>
[
https://issues.apache.org/jira/browse/FLINK-31636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31636:
--
Summary: Upstream supports reading buffers from tiered storage (was:
Upstream supports reading
[
https://issues.apache.org/jira/browse/FLINK-31638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31638:
--
Summary: Downstream supports reading buffers from tiered storage (was:
Downstream supports reading
[
https://issues.apache.org/jira/browse/FLINK-32480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740004#comment-17740004
]
Hangxiang Yu commented on FLINK-32480:
--
Hi, The object cannot be reused as default.
If you are sure
[
https://issues.apache.org/jira/browse/FLINK-31635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31635:
--
Summary: Support writing records to the new tiered storage architecture
(was: Support writing
iceiceiceCN commented on PR #22831:
URL: https://github.com/apache/flink/pull/22831#issuecomment-1620932577
@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
TanYuxin-tyx commented on PR #22851:
URL: https://github.com/apache/flink/pull/22851#issuecomment-1620926912
@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
Yuxin Tan created FLINK-32538:
-
Summary: CI build failed because node is corrupted when compiling
Key: FLINK-32538
URL: https://issues.apache.org/jira/browse/FLINK-32538
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-32506.
---
Resolution: Fixed
> Add the watermark aggregation benchmark for source coordinator
>
[
https://issues.apache.org/jira/browse/FLINK-32506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739793#comment-17739793
]
Rui Fan edited comment on FLINK-32506 at 7/5/23 2:10 AM:
-
Merged via:
1996fanrui merged PR #77:
URL: https://github.com/apache/flink-benchmarks/pull/77
--
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:
1996fanrui commented on PR #77:
URL: https://github.com/apache/flink-benchmarks/pull/77#issuecomment-1620916418
Thanks @pnowojski and @RocMarshal for the review, CI passed, merging~
Let's follow the benchmark result at http://codespeed.dak8s.net:8000/
--
This is an automated
hanyuzheng7 commented on code in PR #22922:
URL: https://github.com/apache/flink/pull/22922#discussion_r1252435731
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -67,6 +67,9 @@
hanyuzheng7 commented on code in PR #22922:
URL: https://github.com/apache/flink/pull/22922#discussion_r1252435731
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -67,6 +67,9 @@
hanyuzheng7 commented on code in PR #22922:
URL: https://github.com/apache/flink/pull/22922#discussion_r1252435539
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -67,6 +67,9 @@
hanyuzheng7 commented on code in PR #22922:
URL: https://github.com/apache/flink/pull/22922#discussion_r1252435539
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -67,6 +67,9 @@
hanyuzheng7 commented on code in PR #22922:
URL: https://github.com/apache/flink/pull/22922#discussion_r1252434610
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -67,6 +68,10 @@
hanyuzheng7 commented on code in PR #22922:
URL: https://github.com/apache/flink/pull/22922#discussion_r1252105421
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementTypeStrategy.java:
##
@@ -67,6 +67,9 @@
hanyuzheng7 commented on PR #22834:
URL: https://github.com/apache/flink/pull/22834#issuecomment-1620780780
@snuyanzin pass ci test, it's ready to 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
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252368976
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252374401
##
docs/data/sql_functions_zh.yml:
##
@@ -760,7 +760,9 @@ collection:
- sql: MAP_FROM_ARRAYS(array_of_keys, array_of_values)
table:
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252368976
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252368976
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252368976
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252368137
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252363975
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252365645
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252363975
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hlteoh37 commented on code in PR #22901:
URL: https://github.com/apache/flink/pull/22901#discussion_r1252358904
##
docs/layouts/shortcodes/generated/expert_rest_section.html:
##
@@ -20,6 +20,18 @@
Long
The time in ms that the client waits for the
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252357094
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CommonMapInputTypeStrategy.java:
##
@@ -0,0 +1,113 @@
+/*
+ *
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252355890
##
docs/data/sql_functions_zh.yml:
##
@@ -760,7 +760,9 @@ collection:
- sql: MAP_FROM_ARRAYS(array_of_keys, array_of_values)
table:
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252354619
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
flinkbot commented on PR #22952:
URL: https://github.com/apache/flink/pull/22952#issuecomment-1620733780
## CI report:
* 3ac64d4d4ecd588397f010a4a39c00c803eded9e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hlteoh37 commented on code in PR #22901:
URL: https://github.com/apache/flink/pull/22901#discussion_r1252350733
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerNG.java:
##
@@ -93,6 +94,8 @@ ExecutionState requestPartitionState(
[
https://issues.apache.org/jira/browse/FLINK-30984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30984:
---
Labels: pull-request-available (was: )
> Remove explicit cast required by 3.1.x janino
>
snuyanzin opened a new pull request, #22952:
URL: https://github.com/apache/flink/pull/22952
## What is the purpose of the change
The PR updates Janino to 3.1.10 and removed WA with explicit cast of nulls
which was introduced at https://github.com/apache/flink/pull/21500 to cope
[
https://issues.apache.org/jira/browse/FLINK-31784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-31784.
---
Fix Version/s: 1.18.0
Resolution: Fixed
master:
XComp merged PR #22844:
URL: https://github.com/apache/flink/pull/22844
--
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:
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252343611
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252343611
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252343611
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252342408
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java:
##
@@ -1468,6 +1469,16 @@ public OutType mapEntries() {
hanyuzheng7 commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252342119
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
hanyuzheng7 closed pull request #22951: [FLINK-26948][table]
Add-ARRAY_SORT-function.
URL: https://github.com/apache/flink/pull/22951
--
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
flinkbot commented on PR #22951:
URL: https://github.com/apache/flink/pull/22951#issuecomment-1620703593
## CI report:
* 8abf50de7e0aeaa49cda4133fb90448a8c390d91 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252336736
##
docs/data/sql_functions.yml:
##
@@ -658,6 +658,9 @@ collection:
- sql: MAP_KEYS(map)
table: MAP.mapKeys()
description: Returns the keys of the map as
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252335930
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
snuyanzin commented on code in PR #22842:
URL: https://github.com/apache/flink/pull/22842#discussion_r1252335930
##
flink-python/pyflink/table/expression.py:
##
@@ -1558,6 +1558,18 @@ def map_keys(self) -> 'Expression':
"""
return _unary_op("mapKeys")(self)
[
https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26948:
---
Labels: pull-request-available (was: )
> Add SORT_ARRAY supported in SQL & Table API
>
hanyuzheng7 opened a new pull request, #22951:
URL: https://github.com/apache/flink/pull/22951
## What is the purpose of the change
Implement the array_sort function to extract a subset of elements from an
array.
Returns the array in sorted order. Sorts the input array in
[
https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739982#comment-17739982
]
Robert Metzger commented on FLINK-32212:
I also just ran into this situation with the Flink K8s
1 - 100 of 348 matches
Mail list logo
