[
https://issues.apache.org/jira/browse/FLINK-31674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31674:
--
Assignee: Ryan Skraba
> [JUnit5 Migration] Module: flink-table-planner
[
https://issues.apache.org/jira/browse/FLINK-31690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-31690.
---
Fix Version/s: 1.16.2
1.18.0
1.17.1
Resolution: Fixed
Fixed
dianfu closed pull request #22323: [FLINK-31690][python] Fix
KeyedCoProcessFunction to set the current k…
URL: https://github.com/apache/flink/pull/22323
--
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
[
https://issues.apache.org/jira/browse/FLINK-31688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31688.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via
reswqa merged PR #22321:
URL: https://github.com/apache/flink/pull/22321
--
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:
flinkbot commented on PR #22324:
URL: https://github.com/apache/flink/pull/22324#issuecomment-1493647373
## CI report:
* 8a534fe42ef69bc595fe9b87f1de924fdc173815 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31691:
---
Labels: pull-request-available (was: )
> Add MAP_FROM_ENTRIES supported in SQL & Table API
liuyongvs opened a new pull request, #22324:
URL: https://github.com/apache/flink/pull/22324
- What is the purpose of the change
This is an implementation of MAP_FROM_ENTRIES
- Brief change log
MAP_FROM_ENTRIES for Table API and SQL
```
map_from_entries(map) -
[
https://issues.apache.org/jira/browse/FLINK-31691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31691:
-
Description:
map_from_entries(map) - Returns a map created from an arrays of row with two
fields. Note
Samrat002 commented on PR #22308:
URL: https://github.com/apache/flink/pull/22308#issuecomment-1493618741
@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
jackylau created FLINK-31691:
Summary: Add MAP_FROM_ENTRIES supported in SQL & Table API
Key: FLINK-31691
URL: https://issues.apache.org/jira/browse/FLINK-31691
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707755#comment-17707755
]
jackylau commented on FLINK-31602:
--
Merged to master as
[
https://issues.apache.org/jira/browse/FLINK-31602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707755#comment-17707755
]
jackylau edited comment on FLINK-31602 at 4/3/23 4:06 AM:
--
Merged to master as
[
https://issues.apache.org/jira/browse/FLINK-31602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau closed FLINK-31602.
Resolution: Fixed
> Add ARRAY_POSITION supported in SQL & Table API
>
flinkbot commented on PR #22323:
URL: https://github.com/apache/flink/pull/22323#issuecomment-1493609975
## CI report:
* e1e4b7235fbdcc5390e5db33ad6b6c69cf313b8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31690:
---
Labels: pull-request-available (was: )
> The current key is not set for
dianfu opened a new pull request, #22323:
URL: https://github.com/apache/flink/pull/22323
…ey into the context
## 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
flinkbot commented on PR #22322:
URL: https://github.com/apache/flink/pull/22322#issuecomment-1493594228
## CI report:
* b84af1fbef1bb8d057a36a5ef90a585047dd89ce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Fanoid commented on code in PR #227:
URL: https://github.com/apache/flink-ml/pull/227#discussion_r1155451901
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java:
##
@@ -280,6 +280,15 @@ public static DataStream aggregate(
* This
chucheng92 commented on PR #22179:
URL: https://github.com/apache/flink/pull/22179#issuecomment-1493592946
@Aitozi Sorry to pin you, all your comments have been addressed, can you
help to re-check it ? thanks.
--
This is an automated message from the Apache Git Service.
To respond to the
xintongsong closed pull request #22311: [FLINK-31652][k8s] Handle the deleted
event in case pod is deleted during the pending phase
URL: https://github.com/apache/flink/pull/22311
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
xintongsong commented on code in PR #22311:
URL: https://github.com/apache/flink/pull/22311#discussion_r1155446163
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriverTest.java:
##
@@ -184,6 +184,18 @@ void testOnPodDeleted() throws
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707742#comment-17707742
]
luoyuxia commented on FLINK-31689:
--
Please remember the state is not compatible as you have changed
FangYongs commented on code in PR #22289:
URL: https://github.com/apache/flink/pull/22289#discussion_r1155438551
##
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java:
##
@@ -18,34 +18,67 @@
package org.apache.flink.table.jdbc;
Dian Fu created FLINK-31690:
---
Summary: The current key is not set for KeyedCoProcessOperator
Key: FLINK-31690
URL: https://issues.apache.org/jira/browse/FLINK-31690
Project: Flink
Issue Type: Bug
BoYiZhang commented on PR #22204:
URL: https://github.com/apache/flink/pull/22204#issuecomment-1493542108
This is my first PR, please help me find out where it doesn't meet the
regulations ...
@reswqa @healchow
--
This is an automated message from the Apache Git Service.
To respond to
libenchao commented on code in PR #22289:
URL: https://github.com/apache/flink/pull/22289#discussion_r1155415681
##
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java:
##
@@ -18,34 +18,67 @@
package org.apache.flink.table.jdbc;
libenchao commented on code in PR #22289:
URL: https://github.com/apache/flink/pull/22289#discussion_r1155415681
##
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java:
##
@@ -18,34 +18,67 @@
package org.apache.flink.table.jdbc;
paul8263 commented on PR #5:
URL:
https://github.com/apache/flink-connector-kafka/pull/5#issuecomment-1493499385
Hi @tzulitai ，
Could you please help approve the workflow? It seems that the CI process
won't run anymore.
I tried pushing the same commit to both this project and
[
https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31108:
---
Labels: pull-request-available (was: )
> Use StreamARN for API calls in Kinesis Connector
hlteoh37 opened a new pull request, #64:
URL: https://github.com/apache/flink-connector-aws/pull/64
…me for Kinesis API calls
## Purpose of the change
Modifies Kinesis Source to use Stream ARN instead of Stream name.
## Verifying this change
This change added tests and
mateczagany commented on code in PR #558:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/558#discussion_r1155350156
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -627,14 +637,42 @@ public
jirawech.s created FLINK-31689:
--
Summary: Filesystem sink fails when parallelism of compactor
operator changed
Key: FLINK-31689
URL: https://issues.apache.org/jira/browse/FLINK-31689
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707680#comment-17707680
]
Qingsheng Ren commented on FLINK-28440:
---
Redirected to here from FLINK-30107:
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707679#comment-17707679
]
Qingsheng Ren commented on FLINK-26974:
---
[
https://issues.apache.org/jira/browse/FLINK-30299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707678#comment-17707678
]
Qingsheng Ren commented on FLINK-30299:
---
flinkbot commented on PR #22321:
URL: https://github.com/apache/flink/pull/22321#issuecomment-1493343603
## CI report:
* a7cd7d1f5b2fbf437caec2f52a00dc72e72b05b1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31688:
---
Labels: pull-request-available (was: )
> Broken links in docs for Azure Table Storage
>
TanYuxin-tyx opened a new pull request, #22321:
URL: https://github.com/apache/flink/pull/22321
## What is the purpose of the change
*Fix the broken links in docs for Azure Table Storage*
## Brief change log
- *Fix the broken links in docs for Azure Table
flinkbot commented on PR #22320:
URL: https://github.com/apache/flink/pull/22320#issuecomment-1493338855
## CI report:
* f86f9fd01d402441cdacd977f71f52461e10fa45 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31688:
--
Description: The doc page of
[
https://issues.apache.org/jira/browse/FLINK-31688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-31688:
-
Assignee: Yuxin Tan
> Broken links in docs for Azure Table Storage
>
Yuxin Tan created FLINK-31688:
-
Summary: Broken links in docs for Azure Table Storage
Key: FLINK-31688
URL: https://issues.apache.org/jira/browse/FLINK-31688
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-31664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31664:
---
Labels: pull-request-available (was: )
> Add ARRAY_INTERSECT supported in SQL & Table API
zzzs opened a new pull request, #22320:
URL: https://github.com/apache/flink/pull/22320
## What is the purpose of the change
Add `array_intersect(array1, array2)` SQL function.
- `array1`: An ARRAY of any type with comparable elements.
- `array2`: n ARRAY of
FangYongs commented on PR #22289:
URL: https://github.com/apache/flink/pull/22289#issuecomment-1493319117
Thanks @libenchao , I have rebased master and updated this PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Aitozi commented on code in PR #22301:
URL: https://github.com/apache/flink/pull/22301#discussion_r1155295984
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/api/TableSchemaTest.java:
##
@@ -328,7 +328,7 @@ void testPrimaryKeyPrinting() {
mbalassi commented on code in PR #558:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/558#discussion_r1155274830
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -627,14 +637,42 @@ public
Aitozi commented on code in PR #22179:
URL: https://github.com/apache/flink/pull/22179#discussion_r1154263645
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCatalogs.java:
##
@@ -28,15 +31,61 @@
import java.util.Collections;
import
49 matches
Mail list logo
