[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706734#comment-17706734
]
Matthias Pohl commented on FLINK-31278:
---
I had an offline discussion with Chesnay
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706732#comment-17706732
]
Rui Fan commented on FLINK-31655:
-
Hi [~tartarus] , thanks for the good proposal, it's r
[
https://issues.apache.org/jira/browse/FLINK-31659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706726#comment-17706726
]
luoyuxia commented on FLINK-31659:
--
Not extactly, it's not whenever as mentioned "thi
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706724#comment-17706724
]
Matthias Pohl commented on FLINK-31669:
---
I attached the logs for this specific tes
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31669:
--
Attachment: mvn.FLINK-31669.log
> DynamicFilteringITCase failed fataly because of NoClassDefFo
Matthias Pohl created FLINK-31669:
-
Summary: DynamicFilteringITCase failed fataly because of
NoClassDefFoundError
Key: FLINK-31669
URL: https://issues.apache.org/jira/browse/FLINK-31669
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31669:
--
Summary: DynamicFilteringITCase failed fataly because of
NoClassDefFoundError of akka/actor/Su
[
https://issues.apache.org/jira/browse/FLINK-29566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29566.
--
Fix Version/s: kubernetes-operator-1.5.0
Resolution: Fixed
merged to main e2a6775ab992234dde259
gyfora merged PR #540:
URL: https://github.com/apache/flink-kubernetes-operator/pull/540
--
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-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui closed FLINK-31653.
Resolution: Duplicate
> Using`if` statement for a string subtype of the row type may meet npe in code
> g
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706711#comment-17706711
]
Yuan Kui commented on FLINK-31653:
--
[~martijnvisser] It does seem to be duplicated with
[
https://issues.apache.org/jira/browse/FLINK-31435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31435:
---
Labels: pull-request-available (was: )
> Introduce event parser for MySql Debezium JSON for
[
https://issues.apache.org/jira/browse/FLINK-24785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706709#comment-17706709
]
Yun Tang commented on FLINK-24785:
--
[~assassinj] I think this is a valid problem. Will
Fang Yong created FLINK-31668:
-
Summary: Gateway should close select query when session is timeout
Key: FLINK-31668
URL: https://issues.apache.org/jira/browse/FLINK-31668
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-30321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706701#comment-17706701
]
Yanfei Lei commented on FLINK-30321:
By upgrading the version of ZLIB.
> Upgrade ZL
flinkbot commented on PR #22306:
URL: https://github.com/apache/flink/pull/22306#issuecomment-1489728144
## CI report:
* 8cd10bb37f4a41f9c5522f4db1543c4f8c43adda UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31447:
---
Labels: pull-request-available (was: )
> Aligning unit tests of FineGrainedSlotManager with
huwh opened a new pull request, #22306:
URL: https://github.com/apache/flink/pull/22306
## What is the purpose of the change
Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager
The unit test diff between FGSM and DSM are list in :
https://docs.google.com/spreadshe
flinkbot commented on PR #22305:
URL: https://github.com/apache/flink/pull/22305#issuecomment-148975
## CI report:
* f84a771b4186acb7a41a82e9554681fe802ed651 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jeff Zhang created FLINK-31667:
--
Summary: Should not enforce attached mode in RemoteEnvironment &
RemoteStreamEnvironment
Key: FLINK-31667
URL: https://issues.apache.org/jira/browse/FLINK-31667
Project:
[
https://issues.apache.org/jira/browse/FLINK-31443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31443:
---
Labels: pull-request-available (was: )
> FineGrainedSlotManager maintain some redundant tas
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152691246
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns a
huwh opened a new pull request, #22305:
URL: https://github.com/apache/flink/pull/22305
## What is the purpose of the change
implementation of
[FLINK-18625](https://issues.apache.org/jira/browse/FLINK-18625) in
FineGrainedSlotManager.
## Brief change log
- *check that red
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706693#comment-17706693
]
jackylau commented on FLINK-31663:
--
should links to https://issues.apache.org/jira/brow
[
https://issues.apache.org/jira/browse/FLINK-31118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31118:
-
Description:
Remove all elements that equal to element from array.
Syntax:
array_union(array)
Argument
jackylau created FLINK-31666:
Summary: Add ARRAY_OVERLAP supported in SQL & Table API
Key: FLINK-31666
URL: https://issues.apache.org/jira/browse/FLINK-31666
Project: Flink
Issue Type: Improvemen
jackylau created FLINK-31665:
Summary: Add ARRAY_CONCAT supported in SQL & Table API
Key: FLINK-31665
URL: https://issues.apache.org/jira/browse/FLINK-31665
Project: Flink
Issue Type: Improvement
jackylau created FLINK-31664:
Summary: Add ARRAY_INTERSECT supported in SQL & Table API
Key: FLINK-31664
URL: https://issues.apache.org/jira/browse/FLINK-31664
Project: Flink
Issue Type: Improvem
zhipeng93 merged PR #228:
URL: https://github.com/apache/flink-ml/pull/228
--
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
zhipeng93 commented on PR #228:
URL: https://github.com/apache/flink-ml/pull/228#issuecomment-1489672277
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
[
https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706679#comment-17706679
]
Yanfei Lei commented on FLINK-31593:
> But it still leaves question marks on why thi
[
https://issues.apache.org/jira/browse/FLINK-31240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-31240:
-
Description:
In some cases, users may need to convert the underlying DataStream to Table and
then conve
JLY2015 closed pull request #22304: fix space
URL: https://github.com/apache/flink/pull/22304
--
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-un
JLY2015 opened a new pull request, #22304:
URL: https://github.com/apache/flink/pull/22304
## 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 on
[
https://issues.apache.org/jira/browse/FLINK-31240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706673#comment-17706673
]
Yunfeng Zhou commented on FLINK-31240:
--
It seems that I do not have permission to m
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152691246
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns a
liuyongvs commented on PR #22267:
URL: https://github.com/apache/flink/pull/22267#issuecomment-1489627172
@luoyuxia fix your review and rebase master to verify whether it is affected
by others.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152687435
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns a
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152685125
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayPositionFunction.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-30321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706669#comment-17706669
]
songwenbin commented on FLINK-30321:
How do you solve the problem with cve-2018-2503
liuyongvs commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152684875
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayPositionFunction.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to t
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152683101
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152683101
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
luoyuxia commented on code in PR #22301:
URL: https://github.com/apache/flink/pull/22301#discussion_r1152682771
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java:
##
@@ -1,111 +0,0 @@
-/*
- * Licensed to the Apache Softw
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152679757
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152679757
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
chucheng92 commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-kafka/pull/10#discussion_r1152677881
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittableSerializer.java:
##
@@ -46,6 +46,15 @@ public byte[] serializ
luoyuxia created FLINK-31663:
Summary: Add ARRAY_EXCEPT supported in SQL & Table API
Key: FLINK-31663
URL: https://issues.apache.org/jira/browse/FLINK-31663
Project: Flink
Issue Type: Sub-task
tzulitai commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152666515
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
tzulitai commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152666515
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
tzulitai commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152668428
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
luoyuxia commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152666906
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayPositionFunction.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to th
tzulitai commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152666515
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
luoyuxia commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152667003
##
docs/data/sql_functions.yml:
##
@@ -634,6 +634,9 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns an
luoyuxia commented on code in PR #22267:
URL: https://github.com/apache/flink/pull/22267#discussion_r1152666906
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayPositionFunction.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to th
reswqa closed pull request #22280: [FLINK-31626] HsSubpartitionFileReaderImpl
should recycle skipped read buffers.
URL: https://github.com/apache/flink/pull/22280
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
reswqa commented on PR #22280:
URL: https://github.com/apache/flink/pull/22280#issuecomment-1489595913
merged via 59462197.
--
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.
liuyongvs commented on code in PR #19873:
URL: https://github.com/apache/flink/pull/19873#discussion_r1152663147
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -178,6 +179,35 @@ ANY, and(logical(LogicalType
liuyongvs commented on code in PR #19873:
URL: https://github.com/apache/flink/pull/19873#discussion_r1152662832
##
docs/data/sql_functions.yml:
##
@@ -617,6 +617,12 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns
lincoln-lil commented on PR #22300:
URL: https://github.com/apache/flink/pull/22300#issuecomment-1489577548
@LadyForest could you also backport this to 1.17 branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-31165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee resolved FLINK-31165.
-
Resolution: Fixed
fixed in master: eeb446c0ed07c38175efdadf7e2e21702ff02b70
> Over Agg: The win
liuyongvs commented on PR #22277:
URL: https://github.com/apache/flink/pull/22277#issuecomment-1489576769
fetch and rebase master and push, waiting for ci passed. thanks @fsk119
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Aitozi commented on code in PR #22301:
URL: https://github.com/apache/flink/pull/22301#discussion_r1152652365
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java:
##
@@ -1,111 +0,0 @@
-/*
- * Licensed to the Apache Softwar
lincoln-lil merged PR #22300:
URL: https://github.com/apache/flink/pull/22300
--
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
liuyongvs commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1152653663
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayReverseFunction.java:
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed to th
liuyongvs commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1152651153
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayReverseFunction.java:
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed to th
fsk119 commented on code in PR #22277:
URL: https://github.com/apache/flink/pull/22277#discussion_r1152647480
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayReverseFunction.java:
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-31652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-31652:
Assignee: xingbe
> Flink should handle the delete event if the pod was deleted while pend
[
https://issues.apache.org/jira/browse/FLINK-31652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706651#comment-17706651
]
Xintong Song commented on FLINK-31652:
--
[~xiasun] You are assigned. Please go ahead
mas-chen commented on PR #22303:
URL: https://github.com/apache/flink/pull/22303#issuecomment-1489514747
@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.
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152609858
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
tzulitai commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152597944
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -420,6 +420,7 @@ private void checkAsyncException
flinkbot commented on PR #22303:
URL: https://github.com/apache/flink/pull/22303#issuecomment-1489485422
## CI report:
* 40f41cfd6c48e484746e5cd8e1ebd126ca6c6a01 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152594238
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:
##
@@ -480,11 +478,6 @@ public UserCodeClassLoade
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152594080
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:
##
@@ -224,10 +223,9 @@ void testNumRecordsOutErr
mas-chen commented on code in PR #22303:
URL: https://github.com/apache/flink/pull/22303#discussion_r1152593857
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -447,15 +448,14 @@ public void onCompletion(Recor
mas-chen opened a new pull request, #22303:
URL: https://github.com/apache/flink/pull/22303
…tSinkInitContext general purpose sink testing tool
## What is the purpose of the change
Fixes a regression of a fix to properly propagate the error from
WriterCallback. Also improve uni
[
https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706608#comment-17706608
]
Timo Walther commented on FLINK-31660:
--
[~dwysakowicz] You also ran into this probl
[
https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706607#comment-17706607
]
Timo Walther commented on FLINK-31660:
--
This is a very annoying issue but iirc shou
tzulitai closed pull request #15: [FLINK-31363] Do not checkpoint a
KafkaCommittable if the transaction was empty
URL: https://github.com/apache/flink-connector-kafka/pull/15
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
tzulitai commented on PR #5:
URL:
https://github.com/apache/flink-connector-kafka/pull/5#issuecomment-1489307778
@paul8263 I think you can just go to the CI job page and re-run the job.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
tzulitai commented on PR #15:
URL:
https://github.com/apache/flink-connector-kafka/pull/15#issuecomment-1489305429
thanks for the review @RamanVerma, merging this now!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
tzulitai closed pull request #19: [Sync apache/flink:master][FLINK-31305]
Propagate producer exceptions outside of mailbox execut…
URL: https://github.com/apache/flink-connector-kafka/pull/19
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
tzulitai commented on PR #22124:
URL: https://github.com/apache/flink/pull/22124#issuecomment-1489271591
@echauchot thanks for opening the PR.
I think I agree with @mas-chen that this default implementation doesn't seem
like a good idea.
> the question can be reduced to "'what
snuyanzin commented on PR #19873:
URL: https://github.com/apache/flink/pull/19873#issuecomment-1489254376
yes i will
--
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 unsu
snuyanzin commented on code in PR #19873:
URL: https://github.com/apache/flink/pull/19873#discussion_r1152441866
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -178,6 +179,35 @@ ANY, and(logical(LogicalType
snuyanzin commented on code in PR #19873:
URL: https://github.com/apache/flink/pull/19873#discussion_r1152440929
##
docs/data/sql_functions.yml:
##
@@ -617,6 +617,12 @@ collection:
- sql: ARRAY_DISTINCT(haystack)
table: haystack.arrayDistinct()
description: Returns
[
https://issues.apache.org/jira/browse/FLINK-27891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-27891:
Description:
{{ARRAY_APPEND}} - adds element to the end of the array and returns the
resu
[
https://issues.apache.org/jira/browse/FLINK-31662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31662:
---
Labels: pull-request-available (was: )
> Migrate flink-connectors-aws to new structure
> --
hlteoh37 opened a new pull request, #62:
URL: https://github.com/apache/flink-connector-aws/pull/62
…flink-formats-aws
## Purpose of the change
Restructure the flink-connector-aws repository to better account for
flink-formats-aws
## Verifying this change
This change is a
snuyanzin commented on PR #22266:
URL: https://github.com/apache/flink/pull/22266#issuecomment-1489194393
based on exception this should help
https://github.com/apache/flink/commit/36f39712d289b6b7b0b957a33bd1891266e3f992
probably need to rebase
--
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-31658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-31658.
---
Resolution: Duplicate
I close it as a duplicate since originally PR was done under
https://
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-27640:
Fix Version/s: 1.16.2
> Flink not compiling, flink-connector-hive_2.12 is missing jhyde
>
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706578#comment-17706578
]
Sergey Nuyanzin commented on FLINK-27640:
-
Fixed in 1.16: 36f39712d289b6b7b0b957
snuyanzin commented on PR #22299:
URL: https://github.com/apache/flink/pull/22299#issuecomment-1489185062
Thanks for having a look!
--
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 co
snuyanzin merged PR #22299:
URL: https://github.com/apache/flink/pull/22299
--
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.apa
Hong Liang Teoh created FLINK-31662:
---
Summary: Migrate flink-connectors-aws to new structure
Key: FLINK-31662
URL: https://issues.apache.org/jira/browse/FLINK-31662
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-31660:
--
Assignee: Natea Eshetu Beshada
> flink-connectors-kafka ITCases are not runnable in t
[
https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-31660:
---
Affects Version/s: 1.18.0
> flink-connectors-kafka ITCases are not runnable in the IDE
> ---
[
https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Natea Eshetu Beshada updated FLINK-31660:
-
Description:
The following exception is thrown when trying to run
{{KafkaChange
1 - 100 of 289 matches
Mail list logo