kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rha...@apache.org
Subject [kafka] branch 2.3 updated: MINOR: Embedded connect cluster should mask exit procedures by default (#7028)
Date Fri, 22 Nov 2019 02:06:07 GMT
This is an automated email from the ASF dual-hosted git repository.

rhauch pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git

The following commit(s) were added to refs/heads/2.3 by this push:
     new 4b64b74  MINOR: Embedded connect cluster should mask exit procedures by default (#7028)
4b64b74 is described below

commit 4b64b74431e8cb08bf536b0fae578be3e5d07e39
Author: Jason Gustafson <jason@confluent.io>
AuthorDate: Tue Jul 2 22:15:22 2019 -0700

    MINOR: Embedded connect cluster should mask exit procedures by default (#7028)
    `EmbeddedConnectCluster` has the ability to mask system exits to avoid killing the jvm.
It appears that the default was intended to be `true`, but is actually `false`. The `maskExitProcedures`
method on `EmbeddedConnectCluster.Builder` documents the parameter as:
    * @param mask if false, exit and halt procedures remain unchanged; true is the default.
    Because this is not enabled by default as intended, we are seeing some build failures
which exit abruptly:
    17:29:11 Execution failed for task ':connect:runtime:integrationTest'.
    17:29:11 > Process 'Gradle Test Executor 25' finished with non-zero exit value 1
    The culprit often appears to be `ExampleConnectIntegrationTest`, which indeed does not
override the default value of `maskExitProcedures`.
    Reviewers: Ewen Cheslack-Postava <me@ewencp.org>
 .../org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
index 07c2755..fc93ae0 100644
--- a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
+++ b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
@@ -429,7 +429,7 @@ public class EmbeddedConnectCluster {
         private int numWorkers = DEFAULT_NUM_WORKERS;
         private int numBrokers = DEFAULT_NUM_BROKERS;
         private Properties brokerProps = DEFAULT_BROKER_CONFIG;
-        private boolean maskExitProcedures = false;
+        private boolean maskExitProcedures = true;
         public Builder name(String name) {
             this.name = name;

View raw message