[
https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818325#comment-17818325
]
Yangze Guo commented on FLINK-34434:
Good catch [~mapohl]. I think the returnedFuture should be
[
https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-34434:
--
Assignee: Yangze Guo
> DefaultSlotStatusSyncer doesn't complete the returned future
>
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818326#comment-17818326
]
Dian Fu commented on FLINK-34202:
-
[~lincoln.86xy] It will randomly select one Python version to test
[
https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34434:
---
Labels: pull-request-available (was: )
> DefaultSlotStatusSyncer doesn't complete the
KarmaGYZ opened a new pull request, #24325:
URL: https://github.com/apache/flink/pull/24325
…ved before allocation success
## What is the purpose of the change
To fix the typo in DefaultSlotStatusSyncer.
## Brief change log
Complete the returnedFuture,
flinkbot commented on PR #24327:
URL: https://github.com/apache/flink/pull/24327#issuecomment-1951615473
## CI report:
* 463196de2af7f16fdb8742e240bf270c4c207bb9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818334#comment-17818334
]
Yangze Guo commented on FLINK-25015:
master: dcb30f934a7953e33d35460414c6ee57cb982ab3
> job name
KarmaGYZ commented on PR #23455:
URL: https://github.com/apache/flink/pull/23455#issuecomment-1951630056
LGTM
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
KarmaGYZ merged PR #23455:
URL: https://github.com/apache/flink/pull/23455
--
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:
wanglijie95 commented on PR #101:
URL:
https://github.com/apache/flink-connector-jdbc/pull/101#issuecomment-1951766110
@MartijnVisser Would you help review this pr? Thanks.
--
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-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818353#comment-17818353
]
junzhong qin commented on FLINK-34261:
--
Close this issue because TaskExecutorManager has been
[ https://issues.apache.org/jira/browse/FLINK-34261 ]
junzhong qin deleted comment on FLINK-34261:
--
was (Author: easonqin):
Close this issue because TaskExecutorManager has been removed from the master
branch.
> When
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin closed FLINK-34261.
Resolution: Fixed
Close this issue because TaskExecutorManager has been removed from the master
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-26050:
-
Assignee: Roman Khachatryan
> Too many small sst files in rocksdb state
flinkbot commented on PR #24326:
URL: https://github.com/apache/flink/pull/24326#issuecomment-1951611530
## CI report:
* 2a689d891e8b40e4caf4df96d6beffa114d0651e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
caodizhou commented on PR #24115:
URL: https://github.com/apache/flink/pull/24115#issuecomment-1951668636
@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
Fang Yong created FLINK-34460:
-
Summary: Jdbc driver get rid of flink-core
Key: FLINK-34460
URL: https://issues.apache.org/jira/browse/FLINK-34460
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818318#comment-17818318
]
lincoln lee commented on FLINK-34202:
-
[~hxb] Thanks for investigating this issue! Regarding the
[
https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818325#comment-17818325
]
Yangze Guo edited comment on FLINK-34434 at 2/19/24 2:33 AM:
-
Good catch
Zakelly commented on PR #24181:
URL: https://github.com/apache/flink/pull/24181#issuecomment-1951593556
@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.
KarmaGYZ opened a new pull request, #24327:
URL: https://github.com/apache/flink/pull/24327
…ved before allocation success
Cherry pick FLINK-34434 to release-1.18
--
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-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-25015:
---
Fix Version/s: 1.20.0
> job name should not always be `collect` submitted by sql client
>
[
https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo resolved FLINK-25015.
Resolution: Fixed
> job name should not always be `collect` submitted by sql client
>
KarmaGYZ opened a new pull request, #24326:
URL: https://github.com/apache/flink/pull/24326
…ved before allocation success
Cherry pick FLINK-34434 to release-1.19
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-34358:
--
Assignee: Lijie Wang
> flink-connector-jdbc nightly fails with "Expecting code to raise a
[
https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34358:
---
Labels: pull-request-available test-stability (was: test-stability)
> flink-connector-jdbc
[
https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818346#comment-17818346
]
Lijie Wang edited comment on FLINK-34358 at 2/19/24 6:15 AM:
-
The test
xintongsong commented on code in PR #22547:
URL: https://github.com/apache/flink/pull/22547#discussion_r1493924976
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java:
##
@@ -285,4 +286,15 @@ private static void
flinkbot commented on PR #24325:
URL: https://github.com/apache/flink/pull/24325#issuecomment-1951607706
## CI report:
* ea75f2c6dedfdebef152e55eb0313a4489f4338e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wanglijie95 opened a new pull request, #101:
URL: https://github.com/apache/flink-connector-jdbc/pull/101
Fix some tests that failed in Flink 1.19, see FLINK-34358 for detailsn
--
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-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-30081:
Assignee: Mingliang Liu
> Local executor can not accept different jvm-overhead.min/max
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-30081:
-
Priority: Major (was: Minor)
> Local executor can not accept different jvm-overhead.min/max
[
https://issues.apache.org/jira/browse/FLINK-34453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34453:
---
Labels: pull-request-available (was: )
> [Benchmark] Add warmup in
fredia commented on code in PR #88:
URL: https://github.com/apache/flink-benchmarks/pull/88#discussion_r1493945319
##
src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkExecutorBase.java:
##
@@ -37,6 +38,7 @@
@State(Scope.Thread)
Zakelly closed pull request #88: [FLINK-34453] Add warmup in
SchedulerBenchmarkExecutorBase
URL: https://github.com/apache/flink-benchmarks/pull/88
--
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
Zakelly commented on PR #88:
URL: https://github.com/apache/flink-benchmarks/pull/88#issuecomment-1951646225
I had a discussion with Zhuzhu and found that the scheduler benchmarks is
aim to measure the code start time. So no warmup should be added. I'm closing
this.
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818345#comment-17818345
]
lincoln lee commented on FLINK-34202:
-
[~dianfu] Yes, the difference is between testing 4 versions
[
https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818346#comment-17818346
]
Lijie Wang commented on FLINK-34358:
The test passes in flink 1.18 but fails in flink 1.19. The root
[
https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818347#comment-17818347
]
Lijie Wang commented on FLINK-34358:
The exception stack in 1.18:
{code:java}
xintongsong commented on code in PR #24163:
URL: https://github.com/apache/flink/pull/24163#discussion_r1494040971
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java:
##
@@ -412,11 +415,9 @@ private void stopPod(String podName) {
hejufang commented on PR #24322:
URL: https://github.com/apache/flink/pull/24322#issuecomment-1951826026
@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-34274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818362#comment-17818362
]
lincoln lee commented on FLINK-34274:
-
1.19:
[
https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818361#comment-17818361
]
lincoln lee commented on FLINK-32006:
-
master:
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818364#comment-17818364
]
lincoln lee commented on FLINK-34202:
-
1.20(master):
flinkbot commented on PR #24324:
URL: https://github.com/apache/flink/pull/24324#issuecomment-1951136417
## CI report:
* 730574e51108e72c2e53ff119cf8dc71a65a05b0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818280#comment-17818280
]
Rui Fan commented on FLINK-34400:
-
Hi [~asardaes] , did you try enable idleness?
I try watermark
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818283#comment-17818283
]
Feifan Wang commented on FLINK-33734:
-
[~roman] :
{quote}Do I understand correctly, that the
[
https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiangyu feng updated FLINK-34452:
-
Description:
Test Suggestion:
# Prepare configuration options:
**
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feifan Wang updated FLINK-33734:
Attachment: flamegraph.control-group.html
Zakelly Lan created FLINK-34456:
---
Summary: Move all checkpoint-related options into
CheckpointingOptions
Key: FLINK-34456
URL: https://issues.apache.org/jira/browse/FLINK-34456
Project: Flink
Zakelly commented on PR #24181:
URL: https://github.com/apache/flink/pull/24181#issuecomment-1951061993
@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-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818266#comment-17818266
]
Rui Fan commented on FLINK-34252:
-
Thanks [~dchristle] for the report and fix, and thanks
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34252:
Fix Version/s: 1.19.0
1.18.2
1.20.0
> WatermarkAssignerOperator
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818266#comment-17818266
]
Rui Fan edited comment on FLINK-34252 at 2/18/24 10:13 AM:
---
Sorry for the late
flinkbot commented on PR #24323:
URL: https://github.com/apache/flink/pull/24323#issuecomment-1951078851
## CI report:
* 5b571eff191353c112f86f2c4b217ff982f7f75f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34202:
---
Labels: pull-request-available test-stability (was: test-stability)
> python tests take
HuangXingBo commented on PR #24321:
URL: https://github.com/apache/flink/pull/24321#issuecomment-1951115536
https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=2219=logs=fba17979-6d2e-591d-72f1-97cf42797c11=727942b6-6137-54f7-1ef9-e66e706ea068
- random select python 3.10
[
https://issues.apache.org/jira/browse/FLINK-34458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34458:
---
Labels: pull-request-available (was: )
> Rename options for Generalized incremental
Zakelly opened a new pull request, #24324:
URL: https://github.com/apache/flink/pull/24324
## What is the purpose of the change
As one part of FLIP-406, this PR relocate the options for changelog under
the prefix `state.changelog`.
## Brief change log
- Rename the
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818269#comment-17818269
]
Xingbo Huang commented on FLINK-34202:
--
I reviewed all the stages where timeouts occurred and found
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818251#comment-17818251
]
Roman Khachatryan commented on FLINK-33734:
---
As for
{quote}IIUC, ByteStreamStateHandle in each
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818255#comment-17818255
]
Zakelly Lan commented on FLINK-33734:
-
[~Feifan Wang] Sorry for the late reply as I was on vacation
Zakelly Lan created FLINK-34458:
---
Summary: Rename options for Generalized incremental checkpoints
(changelog)
Key: FLINK-34458
URL: https://issues.apache.org/jira/browse/FLINK-34458
Project: Flink
Zakelly commented on PR #24181:
URL: https://github.com/apache/flink/pull/24181#issuecomment-1951057156
The CI failure is not related with this PR since I only add comments based
on last CI green.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-34455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34455:
---
Labels: pull-request-available (was: )
> Move RestoreMode from flink-runtime to flink-core
Zakelly commented on PR #24320:
URL: https://github.com/apache/flink/pull/24320#issuecomment-1951058432
@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.
hejufang opened a new pull request, #24322:
URL: https://github.com/apache/flink/pull/24322
## What is the purpose of the change
Add sub-task level RocksDB file count metrics.
## Brief change log
Get RocksDB file count of each level via RocksDB Property, and
[
https://issues.apache.org/jira/browse/FLINK-34334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34334:
---
Labels: pull-request-available (was: )
> Add sub-task level RocksDB file count metric
>
Zakelly commented on PR #24320:
URL: https://github.com/apache/flink/pull/24320#issuecomment-1951061127
@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.
flinkbot commented on PR #24322:
URL: https://github.com/apache/flink/pull/24322#issuecomment-1951070593
## CI report:
* 2b3519ac9c6810720536503e2eb777d8bc566a30 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #24323:
URL: https://github.com/apache/flink/pull/24323
## What is the purpose of the change
As one part of FLIP-406, this PR relocate the options for latency tracking
under the prefix `state.latency-track`.
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-34457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34457:
---
Labels: pull-request-available (was: )
> Rename options for latency tracking
>
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34252:
---
Assignee: David Christle
> WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under
>
Zakelly Lan created FLINK-34457:
---
Summary: Rename options for latency tracking
Key: FLINK-34457
URL: https://issues.apache.org/jira/browse/FLINK-34457
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815475#comment-17815475
]
Rui Fan edited comment on FLINK-33960 at 2/18/24 9:38 AM:
--
Merged to:
[
https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33960.
-
Resolution: Fixed
> Adaptive Scheduler doesn't respect the lowerBound for tasks
>
swuferhong commented on code in PR #24271:
URL: https://github.com/apache/flink/pull/24271#discussion_r1493723623
##
docs/setup_docs.sh:
##
@@ -36,24 +36,34 @@ function integrate_connector_docs {
}
+SKIP_INTEGRATE_CONNECTOR_DOCS=false
+for arg in "$@"; do
+ if [ "$arg" ==
gyfora commented on code in PR #774:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/774#discussion_r1493771207
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -379,22 +484,75 @@ public static double getAverage(
gyfora commented on code in PR #774:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/774#discussion_r1493771147
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java:
##
@@ -223,128 +203,65 @@ public static void
Zakelly commented on PR #24181:
URL: https://github.com/apache/flink/pull/24181#issuecomment-1951336353
@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.
Jeyhun Karimov created FLINK-34459:
--
Summary: Results column names should match SELECT clause
expression names
Key: FLINK-34459
URL: https://issues.apache.org/jira/browse/FLINK-34459
Project: Flink
xiangyuf commented on PR #23455:
URL: https://github.com/apache/flink/pull/23455#issuecomment-1951356537
Hi @libenchao @KarmaGYZ , can you kindly help review this when you have
time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-34391.
---
Resolution: Fixed
[~xiangyu0xf] Thanks for the updating!
> Release Testing Instructions: Verify
[
https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-34399:
---
Assignee: Ferenc Csaky
> Release Testing: Verify FLINK-33644 Make QueryOperations SQL
[
https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818287#comment-17818287
]
lincoln lee commented on FLINK-34399:
-
[~ferenc-csaky] Thanks for taking this! Assigned to you.
>
[
https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-34459:
---
Description:
When printing {{SQL SELECT}} results, Flink will output generated expression
86 matches
Mail list logo