reswqa commented on PR #23013:
URL: https://github.com/apache/flink/pull/23013#issuecomment-1702274990
@MartijnVisser Yes, sorry for the delay. I just waiting for the 1.18 branch
cut-off before as this is for 1.19. It's time to rebase and merge this.
--
This is an automated message from t
[
https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-20886:
---
Assignee: Zakelly Lan
> Add the option to get a threaddump on checkpoint timeouts
> ---
[
https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761201#comment-17761201
]
Zakelly Lan commented on FLINK-20886:
-
Hi guys,
I noticed this issue and also found
[
https://issues.apache.org/jira/browse/FLINK-32620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-32620:
---
Affects Version/s: 1.19.0
(was: 1.18.0)
> Migrate DiscardingSink to sinkv
hackergin opened a new pull request, #23346:
URL: https://github.com/apache/flink/pull/23346
cherry-pick FLINK-32475
--
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 uns
flinkbot commented on PR #23346:
URL: https://github.com/apache/flink/pull/23346#issuecomment-1702291703
## CI report:
* e005ab43fdf0c7800f0e979e6b8083e7dc93e848 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761205#comment-17761205
]
Sergey Nuyanzin commented on FLINK-33010:
-
I submitted PR btw
> NPE when using
[
https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33010:
Labels: pull-request-available (was: )
> NPE when using GREATEST() in Flink SQL
> ---
swuferhong commented on PR #23338:
URL: https://github.com/apache/flink/pull/23338#issuecomment-1702299505
@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-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32570:
--
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Deprecate API t
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32570:
--
Affects Version/s: 1.19.0
> Deprecate API that uses Flink's Time implementation (related to FL
[
https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32570:
--
Fix Version/s: (was: 1.18.0)
> Deprecate API that uses Flink's Time implementation (relate
[
https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761215#comment-17761215
]
Matthias Pohl commented on FLINK-33014:
---
Hi [~zhuyinjun] do you use a LoadBalancer
[
https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33014:
--
Description:
The Flink cluster was deployed using the Docker image of Flink 1.17.1 java8.
A
[
https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33014:
--
Component/s: Runtime / Coordination
> flink jobmanager raise java.io.IOException: Connection
[
https://issues.apache.org/jira/browse/FLINK-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761218#comment-17761218
]
Yangyang ZHANG commented on FLINK-9631:
---
[~hangxiang] I would like to fix this issu
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761219#comment-17761219
]
Jane Chan commented on FLINK-31788:
---
Sorry for just noticing this issue now. This prob
[
https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-32785:
---
Assignee: Sergey Nuyanzin (was: Sergey Nuyanzin)
> Release Testing: Verify FLIP-29
[
https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761222#comment-17761222
]
Sergey Nuyanzin commented on FLINK-32785:
-
Please let me know if anything else i
gfmio opened a new pull request, #337:
URL: https://github.com/apache/flink-statefun/pull/337
This PR adds a `maxRetries` option that limits the amount of times a request
will be attempted before the request is dropped. When set to the default value
of -1, batches will be retried indefinite
[
https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761229#comment-17761229
]
zhu commented on FLINK-33014:
-
Hi [~mapohl] There is no LoadBalancer configured on my k8s s
xiangyuf commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1312731126
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -359,24 +425,45 @@ private void tryFu
RanJinh commented on PR #23000:
URL: https://github.com/apache/flink/pull/23000#issuecomment-1702377438
@lindong28 could you please take another 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
xiangyuf commented on PR #23328:
URL: https://github.com/apache/flink/pull/23328#issuecomment-1702398434
Hi @FangYongs @KarmaGYZ this is a joint work between @zoudan and me. Pls
add this into the commit message if it has passed the review.
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761243#comment-17761243
]
Matthias Pohl commented on FLINK-33014:
---
[~wangyang0918] Did you experience someth
xintongsong commented on code in PR #672:
URL: https://github.com/apache/flink-web/pull/672#discussion_r1312716081
##
docs/content/roadmap.md:
##
@@ -25,19 +25,14 @@ under the License.
# Roadmap
-**Preamble:** This roadmap means to provide user and contributors with a
high
[
https://issues.apache.org/jira/browse/FLINK-32994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32994:
--
Fix Version/s: (was: 1.19.0)
> LeaderElectionDriver.toString() is not implemented
> --
KarmaGYZ commented on PR #23328:
URL: https://github.com/apache/flink/pull/23328#issuecomment-1702431802
> Hi @FangYongs @KarmaGYZ @libenchao this is a joint work between @zoudan
and me. Pls add this into the commit message if it has passed the review.
You can directly add him. Pls ta
XComp merged PR #23271:
URL: https://github.com/apache/flink/pull/23271
--
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 merged PR #23278:
URL: https://github.com/apache/flink/pull/23278
--
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 merged PR #23280:
URL: https://github.com/apache/flink/pull/23280
--
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 merged PR #23279:
URL: https://github.com/apache/flink/pull/23279
--
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.
[
https://issues.apache.org/jira/browse/FLINK-32869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32869:
--
Fix Version/s: (was: 1.19.0)
> Flink Kubernetes related tests failed to run on aarch64
> -
[
https://issues.apache.org/jira/browse/FLINK-32909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32909.
---
Fix Version/s: 1.18.0
1.16.3
1.17.2
Resolution:
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761246#comment-17761246
]
Jinzhong Li commented on FLINK-14032:
-
hi, [~yunta] , are you still working on this
aajisaka commented on PR #19233:
URL: https://github.com/apache/flink/pull/19233#issuecomment-1702446504
Thank you @gaborgsomogyi!
--
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
[
https://issues.apache.org/jira/browse/FLINK-23632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761249#comment-17761249
]
Akira Ajisaka commented on FLINK-23632:
---
Hi [~gaborgsomogyi] would you set the ass
[
https://issues.apache.org/jira/browse/FLINK-23632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-23632:
-
Assignee: Akira Ajisaka (was: wuguihu)
> [DOCS]The link to setup-Pyflink-virtual-env.s
[
https://issues.apache.org/jira/browse/FLINK-23632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761251#comment-17761251
]
Gabor Somogyi commented on FLINK-23632:
---
Done
> [DOCS]The link to setup-Pyflink-v
lindong28 commented on code in PR #23331:
URL: https://github.com/apache/flink/pull/23331#discussion_r1312867815
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java:
##
@@ -129,40 +131,56 @@ public void testRestoreAfterSome
lindong28 merged PR #23331:
URL: https://github.com/apache/flink/pull/23331
--
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-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761270#comment-17761270
]
Dong Lin commented on FLINK-32996:
--
Merged to apache/flink master branch 6608d873db5fd9
lindong28 closed pull request #23332: [FLINK-32996][Tests] Fix the
CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails
URL: https://github.com/apache/flink/pull/23332
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-32996:
-
Fix Version/s: 1.18.0
> CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished
> fai
[
https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-32996.
Resolution: Fixed
> CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished
> fails on
TanYuxin-tyx commented on code in PR #23255:
URL: https://github.com/apache/flink/pull/23255#discussion_r1312873829
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java:
##
@@ -78,4 +91,165 @@ long getPriority(
TanYuxin-tyx commented on code in PR #23255:
URL: https://github.com/apache/flink/pull/23255#discussion_r1312875141
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java:
##
@@ -99,40 +115,96 @@ pub
TanYuxin-tyx commented on code in PR #23255:
URL: https://github.com/apache/flink/pull/23255#discussion_r1312876023
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java:
##
@@ -99,40 +115,96 @@ pub
TanYuxin-tyx commented on code in PR #23255:
URL: https://github.com/apache/flink/pull/23255#discussion_r1312876410
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java:
##
@@ -204,6 +279,159 @@ pr
TanYuxin-tyx commented on code in PR #23255:
URL: https://github.com/apache/flink/pull/23255#discussion_r1312876903
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskIOScheduler.java:
##
@@ -338,6 +338,8 @@ private class Sch
TanYuxin-tyx commented on code in PR #23255:
URL: https://github.com/apache/flink/pull/23255#discussion_r1312877483
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskIOScheduler.java:
##
@@ -399,8 +405,48 @@ private void pre
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761284#comment-17761284
]
Sergey Nuyanzin commented on FLINK-26644:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761285#comment-17761285
]
Sergey Nuyanzin commented on FLINK-32988:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761286#comment-17761286
]
Sergey Nuyanzin commented on FLINK-32006:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-26644:
Affects Version/s: 1.19.0
> python
> StreamExecutionEnvironmentTests.test_generate_stream
[
https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32006:
Affects Version/s: 1.19.0
> AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrd
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-14032:
-
Priority: Major (was: Minor)
> Make the cache size of RocksDBPriorityQueueSetFactory configurable
> ---
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-14032:
Assignee: Jinzhong Li
> Make the cache size of RocksDBPriorityQueueSetFactory configurable
>
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761288#comment-17761288
]
Yun Tang commented on FLINK-14032:
--
[~lijinzhong] already assigned to you.
> Make the
[
https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761292#comment-17761292
]
Yun Tang commented on FLINK-20886:
--
[~Zakelly] If the task cannot receive the checkpoin
Myasuka commented on code in PR #14611:
URL: https://github.com/apache/flink/pull/14611#discussion_r1312966645
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java:
##
@@ -30,6 +30,11 @@
/**
* A keyed state backend provides methods for managing
[
https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761316#comment-17761316
]
Jörn Kottmann commented on FLINK-26948:
---
Sorry for the delay, I will try to get th
[
https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761317#comment-17761317
]
Jörn Kottmann commented on FLINK-27146:
---
The PR is available and is waiting for a
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reopened FLINK-32523:
-
> NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout
> on AZP
> -
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-32523:
Fix Version/s: (was: 1.16.3)
> NotifyCheckpointAbortedITCase.testNotifyCheckpointAbort
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761319#comment-17761319
]
Sergey Nuyanzin commented on FLINK-32523:
-
I reopen this since it is reproduced
[
https://issues.apache.org/jira/browse/FLINK-32571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32571:
---
Fix Version/s: hbase-3.0.1
(was: hbase-3.0.0)
> Prebuild HBase testin
[
https://issues.apache.org/jira/browse/FLINK-28013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28013:
--
Assignee: He Wang
> java.lang.ClassNotFoundException:
> org.apache.flink.hbase.shade
gaborgsomogyi commented on PR #21788:
URL: https://github.com/apache/flink/pull/21788#issuecomment-1702976674
@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 comm
gaborgsomogyi commented on PR #21788:
URL: https://github.com/apache/flink/pull/21788#issuecomment-1702977545
Unless there are objections + azure is passing I'm intended to merge this
tomorrow.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
wuchong commented on PR #672:
URL: https://github.com/apache/flink-web/pull/672#issuecomment-1702977949
Thank you @xintongsong , I will merge it.
--
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
wuchong merged PR #672:
URL: https://github.com/apache/flink-web/pull/672
--
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.apach
darenwkt opened a new pull request, #662:
URL: https://github.com/apache/flink-kubernetes-operator/pull/662
## What is the purpose of the change
Refactor code to use KubernetesClient from JOSDK Context
## Brief change log
KubernetesClient is passed from josdkC
Zakelly opened a new pull request, #23347:
URL: https://github.com/apache/flink/pull/23347
## What is the purpose of the change
The thread dump of TM is very useful to investigate the reason why
checkpoint happens to timeout. This PR make it possible for TM to print thread
dump to l
flinkbot commented on PR #23347:
URL: https://github.com/apache/flink/pull/23347#issuecomment-1703101331
## CI report:
* 6b832dd160c87d252c29980964adecf96cbb54ae UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyi Yan updated FLINK-29855:
--
Affects Version/s: 1.17.0
1.18.0
> UDF randomly processed input data twice
> -
[
https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761373#comment-17761373
]
padavan commented on FLINK-31958:
-
up
> Table to DataStream allow partial fields
>
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-31757:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761421#comment-17761421
]
haiqingchen commented on FLINK-30519:
-
[~gyfora] sorry, I'm not working on this righ
[
https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761442#comment-17761442
]
Arseniy Tashoyan commented on FLINK-30530:
--
I would say that default config is
80 matches
Mail list logo