yunfengzhou-hub commented on PR #23927:
URL: https://github.com/apache/flink/pull/23927#issuecomment-1862278523
Hi @TanYuxin-tyx could you please take a look at this PR?
--
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-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798468#comment-17798468
]
Jing Ge commented on FLINK-33588:
-
[~zhutong66] Thanks for the feedback. Could you pleas
rinkako commented on PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1862265394
> > @mtfelisb Are you still active on this PR?
>
> Hi, @MartijnVisser. Yes, I'm waiting for review. Also, I'll not implement
the `DynamicTableSink` because @rinka
liming30 commented on code in PR #23922:
URL: https://github.com/apache/flink/pull/23922#discussion_r1430990459
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java:
##
@@ -359,6 +365,58 @@ p
liming30 commented on code in PR #23922:
URL: https://github.com/apache/flink/pull/23922#discussion_r1430988502
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java:
##
@@ -359,6 +365,58 @@ p
liming30 commented on code in PR #23922:
URL: https://github.com/apache/flink/pull/23922#discussion_r1430987609
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java:
##
@@ -359,6 +365,58 @@ p
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798442#comment-17798442
]
Tongtong Zhu commented on FLINK-33588:
--
[~jingge] I have tested this change on the
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tongtong Zhu updated FLINK-33588:
-
Attachment: image-2023-12-19-14-03-27-062.png
> Fix Flink Checkpointing Statistics Bug
> ---
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tongtong Zhu updated FLINK-33588:
-
Attachment: image-2023-12-19-14-02-49-083.png
> Fix Flink Checkpointing Statistics Bug
> ---
singhravidutt commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-1862159340
> Also @singhravidutt what's your Jira user name, so I can assign this
ticket to you?
you can assign this to me now. My jira username is: singhravidutt
--
This is an automa
[
https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798422#comment-17798422
]
zhilinli commented on FLINK-32346:
--
Currently the documentation and the code already di
[
https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798422#comment-17798422
]
zhilinli edited comment on FLINK-32346 at 12/19/23 4:38 AM:
X-czh commented on PR #23447:
URL: https://github.com/apache/flink/pull/23447#issuecomment-1862095289
@wanglijie95 Squashed and rebased, thanks!
--
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 th
leonardBang commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1862084984
Hi, @HuangZhenQiu Would you like to rebase the PR to the latest master
branch ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
xiangforever2014 commented on PR #23253:
URL: https://github.com/apache/flink/pull/23253#issuecomment-1862077615
@masteryhx kindly remind~
--
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 spec
flinkbot commented on PR #23956:
URL: https://github.com/apache/flink/pull/23956#issuecomment-1862077122
## CI report:
* 8db6276722e5ead414953e0c782ca1b062e902a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23955:
URL: https://github.com/apache/flink/pull/23955#issuecomment-1862076600
## CI report:
* e5da58df5653766d430260ae75c1c5f186652b8b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wuchong commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1862075968
Hi @PatrickRen @leonardBang , do you have time to help review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
1996fanrui commented on code in PR #23922:
URL: https://github.com/apache/flink/pull/23922#discussion_r1430885170
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendConfigTest.java:
##
@@ -359,6 +365,58 @@
[
https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798417#comment-17798417
]
Jiabao Sun commented on FLINK-33877:
Based on the exception stack trace, it is possi
bvarghese1 opened a new pull request, #23956:
URL: https://github.com/apache/flink/pull/23956
## What is the purpose of the change
*Add restore tests for WindowRank node*
## Verifying this change
This change added tests and can be verified as follows:
- Added r
[
https://issues.apache.org/jira/browse/FLINK-33861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33861:
---
Labels: pull-request-available (was: )
> Implement restore tests for WindowRank node
>
[
https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33877:
---
Labels: pull-request-available test-stability (was: test-stability)
> CollectSinkFunctionTe
Jiabao-Sun opened a new pull request, #23955:
URL: https://github.com/apache/flink/pull/23955
## What is the purpose of the change
[FLINK-33877][streaming] Fix unstable test of
CollectSinkFunctionTest.testConfiguredPortIsUsed
https://dev.azure.com/apache-flink/apache-f
flashJd commented on code in PR #728:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1430882288
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -143,7 +145,11 @@ public CollectedMetricHistory update
flinkbot commented on PR #23954:
URL: https://github.com/apache/flink/pull/23954#issuecomment-1862054502
## CI report:
* ba611f6691b0383e2861828d2e3d968d1d4aa74d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798413#comment-17798413
]
Wencong Liu commented on FLINK-33502:
-
Sorry for the late reply. I've just identifie
WencongLiu opened a new pull request, #23954:
URL: https://github.com/apache/flink/pull/23954
## What is the purpose of the change
*The preparation step of ScheduledSubpartitionReader should not shut down
the process.*
## Does this pull request potentially affect one of the fol
[
https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-33877:
---
Labels: test-stability (was: )
> CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to Bind
X-czh commented on code in PR #23447:
URL: https://github.com/apache/flink/pull/23447#discussion_r1430859019
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java:
##
@@ -570,6 +578,19 @@ void retainSubtasks(Set activeSubtasks) {
JunRuiLee commented on code in PR #23447:
URL: https://github.com/apache/flink/pull/23447#discussion_r1430850407
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java:
##
@@ -570,6 +578,19 @@ void retainSubtasks(Set activeSubtasks)
lincoln-lil commented on code in PR #23827:
URL: https://github.com/apache/flink/pull/23827#discussion_r1430848529
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala:
##
@@ -1916,4 +1916,44 @@ class Aggregate
flinkbot commented on PR #23953:
URL: https://github.com/apache/flink/pull/23953#issuecomment-1861985105
## CI report:
* 0165b2d94c1464a19c1b74f77e2fbaa1e5e236eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-33878:
---
Summary: Many Keyed Operators extends `TableStreamOperator` which is marked
without key. (was: Many Keyed
[
https://issues.apache.org/jira/browse/FLINK-33878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798406#comment-17798406
]
xuyang commented on FLINK-33878:
Do you think we should fix it? If yes, I want to take t
xuyang created FLINK-33878:
--
Summary: Many Keyed Operator extends `TableStreamOperator` which
is marked without key.
Key: FLINK-33878
URL: https://issues.apache.org/jira/browse/FLINK-33878
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798405#comment-17798405
]
xuyang commented on FLINK-33878:
cc [~qingyue]
> Many Keyed Operator extends `TableStr
yunfengzhou-hub commented on PR #23953:
URL: https://github.com/apache/flink/pull/23953#issuecomment-1861973471
Hi @reswqa could you please take a look at 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
UR
yunfengzhou-hub opened a new pull request, #23953:
URL: https://github.com/apache/flink/pull/23953
## What is the purpose of the change
This pull request supports configuring the PARALLELISM_OVERRIDES
configuration during the job submission process. Before this PR, Flink has
currentl
[
https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-33534.
--
Fix Version/s: 1.19.0
Resolution: Fixed
master(1.19) via 4cc24c1dd17b0abe3c4372652c7ab88fedc7e4
reswqa merged PR #23944:
URL: https://github.com/apache/flink/pull/23944
--
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
Jiabao-Sun commented on PR #23952:
URL: https://github.com/apache/flink/pull/23952#issuecomment-1861943681
@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
Jiabao Sun created FLINK-33877:
--
Summary: CollectSinkFunctionTest.testConfiguredPortIsUsed fails
due to BindException
Key: FLINK-33877
URL: https://issues.apache.org/jira/browse/FLINK-33877
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-33877:
---
Priority: Critical (was: Major)
> CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to Bin
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798370#comment-17798370
]
Sergey Nuyanzin commented on FLINK-33531:
-
Merged to 1.18.1 as
[0d6ab1db6c04cd88
snuyanzin merged PR #23950:
URL: https://github.com/apache/flink/pull/23950
--
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-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798369#comment-17798369
]
Jim Hughes commented on FLINK-27756:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798368#comment-17798368
]
Jim Hughes commented on FLINK-27756:
https://dev.azure.com/apache-flink/apache-flink
snuyanzin commented on PR #23950:
URL: https://github.com/apache/flink/pull/23950#issuecomment-1861775006
thanks for taking 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 com
ryanvanhuuksloot opened a new pull request, #736:
URL: https://github.com/apache/flink-kubernetes-operator/pull/736
## What is the purpose of the change
Fix a few things in the docs
## Brief change log
Fix a few things in the docs
## Verifying this change
No verificatio
ryanvanhuuksloot commented on PR #736:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/736#issuecomment-1861544730
Someone with merge privileges please merge after reviewing 🙏
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dannycranmer commented on code in PR #23949:
URL: https://github.com/apache/flink/pull/23949#discussion_r1430540231
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -683,6 +685,129 @@ public void testRetrieveCheckpointStats() throws
dannycranmer commented on PR #23949:
URL: https://github.com/apache/flink/pull/23949#issuecomment-1861348278
CI Failure:
> Dec 18 16:52:43 16:52:43.222 [ERROR]
DispatcherTest.testRetrieveCheckpointStatsOnNonExistentJob:804
--
This is an automated message from the Apache Git Service
dannycranmer commented on code in PR #23949:
URL: https://github.com/apache/flink/pull/23949#discussion_r1430540231
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -683,6 +685,129 @@ public void testRetrieveCheckpointStats() throws
dannycranmer commented on code in PR #23949:
URL: https://github.com/apache/flink/pull/23949#discussion_r1430538449
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -683,6 +685,129 @@ public void testRetrieveCheckpointStats() throws
Zakelly commented on code in PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#discussion_r1430468167
##
src/main/java/org/apache/flink/state/benchmark/ttl/TtlStateBenchmarkBase.java:
##
@@ -0,0 +1,48 @@
+package org.apache.flink.state.benchmark.ttl;
+
+import org.
eskabetxe commented on PR #84:
URL:
https://github.com/apache/flink-connector-jdbc/pull/84#issuecomment-1861086328
@MartijnVisser 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 specifi
JingGe commented on PR #23950:
URL: https://github.com/apache/flink/pull/23950#issuecomment-1860976058
@snuyanzin thanks for the heads-up. Let's add it into 1.18.1 release
--
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-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33531:
Affects Version/s: 1.18.0
> Nightly Python fails with NPE at metadataHandlerProvider on AZP
> (StreamDepe
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33531:
Fix Version/s: 1.18.1
> Nightly Python fails with NPE at metadataHandlerProvider on AZP
> (StreamDependen
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798275#comment-17798275
]
Jing Ge commented on FLINK-33531:
-
let's add it into 1.18.1 release
> Nightly Python fa
dannycranmer opened a new pull request, #121:
URL: https://github.com/apache/flink-connector-aws/pull/121
## Purpose of the change
Inspired by https://github.com/apache/flink-connector-kafka/pull/69, moves
`kinesis.py` and `test_kinesis.py` from `apache/flink` to
`apache/flink-connec
[
https://issues.apache.org/jira/browse/FLINK-33560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33560:
---
Labels: pull-request-available (was: )
> Externalize Kinesis Python connector code
> --
Zakelly commented on code in PR #83:
URL: https://github.com/apache/flink-benchmarks/pull/83#discussion_r1430371694
##
src/main/java/org/apache/flink/state/benchmark/ttl/TtlListStateBenchmark.java:
##
@@ -0,0 +1,150 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798267#comment-17798267
]
Jiabao Sun commented on FLINK-32850:
Merged master (1.19) via:
1c67cccd2fdd6c674a38
twalthr commented on code in PR #23948:
URL: https://github.com/apache/flink/pull/23948#discussion_r1430361998
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java:
##
@@ -72,6 +75,13 @@ public String asSummaryStri
flinkbot commented on PR #23952:
URL: https://github.com/apache/flink/pull/23952#issuecomment-1860933072
## CI report:
* 85c84e98f1c1c483972dbe30b4e30ca127817360 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr commented on code in PR #23948:
URL: https://github.com/apache/flink/pull/23948#discussion_r1430361475
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java:
##
@@ -72,6 +75,13 @@ public String asSummaryStri
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798178#comment-17798178
]
david radley edited comment on FLINK-33365 at 12/18/23 4:12 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798178#comment-17798178
]
david radley edited comment on FLINK-33365 at 12/18/23 4:10 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33876:
---
Labels: pull-request-available (was: )
> [JUnit5 Migration] Introduce methodName method in
Jiabao-Sun commented on PR #23952:
URL: https://github.com/apache/flink/pull/23952#issuecomment-1860909405
Hi @leonardBang, please help review it when you have time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Jiabao-Sun opened a new pull request, #23952:
URL: https://github.com/apache/flink/pull/23952
## What is the purpose of the change
[FLINK-33876][table-planner][JUnit5 Migration] Introduce methodName method
in TableTestBase
## Brief change log
After completing the
[
https://issues.apache.org/jira/browse/FLINK-33876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-33876:
---
Summary: [JUnit5 Migration] Introduce methodName method in TableTestBase
(was: [JUnit5 Migration] I
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798256#comment-17798256
]
Ahmed Hamdy commented on FLINK-31472:
-
[~Sergey Nuyanzin] I have pushed a PR with th
Jiabao Sun created FLINK-33876:
--
Summary: [JUnit5 Migration] Introduce testName method in
TableTestBase
Key: FLINK-33876
URL: https://issues.apache.org/jira/browse/FLINK-33876
Project: Flink
Is
dawidwys merged PR #23590:
URL: https://github.com/apache/flink/pull/23590
--
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-33862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798251#comment-17798251
]
Prabhu Joseph commented on FLINK-33862:
---
Yes right. Thanks [~martijnvisser].
> Fl
dawidwys commented on code in PR #23590:
URL: https://github.com/apache/flink/pull/23590#discussion_r1430305765
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/CheckpointBarrierTest.java:
##
@@ -22,37 +22,29 @@
import org.apache.flink.core.memory.DataOutp
twalthr commented on code in PR #23948:
URL: https://github.com/apache/flink/pull/23948#discussion_r1430298273
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java:
##
@@ -72,6 +75,13 @@ public String asSummaryStri
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798240#comment-17798240
]
Jing Ge commented on FLINK-33588:
-
[~zhutong66] could you please write a test for your c
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:42 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:41 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:41 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:40 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:40 PM:
---
RocMarshal created FLINK-33875:
--
Summary: Support slots wait mechanism at DeclarativeSlotPoolBridge
side for Default Scheduler
Key: FLINK-33875
URL: https://issues.apache.org/jira/browse/FLINK-33875
Proj
[
https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33874:
---
Summary: Support resource request wait mechanism at
DefaultDeclarativeSlotPool side for Default Sche
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:36 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33874:
---
Parent: FLINK-31757
Issue Type: Sub-task (was: New Feature)
> Introduce resource request wa
RocMarshal created FLINK-33874:
--
Summary: Introduce resource request wait mechanism at
DefaultDeclarativeSlotPool side for Default Scheduler
Key: FLINK-33874
URL: https://issues.apache.org/jira/browse/FLINK-33874
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798229#comment-17798229
]
Jan Kamieth commented on FLINK-32964:
-
Hi,
we have the same issue in the same setup
[
https://issues.apache.org/jira/browse/FLINK-33873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798220#comment-17798220
]
Martijn Visser commented on FLINK-33873:
[~jinsuichen] I've granted you the nece
[
https://issues.apache.org/jira/browse/FLINK-32949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-32949:
Fix Version/s: 1.19.0
> Allow specifying the ServerSocket port for the collect function when
> accessing
[
https://issues.apache.org/jira/browse/FLINK-32949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-32949.
-
Resolution: Fixed
> Allow specifying the ServerSocket port for the collect function when
> accessing th
[
https://issues.apache.org/jira/browse/FLINK-32949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798219#comment-17798219
]
Jing Ge commented on FLINK-32949:
-
master: e6169cee12d66ce22f7907b8dc947d4e96228b30
> A
JingGe merged PR #23870:
URL: https://github.com/apache/flink/pull/23870
--
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
jnh5y commented on PR #23612:
URL: https://github.com/apache/flink/pull/23612#issuecomment-1860558626
> Hi @jnh5y could you please check if your comments are addressed? Thanks!
Hi @jeyhunkarimov, sorry to be slow to look again. Things are looking good.
@dawidwys would you be willing
jnh5y commented on code in PR #23612:
URL: https://github.com/apache/flink/pull/23612#discussion_r1430168768
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlShowDatabasesConverter.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed
jnh5y commented on code in PR #23612:
URL: https://github.com/apache/flink/pull/23612#discussion_r1430167319
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowDatabasesOperation.java:
##
@@ -20,26 +20,108 @@
import org.apache.flink.annota
1 - 100 of 249 matches
Mail list logo
