WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510727272
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java:
##
@@ -1071,6 +1077,110 @@ protected SingleOutputStreamOperator
ag
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510728074
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510732371
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510732710
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510733360
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510733720
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/AbstractSortPartitionOperator.java:
##
@@ -0,0 +1,229 @@
+/*
+ * Licensed to the
WencongLiu commented on code in PR #24398:
URL: https://github.com/apache/flink/pull/24398#discussion_r1510734111
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/NonKeyedSortPartitionOperator.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the
WencongLiu commented on PR #24398:
URL: https://github.com/apache/flink/pull/24398#issuecomment-1975951178
> Thanks @WencongLiu for bring this up. This is a valuable feature!
>
> I I've only reviewed two of the commits so far and will look at the rest
later.
Thanks for the care
BIOINSu opened a new pull request, #24431:
URL: https://github.com/apache/flink/pull/24431
## What is the purpose of the change
This pull request removes redundant transformation verification logic and
use `ExplainDetail.JSON_EXECUTION_PLAN` toverify the parallelism instea
flinkbot commented on PR #24431:
URL: https://github.com/apache/flink/pull/24431#issuecomment-1975961845
## CI report:
* 127a4cc3bdd4818a23e546646c4750605c8d38de UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
luoyuxia merged PR #24419:
URL: https://github.com/apache/flink/pull/24419
--
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
[
https://issues.apache.org/jira/browse/FLINK-34517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823069#comment-17823069
]
luoyuxia commented on FLINK-34517:
--
1.18: 620c5a7aeba448d247107ad44a6ba6f1e759052e
mas
[
https://issues.apache.org/jira/browse/FLINK-34517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823069#comment-17823069
]
luoyuxia edited comment on FLINK-34517 at 3/4/24 8:20 AM:
--
1.18
mxm commented on code in PR #787:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/787#discussion_r1509934269
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -129,6 +131,11 @@ public boolean scaleResource(
zhuzhurk commented on PR #24115:
URL: https://github.com/apache/flink/pull/24115#issuecomment-1976014749
Hi @caodizhou , is there any progress? Should we re-enable the excluded
tests?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mxm commented on code in PR #788:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/788#discussion_r1510789812
##
docs/content/docs/custom-resource/overview.md:
##
@@ -85,7 +85,7 @@ The spec contains all the information the operator need to
deploy and manage you
Zakelly commented on code in PR #24418:
URL: https://github.com/apache/flink/pull/24418#discussion_r1510799597
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/WithinCheckpointFileMergingSnapshotManager.java:
##
@@ -41,12 +41,13 @@ public class With
[
https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823102#comment-17823102
]
Alexis Sarda-Espinosa commented on FLINK-34400:
---
Hi [~fanrui], sorry for t
[
https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823102#comment-17823102
]
Alexis Sarda-Espinosa edited comment on FLINK-34400 at 3/4/24 9:32 AM:
---
dannycranmer commented on PR #24348:
URL: https://github.com/apache/flink/pull/24348#issuecomment-1976154596
@barakbn please rebase and squash commits and I will merge.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
masteryhx commented on PR #24396:
URL: https://github.com/apache/flink/pull/24396#issuecomment-1976157579
> Hi @masteryhx , I suggest minor adjustments in Chinese. PTAL, thanks!
Thanks for the suggestions, I have addressed and rebased commits. PTAL again.
--
This is an automated mes
Jiabao-Sun opened a new pull request, #24432:
URL: https://github.com/apache/flink/pull/24432
## What is the purpose of the change
[FLINK-25544][streaming][JUnit5 Migration] The
util,graph,experimental,environment package of module flink-stream-java
## Brief change log
flinkbot commented on PR #24432:
URL: https://github.com/apache/flink/pull/24432#issuecomment-1976310900
## CI report:
* 267e6e0287c75dd99ddd81950d5c6fa285ed1e0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1510982540
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -1516,4 +1517,141 @@ private Stream arr
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1510988286
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed to the
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1510988286
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed to the
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1510994873
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the Apac
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1510994873
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the Apac
masteryhx commented on code in PR #24322:
URL: https://github.com/apache/flink/pull/24322#discussion_r1511001449
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBNativeMetricMonitor.java:
##
@@ -114,7 +114,14 @@ pri
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511000467
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/ObjectContainer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software
whhe commented on PR #43:
URL:
https://github.com/apache/flink-connector-jdbc/pull/43#issuecomment-1976373645
Any plan for this PR?
--
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
He Wang created FLINK-34572:
---
Summary: JDBC: Support OceanBase catalog
Key: FLINK-34572
URL: https://issues.apache.org/jira/browse/FLINK-34572
Project: Flink
Issue Type: New Feature
Compo
zentol closed pull request #8519: [FLINK-12590][docs] Replace HTTP links
URL: https://github.com/apache/flink/pull/8519
--
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
zentol closed pull request #9867: [FLINK-7958][metrics] Reporters provide
default delimiter
URL: https://github.com/apache/flink/pull/9867
--
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 specifi
zentol closed pull request #13190: [FLINK-18986][kubernetes] Create
ClusterClient only for attached deployments
URL: https://github.com/apache/flink/pull/13190
--
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
zentol closed pull request #19620: [FLINK-27467][cli][tests] Drop
CliFrontendTestBase
URL: https://github.com/apache/flink/pull/19620
--
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
zentol closed pull request #20952: [FLINK-29399][tests] Wait until job was
cancelled
URL: https://github.com/apache/flink/pull/20952
--
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-29399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29399:
---
Labels: pull-request-available (was: )
> TableITCase is unstable
> ---
zentol closed pull request #21228: [FLINK-29866][build] Split flink-dist
URL: https://github.com/apache/flink/pull/21228
--
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
zentol closed pull request #38: [hotfix][ci] Sync CI setup & Reuse workflow
URL: https://github.com/apache/flink-connector-aws/pull/38
--
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 com
zentol closed pull request #22653: [FLINK-32179][tests] Harden
FileUtils#findFlinkDist against custom repo names
URL: https://github.com/apache/flink/pull/22653
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-32179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32179:
---
Labels: pull-request-available (was: )
> Handle more repo names for automatic dist discover
zentol closed pull request #21532: FLINK-30455 [core] Excluding
java.lang.String and primitive types from closure cleaning
URL: https://github.com/apache/flink/pull/21532
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
flinkbot commented on PR #7980:
URL: https://github.com/apache/flink/pull/7980#issuecomment-1976427637
## CI report:
* a523bdc12f9f0f00c60d1940927454bd497859a5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure` re
flinkbot commented on PR #8545:
URL: https://github.com/apache/flink/pull/8545#issuecomment-1976428068
## CI report:
* dcf2c5bd6d1c3ebe4b349c2b479a66f8c225f7ce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure` re
masteryhx commented on code in PR #24401:
URL: https://github.com/apache/flink/pull/24401#discussion_r1511051492
##
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##
@@ -76,6 +76,17 @@ public class CheckpointingOptions {
* CheckpointStor
masteryhx closed pull request #24181: [FLINK-32075][FLIP-306][Checkpoint]
Delete merged files on checkpoint abort or subsumption
URL: https://github.com/apache/flink/pull/24181
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-32075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-32075.
--
Fix Version/s: 1.20.0
(was: 1.19.0)
Resolution: Fixed
merged cd9
[
https://issues.apache.org/jira/browse/FLINK-34536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823143#comment-17823143
]
yisha zhou commented on FLINK-34536:
[~libenchao] Thanks for your insight, it helps
ferenc-csaky commented on PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#issuecomment-1976453914
@echauchot Sorry to ping you out of the blue, I saw that you were an active
contributor to the Cassandra connector. If you have some time, would you mind
reviewing thi
FangYongs commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1976455987
Thanks @JingGe , please help to review this PR again
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
FangYongs commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1976458731
@HuangZhenQiu @mobuchowski I have add dataset and facet interfaces in
lineage vertex, please help to review this PR cc @X-czh
--
This is an automated message from the Apache Git Serv
caicancai commented on code in PR #788:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/788#discussion_r1511081946
##
docs/content/docs/custom-resource/overview.md:
##
@@ -85,7 +85,7 @@ The spec contains all the information the operator need to
deploy and manage
X-czh commented on code in PR #23626:
URL: https://github.com/apache/flink/pull/23626#discussion_r1511095895
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/lineage/DefaultLineageGraphTest.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823159#comment-17823159
]
Ahmed Soliman commented on FLINK-33992:
---
Hello [~skala]
I have some thoughts her
masteryhx closed pull request #24396: [FLINK-34352][doc] Improve the
documentation of allowNonRestoredState
URL: https://github.com/apache/flink/pull/24396
--
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
X-czh commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1976492211
@FangYongs Thanks for the PR. The changes LGTM except for a nit on the UT.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-34352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34352.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged e168cd4d into master.
> Improve the doc
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823163#comment-17823163
]
Gyula Fora commented on FLINK-34566:
Looking at this in detail I think it should wor
dawidwys commented on code in PR #24219:
URL: https://github.com/apache/flink/pull/24219#discussion_r1511101924
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java:
##
@@ -0,0 +1,129 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823164#comment-17823164
]
Gyula Fora commented on FLINK-34566:
Even if the core pool size is 10, the maxpoolsi
[ https://issues.apache.org/jira/browse/FLINK-34566 ]
Gyula Fora deleted comment on FLINK-34566:
was (Author: gyfora):
{noformat}
A ThreadPoolExecutor will automatically adjust the pool size (see getPoolSize)
according to the bounds set by core
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823166#comment-17823166
]
Gyula Fora commented on FLINK-34566:
>From the java docs:
"A ThreadPoolExecutor wil
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823165#comment-17823165
]
Gyula Fora commented on FLINK-34566:
{noformat}
A ThreadPoolExecutor will automatica
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823168#comment-17823168
]
Gyula Fora commented on FLINK-33992:
For session job submissions the jar generally h
[
https://issues.apache.org/jira/browse/FLINK-33992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823169#comment-17823169
]
Gyula Fora commented on FLINK-33992:
It would be great if Flink itself would have a
LSZ created FLINK-34573:
---
Summary: the task is stuck on the high presure
Key: FLINK-34573
URL: https://issues.apache.org/jira/browse/FLINK-34573
Project: Flink
Issue Type: Bug
Components: Run
mxm merged PR #788:
URL: https://github.com/apache/flink-kubernetes-operator/pull/788
--
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-32497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823172#comment-17823172
]
david radley commented on FLINK-32497:
--
I notice this is a critical issue. But from
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LSZ updated FLINK-34573:
Attachment: rate.PNG
> the task is stuck on the high presure
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LSZ updated FLINK-34573:
Description:
we havae a flink job , jst one taskmanger;
when use high presure as soure data,it will be stuck. som
Gabor Somogyi created FLINK-34574:
-
Summary: Add CPU and memory size autoscaler quota
Key: FLINK-34574
URL: https://issues.apache.org/jira/browse/FLINK-34574
Project: Flink
Issue Type: New Fe
[
https://issues.apache.org/jira/browse/FLINK-34574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-34574:
-
Assignee: Gabor Somogyi
> Add CPU and memory size autoscaler quota
> --
libenchao merged PR #24431:
URL: https://github.com/apache/flink/pull/24431
--
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
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823188#comment-17823188
]
Lorenzo Affetti commented on FLINK-20392:
-
[~mapohl] [~jark]
In order to bette
[
https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823193#comment-17823193
]
Matthias Pohl commented on FLINK-20392:
---
The goal is to move away from bash-based
gaborgsomogyi opened a new pull request, #789:
URL: https://github.com/apache/flink-kubernetes-operator/pull/789
## What is the purpose of the change
Flink can report slot sharing group information in the vertex information.
This can be used to fine tune the autoscaler algorithm to de
[
https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823201#comment-17823201
]
Matthias Pohl commented on FLINK-29114:
---
*
https://github.com/apache/flink/action
ferenc-csaky commented on code in PR #22789:
URL: https://github.com/apache/flink/pull/22789#discussion_r1511222835
##
flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopFreeTests.java:
##
Review Comment:
Use AssertJ's `assertThatThrownBy
XComp commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1511250389
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SNAP
ferenc-csaky commented on PR #42:
URL:
https://github.com/apache/flink-connector-hbase/pull/42#issuecomment-1976709968
@Tan-JiaLiang if you have some time can you PTAL?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
echauchot commented on PR #26:
URL:
https://github.com/apache/flink-connector-cassandra/pull/26#issuecomment-1976742586
> @echauchot Sorry to ping you out of the blue, I saw that you were an
active contributor to the Cassandra connector. If you have some time, would you
mind reviewing this
gyfora commented on code in PR #786:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/786#discussion_r1511285884
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java:
##
@@ -148,8 +149,11 @@ public static ConfigChanges tuneTaskMana
mxm commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1511294060
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/JobTopology.java:
##
@@ -97,10 +109,6 @@ public boolean isSource(JobVertexID jobVert
[
https://issues.apache.org/jira/browse/FLINK-34566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34566.
--
Resolution: Not A Problem
I am closing this ticket for now, if you feel that this resolution is incorr
mxm commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1511292849
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/EvaluatedMetrics.java:
##
@@ -30,6 +31,7 @@
@NoArgsConstructor
@AllArgsConstructor
mxm commented on code in PR #786:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/786#discussion_r1511334711
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java:
##
@@ -148,8 +149,11 @@ public static ConfigChanges tuneTaskManager
Adrian Vasiliu created FLINK-34575:
--
Summary: Vulnerabilities in commons-compress 1.24.0; upgrade to
1.26.0 needed.
Key: FLINK-34575
URL: https://issues.apache.org/jira/browse/FLINK-34575
Project: Fl
LadyForest commented on PR #24390:
URL: https://github.com/apache/flink/pull/24390#issuecomment-1976845985
Hi @XComp, would you mind taking a look when you're available?
--
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-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823242#comment-17823242
]
Lorenzo Affetti commented on FLINK-20392:
-
{quote}I'm not able to follow what yo
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511439120
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed to
XComp commented on code in PR #24390:
URL: https://github.com/apache/flink/pull/24390#discussion_r1511414346
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/utils/PathUtils.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Sof
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511453416
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511453416
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-34531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-34531:
---
Assignee: lincoln lee
> Build and stage Java and Python artifacts
> ---
[
https://issues.apache.org/jira/browse/FLINK-34532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-34532:
---
Assignee: lincoln lee
> Stage source and binary releases on dist.apache.org
> -
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511584785
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -1516,4 +1517,141 @@ private Stream
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511610616
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/ObjectContainer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Softwa
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511610976
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/EqualityAndHashcodeProvider.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the A
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1511611341
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/ObjectContainer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Softwa
1 - 100 of 146 matches
Mail list logo
