[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939350#comment-17939350
]
Ao Li edited comment on KAFKA-17354 at 3/28/25 11:41 PM:
-
We rec
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939350#comment-17939350
]
Ao Li edited comment on KAFKA-17354 at 3/28/25 11:49 PM:
-
We rec
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939350#comment-17939350
]
Ao Li commented on KAFKA-17354:
---
We recently released the Fray Gradle plugin, which allows
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939349#comment-17939349
]
Ao Li commented on KAFKA-17354:
---
Yes, the bug still appears. Here is the log I got from th
[
https://issues.apache.org/jira/browse/KAFKA-17379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17379:
--
Description:
I saw a failing test: `KafkaStreamsTest::shouldNotAddThreadWhenError`
{code}
Stream-client test-
[
https://issues.apache.org/jira/browse/KAFKA-17162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914288#comment-17914288
]
Ao Li commented on KAFKA-17162:
---
Yes, I can confirm that adding `join` in the test method
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914282#comment-17914282
]
Ao Li commented on KAFKA-17114:
---
[~mjsax] Thanks for confirming this!
Sorry for not catch
[
https://issues.apache.org/jira/browse/KAFKA-17162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913543#comment-17913543
]
Ao Li commented on KAFKA-17162:
---
Thanks for proposing the fix. I've tried to download a cl
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913541#comment-17913541
]
Ao Li commented on KAFKA-17114:
---
Yes, I can still see the failure. Increasing the sleep du
[
https://issues.apache.org/jira/browse/KAFKA-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910687#comment-17910687
]
Ao Li commented on KAFKA-18418:
---
[~mjsax] Thanks for your comments! I've submitted a new P
[
https://issues.apache.org/jira/browse/KAFKA-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910404#comment-17910404
]
Ao Li edited comment on KAFKA-18418 at 1/6/25 9:03 PM:
---
Actually,
[
https://issues.apache.org/jira/browse/KAFKA-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910404#comment-17910404
]
Ao Li edited comment on KAFKA-18418 at 1/6/25 9:03 PM:
---
Actually,
[
https://issues.apache.org/jira/browse/KAFKA-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910404#comment-17910404
]
Ao Li commented on KAFKA-18418:
---
Actually, many tests fail because of this:
KafkaStreamsT
[
https://issues.apache.org/jira/browse/KAFKA-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-18418:
--
Description:
KafkaStreams does not synchronize with CloseThread after shutdown thread starts
at line
https:/
Ao Li created KAFKA-18418:
-
Summary: Flaky test in
KafkaStreamsTest::shouldThrowOnCleanupWhileShuttingDownStreamClosedWithCloseOptionLeaveGroupFalse
Key: KAFKA-18418
URL: https://issues.apache.org/jira/browse/KAFKA-18418
[
https://issues.apache.org/jira/browse/KAFKA-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reassigned KAFKA-18418:
-
Assignee: Ao Li
> Flaky test in
> KafkaStreamsTest::shouldThrowOnCleanupWhileShuttingDownStreamClosedW
[
https://issues.apache.org/jira/browse/KAFKA-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li resolved KAFKA-17113.
---
Resolution: Fixed
The CDL has fixed this concurrency issue.
> Flaky Test in
> GlobalStreamThreadTest#shou
[
https://issues.apache.org/jira/browse/KAFKA-17929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897759#comment-17897759
]
Ao Li commented on KAFKA-17929:
---
Yes, this issue exists across all Java versions. Apologie
[
https://issues.apache.org/jira/browse/KAFKA-17946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895807#comment-17895807
]
Ao Li commented on KAFKA-17946:
---
Multiple tests can fail because of this. See branch
http
Ao Li created KAFKA-17946:
-
Summary: Flaky test
DeafultStateUpdaterTest::shouldResumeStandbyTask due to concurrency issue
Key: KAFKA-17946
URL: https://issues.apache.org/jira/browse/KAFKA-17946
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-17946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17946:
--
Component/s: streams
> Flaky test DeafultStateUpdaterTest::shouldResumeStandbyTask due to
> concurrency issue
[
https://issues.apache.org/jira/browse/KAFKA-17929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17929:
--
Summary: `awaitProcessableTasks` is not safe in the presence of spurious
wakeups. (was: `awaitProcessableTask
Ao Li created KAFKA-17929:
-
Summary: `awaitProcessableTasks` is not safe in the presence of
spurious wakeups.”
Key: KAFKA-17929
URL: https://issues.apache.org/jira/browse/KAFKA-17929
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-17929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17929:
--
Component/s: streams
> `awaitProcessableTasks` is not safe in the presence of spurious wakeups.”
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reopened KAFKA-17114:
---
This bug is not resolved. Please check the fork to reproduce the failure:
https://github.com/aoli-al/kafka/tre
[
https://issues.apache.org/jira/browse/KAFKA-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li closed KAFKA-17371.
-
> Flaky test in DefaultTaskExecutorTest.shouldUnassignTaskWhenRequired
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li closed KAFKA-17112.
-
> StreamThread shutdown calls completeShutdown only in CREATED state
> -
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li closed KAFKA-17112.
-
> StreamThread shutdown calls completeShutdown only in CREATED state
> -
[
https://issues.apache.org/jira/browse/KAFKA-17402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reopened KAFKA-17402:
---
I don't think this bug is fixed.
I've rebased the branch to the current truck and can still reproduce the
fai
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876540#comment-17876540
]
Ao Li commented on KAFKA-17354:
---
[~anton.liauchuk] Yes, I'm able to reproduce the failure.
Ao Li created KAFKA-17402:
-
Summary: Test failure:
DefaultStateUpdaterTest.shouldGetTasksFromRestoredActiveTasks expected: <2>
but was: <3>
Key: KAFKA-17402
URL: https://issues.apache.org/jira/browse/KAFKA-17402
[
https://issues.apache.org/jira/browse/KAFKA-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reassigned KAFKA-17394:
-
Assignee: TengYao Chi
> Flaky test in DefaultTaskExecutorTest.shouldSetUncaughtStreamsException
> -
[
https://issues.apache.org/jira/browse/KAFKA-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875549#comment-17875549
]
Ao Li commented on KAFKA-17394:
---
Since there are multiple tests related to this. We may co
Ao Li created KAFKA-17394:
-
Summary: Flaky test in
DefaultTaskExecutorTest.shouldSetUncaughtStreamsException
Key: KAFKA-17394
URL: https://issues.apache.org/jira/browse/KAFKA-17394
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-17379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875246#comment-17875246
]
Ao Li commented on KAFKA-17379:
---
Done! Thanks for taking care of this [~frankvicky]
> Kaf
[
https://issues.apache.org/jira/browse/KAFKA-17379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reassigned KAFKA-17379:
-
Assignee: Ao Li
> KafkaStreams: Unexpected state transition from ERROR to PENDING_SHUTDOWN
> --
[
https://issues.apache.org/jira/browse/KAFKA-17379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reassigned KAFKA-17379:
-
Assignee: TengYao Chi (was: Ao Li)
> KafkaStreams: Unexpected state transition from ERROR to PENDING_S
Ao Li created KAFKA-17379:
-
Summary: KafkaStreams: Unexpected state transition from ERROR to
PENDING_SHUTDOWN
Key: KAFKA-17379
URL: https://issues.apache.org/jira/browse/KAFKA-17379
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875196#comment-17875196
]
Ao Li commented on KAFKA-17113:
---
This patch helps to reproduce the failure deterministical
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875194#comment-17875194
]
Ao Li commented on KAFKA-17114:
---
Please use this branch to reproduce the failure:
https:/
[
https://issues.apache.org/jira/browse/KAFKA-17162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875192#comment-17875192
]
Ao Li commented on KAFKA-17162:
---
Please follow this branch https://github.com/aoli-al/kafk
[
https://issues.apache.org/jira/browse/KAFKA-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875170#comment-17875170
]
Ao Li edited comment on KAFKA-17371 at 8/20/24 12:35 PM:
-
[~fran
[
https://issues.apache.org/jira/browse/KAFKA-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875170#comment-17875170
]
Ao Li commented on KAFKA-17371:
---
[~frankvicky] Thanks for taking care of this! Making both
[
https://issues.apache.org/jira/browse/KAFKA-17371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reassigned KAFKA-17371:
-
Assignee: TengYao Chi
> Flaky test in DefaultTaskExecutorTest.shouldUnassignTaskWhenRequired
>
Ao Li created KAFKA-17371:
-
Summary: Flaky test in
DefaultTaskExecutorTest.shouldUnassignTaskWhenRequired
Key: KAFKA-17371
URL: https://issues.apache.org/jira/browse/KAFKA-17371
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li reassigned KAFKA-17354:
-
Assignee: Anton Liauchuk
> StreamThread::setState race condition causes java.lang.RuntimeException:
>
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874288#comment-17874288
]
Ao Li commented on KAFKA-17354:
---
Assigned! Thanks for the quick response.
> StreamThread
Ao Li created KAFKA-17354:
-
Summary: StreamThread::setState race condition causes
java.lang.RuntimeException: State mismatch PENDING_SHUTDOWN different from
STARTING
Key: KAFKA-17354
URL: https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868965#comment-17868965
]
Ao Li commented on KAFKA-17112:
---
Hi [~cadonna], I've submitted a patch. Could you please t
[
https://issues.apache.org/jira/browse/KAFKA-17162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17162:
--
Description:
The `DefaultTaskManagerTest#shouldReturnFromAwaitOnInterruption` will fail with
the following pa
Ao Li created KAFKA-17162:
-
Summary: DefaultTaskManagerTest may leak AwaitingRunnable thread
Key: KAFKA-17162
URL: https://issues.apache.org/jira/browse/KAFKA-17162
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865693#comment-17865693
]
Ao Li commented on KAFKA-17112:
---
[~cadonna]Thanks for your reply! I've tried moving `state
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865569#comment-17865569
]
Ao Li commented on KAFKA-17112:
---
[~cadonna] Aren't stateUpdater and processingThread expec
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865080#comment-17865080
]
Ao Li commented on KAFKA-17112:
---
Yes, I'm happy to submit a patch. I'm thinking of two pot
[
https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17112:
--
Component/s: unit tests
> StreamThread shutdown calls completeShutdown only in CREATED state
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17114:
--
Affects Version/s: 3.9.0
> DefaultStateUpdater::handleRuntimeException should update isRunning before
> calli
[
https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17114:
--
Component/s: streams
Description:
I saw a flaky test in
DefaultStateUpdaterTest::shouldThrowIfAddingStand
Ao Li created KAFKA-17114:
-
Summary: handleRuntimeException
Key: KAFKA-17114
URL: https://issues.apache.org/jira/browse/KAFKA-17114
Project: Kafka
Issue Type: Bug
Reporter: Ao Li
--
[
https://issues.apache.org/jira/browse/KAFKA-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17113:
--
Affects Version/s: 3.9.0
> Flaky Test in
> GlobalStreamThreadTest#shouldThrowStreamsExceptionOnStartupIfExcep
[
https://issues.apache.org/jira/browse/KAFKA-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17113:
--
Description:
The `shouldThrowStreamsExceptionOnStartupIfExceptionOccurred` test expects `
globalStreamThread.s
[
https://issues.apache.org/jira/browse/KAFKA-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17113:
--
Description:
The `shouldThrowStreamsExceptionOnStartupIfExceptionOccurred` test expects `
globalStreamThread.s
Ao Li created KAFKA-17113:
-
Summary: Flaky Test in
GlobalStreamThreadTest#shouldThrowStreamsExceptionOnStartupIfExceptionOccurred
Key: KAFKA-17113
URL: https://issues.apache.org/jira/browse/KAFKA-17113
Projec
Ao Li created KAFKA-17112:
-
Summary: StreamThread shutdown calls completeShutdown only in
CREATED state
Key: KAFKA-17112
URL: https://issues.apache.org/jira/browse/KAFKA-17112
Project: Kafka
Issue T
63 matches
Mail list logo
