dajac commented on a change in pull request #9051:
URL: https://github.com/apache/kafka/pull/9051#discussion_r459252113
##
File path:
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala
##
@@ -775,6 +775,24 @@ class DynamicBrokerReconfigurationT
dajac commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r459258170
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -96,13 +104,15 @@ public InternalTopicManage
dajac commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r459258170
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -96,13 +104,15 @@ public InternalTopicManage
stanislavkozlovski commented on a change in pull request #9050:
URL: https://github.com/apache/kafka/pull/9050#discussion_r459262136
##
File path:
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala
##
@@ -598,6 +603,86 @@ class ControllerIntegrationTest
stanislavkozlovski commented on pull request #9050:
URL: https://github.com/apache/kafka/pull/9050#issuecomment-662860332
> add preempt(): Unit method for all ControllerEvent so that all events (and
future events) must implement it
> for events that have callbacks, move the preemption fr
[
https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163344#comment-17163344
]
Paul Webb commented on KAFKA-8154:
--
Hi. Please note that we were recently affected by t
[
https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Zhang reassigned KAFKA-9343:
-
Assignee: Shuo Zhang
> Add ps command for Kafka and zookeeper process on z/OS.
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163344#comment-17163344
]
Paul Webb edited comment on KAFKA-8154 at 7/23/20, 8:52 AM:
H
[
https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163344#comment-17163344
]
Paul Webb edited comment on KAFKA-8154 at 7/23/20, 8:53 AM:
[
[
https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Zhang updated KAFKA-9343:
--
Fix Version/s: 2.6.0
> Add ps command for Kafka and zookeeper process on z/OS.
> --
showuon opened a new pull request #9062:
URL: https://github.com/apache/kafka/pull/9062
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade not
showuon commented on pull request #9062:
URL: https://github.com/apache/kafka/pull/9062#issuecomment-662919173
@feyman2016 @huxihx , since you have experience in this test before, could
you review this small PR? Thanks.
This
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez reassigned KAFKA-10205:
---
Assignee: Igor Soarez
> NullPointerException in StreamTask
> --
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163394#comment-17163394
]
Igor Soarez commented on KAFKA-10205:
-
I'm happy take this one on.
> NullPointer
leonardge opened a new pull request #9063:
URL: https://github.com/apache/kafka/pull/9063
Gradle properties: `baseName`, `classifier` and `version` has been
deprecated. So I have change these to `archiveBaseName`, `archiveClassifier`
and `archiveVersion`. More infomration
[here](https://d
[
https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163397#comment-17163397
]
Luke Chen commented on KAFKA-8098:
--
In the test, we first test removing 1 member from gr
mimaison commented on pull request #8295:
URL: https://github.com/apache/kafka/pull/8295#issuecomment-662968116
Rebased on trunk
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163485#comment-17163485
]
Bruno Cadonna commented on KAFKA-8037:
--
I find the idea of putting records in its or
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163485#comment-17163485
]
Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:04 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163485#comment-17163485
]
Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:21 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163529#comment-17163529
]
Igor Piddubnyi commented on KAFKA-8582:
---
Hi [~mjsax], as discussed in PR please ass
[
https://issues.apache.org/jira/browse/KAFKA-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163590#comment-17163590
]
Thiago Santos commented on KAFKA-9531:
--
I am experiencing the same problem. When i s
[
https://issues.apache.org/jira/browse/KAFKA-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163590#comment-17163590
]
Thiago Santos edited comment on KAFKA-9531 at 7/23/20, 1:44 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163590#comment-17163590
]
Thiago Santos edited comment on KAFKA-9531 at 7/23/20, 1:45 PM:
---
soarez opened a new pull request #9064:
URL: https://github.com/apache/kafka/pull/9064
Kafka Streams topologies must be defined in a deterministic order, otherwise
users can run into confusing NPE.
This patch adds a more descriptive exception and documentation clarifying
the determinist
[
https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163394#comment-17163394
]
Igor Soarez edited comment on KAFKA-10205 at 7/23/20, 2:01 PM:
---
piddubnyi commented on pull request #9017:
URL: https://github.com/apache/kafka/pull/9017#issuecomment-663037679
Hi @mjsax, I commented the ticket to get it assigned.
Regarding the KIP, I just created a fresh account in Confluence, however, it
looks like there are no rights to trigger th
mumrah commented on a change in pull request #9008:
URL: https://github.com/apache/kafka/pull/9008#discussion_r459499911
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/RecordsWriter.java
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the Apache Software Foundat
[
https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-10301:
Summary: Partition#remoteReplicasMap can be empty in certain race
conditions (was
Stanislav Kozlovski created KAFKA-10301:
---
Summary: RemoteReplicasMap can be empty in certain race conditions
Key: KAFKA-10301
URL: https://issues.apache.org/jira/browse/KAFKA-10301
Project: Kafka
mimaison commented on a change in pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#discussion_r459460614
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorConnectorsIntegrationTest.java
##
@@ -62,6 +65,7 @@
private static f
[
https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-10301:
Description:
In Partition#updateAssignmentAndIsr, we would previously update the
Stanislav Kozlovski created KAFKA-10302:
---
Summary: Ensure thread-safe access to Partition#remoteReplicasMap
Key: KAFKA-10302
URL: https://issues.apache.org/jira/browse/KAFKA-10302
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-10301:
Description:
In Partition#updateAssignmentAndIsr, we would previously update the
stanislavkozlovski opened a new pull request #9065:
URL: https://github.com/apache/kafka/pull/9065
We would previously update the map by adding the new replicas to the map and
then removing the old ones. During a recent refactoring, we changed the logic
to first clear the map and then add
stanislavkozlovski commented on pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#issuecomment-663065197
cc @ijuma
This is an automated message from the Apache Git Service.
To respond to the message, please
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459527097
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -678,11 +678,13 @@ class Partition(val topicPartition: TopicPartition,
[
https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163686#comment-17163686
]
Stanislav Kozlovski commented on KAFKA-10301:
-
cc [~rhauch] - this would be
AshishRoyJava commented on pull request #9034:
URL: https://github.com/apache/kafka/pull/9034#issuecomment-663066844
@abbccdda Unit test added.
This is an automated message from the Apache Git Service.
To respond to the messa
ijuma commented on pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#issuecomment-663069630
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
asdaraujo commented on a change in pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#discussion_r459536318
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
##
@@ -132,7 +132,7 @@ public String version() {
Yogesh BG created KAFKA-10303:
-
Summary: kafka producer says connect failed in cluster mode
Key: KAFKA-10303
URL: https://issues.apache.org/jira/browse/KAFKA-10303
Project: Kafka
Issue Type: Bug
stanislavkozlovski commented on pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#issuecomment-663088134
Currently working on introducing a test case for this
This is an automated message from the Apache Git
mimaison commented on a change in pull request #9007:
URL: https://github.com/apache/kafka/pull/9007#discussion_r459540733
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -2306,6 +2310,22 @@ void handleFailure(Throwable throwable)
ijuma commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459563205
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -678,11 +678,13 @@ class Partition(val topicPartition: TopicPartition,
mimaison commented on pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#issuecomment-663094946
While not part of your changes, I noticed the tests assumptions are pretty
loose. For example, we assume
https://github.com/apache/kafka/pull/9029/files#diff-a03d58195cfe119d0b1e
mjsax commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r459577643
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -96,13 +104,15 @@ public InternalTopicManage
[
https://issues.apache.org/jira/browse/KAFKA-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163747#comment-17163747
]
Matthias J. Sax commented on KAFKA-10255:
-
Two more:
*
[https://builds.apache.
[
https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163749#comment-17163749
]
Matthias J. Sax commented on KAFKA-9013:
[https://builds.apache.org/job/kafka-pr-
mjsax commented on pull request #9052:
URL: https://github.com/apache/kafka/pull/9052#issuecomment-663107263
Only flaky tests failed. I updated the corresponding Jira tickets.
This is an automated message from the Apache Git
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-663109443
@chia7712: Only 6 test failures in the latest run with your PR.
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-07-23--001.1595503536--chia
dajac commented on a change in pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#discussion_r459582710
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -96,13 +104,15 @@ public InternalTopicManage
chia7712 edited a comment on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-662810186
> Could you rebase again? I will run the system tests after that. Thanks.
done. the known flaky ```group_mode_transactions_test.py``` is traced by
#9059
--
mjsax commented on a change in pull request #9064:
URL: https://github.com/apache/kafka/pull/9064#discussion_r459581717
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java
##
@@ -49,6 +49,9 @@
/**
* {@code StreamsBuilder} provide the high-level K
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163759#comment-17163759
]
Guozhang Wang commented on KAFKA-10134:
---
[~zhowei] Did your run include both the l
mjsax commented on pull request #9064:
URL: https://github.com/apache/kafka/pull/9064#issuecomment-663113463
Btw: The PR should be against `trunk`.
This is an automated message from the Apache Git Service.
To respond to the m
ijuma commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459588501
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -678,11 +678,13 @@ class Partition(val topicPartition: TopicPartition,
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163761#comment-17163761
]
Guozhang Wang commented on KAFKA-10134:
---
BTW I found that the main latency during
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459596274
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -678,11 +678,13 @@ class Partition(val topicPartition: TopicPartition,
[
https://issues.apache.org/jira/browse/KAFKA-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-8582:
--
Assignee: Igor Piddubnyi
> Consider adding an ExpiredWindowRecordHandler to Suppress
>
[
https://issues.apache.org/jira/browse/KAFKA-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163770#comment-17163770
]
Matthias J. Sax commented on KAFKA-8582:
Added you to the list of contributors an
mjsax commented on pull request #9017:
URL: https://github.com/apache/kafka/pull/9017#issuecomment-663122659
I found your wiki account and granted write access. You should be all set.
This is an automated message from the Apa
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459598439
##
File path: core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala
##
@@ -116,6 +117,56 @@ class PartitionLockTest extends Logging {
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459599939
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -678,11 +678,13 @@ class Partition(val topicPartition: TopicPartition,
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163796#comment-17163796
]
Sophie Blee-Goldman commented on KAFKA-10284:
-
You know, I think we actually
ijuma commented on pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#issuecomment-663130390
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
ijuma commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459607476
##
File path: core/src/test/scala/unit/kafka/utils/PoolTest.scala
##
@@ -0,0 +1,41 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or m
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163802#comment-17163802
]
Ning Zhang commented on KAFKA-1:
Hi Chris, the purpose of this ticket is very in
mjsax commented on pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#issuecomment-663134416
Only the `StreamsStandbyTask.test_standby_tasks_rebalance` system test
failed and it's know to be buggy.
This is an
[
https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163803#comment-17163803
]
Matthias J. Sax commented on KAFKA-7540:
[https://builds.apache.org/job/kafka-pr-
[
https://issues.apache.org/jira/browse/KAFKA-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163804#comment-17163804
]
Matthias J. Sax commented on KAFKA-10255:
-
And one more: [https://builds.apache.
mjsax commented on pull request #9060:
URL: https://github.com/apache/kafka/pull/9060#issuecomment-663135369
Jenkins failed on know flaky tests only.
This is an automated message from the Apache Git Service.
To respond to the
mjsax commented on pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#issuecomment-663136110
Flaky tests only.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163807#comment-17163807
]
Matthias J. Sax commented on KAFKA-10255:
-
[https://builds.apache.org/job/kafka-
soondenana commented on a change in pull request #9054:
URL: https://github.com/apache/kafka/pull/9054#discussion_r459603473
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1151,6 +1144,12 @@ class LogManager(logDirs: Seq[File],
}
}
}
+
+ pri
ijuma commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459616154
##
File path: core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala
##
@@ -116,6 +117,56 @@ class PartitionLockTest extends Logging {
future.get
ning2008wisc commented on pull request #9029:
URL: https://github.com/apache/kafka/pull/9029#issuecomment-663147296
totally agree that it may be better to revisit the tests in MM2 and I
created a ticket https://issues.apache.org/jira/browse/KAFKA-10304 and assign
it to myself.
-
Ning Zhang created KAFKA-10304:
--
Summary: Revisit and improve the tests of MirrorMaker 2
Key: KAFKA-10304
URL: https://issues.apache.org/jira/browse/KAFKA-10304
Project: Kafka
Issue Type: Test
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459640134
##
File path: core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala
##
@@ -116,6 +117,56 @@ class PartitionLockTest extends Logging {
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459640854
##
File path: core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala
##
@@ -116,6 +117,56 @@ class PartitionLockTest extends Logging {
stanislavkozlovski commented on a change in pull request #9065:
URL: https://github.com/apache/kafka/pull/9065#discussion_r459645411
##
File path: core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala
##
@@ -116,6 +117,56 @@ class PartitionLockTest extends Logging {
jeffkbkim commented on a change in pull request #9050:
URL: https://github.com/apache/kafka/pull/9050#discussion_r459647273
##
File path:
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala
##
@@ -598,6 +603,86 @@ class ControllerIntegrationTest extends
abbccdda commented on a change in pull request #8512:
URL: https://github.com/apache/kafka/pull/8512#discussion_r459648674
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
##
@@ -1388,9 +1388,9 @@ public void commitSync() {
*/
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163871#comment-17163871
]
Boyang Chen commented on KAFKA-10284:
-
[~akshaysh] I didn't see any trace that the g
[
https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9161:
---
Fix Version/s: 2.6.0
> Close gaps in Streams configs documentation
>
cadonna opened a new pull request #9066:
URL: https://github.com/apache/kafka/pull/9066
In PR #8962 we introduced a sentinel UNKNOWN_OFFSET to mark unknown offsets
in checkpoint files. The sentinel was set to -2 which is the same value used
for the sentinel LATEST_OFFSET that is used in su
cadonna commented on pull request #9066:
URL: https://github.com/apache/kafka/pull/9066#issuecomment-663197156
Started 10x runs of the failing system test here:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4074/
cadonna commented on pull request #9066:
URL: https://github.com/apache/kafka/pull/9066#issuecomment-663197372
Call for review: @ableegoldman @mjsax @vvcephei @guozhangwang
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163911#comment-17163911
]
Bruno Cadonna commented on KAFKA-10287:
---
[~chia7712] Sorry, I was not aware that y
vvcephei opened a new pull request #9067:
URL: https://github.com/apache/kafka/pull/9067
Fixes this issue:
```
Execution failed for task ':streams:unitTest'.
> Process 'Gradle Test Executor 69' finished with non-zero exit value 134
```
### Committer Checklist (excluded fro
vvcephei commented on pull request #9067:
URL: https://github.com/apache/kafka/pull/9067#issuecomment-663223325
Hey @mjsax , can you review this?
It's weird that the error is reported from `unitTest`, but the only call
path to the `Exit.exit()` method is though this integration test.
soarez commented on pull request #9064:
URL: https://github.com/apache/kafka/pull/9064#issuecomment-663252849
Thanks for review @mjsax. I've changed the merge base to `trunk` and believe
I have addressed all your feedback so far. Please take another look.
-
soarez edited a comment on pull request #9064:
URL: https://github.com/apache/kafka/pull/9064#issuecomment-663252849
Thanks for review @mjsax. I've changed the base branch to `trunk` and
believe I have addressed all your feedback so far. Please take another look.
-
mjsax commented on pull request #9067:
URL: https://github.com/apache/kafka/pull/9067#issuecomment-663255631
Is this the right fix? I thought we should replace `System.exit()` with
`Exit.exit()` to address the isssu? -- We call `System.exit()` in multiple
system tests. -- And we hav
mjsax commented on pull request #9066:
URL: https://github.com/apache/kafka/pull/9066#issuecomment-663256239
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #9066:
URL: https://github.com/apache/kafka/pull/9066#issuecomment-663256489
@cadonna Should the PR be against `trunk` ?
This is an automated message from the Apache Git Service.
To respond to
mjsax edited a comment on pull request #9067:
URL: https://github.com/apache/kafka/pull/9067#issuecomment-663255631
Is this the right fix? I thought we should replace `System.exit()` with
`Exit.exit()` to address the isssu? -- We call `System.exit()` in multiple
system tests.
---
vvcephei commented on a change in pull request #9047:
URL: https://github.com/apache/kafka/pull/9047#discussion_r459762279
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -299,7 +318,17 @@ private void restoreS
[
https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10287:
-
Priority: Blocker (was: Major)
> fix flaky streams/streams_standby_replica_test.py
> --
[
https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10287:
-
Fix Version/s: 2.6.0
> fix flaky streams/streams_standby_replica_test.py
> -
1 - 100 of 148 matches
Mail list logo