kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Embedded connect cluster should mask exit procedures by default (#7028)
Date Wed, 03 Jul 2019 05:15:41 GMT
This is an automated email from the ASF dual-hosted git repository.

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

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

commit b0935e548b9d698f3ee7e9cb2ea5efc9647d6ba3
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