flinkbot commented on PR #23984:
URL: https://github.com/apache/flink/pull/23984#issuecomment-1867349736
## CI report:
* d996c020cea9582b5df989f4eb277efb395931fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799692#comment-17799692
]
Jane Chan commented on FLINK-33217:
---
Sorry for being late.
Hi, [~xuyangzhong], thanks
flinkbot commented on PR #23983:
URL: https://github.com/apache/flink/pull/23983#issuecomment-1867344725
## CI report:
* d8230c9858c38019428e42bc8a7ee411fdb2d345 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33792:
---
Labels: pull-request-available (was: )
> Generate the same code for the same logic
> --
zoudan opened a new pull request, #23984:
URL: https://github.com/apache/flink/pull/23984
## What is the purpose of the change
This pull request ensure that we generate the same code for the same logic,
it is a precondition for sharing generated classes between different jobs.
liyubin117 opened a new pull request, #23983:
URL: https://github.com/apache/flink/pull/23983
## What is the purpose of the change
Cleanup the usage of deprecated
org.apache.flink.table.api.config.ExecutionConfigOptions#TABLE_EXEC_SHUFFLE_MODE,
org.apache.flink.table.api.config.Exec
[
https://issues.apache.org/jira/browse/FLINK-33927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33927:
---
Labels: pull-request-available (was: )
> Cleanup usage of deprecated ExecutionConfigOptions
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799688#comment-17799688
]
Benchao Li commented on FLINK-33490:
[~xuyangzhong] No, I mean
{code:SQL}
CREATE VI
[
https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799686#comment-17799686
]
Tom commented on FLINK-33917:
-
I've also raised this as a JDK bug in the mean time
https://
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434780474
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOve
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434780474
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOve
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434780474
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOve
[
https://issues.apache.org/jira/browse/FLINK-33927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-33927:
-
Description:
|org.apache.flink.table.api.config.ExecutionConfigOptions#TABLE_EXEC_SHUFFLE_MODE|
|org.apa
Yubin Li created FLINK-33927:
Summary: Cleanup usage of deprecated
ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE,
TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS)
Key: FLINK-33927
URL: https://issues.apache.org/jira/browse/F
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434766546
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java:
##
@@ -83,12 +92,27 @@ default void handleScalingEvent
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799679#comment-17799679
]
xuyang commented on FLINK-33490:
Hi, [~libenchao] .IIUC, do you mean we need to support
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434764455
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOve
[
https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom updated FLINK-33917:
Description:
In certain scenarios, if the hostname contains certain characters it will throw
an exception when it
[
https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799677#comment-17799677
]
Tom edited comment on FLINK-33917 at 12/22/23 6:25 AM:
---
Actually u
[
https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799677#comment-17799677
]
Tom edited comment on FLINK-33917 at 12/22/23 6:25 AM:
---
Actually u
[
https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom updated FLINK-33917:
Description:
In certain scenarios, if the hostname contains certain characters it will throw
an exception when it
[
https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799677#comment-17799677
]
Tom commented on FLINK-33917:
-
Actually uri("123-test") does work. The issue here is the '.
LadyForest commented on PR #23752:
URL: https://github.com/apache/flink/pull/23752#issuecomment-1867289962
Hi @xuyangzhong, sorry for being late. Could you mind rebasing the master
and resolving the conflicts? I'll take a look within this week.
--
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-32850.
Resolution: Implemented
All PRs merged, close this ticket
> [JUnit5 Migration] The io package of
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-32850:
---
Affects Version/s: 1.18.0
> [JUnit5 Migration] The io package of flink-runtime module
>
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-32850:
---
Fix Version/s: 1.19.0
> [JUnit5 Migration] The io package of flink-runtime module
>
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799659#comment-17799659
]
Jiabao Sun commented on FLINK-32850:
Thanks [~Weijie Guo], this task is finished.
Co
[
https://issues.apache.org/jira/browse/FLINK-33653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33653:
---
Assignee: RocMarshal
> Introduce a benchmark for balanced tasks scheduling
> --
[
https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33874:
---
Assignee: RocMarshal
> Support resource request wait mechanism at DefaultDeclarativeSlotPool side
[
https://issues.apache.org/jira/browse/FLINK-33875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-33875:
---
Assignee: RocMarshal
> Support slots wait mechanism at DeclarativeSlotPoolBridge side for Default
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799652#comment-17799652
]
Weijie Guo commented on FLINK-32850:
master(1.19) via 462708228df253de09e0a002ee0f2b
reswqa closed pull request #23974: [FLINK-32850][flink-runtime][JUnit5
Migration] The io.network.partition package of flink-runtime module
URL: https://github.com/apache/flink/pull/23974
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799647#comment-17799647
]
Zhu Zhu edited comment on FLINK-32513 at 12/22/23 2:46 AM:
---
Th
Jiabao-Sun commented on PR #23974:
URL: https://github.com/apache/flink/pull/23974#issuecomment-1867163701
> After this PR, whether all tests in `io.network` have been migrated?
Yes. Thanks a lot.
--
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799647#comment-17799647
]
Zhu Zhu commented on FLINK-32513:
-
The problem happens because the {{getTransitivePredec
reswqa commented on PR #23974:
URL: https://github.com/apache/flink/pull/23974#issuecomment-1867145877
After this PR, whether all tests in `io.network` have been migrated?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-25476.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> CharType lost in the creation of MaxAggFunction & M
[
https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799640#comment-17799640
]
dalongliu commented on FLINK-25476:
---
Merged to master: 085859ec19f59d2f8e73632e96fae59
lsyldliu closed pull request #18375: [FLINK-25476][table-planner] support CHAR
type in function MAX and MIN
URL: https://github.com/apache/flink/pull/18375
--
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
flinkbot commented on PR #23982:
URL: https://github.com/apache/flink/pull/23982#issuecomment-1867064898
## CI report:
* 6c905021e5b09a3537a68d208749bdc8ee1061f5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp merged PR #23962:
URL: https://github.com/apache/flink/pull/23962
--
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.apache.
XComp commented on PR #23982:
URL: https://github.com/apache/flink/pull/23982#issuecomment-1867063585
@snuyanzin can you do another quick pass over this one considering that
there were some conflicts which I had to resolve?
--
This is an automated message from the Apache Git Service.
To r
snuyanzin commented on PR #35:
URL:
https://github.com/apache/flink-connector-hbase/pull/35#issuecomment-1867027544
There was snappy update, probably need to add explicit dependency to cope
with
https://github.com/apache/flink-connector-hbase/actions/runs/7085132836/job/19876358681?pr=
snuyanzin commented on code in PR #23962:
URL: https://github.com/apache/flink/pull/23962#discussion_r1434572736
##
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemTest.java:
##
@@ -236,6 +237,7 @@ public void testRenameNonExistingFile() throws IOException
XComp commented on code in PR #23962:
URL: https://github.com/apache/flink/pull/23962#discussion_r1434558666
##
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemTest.java:
##
@@ -236,6 +237,7 @@ public void testRenameNonExistingFile() throws IOException {
[
https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799584#comment-17799584
]
Sai Sharath Dandi commented on FLINK-33817:
---
[~libenchao] , Can you please tak
[
https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sai Sharath Dandi updated FLINK-33817:
--
Description:
*Background*
The current Protobuf format
[implementation|https://git
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560
]
Sai Sharath Dandi edited comment on FLINK-33611 at 12/21/23 9:23 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560
]
Sai Sharath Dandi edited comment on FLINK-33611 at 12/21/23 9:22 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799583#comment-17799583
]
Sai Sharath Dandi commented on FLINK-33611:
---
Fwiw, I've run into this issue fo
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560
]
Sai Sharath Dandi edited comment on FLINK-33611 at 12/21/23 8:18 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560
]
Sai Sharath Dandi commented on FLINK-33611:
---
[~libenchao] , The constant pool
sharath1709 commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1866817077
@libenchao Thanks for the quick response. Sure, let's try to reach an
agreement on the JIRA first
--
This is an automated message from the Apache Git Service.
To respond to the mess
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Trystan updated FLINK-33926:
Description:
It appears that the combination of the running operator-controlled jobs in
native k8s + appl
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Trystan updated FLINK-33926:
Component/s: Kubernetes Operator
> Can't start a job with a jar in the system classpath in native k8s mode
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Trystan updated FLINK-33926:
Description:
It appears that the combination of the running operator-controlled jobs in
native k8s + appl
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Trystan updated FLINK-33926:
Description:
It appears that the combination of the running operator-controlled jobs in
native k8s + appl
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Trystan updated FLINK-33926:
Description:
It appears that the combination of the running operator-controlled jobs in
native k8s + appl
Trystan created FLINK-33926:
---
Summary: Can't start a job with a jar in the system classpath in
native k8s mode
Key: FLINK-33926
URL: https://issues.apache.org/jira/browse/FLINK-33926
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Trystan updated FLINK-33926:
Description:
It appears that the combination of the running operator-controlled jobs in
native k8s applic
ness-MirceaLutic opened a new pull request, #68:
URL: https://github.com/apache/flink-training/pull/68
(no comment)
--
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 unsub
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434220037
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434216202
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java:
##
@@ -83,12 +92,27 @@ default void handleScalingEvent(
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434212997
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434211420
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434209212
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
[
https://issues.apache.org/jira/browse/FLINK-20772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799448#comment-17799448
]
Seongbae Chang commented on FLINK-20772:
[~masteryhx], [~Zakelly] Sorry for the
mxm commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434199585
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOverrid
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1434166658
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java:
##
@@ -96,28 +97,115 @@ public JdbcDynamicTableSour
XComp commented on code in PR #23962:
URL: https://github.com/apache/flink/pull/23962#discussion_r1434112468
##
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemTest.java:
##
@@ -236,6 +237,7 @@ public void testRenameNonExistingFile() throws IOException {
Samrat002 commented on PR #114:
URL:
https://github.com/apache/flink-connector-aws/pull/114#issuecomment-1866305970
@hlteoh37, @vahmed-hamdy please review in free time 🙏🏻
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
snuyanzin commented on PR #23981:
URL: https://github.com/apache/flink/pull/23981#issuecomment-1866302758
having maven wrapper does not protect from running with installed maven
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-33902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33902.
---
Fix Version/s: 1.19.0
1.18.1
Resolution: Fixed
master:
[87738d3f0
XComp merged PR #23979:
URL: https://github.com/apache/flink/pull/23979
--
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.apache.
XComp commented on PR #23979:
URL: https://github.com/apache/flink/pull/23979#issuecomment-1866296953
I'm merging w/o extra review because there were no conflicts in the backport
and the parent PR was approved.
--
This is an automated message from the Apache Git Service.
To respond to the
XComp merged PR #23961:
URL: https://github.com/apache/flink/pull/23961
--
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.apache.
flinkbot commented on PR #23981:
URL: https://github.com/apache/flink/pull/23981#issuecomment-1866287852
## CI report:
* 8bac98b51ccb4a13d5a498e377f17bb86b953b1d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
asafm opened a new pull request, #23981:
URL: https://github.com/apache/flink/pull/23981
## What is the purpose of the change
Small fix to README
## Brief change log
No need for pre-installed maven, since we have Maven Wrapper
## Verifying this change
Please
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1434090851
##
pom.xml:
##
@@ -63,6 +63,9 @@ under the License.
flink-connector-jdbc-parent
1
+
+-XX:+UseG1GC -Xms256m
-XX:+Ignore
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1434090595
##
flink-connector-jdbc/pom.xml:
##
@@ -42,6 +42,10 @@ under the License.
21.8.0.0
418
1.12.10
+
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1434090293
##
.github/workflows/push_pr.yml:
##
@@ -25,7 +25,14 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [1.16-SNAPSHOT, 1.17-SNAPSH
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1434090293
##
.github/workflows/push_pr.yml:
##
@@ -25,7 +25,14 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [1.16-SNAPSHOT, 1.17-SNAPSH
snuyanzin commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1434090595
##
flink-connector-jdbc/pom.xml:
##
@@ -42,6 +42,10 @@ under the License.
21.8.0.0
418
1.12.10
+
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1434066148
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
liyubin117 commented on PR #23980:
URL: https://github.com/apache/flink/pull/23980#issuecomment-1866172964
@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
[
https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799400#comment-17799400
]
Benchao Li commented on FLINK-33611:
I'm wondering how large will it be that can rea
libenchao commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1866145686
@sharath1709 Thanks for your contribution. Per the community's convention,
we need to reach an agreement on the issue before we go to the PR review. I'll
comment on the corresponding Ji
mxm commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1433991220
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java:
##
@@ -83,12 +92,27 @@ default void handleScalingEvent(
mxm commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1433989601
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOverrid
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799398#comment-17799398
]
Benchao Li commented on FLINK-33490:
The standard states that:
{quote}i) If any two
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1433973975
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
gyfora commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1433973067
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -264,4 +262,21 @@ private static Map
getVertexParallelismOver
flinkbot commented on PR #23980:
URL: https://github.com/apache/flink/pull/23980#issuecomment-1866115231
## CI report:
* 620ea94f2829ebc8c55ab0657261c65f6881054b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33925:
---
Labels: pull-request-available (was: )
> Extended failure handling for bulk requests (elast
boring-cyborg[bot] commented on PR #39:
URL:
https://github.com/apache/flink-connector-opensearch/pull/39#issuecomment-1866114172
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
schulzp opened a new pull request, #39:
URL: https://github.com/apache/flink-connector-opensearch/pull/39
This is a back port of the implementation for the elasticsearch connector,
see [FLINK-32028](https://issues.apache.org/jira/browse/FLINK-32028), to
achieve consistent APIs.
Extra
Peter Schulz created FLINK-33925:
Summary: Extended failure handling for bulk requests
(elasticsearch back port)
Key: FLINK-33925
URL: https://issues.apache.org/jira/browse/FLINK-33925
Project: Flink
liyubin117 opened a new pull request, #23980:
URL: https://github.com/apache/flink/pull/23980
## What is the purpose of the change
Cleanup the usage of deprecated
org.apache.flink.table.api.TableConfig#getMinIdleStateRetentionTime,
org.apache.flink.table.api.TableConfig#getMaxIdleSta
flinkbot commented on PR #23979:
URL: https://github.com/apache/flink/pull/23979#issuecomment-1866078496
## CI report:
* 7d32f61389784a833100d065c17ffd2fca753eb4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on PR #23961:
URL: https://github.com/apache/flink/pull/23961#issuecomment-1866076157
Thanks for approving the PR. I created the corresponding 1.18 backport. :+1:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
1 - 100 of 177 matches
Mail list logo
