Sagar Rao created KAFKA-16056:
-
Summary: Worker poll timeout expiry can lead to Duplicate task
assignments.
Key: KAFKA-16056
URL: https://issues.apache.org/jira/browse/KAFKA-16056
Project: Kafka
sciclon2 commented on code in PR #15030:
URL: https://github.com/apache/kafka/pull/15030#discussion_r1437137364
##
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java:
##
@@ -99,8 +99,12 @@ static void run(Duration timeoutMs, String... args) throws
Exception
Phuc-Hong-Tran commented on PR #15020:
URL: https://github.com/apache/kafka/pull/15020#issuecomment-1870808021
@philipnee @kirktrue, Please take a look if you guys have some free time.
Thanks in advance.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-15948.
Assignee: Philip Nee (was: Phuc Hong Tran)
Resolution: Fixed
> Refactor AsyncKafkaConsumer
[
https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phuc Hong Tran reassigned KAFKA-15948:
--
Assignee: Phuc Hong Tran
> Refactor AsyncKafkaConsumer shutdown
>
github-actions[bot] commented on PR #14454:
URL: https://github.com/apache/kafka/pull/14454#issuecomment-1870790976
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
github-actions[bot] commented on PR #14345:
URL: https://github.com/apache/kafka/pull/14345#issuecomment-1870791020
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437350376
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler =
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437350213
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2639,59 +2639,65 @@ class ReplicaManagerTest {
time = time,
scheduler =
satishd commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437344252
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -167,7 +167,7 @@ class ReplicaManagerTest {
.foreach(checkpointFile =>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800911#comment-17800911
]
Justine Olshan commented on KAFKA-16052:
What do we think about lowering the number of sequences
satishd commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437341409
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler =
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800909#comment-17800909
]
Justine Olshan edited comment on KAFKA-16052 at 12/28/23 2:35 AM:
--
So I
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800909#comment-17800909
]
Justine Olshan commented on KAFKA-16052:
So I realized that every test runs thousands of
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800903#comment-17800903
]
Justine Olshan edited comment on KAFKA-16052 at 12/28/23 2:05 AM:
--
It
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800903#comment-17800903
]
Justine Olshan commented on KAFKA-16052:
It looks like the method that is actually being called
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800902#comment-17800902
]
Justine Olshan commented on KAFKA-16052:
Thanks Divij. This might be a few things then since the
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800900#comment-17800900
]
Ritika Reddy edited comment on KAFKA-15997 at 12/28/23 1:41 AM:
Hey,
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800901#comment-17800901
]
Ritika Reddy commented on KAFKA-15997:
--
In case of the first assignment, I have written a test for
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800900#comment-17800900
]
Ritika Reddy edited comment on KAFKA-15997 at 12/28/23 1:39 AM:
Hey,
[
https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800900#comment-17800900
]
Ritika Reddy commented on KAFKA-15997:
--
Hey, from what I understand you are trying to test the
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800893#comment-17800893
]
Divij Vaidya edited comment on KAFKA-16052 at 12/27/23 11:23 PM:
-
Also,
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800893#comment-17800893
]
Divij Vaidya commented on KAFKA-16052:
--
Also, when we look at what is inside the
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-28 at 00.18.56.png
> OOM in Kafka test suite
>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800892#comment-17800892
]
Divij Vaidya edited comment on KAFKA-16052 at 12/27/23 11:19 PM:
-
I
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800892#comment-17800892
]
Divij Vaidya commented on KAFKA-16052:
--
I don't think that clearing the mocks is helping here. I
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-28 at 00.13.06.png
> OOM in Kafka test suite
>
Kohei Nozaki created KAFKA-16055:
Summary: Thread unsafe use of HashMap stored in
QueryableStoreProvider#storeProviders
Key: KAFKA-16055
URL: https://issues.apache.org/jira/browse/KAFKA-16055
jolshan commented on PR #15066:
URL: https://github.com/apache/kafka/pull/15066#issuecomment-1870661247
@afshing -- can you link the commit that moved the code in your description?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mumrah opened a new pull request, #15082:
URL: https://github.com/apache/kafka/pull/15082
(no comment)
--
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,
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800880#comment-17800880
]
Justine Olshan commented on KAFKA-16052:
There are only four tests in the group coordinator
jolshan opened a new pull request, #15081:
URL: https://github.com/apache/kafka/pull/15081
(no comment)
--
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,
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800877#comment-17800877
]
Justine Olshan commented on KAFKA-16052:
Ah – good point [~ijuma]. I will look into that as
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800875#comment-17800875
]
Ismael Juma commented on KAFKA-16052:
-
It can be done via Mockito.framework().clearInlineMocks().
>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800874#comment-17800874
]
Ismael Juma commented on KAFKA-16052:
-
Have you tried clearing the mocks during tearDown?
> OOM in
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800865#comment-17800865
]
Justine Olshan commented on KAFKA-16052:
Taking a look at removing the mock as well. There are
[
https://issues.apache.org/jira/browse/KAFKA-16045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reassigned KAFKA-16045:
Assignee: David Arthur
> ZkMigrationIntegrationTest.testMigrateTopicDeletion flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800855#comment-17800855
]
Justine Olshan edited comment on KAFKA-16052 at 12/27/23 7:20 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800855#comment-17800855
]
Justine Olshan edited comment on KAFKA-16052 at 12/27/23 7:19 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800855#comment-17800855
]
Justine Olshan commented on KAFKA-16052:
Doing a quick scan at the InterceptedInvocations, I see
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800853#comment-17800853
]
Divij Vaidya commented on KAFKA-16052:
--
Yes Justine, that is my current line of thought as well.
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800852#comment-17800852
]
Justine Olshan commented on KAFKA-16052:
I can also take a look at the heap dump if that is
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800851#comment-17800851
]
Justine Olshan commented on KAFKA-16052:
Thanks Divij for the digging. These tests share the
gharris1727 commented on code in PR #15078:
URL: https://github.com/apache/kafka/pull/15078#discussion_r1437200184
##
clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java:
##
@@ -82,9 +86,10 @@ InitProducerIdRequest.Builder
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800845#comment-17800845
]
Ron Dagostino commented on KAFKA-15495:
---
Thanks, [~jsancio]. I've updated the title and
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800833#comment-17800833
]
Christo Lolov commented on KAFKA-14132:
---
Heya [~enether], thanks for checking in on this one! I
[
https://issues.apache.org/jira/browse/KAFKA-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800832#comment-17800832
]
Christo Lolov commented on KAFKA-15147:
---
Heya [~enether]! I believe all the work that we wanted to
jolshan commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437157116
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2639,59 +2639,65 @@ class ReplicaManagerTest {
time = time,
scheduler =
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800828#comment-17800828
]
Divij Vaidya commented on KAFKA-16052:
--
Digging into the new heap dump after disabling
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 17.44.09.png
> OOM in Kafka test suite
>
sciclon2 commented on code in PR #15030:
URL: https://github.com/apache/kafka/pull/15030#discussion_r1437137364
##
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java:
##
@@ -99,8 +99,12 @@ static void run(Duration timeoutMs, String... args) throws
Exception
sciclon2 commented on code in PR #15030:
URL: https://github.com/apache/kafka/pull/15030#discussion_r1437137364
##
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java:
##
@@ -99,8 +99,12 @@ static void run(Duration timeoutMs, String... args) throws
Exception
[
https://issues.apache.org/jira/browse/KAFKA-16043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Afshin Moazami reassigned KAFKA-16043:
--
Assignee: Afshin Moazami
> Add Quota configuration for topics
>
[
https://issues.apache.org/jira/browse/KAFKA-16044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Afshin Moazami reassigned KAFKA-16044:
--
Assignee: Afshin Moazami
> Throttling using Topic Partition Quota
>
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Description:
Assume a topic-partition has just a single leader replica in the ISR. Assume
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 2.2.1
2.3.0
2.1.1
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 2.7.2
2.6.3
3.1.0
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 3.2.1
3.1.2
3.0.2
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Affects Version/s: 3.6.1
3.5.2
3.5.0
[
https://issues.apache.org/jira/browse/KAFKA-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino updated KAFKA-15495:
--
Summary: Partition truncated when the only ISR member restarts with an
empty disk (was:
[
https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800815#comment-17800815
]
Octavian Ciubotaru commented on KAFKA-16051:
I do not have the privileges to assign Jira
[
https://issues.apache.org/jira/browse/KAFKA-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800814#comment-17800814
]
Octavian Ciubotaru commented on KAFKA-16051:
Hi [~gharris1727] , Thank you for you insights,
developster opened a new pull request, #15080:
URL: https://github.com/apache/kafka/pull/15080
*Description of the change*
Changed StandaloneHerder to always synchronize on itself before invoking any
methods on MemoryConfigBackingStore. This helped the situation as the order of
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800797#comment-17800797
]
Divij Vaidya commented on KAFKA-16052:
--
I am now running a single threaded test execution after
[
https://issues.apache.org/jira/browse/KAFKA-15904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-15904.
---
Resolution: Fixed
This was merged into trunk a month ago, long before the 3.7
[
https://issues.apache.org/jira/browse/KAFKA-15904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano updated KAFKA-15904:
--
Fix Version/s: 3.7.0
(was: 3.8.0)
> Downgrade tests are
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 15.31.09.png
> OOM in Kafka test suite
>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800788#comment-17800788
]
Divij Vaidya commented on KAFKA-16052:
--
ok, I might have found the offending test. It is probably
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800772#comment-17800772
]
Divij Vaidya edited comment on KAFKA-16052 at 12/27/23 2:01 PM:
-Let's
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a
[
https://issues.apache.org/jira/browse/KAFKA-16054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Shulgin updated KAFKA-16054:
--
Description:
We have observed now for the 3rd time in production the issue where a
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800772#comment-17800772
]
Divij Vaidya commented on KAFKA-16052:
--
Let's try to find the test which was running at the time of
Oleksandr Shulgin created KAFKA-16054:
-
Summary: Sudden 100% CPU on a broker
Key: KAFKA-16054
URL: https://issues.apache.org/jira/browse/KAFKA-16054
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800770#comment-17800770
]
Divij Vaidya commented on KAFKA-16052:
--
We have a
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 14.45.20.png
> OOM in Kafka test suite
>
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
*Problem*
Our test suite is failing with frequent OOM. Discussion in the mailing
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Description:
Our test suite is failing with frequent OOM. Discussion in the mailing list is
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 14.22.21.png
> OOM in Kafka test suite
>
divijvaidya commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437034332
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler =
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800764#comment-17800764
]
Divij Vaidya commented on KAFKA-16052:
--
The tests are still running but as of now the root cause
[
https://issues.apache.org/jira/browse/KAFKA-16052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16052:
-
Attachment: Screenshot 2023-12-27 at 14.04.52.png
> OOM in Kafka test suite
>
divijvaidya commented on PR #15079:
URL: https://github.com/apache/kafka/pull/15079#issuecomment-1870288475
@dajac @ableegoldman please review. This is not the root cause of our recent
OOM errors but is a contributor to it.
(cc: @stanislavkozlovski as a potential backport to 3.7)
[
https://issues.apache.org/jira/browse/KAFKA-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16053:
-
Attachment: Screenshot 2023-12-27 at 13.18.33.png
> Fix leaked Default DirectoryService
>
[
https://issues.apache.org/jira/browse/KAFKA-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-16053:
-
Description:
Heap dump hinted towards a leaked DefaultDirectoryService while running
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437026129
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler =
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437024347
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler =
divijvaidya commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1437022630
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2704,28 +2710,30 @@ class ReplicaManagerTest {
time = time,
scheduler =
divijvaidya opened a new pull request, #15079:
URL: https://github.com/apache/kafka/pull/15079
# Problem
We are facing OOM while running test suite for Apache Kafka as discussed in
https://lists.apache.org/thread/d5js0xpsrsvhgjb10mbzo9cwsy8087x4
# Changes
This JIRA fixes
Divij Vaidya created KAFKA-16053:
Summary: Fix leaked Default DirectoryService
Key: KAFKA-16053
URL: https://issues.apache.org/jira/browse/KAFKA-16053
Project: Kafka
Issue Type: Sub-task
Divij Vaidya created KAFKA-16052:
Summary: OOM in Kafka test suite
Key: KAFKA-16052
URL: https://issues.apache.org/jira/browse/KAFKA-16052
Project: Kafka
Issue Type: Bug
Affects
showuon commented on PR #15077:
URL: https://github.com/apache/kafka/pull/15077#issuecomment-1870263212
@satishd , I've closed all the instances in finally block quietly in this
commit:
https://github.com/apache/kafka/pull/15077/commits/dd913a8668cf773a51403e482cc704b44cb0e8a1
. Thanks.
vamossagar12 commented on PR #15072:
URL: https://github.com/apache/kafka/pull/15072#issuecomment-1870244078
Thanks @divijvaidya , I think Ismael's point is correct. From what I recall,
the streams final rule also expects the method arguements etc to be final as
well (apart from local
satishd commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1436993064
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -4020,6 +4031,7 @@ class ReplicaManagerTest {
doneLatch.countDown()
} finally {
showuon commented on code in PR #15077:
URL: https://github.com/apache/kafka/pull/15077#discussion_r1436972102
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2693,6 +2693,9 @@ class ReplicaManagerTest {
} else {
divijvaidya commented on PR #15072:
URL: https://github.com/apache/kafka/pull/15072#issuecomment-1870156605
Checkstyle doesn't have a rule [1] available to enforce that fields which
are not changing are marked as final. Hence, I am not changing anything in the
checkstyle here in this PR.
1 - 100 of 108 matches
Mail list logo
