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=17798468#comment-17798468
]
Jing Ge commented on FLINK-33588:
-
[~zhutong66] Thanks for the feedback. Could you please add UT or IT?
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
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 @@
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 @@
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 @@
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798442#comment-17798442
]
Tongtong Zhu commented on FLINK-33588:
--
[~jingge] I have tested this change on the local cluster
[
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
[
https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798422#comment-17798422
]
zhilinli commented on FLINK-32346:
--
Currently the documentation and the code already diverge. The
[
https://issues.apache.org/jira/browse/FLINK-32346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798422#comment-17798422
]
zhilinli edited comment on FLINK-32346 at 12/19/23 4:38 AM:
Due to some
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
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
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
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
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=17798417#comment-17798417
]
Jiabao Sun commented on FLINK-33877:
Based on the exception stack trace, it is possible that port
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
[
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)
>
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
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
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=17798413#comment-17798413
]
Wencong Liu commented on FLINK-33502:
-
Sorry for the late reply. I've just identified the issue and
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
[
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
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
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=17798406#comment-17798406
]
xuyang commented on FLINK-33878:
Do you think we should fix it? If yes, I want to take this Jira and fix
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=17798405#comment-17798405
]
xuyang commented on FLINK-33878:
cc [~qingyue]
> Many Keyed Operator extends `TableStreamOperator`
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
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
[
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
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:
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
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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798370#comment-17798370
]
Sergey Nuyanzin commented on FLINK-33531:
-
Merged to 1.18.1 as
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:
[
https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798369#comment-17798369
]
Jim Hughes commented on FLINK-27756:
[
https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798368#comment-17798368
]
Jim Hughes commented on FLINK-27756:
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
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
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
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
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
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
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
[
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
>
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798275#comment-17798275
]
Jing Ge commented on FLINK-33531:
-
let's add it into 1.18.1 release
> Nightly Python fails with NPE at
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
[
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)
[
https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798267#comment-17798267
]
Jiabao Sun commented on FLINK-32850:
Merged master (1.19) via:
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
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
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798178#comment-17798178
]
david radley edited comment on FLINK-33365 at 12/18/23 4:12 PM:
[~Sergey
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798178#comment-17798178
]
david radley edited comment on FLINK-33365 at 12/18/23 4:10 PM:
[~Sergey
[
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
[
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]
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798256#comment-17798256
]
Ahmed Hamdy commented on FLINK-31472:
-
[~Sergey Nuyanzin] I have pushed a PR with the fix, would be
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
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:
[
https://issues.apache.org/jira/browse/FLINK-33862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798251#comment-17798251
]
Prabhu Joseph commented on FLINK-33862:
---
Yes right. Thanks [~martijnvisser].
> Flink Unit Test
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
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
[
https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798240#comment-17798240
]
Jing Ge commented on FLINK-33588:
-
[~zhutong66] could you please write a test for your change?
> Fix
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:42 PM:
---
Hi,
we
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:41 PM:
---
Hi,
we
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:41 PM:
---
Hi,
we
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:40 PM:
---
Hi,
we
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:40 PM:
---
Hi,
we
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798229#comment-17798229
]
Jan Kamieth edited comment on FLINK-32964 at 12/18/23 2:36 PM:
---
Hi,
we
[
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
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=17798229#comment-17798229
]
Jan Kamieth commented on FLINK-32964:
-
Hi,
we have the same issue in the same setup.
Flink 1.17
[
https://issues.apache.org/jira/browse/FLINK-33873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798220#comment-17798220
]
Martijn Visser commented on FLINK-33873:
[~jinsuichen] I've granted you the necessary
[
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
[
https://issues.apache.org/jira/browse/FLINK-32949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798219#comment-17798219
]
Jing Ge commented on FLINK-32949:
-
master: e6169cee12d66ce22f7907b8dc947d4e96228b30
> Allow specifying
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:
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
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 @@
+/*
+ *
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
1 - 100 of 249 matches
Mail list logo
