sudeephazra commented on issue #6345: URL: https://github.com/apache/seatunnel/issues/6345#issuecomment-2350910832
So, I rolled back to JDK 8 since nothing was working. And moved development to my Ubuntu VM. Then I forked the dev branch from commit 154e866 - Cloned the repo - Opened the repo on IntelliJ IDEA 2024.2.1 - The JDK configuration is as follows  - Built the code using the following command ``` ./mvnw install -Dmaven.test.skip ``` - Identified the sample `${SEATUNNEL_HOME}/seatunnel-examples/seatunnel-engine-examples/src/main/java/org/apache/seatunnel/example/engineSeaTunnelEngineExample.java` - Modified the config file `fake_to_console.conf` as below ``` env { parallelism = 1 job.mode = "BATCH" } source { FakeSource { result_table_name = "fakedata" parallelism = 1 schema = { fields { name = "string" age = "int" } } } } transform { } sink { LocalFile { source_table_name = "fakedata" path = "/tmp/dest/" file_format_type = "csv" } } ``` - Modified the pom.xml as below ```xml <?xml version="1.0" encoding="UTF-8"?> <!-- ~ Licensed to the Apache Software Foundation (ASF) under one or more ~ contributor license agreements. See the NOTICE file distributed with ~ this work for additional information regarding copyright ownership. ~ The ASF licenses this file to You under the Apache License, Version 2.0 ~ (the "License"); you may not use this file except in compliance with ~ the License. You may obtain a copy of the License at ~ ~ http://www.apache.org/licenses/LICENSE-2.0 ~ ~ Unless required by applicable law or agreed to in writing, software ~ distributed under the License is distributed on an "AS IS" BASIS, ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. ~ See the License for the specific language governing permissions and ~ limitations under the License. --> <project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.apache.seatunnel</groupId> <artifactId>seatunnel-examples</artifactId> <version>${revision}</version> </parent> <artifactId>seatunnel-engine-examples</artifactId> <name>SeaTunnel : Examples : Engine</name> <dependencies> <!-- seatunnel core dependencies --> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>seatunnel-starter</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>seatunnel-transforms-v2</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>seatunnel-hadoop3-3.1.4-uber</artifactId> <version>${project.version}</version> </dependency> <!-- seatunnel connectors --> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>connector-fake</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>connector-file-local</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>connector-console</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.apache.seatunnel</groupId> <artifactId>connector-assert</artifactId> <version>${project.version}</version> </dependency> </dependencies> </project> ``` - Then I run the same code `${seatunnel}/seatunnel-examples/seatunnel-engine-examples/src/main/java/org.apache.seatunnel.example.engine/SeaTunnelEngineExample` from inside IntelliJ IDEA - And BOOM! I get an error as follows ``` /home/sudeep/.sdkman/candidates/java/8.0.422-zulu/bin/java -javaagent:/snap/intellij-idea-community/530/lib/idea_rt.jar=36635:/snap/intellij-idea-community/530/bin -Dfile.encoding=UTF-8 -classpath /home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/cat.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/charsets.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/cldrdata.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/crs-agent.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/dnsns.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/jaccess.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/localedata.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/nashorn.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/sunec.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/sunjce_provider.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/e xt/sunpkcs11.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/ext/zipfs.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/jce.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/jfr.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/jsse.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/management-agent.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/resources.jar:/home/sudeep/.sdkman/candidates/java/8.0.422-zulu/jre/lib/rt.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-examples/seatunnel-engine-examples/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-core/seatunnel-starter/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-api/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-common/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-config/seatunnel-config-shade/target/seatunnel-config-shade-2.3. 8-SNAPSHOT.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-config/seatunnel-config-shade/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-config/seatunnel-config-base/target/seatunnel-config-base-2.3.8-SNAPSHOT.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-config/seatunnel-config-base/target/classes:/home/sudeep/.m2/repository/com/typesafe/config/1.3.3/config-1.3.3.jar:/home/sudeep/.m2/repository/org/scala-lang/scala-library/2.12.15/scala-library-2.12.15.jar:/home/sudeep/.m2/repository/org/apache/commons/commons-collections4/4.4/commons-collections4-4.4.jar:/home/sudeep/.m2/repository/org/apache/commons/commons-csv/1.10.0/commons-csv-1.10.0.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-guava/target/seatunnel-guava.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-guava/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-ja ckson/target/seatunnel-jackson.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-jackson/target/classes:/home/sudeep/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-properties/2.13.3/jackson-dataformat-properties-2.13.3.jar:/home/sudeep/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jsr310/2.13.3/jackson-datatype-jsr310-2.13.3.jar:/home/sudeep/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.13.3/jackson-core-2.13.3.jar:/home/sudeep/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.13.3/jackson-databind-2.13.3.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-core/seatunnel-core-starter/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-config/seatunnel-config-sql/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-plugin-discovery/target/classes:/home/sudeep/.m2/repository/org/apache/commons/commons-compress/1.20/commons-compress-1.20.jar: /home/sudeep/.m2/repository/com/beust/jcommander/1.81/jcommander-1.81.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-client/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/target/seatunnel-hazelcast-shade-2.3.8-SNAPSHOT.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-base/target/seatunnel-hazelcast-base-2.3.8-SNAPSHOT.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-base/target/classes:/home/sudeep/.m2/repository/com/hazelcast/hazelcast/5.1/hazelcast-5.1.jar:/home/sudeep/.m2/repository/org/apache/commons/commons-lang3/3.5/commons-lang3-3.5.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel- engine-core/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-common/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-local-file/target/classes:/home/sudeep/.m2/repository/commons-io/commons-io/2.11.0/commons-io-2.11.0.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-api/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-server/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-hdfs/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engi ne-serializer/serializer-protobuf/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-serializer/serializer-api/target/classes:/home/sudeep/.m2/repository/io/protostuff/protostuff-core/1.8.0/protostuff-core-1.8.0.jar:/home/sudeep/.m2/repository/io/protostuff/protostuff-api/1.8.0/protostuff-api-1.8.0.jar:/home/sudeep/.m2/repository/io/protostuff/protostuff-runtime/1.8.0/protostuff-runtime-1.8.0.jar:/home/sudeep/.m2/repository/io/protostuff/protostuff-collectionschema/1.8.0/protostuff-collectionschema-1.8.0.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-engine/seatunnel-engine-storage/imap-storage-api/target/classes:/home/sudeep/.m2/repository/com/lmax/disruptor/3.4.4/disruptor-3.4.4.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-transforms-v2/target/classes:/home/sudeep/.m2/repository/com/github/jsqlparser/jsqlparser/4.5/jsqlparser-4.5.jar:/home/sudeep/.m2/repository/com/jayway/jsonpath/json-path/2.7.0/j son-path-2.7.0.jar:/home/sudeep/.m2/repository/net/minidev/json-smart/2.4.7/json-smart-2.4.7.jar:/home/sudeep/.m2/repository/net/minidev/accessors-smart/2.4.7/accessors-smart-2.4.7.jar:/home/sudeep/.m2/repository/org/ow2/asm/asm/9.1/asm-9.1.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-formats/seatunnel-format-json/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-connectors-v2/connector-common/target/classes:/home/sudeep/.m2/repository/org/apache/groovy/groovy/4.0.16/groovy-4.0.16.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-janino/target/seatunnel-janino.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-janino/target/classes:/home/sudeep/.m2/repository/org/apache/httpcomponents/httpclient/4.5.13/httpclient-4.5.13.jar:/home/sudeep/.m2/repository/commons-codec/commons-codec/1.13/commons-codec-1.13.jar:/home/sudeep/.m2/repository/org/apache/httpcomponents/httpcore/4.4.4/httpcor e-4.4.4.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hadoop3-3.1.4-uber/target/seatunnel-hadoop3-3.1.4-uber.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hadoop3-3.1.4-uber/target/classes:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-client/3.1.4/hadoop-client-3.1.4.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-common/3.1.4/hadoop-common-3.1.4.jar:/home/sudeep/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/home/sudeep/.m2/repository/org/apache/commons/commons-math3/3.1.1/commons-math3-3.1.1.jar:/home/sudeep/.m2/repository/commons-net/commons-net/3.6/commons-net-3.6.jar:/home/sudeep/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/home/sudeep/.m2/repository/org/eclipse/jetty/jetty-servlet/9.4.20.v20190813/jetty-servlet-9.4.20.v20190813.jar:/home/sudeep/.m2/repository/org/eclipse/jetty/jetty-security/9.4.20.v20190813/jetty-security-9.4.20.v 20190813.jar:/home/sudeep/.m2/repository/org/eclipse/jetty/jetty-webapp/9.4.20.v20190813/jetty-webapp-9.4.20.v20190813.jar:/home/sudeep/.m2/repository/org/eclipse/jetty/jetty-xml/9.4.20.v20190813/jetty-xml-9.4.20.v20190813.jar:/home/sudeep/.m2/repository/javax/servlet/jsp/jsp-api/2.1/jsp-api-2.1.jar:/home/sudeep/.m2/repository/com/sun/jersey/jersey-servlet/1.19/jersey-servlet-1.19.jar:/home/sudeep/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/home/sudeep/.m2/repository/commons-beanutils/commons-beanutils/1.9.4/commons-beanutils-1.9.4.jar:/home/sudeep/.m2/repository/org/apache/commons/commons-configuration2/2.1.1/commons-configuration2-2.1.1.jar:/home/sudeep/.m2/repository/org/apache/avro/avro/1.7.7/avro-1.7.7.jar:/home/sudeep/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/home/sudeep/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/home/sudeep/.m2/repository/com/thoughtworks/pa ranamer/paranamer/2.3/paranamer-2.3.jar:/home/sudeep/.m2/repository/com/google/re2j/re2j/1.1/re2j-1.1.jar:/home/sudeep/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/home/sudeep/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-auth/3.1.4/hadoop-auth-3.1.4.jar:/home/sudeep/.m2/repository/com/nimbusds/nimbus-jose-jwt/7.9/nimbus-jose-jwt-7.9.jar:/home/sudeep/.m2/repository/com/github/stephenc/jcip/jcip-annotations/1.0-1/jcip-annotations-1.0-1.jar:/home/sudeep/.m2/repository/org/apache/curator/curator-framework/2.13.0/curator-framework-2.13.0.jar:/home/sudeep/.m2/repository/org/apache/curator/curator-client/2.13.0/curator-client-2.13.0.jar:/home/sudeep/.m2/repository/org/apache/curator/curator-recipes/2.13.0/curator-recipes-2.13.0.jar:/home/sudeep/.m2/repository/org/apache/htrace/htrace-core4/4.1.0-incubating/htrace-core4-4.1.0-incubating.jar:/home/sudeep/.m2/repository/org/apache/kerby/ke rb-simplekdc/1.0.1/kerb-simplekdc-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-client/1.0.1/kerb-client-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerby-config/1.0.1/kerby-config-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-core/1.0.1/kerb-core-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerby-pkix/1.0.1/kerby-pkix-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerby-asn1/1.0.1/kerby-asn1-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerby-util/1.0.1/kerby-util-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-common/1.0.1/kerb-common-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-crypto/1.0.1/kerb-crypto-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-util/1.0.1/kerb-util-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/token-provider/1.0.1/token-provider-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-admin/1.0.1/kerb-admin-1.0.1.jar:/home/sudeep/.m2/repositor y/org/apache/kerby/kerb-server/1.0.1/kerb-server-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerb-identity/1.0.1/kerb-identity-1.0.1.jar:/home/sudeep/.m2/repository/org/apache/kerby/kerby-xdr/1.0.1/kerby-xdr-1.0.1.jar:/home/sudeep/.m2/repository/org/codehaus/woodstox/stax2-api/3.1.4/stax2-api-3.1.4.jar:/home/sudeep/.m2/repository/com/fasterxml/woodstox/woodstox-core/5.0.3/woodstox-core-5.0.3.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-hdfs-client/3.1.4/hadoop-hdfs-client-3.1.4.jar:/home/sudeep/.m2/repository/com/squareup/okhttp/okhttp/2.7.5/okhttp-2.7.5.jar:/home/sudeep/.m2/repository/com/squareup/okio/okio/1.6.0/okio-1.6.0.jar:/home/sudeep/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.13.3/jackson-annotations-2.13.3.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-yarn-api/3.1.4/hadoop-yarn-api-3.1.4.jar:/home/sudeep/.m2/repository/javax/xml/bind/jaxb-api/2.2.11/jaxb-api-2.2.11.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoo p-yarn-client/3.1.4/hadoop-yarn-client-3.1.4.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-core/3.1.4/hadoop-mapreduce-client-core-3.1.4.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-yarn-common/3.1.4/hadoop-yarn-common-3.1.4.jar:/home/sudeep/.m2/repository/javax/servlet/javax.servlet-api/3.1.0/javax.servlet-api-3.1.0.jar:/home/sudeep/.m2/repository/org/eclipse/jetty/jetty-util/9.4.20.v20190813/jetty-util-9.4.20.v20190813.jar:/home/sudeep/.m2/repository/com/sun/jersey/jersey-core/1.19/jersey-core-1.19.jar:/home/sudeep/.m2/repository/javax/ws/rs/jsr311-api/1.1.1/jsr311-api-1.1.1.jar:/home/sudeep/.m2/repository/com/sun/jersey/jersey-client/1.19/jersey-client-1.19.jar:/home/sudeep/.m2/repository/com/fasterxml/jackson/module/jackson-module-jaxb-annotations/2.9.10/jackson-module-jaxb-annotations-2.9.10.jar:/home/sudeep/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-json-provider/2.9.10/jackson-jaxrs-json-provider-2.9.10.jar:/home/sudeep/.m 2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-base/2.9.10/jackson-jaxrs-base-2.9.10.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-jobclient/3.1.4/hadoop-mapreduce-client-jobclient-3.1.4.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-common/3.1.4/hadoop-mapreduce-client-common-3.1.4.jar:/home/sudeep/.m2/repository/org/apache/hadoop/hadoop-annotations/3.1.4/hadoop-annotations-3.1.4.jar:/home/sudeep/.m2/repository/org/xerial/snappy/snappy-java/1.1.10.4/snappy-java-1.1.10.4.jar:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-connectors-v2/connector-fake/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-connectors-v2/connector-console/target/classes:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-connectors-v2/connector-assert/target/classes:/home/sudeep/.m2/repository/com/google/guava/guava/27.0-jre/guava-27.0-jre.jar:/home/sudeep/.m2/repository/com/google/guava/failureaccess /1.0/failureaccess-1.0.jar:/home/sudeep/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/home/sudeep/.m2/repository/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar:/home/sudeep/.m2/repository/org/checkerframework/checker-qual/3.10.0/checker-qual-3.10.0.jar:/home/sudeep/.m2/repository/com/google/errorprone/error_prone_annotations/2.2.0/error_prone_annotations-2.2.0.jar:/home/sudeep/.m2/repository/com/google/j2objc/j2objc-annotations/1.1/j2objc-annotations-1.1.jar:/home/sudeep/.m2/repository/org/codehaus/mojo/animal-sniffer-annotations/1.17/animal-sniffer-annotations-1.17.jar:/home/sudeep/.m2/repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar:/home/sudeep/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.17.1/log4j-slf4j-impl-2.17.1.jar:/home/sudeep/.m2/repository/org/apache/logging/log4j/log4j-api/2.17.1/log4j-api-2.17.1.jar:/home/sudeep/.m2/repository/org /apache/logging/log4j/log4j-core/2.17.1/log4j-core-2.17.1.jar:/home/sudeep/.m2/repository/org/slf4j/jcl-over-slf4j/1.7.25/jcl-over-slf4j-1.7.25.jar:/home/sudeep/.m2/repository/org/apache/logging/log4j/log4j-1.2-api/2.17.1/log4j-1.2-api-2.17.1.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient/0.16.0/simpleclient-0.16.0.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient_tracer_otel/0.16.0/simpleclient_tracer_otel-0.16.0.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient_tracer_common/0.16.0/simpleclient_tracer_common-0.16.0.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient_tracer_otel_agent/0.16.0/simpleclient_tracer_otel_agent-0.16.0.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient_hotspot/0.16.0/simpleclient_hotspot-0.16.0.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient_httpserver/0.16.0/simpleclient_httpserver-0.16.0.jar:/home/sudeep/.m2/repository/io/prometheus/simpleclient_common/0.16.0/simpleclient_common-0.16.0.jar org.apac he.seatunnel.example.engine.SeaTunnelEngineExample Sep 14, 2024 1:45:15 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'seatunnel.yaml' from the classpath. Sep 14, 2024 1:45:15 PM org.apache.seatunnel.engine.common.config.SeaTunnelConfig INFO: seatunnel.home is /home/sudeep/projects/seatunnel-adls-connector-v2 Sep 14, 2024 1:45:15 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'hazelcast.yaml' from the classpath. Sep 14, 2024 1:45:16 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'hazelcast-client.yaml' from the classpath. Sep 14, 2024 1:45:16 PM com.hazelcast.instance.impl.HazelcastInstanceFactory WARNING: WARNING: Classpath misconfiguration: found multiple META-INF/services/com.hazelcast.instance.impl.NodeExtension resources: jar:file:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/target/seatunnel-hazelcast-shade-2.3.8-SNAPSHOT.jar!/META-INF/services/com.hazelcast.instance.impl.NodeExtension, jar:file:/home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-base/target/seatunnel-hazelcast-base-2.3.8-SNAPSHOT.jar!/META-INF/services/com.hazelcast.instance.impl.NodeExtension, jar:file:/home/sudeep/.m2/repository/com/hazelcast/hazelcast/5.1/hazelcast-5.1.jar!/META-INF/services/com.hazelcast.instance.impl.NodeExtension [] 2024-09-14 13:45:16,206 WARN com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-988403] [5.1] You configured your member address as host name. Please be aware of that your dns can be spoofed. Make sure that your dns configurations are correct. [] 2024-09-14 13:45:16,214 INFO com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-988403] [5.1] Resolving domain name 'localhost' to address(es): [127.0.0.1] [] 2024-09-14 13:45:16,214 INFO com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-988403] [5.1] Interfaces is disabled, trying to pick one address from TCP-IP config addresses: [localhost/127.0.0.1] [] 2024-09-14 13:45:16,219 DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-988403] [5.1] Trying to bind inet socket address: 0.0.0.0/0.0.0.0:5801 [] 2024-09-14 13:45:16,219 DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-988403] [5.1] Bind successful to inet socket address: /0:0:0:0:0:0:0:0:5801 [] 2024-09-14 13:45:16,220 DEBUG com.hazelcast.instance.AddressPicker - [LOCAL] [seatunnel-988403] [5.1] Picked [localhost]:5801, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5801], bind any local is true [] 2024-09-14 13:45:16,240 INFO org.apache.seatunnel.engine.server.SeaTunnelServer - SeaTunnel server start... [] 2024-09-14 13:45:16,242 INFO com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] Based on Hazelcast IMDG version: 5.1.0 (20220228 - 21f20e7) [] 2024-09-14 13:45:16,242 INFO com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] Cluster name: seatunnel-988403 [] 2024-09-14 13:45:16,243 DEBUG com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] Configured Hazelcast Serialization version: 1 [] 2024-09-14 13:45:16,243 INFO com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] _____ _____ _ / ___| |_ _| | | \ `--. ___ __ _ | | _ _ _ __ _ __ ___ | | `--. \ / _ \ / _` | | | | | | || '_ \ | '_ \ / _ \| | /\__/ /| __/| (_| | | | | |_| || | | || | | || __/| | \____/ \___| \__,_| \_/ \__,_||_| |_||_| |_| \___||_| [] 2024-09-14 13:45:16,243 INFO com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] Copyright © 2021-2022 The Apache Software Foundation. Apache SeaTunnel, SeaTunnel, and its feather logo are trademarks of The Apache Software Foundation. [] 2024-09-14 13:45:16,243 INFO com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] Integrity Checker is disabled. Fail-fast on corrupted executables will not be performed. To enable integrity checker do one of the following: - Change member config using Java API: config.setIntegrityCheckerEnabled(true); - Change XML/YAML configuration property: Set hazelcast.integrity-checker.enabled to true - Add system property: -Dhz.integritychecker.enabled=true (for Hazelcast embedded, works only when loading config via Config.load) - Add environment variable: HZ_INTEGRITYCHECKER_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load) [] 2024-09-14 13:45:16,245 INFO com.hazelcast.system - [localhost]:5801 [seatunnel-988403] [5.1] The Jet engine is disabled. To enable the Jet engine on the members, do one of the following: - Change member config using Java API: config.getJetConfig().setEnabled(true) - Change XML/YAML configuration property: Set hazelcast.jet.enabled to true - Add system property: -Dhz.jet.enabled=true (for Hazelcast embedded, works only when loading config via Config.load) - Add environment variable: HZ_JET_ENABLED=true (recommended when running container image. For Hazelcast embedded, works only when loading config via Config.load) [] 2024-09-14 13:45:16,517 DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook [] 2024-09-14 13:45:16,538 DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook [] 2024-09-14 13:45:16,561 DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook [] 2024-09-14 13:45:16,563 DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook [] 2024-09-14 13:45:16,573 DEBUG com.hazelcast.internal.metrics.impl.MetricsConfigHelper - [localhost]:5801 [seatunnel-988403] [5.1] Collecting debug metrics and sending to diagnostics is disabled [] 2024-09-14 13:45:16,591 DEBUG com.hazelcast.spi.impl.operationservice.impl.BackpressureRegulator - [localhost]:5801 [seatunnel-988403] [5.1] Backpressure is disabled [] 2024-09-14 13:45:16,603 DEBUG com.hazelcast.spi.impl.operationservice.impl.InboundResponseHandlerSupplier - [localhost]:5801 [seatunnel-988403] [5.1] Running with 2 response threads [] 2024-09-14 13:45:16,718 DEBUG com.hazelcast.internal.server.tcp.LocalAddressRegistry - [localhost]:5801 [seatunnel-988403] [5.1] LinkedAddresses{primaryAddress=[localhost]:5801, allLinkedAddresses=[[127.0.0.1]:5801, [0:0:0:0:0:0:0:1%lo]:5801, [fe80:0:0:0:a00:27ff:fe21:40a7]:5801, [fe80:0:0:0:a00:27ff:fe21:40a7%enp0s3]:5801, [0:0:0:0:0:0:0:1]:5801, [172.17.0.1]:5801, [localhost]:5801, [10.0.2.15]:5801]} are registered for the local member with local uuid=d77c7224-1706-4981-8785-81fa6c671cab [] 2024-09-14 13:45:16,904 DEBUG com.hazelcast.system.security - [localhost]:5801 [seatunnel-988403] [5.1] 🔒 Security recommendations and their status: ✅ Use a custom cluster name ✅ Disable member multicast discovery/join method ⚠️ Use advanced networking, separate client and member sockets ⚠️ Bind Server sockets to a single network interface (disable hazelcast.socket.server.bind.any) ✅ Disable scripting in the Management Center ✅ Disable console in the Management Center ⚠️ Enable Security (Enterprise) ⚠️ Use TLS communication protection (Enterprise) ⚠️ Enable auditlog (Enterprise) Check the hazelcast-security-hardened.xml/yaml example config file to find why and how to configure these security related settings. [] 2024-09-14 13:45:16,984 INFO org.apache.seatunnel.engine.server.SeaTunnelNodeContext - Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery [] 2024-09-14 13:45:16,986 WARN com.hazelcast.cp.CPSubsystem - [localhost]:5801 [seatunnel-988403] [5.1] CP Subsystem is not enabled. CP data structures will operate in UNSAFE mode! Please note that UNSAFE mode will not provide strong consistency guarantees. [] 2024-09-14 13:45:17,239 INFO org.apache.seatunnel.engine.core.classloader.DefaultClassLoaderService - start classloader service Sep 14, 2024 1:45:17 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'seatunnel.yaml' from the classpath. Sep 14, 2024 1:45:17 PM com.hazelcast.internal.config.AbstractConfigLocator INFO: Loading 'hazelcast.yaml' from the classpath. [] 2024-09-14 13:45:17,272 WARN org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-988403] [5.1] The Node is not ready yet, Node state STARTING,looking forward to the next scheduling [] 2024-09-14 13:45:17,288 WARN org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - failed send heartbeat to resource manager, will retry later. this address: [localhost]:5801 [] 2024-09-14 13:45:17,275 INFO org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801 [seatunnel-988403] [5.1] Created new BusWork : 1417126346 [] 2024-09-14 13:45:17,286 DEBUG org.apache.seatunnel.engine.server.service.slot.DefaultSlotService - start send heartbeat to resource manager, this address: [localhost]:5801 [] 2024-09-14 13:45:17,293 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-988403] [5.1] *********************************************** CoordinatorService Thread Pool Status *********************************************** activeCount : 0 corePoolSize : 0 maximumPoolSize : 2147483647 poolSize : 0 completedTaskCount : 0 taskCount : 0 *********************************************** [] 2024-09-14 13:45:17,313 DEBUG com.hazelcast.internal.metrics.impl.MetricsService - [localhost]:5801 [seatunnel-988403] [5.1] Configuring metrics collection, collection interval=5 seconds, retention=5 seconds, publishers=[Management Center Publisher, JMX Publisher] [] 2024-09-14 13:45:17,340 DEBUG com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl - [localhost]:5801 [seatunnel-988403] [5.1] Starting 4 partition threads and 51 generic threads (1 dedicated for priority tasks) [] 2024-09-14 13:45:17,435 DEBUG com.hazelcast.sql.impl.SqlServiceImpl - [localhost]:5801 [seatunnel-988403] [5.1] Optimizer class "com.hazelcast.jet.sql.impl.CalciteSqlOptimizer" not found, falling back to com.hazelcast.sql.impl.optimizer.DisabledSqlOptimizer [] 2024-09-14 13:45:17,439 INFO com.hazelcast.internal.diagnostics.Diagnostics - [localhost]:5801 [seatunnel-988403] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. [] 2024-09-14 13:45:17,450 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5801 is STARTING [] 2024-09-14 13:45:17,450 DEBUG com.hazelcast.internal.partition.InternalPartitionService - [localhost]:5801 [seatunnel-988403] [5.1] Adding Member [localhost]:5801 - d77c7224-1706-4981-8785-81fa6c671cab this [] 2024-09-14 13:45:17,460 DEBUG com.hazelcast.internal.networking.nio.NioNetworking - [localhost]:5801 [seatunnel-988403] [5.1] TcpIpConnectionManager configured with Non Blocking IO-threading model: 3 input threads and 3 output threads [] 2024-09-14 13:45:17,461 DEBUG com.hazelcast.internal.networking.nio.NioNetworking - [localhost]:5801 [seatunnel-988403] [5.1] write through enabled:true [] 2024-09-14 13:45:17,462 DEBUG com.hazelcast.internal.networking.nio.NioNetworking - [localhost]:5801 [seatunnel-988403] [5.1] IO threads selector mode is SELECT [] 2024-09-14 13:45:17,472 DEBUG com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-988403] [5.1] Setting master address to null [] 2024-09-14 13:45:17,473 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5801 is local? true [] 2024-09-14 13:45:17,474 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5802 is local? false [] 2024-09-14 13:45:17,474 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5803 is local? false [] 2024-09-14 13:45:17,474 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5804 is local? false [] 2024-09-14 13:45:17,474 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5805 is local? false [] 2024-09-14 13:45:17,474 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5806 is local? false [] 2024-09-14 13:45:17,474 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5807 is local? false [] 2024-09-14 13:45:17,475 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5808 is local? false [] 2024-09-14 13:45:17,475 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5809 is local? false [] 2024-09-14 13:45:17,475 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5810 is local? false [] 2024-09-14 13:45:17,476 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5811 is local? false [] 2024-09-14 13:45:17,476 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5812 is local? false [] 2024-09-14 13:45:17,476 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5813 is local? false [] 2024-09-14 13:45:17,476 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5814 is local? false [] 2024-09-14 13:45:17,476 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5815 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5816 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5817 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5818 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5819 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5820 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5821 is local? false [] 2024-09-14 13:45:17,477 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5822 is local? false [] 2024-09-14 13:45:17,478 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5823 is local? false [] 2024-09-14 13:45:17,478 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5824 is local? false [] 2024-09-14 13:45:17,478 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5825 is local? false [] 2024-09-14 13:45:17,478 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5826 is local? false [] 2024-09-14 13:45:17,496 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5827 is local? false [] 2024-09-14 13:45:17,496 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5828 is local? false [] 2024-09-14 13:45:17,496 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5829 is local? false [] 2024-09-14 13:45:17,496 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5830 is local? false [] 2024-09-14 13:45:17,497 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] NOT sending master question to blacklisted endpoints: {} [] 2024-09-14 13:45:17,497 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5823 [] 2024-09-14 13:45:17,532 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5823 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,541 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5821 [] 2024-09-14 13:45:17,543 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5821 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,545 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5821 is added to the blacklist. [] 2024-09-14 13:45:17,546 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5823 is added to the blacklist. [] 2024-09-14 13:45:17,546 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5827 [] 2024-09-14 13:45:17,548 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5827 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,550 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5827 is added to the blacklist. [] 2024-09-14 13:45:17,551 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5825 [] 2024-09-14 13:45:17,552 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5825 is added to the blacklist. [] 2024-09-14 13:45:17,552 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5825 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,552 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5815 [] 2024-09-14 13:45:17,554 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5815 is added to the blacklist. [] 2024-09-14 13:45:17,554 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5815 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,554 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5813 [] 2024-09-14 13:45:17,558 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5813 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,559 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5819 [] 2024-09-14 13:45:17,564 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5813 is added to the blacklist. [] 2024-09-14 13:45:17,564 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5819 is added to the blacklist. [] 2024-09-14 13:45:17,564 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5819 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,564 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5817 [] 2024-09-14 13:45:17,567 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5817 is added to the blacklist. [] 2024-09-14 13:45:17,567 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5817 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,567 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5806 [] 2024-09-14 13:45:17,569 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5806 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,569 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5806 is added to the blacklist. [] 2024-09-14 13:45:17,569 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5804 [] 2024-09-14 13:45:17,570 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5804 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,571 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5810 [] 2024-09-14 13:45:17,571 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5810 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,571 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5808 [] 2024-09-14 13:45:17,571 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5808 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,572 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5804 is added to the blacklist. [] 2024-09-14 13:45:17,572 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5829 [] 2024-09-14 13:45:17,572 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5810 is added to the blacklist. [] 2024-09-14 13:45:17,573 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5808 is added to the blacklist. [] 2024-09-14 13:45:17,573 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5829 is added to the blacklist. [] 2024-09-14 13:45:17,573 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5829 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,573 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5802 [] 2024-09-14 13:45:17,574 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5802 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,574 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5822 [] 2024-09-14 13:45:17,575 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5802 is added to the blacklist. [] 2024-09-14 13:45:17,575 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5822 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,576 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5820 [] 2024-09-14 13:45:17,576 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5822 is added to the blacklist. [] 2024-09-14 13:45:17,576 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5820 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,576 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5826 [] 2024-09-14 13:45:17,576 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5820 is added to the blacklist. [] 2024-09-14 13:45:17,578 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5826 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,578 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5824 [] 2024-09-14 13:45:17,578 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5826 is added to the blacklist. [] 2024-09-14 13:45:17,579 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5824 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,579 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5814 [] 2024-09-14 13:45:17,579 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5824 is added to the blacklist. [] 2024-09-14 13:45:17,581 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5814 is added to the blacklist. [] 2024-09-14 13:45:17,581 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5814 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,581 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5812 [] 2024-09-14 13:45:17,582 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5812 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,582 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5812 is added to the blacklist. [] 2024-09-14 13:45:17,582 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5818 [] 2024-09-14 13:45:17,583 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5818 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,583 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5818 is added to the blacklist. [] 2024-09-14 13:45:17,584 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5816 [] 2024-09-14 13:45:17,585 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5816 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,585 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5807 [] 2024-09-14 13:45:17,586 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5816 is added to the blacklist. [] 2024-09-14 13:45:17,586 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5807 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,587 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5805 [] 2024-09-14 13:45:17,587 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5807 is added to the blacklist. [] 2024-09-14 13:45:17,588 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5805 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,588 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5805 is added to the blacklist. [] 2024-09-14 13:45:17,588 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5811 [] 2024-09-14 13:45:17,589 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5811 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,589 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5809 [] 2024-09-14 13:45:17,589 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5811 is added to the blacklist. [] 2024-09-14 13:45:17,590 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5809 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,590 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5830 [] 2024-09-14 13:45:17,591 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5809 is added to the blacklist. [] 2024-09-14 13:45:17,592 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5830 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,592 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5828 [] 2024-09-14 13:45:17,593 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5830 is added to the blacklist. [] 2024-09-14 13:45:17,593 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5828 is added to the blacklist. [] 2024-09-14 13:45:17,593 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5828 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,593 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] Sending master question to [localhost]:5803 [] 2024-09-14 13:45:17,593 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5803 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,600 INFO org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5803 is added to the blacklist. [] 2024-09-14 13:45:17,648 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5821 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,650 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5827 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,634 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5823 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,653 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5825 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,659 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5815 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,659 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5813 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,667 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5819 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,671 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5817 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,673 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5806 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,673 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5804 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,673 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5810 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,674 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5829 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,673 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5808 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,681 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5802 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,681 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5824 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,681 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5826 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,686 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5820 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,687 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5818 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,687 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5816 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,688 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5807 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,688 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5812 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,688 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5822 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,689 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5805 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,689 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5814 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,689 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5811 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,693 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5809 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,693 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5830 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,694 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5828 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,694 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5803 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,926 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5821 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,926 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5827 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,926 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5823 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,926 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5825 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,926 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5815 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,926 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5813 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,928 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5806 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,928 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5804 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,928 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5810 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,928 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5829 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,928 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5808 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,929 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5802 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,929 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5824 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,930 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5826 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,930 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5817 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,930 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5816 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,930 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5807 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,930 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5812 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,931 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5822 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,931 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5805 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,931 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5814 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,931 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5811 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,931 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5809 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,931 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5830 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,935 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5818 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,935 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5820 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,935 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5819 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,935 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5803 streamId:-1 is not yet in progress [] 2024-09-14 13:45:17,936 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5828 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,232 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5823 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,236 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5827 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,237 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5825 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,237 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5815 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,237 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5813 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,237 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5806 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,237 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5804 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,238 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5829 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,238 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5808 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,238 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5802 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,232 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5821 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,239 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5810 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5824 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5807 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5812 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5822 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5805 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5814 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5811 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5809 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5830 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5818 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5820 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5819 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5803 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,240 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5828 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,241 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5817 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,241 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5826 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,246 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5816 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,594 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5823 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5821 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5827 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5825 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5815 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5813 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5819 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5817 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5806 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5804 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5810 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5808 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5829 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5802 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5822 is local? false [] 2024-09-14 13:45:18,595 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5820 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5826 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5824 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5814 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5812 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5818 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5816 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5807 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5805 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5811 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5809 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5830 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5828 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5803 is local? false [] 2024-09-14 13:45:18,596 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] This node will assume master role since none of the possible members accepted join request. [] 2024-09-14 13:45:18,596 DEBUG com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-988403] [5.1] Setting master address to [localhost]:5801 [] 2024-09-14 13:45:18,596 DEBUG com.hazelcast.internal.cluster.impl.MembershipManager - [localhost]:5801 [seatunnel-988403] [5.1] Local member list join version is set to 1 [] 2024-09-14 13:45:18,597 DEBUG org.apache.seatunnel.engine.server.LiteNodeDropOutTcpIpJoiner - [localhost]:5801 [seatunnel-988403] [5.1] PostJoin master: [localhost]:5801, isMaster: true [] 2024-09-14 13:45:18,597 INFO com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-988403] [5.1] Members {size:1, ver:1} [ Member [localhost]:5801 - d77c7224-1706-4981-8785-81fa6c671cab this master ] [] 2024-09-14 13:45:18,628 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5801 is STARTED [] 2024-09-14 13:45:18,643 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5827 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,644 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5825 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,644 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5815 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,644 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5813 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,645 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5806 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,645 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5804 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,645 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5823 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,688 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5829 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,688 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5808 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5802 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5824 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5807 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5821 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5812 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5822 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,692 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5805 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,693 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5814 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,693 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5811 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,694 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5809 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,694 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-988403] [5.1] This node become a new active master node, begin init coordinator service [] 2024-09-14 13:45:18,694 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5830 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,695 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5810 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,698 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5819 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,698 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5803 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,698 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5828 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,698 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5817 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,698 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5826 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,698 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5816 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,696 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5818 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,697 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Connection to: [localhost]:5820 streamId:-1 is not yet in progress [] 2024-09-14 13:45:18,703 DEBUG com.hazelcast.internal.metrics.impl.MetricsConfigHelper - hz.client_1 [seatunnel-988403] [5.1] Collecting debug metrics and sending to diagnostics is disabled [] 2024-09-14 13:45:18,707 DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.metrics.JetMetricsDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook [] 2024-09-14 13:45:18,708 DEBUG com.hazelcast.internal.util.ServiceLoader - The class com.hazelcast.jet.impl.observer.JetObserverDataSerializerHook does not implement the expected interface com.hazelcast.nio.serialization.SerializerHook [] 2024-09-14 13:45:18,726 INFO com.hazelcast.client.impl.spi.ClientInvocationService - hz.client_1 [seatunnel-988403] [5.1] Running with 2 response threads, dynamic=true [] 2024-09-14 13:45:18,741 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-988403] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTING [] 2024-09-14 13:45:18,742 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-988403] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is STARTED [] 2024-09-14 13:45:18,746 DEBUG com.hazelcast.internal.networking.nio.NioNetworking - hz.client_1 [seatunnel-988403] [5.1] TcpIpConnectionManager configured with Non Blocking IO-threading model: 1 input threads and 1 output threads [] 2024-09-14 13:45:18,746 DEBUG com.hazelcast.internal.networking.nio.NioNetworking - hz.client_1 [seatunnel-988403] [5.1] write through enabled:true [] 2024-09-14 13:45:18,747 DEBUG com.hazelcast.internal.networking.nio.NioNetworking - hz.client_1 [seatunnel-988403] [5.1] IO threads selector mode is SELECT [] 2024-09-14 13:45:18,750 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-988403] [5.1] Trying to connect to cluster: seatunnel-988403 [] 2024-09-14 13:45:18,752 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-988403] [5.1] Trying to connect to [localhost]:5801 [] 2024-09-14 13:45:18,757 DEBUG com.hazelcast.internal.server.tcp.TcpServerAcceptor - [localhost]:5801 [seatunnel-988403] [5.1] Accepting socket connection from /127.0.0.1:35515 [] 2024-09-14 13:45:18,770 DEBUG com.hazelcast.internal.server.tcp.TcpServerConnectionManager - [localhost]:5801 [seatunnel-988403] [5.1] Established socket connection between /127.0.0.1:5801 and /127.0.0.1:35515 [] 2024-09-14 13:45:18,798 DEBUG com.hazelcast.client.impl.protocol.task.AuthenticationMessageTask - [localhost]:5801 [seatunnel-988403] [5.1] Processing authentication with clientUuid cf308803-a59d-4fc2-821e-9b6b8df1e8f8 and clientName hz.client_1 [] 2024-09-14 13:45:18,800 INFO com.hazelcast.client.impl.protocol.task.AuthenticationMessageTask - [localhost]:5801 [seatunnel-988403] [5.1] Received auth from Connection[id=1, /127.0.0.1:5801->/127.0.0.1:35515, qualifier=null, endpoint=[127.0.0.1]:35515, remoteUuid=cf308803-a59d-4fc2-821e-9b6b8df1e8f8, alive=true, connectionType=JVM, planeIndex=-1], successfully authenticated, clientUuid: cf308803-a59d-4fc2-821e-9b6b8df1e8f8, client name: hz.client_1, client version: 5.1 [] 2024-09-14 13:45:18,808 DEBUG com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-988403] [5.1] Checking the cluster: c6bea29f-3980-4ef0-8ddc-137330dd3cdb, current cluster: null [] 2024-09-14 13:45:18,808 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-988403] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_CONNECTED [] 2024-09-14 13:45:18,809 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-988403] [5.1] Authenticated with server [localhost]:5801:d77c7224-1706-4981-8785-81fa6c671cab, server version: 5.1, local address: /127.0.0.1:35515 [] 2024-09-14 13:45:18,819 INFO com.hazelcast.internal.diagnostics.Diagnostics - hz.client_1 [seatunnel-988403] [5.1] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments. [] 2024-09-14 13:45:18,836 DEBUG com.hazelcast.client.impl.spi.ClientClusterService - hz.client_1 [seatunnel-988403] [5.1] Resetting the member list version [] 2024-09-14 13:45:18,856 DEBUG com.hazelcast.client.impl.spi.ClientClusterService - hz.client_1 [seatunnel-988403] [5.1] There are internal addresses of members used in the config. The client will use internal addresses [] 2024-09-14 13:45:18,856 INFO com.hazelcast.client.impl.spi.ClientClusterService - hz.client_1 [seatunnel-988403] [5.1] Members [1] { Member [localhost]:5801 - d77c7224-1706-4981-8785-81fa6c671cab } [] 2024-09-14 13:45:18,933 INFO org.apache.seatunnel.engine.server.CoordinatorService - [localhost]:5801 [seatunnel-988403] [5.1] Loaded event handlers: [org.apache.seatunnel.api.event.LoggingEventHandler@2ee2534b] [] 2024-09-14 13:45:18,938 INFO com.hazelcast.client.impl.statistics.ClientStatisticsService - Client statistics is enabled with period 5 seconds. [] 2024-09-14 13:45:18,985 INFO com.hazelcast.internal.partition.impl.PartitionStateManager - [localhost]:5801 [seatunnel-988403] [5.1] Initializing cluster partition table arrangement... [] 2024-09-14 13:45:19,000 DEBUG com.hazelcast.flakeidgen.impl.FlakeIdGeneratorProxy - [localhost]:5801 [seatunnel-988403] [5.1] Node ID assigned to 'SeaTunnelIdGenerator': 1 [] 2024-09-14 13:45:19,016 INFO org.apache.seatunnel.core.starter.utils.ConfigBuilder - Loading config file from path: /home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-examples/seatunnel-engine-examples/target/classes/examples/file_to_file.conf [] 2024-09-14 13:45:19,027 DEBUG com.hazelcast.internal.partition.InternalPartitionService - [localhost]:5801 [seatunnel-988403] [5.1] Publishing partition state, stamp: -8661523421455686299 [] 2024-09-14 13:45:19,130 DEBUG com.hazelcast.client.impl.spi.ClientPartitionService - hz.client_1 [seatunnel-988403] [5.1] Applied partition table with partitionStateVersion : 1 [] 2024-09-14 13:45:19,237 INFO org.apache.seatunnel.core.starter.utils.ConfigShadeUtils - Load config shade spi: [base64] [] 2024-09-14 13:45:19,366 INFO org.apache.seatunnel.core.starter.utils.ConfigBuilder - Parsed config file: { "transform" : [], "sink" : [ { "path" : "/tmp/dest/", "file_format_type" : "csv", "source_table_name" : "fakedata", "plugin_name" : "LocalFile" } ], "source" : [ { "schema" : { "fields" : { "name" : "string", "age" : "int" } }, "parallelism" : 1, "result_table_name" : "fakedata", "plugin_name" : "FakeSource" } ], "env" : { "job.mode" : "BATCH", "parallelism" : 1 } } [] 2024-09-14 13:45:19,371 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - add common jar in plugins :[] [] 2024-09-14 13:45:19,379 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-common/connectors [] 2024-09-14 13:45:19,380 DEBUG org.apache.seatunnel.engine.core.parse.ConfigParserUtil - Check whether this config file can generate DAG: [] 2024-09-14 13:45:19,382 DEBUG org.apache.seatunnel.engine.core.parse.ConfigParserUtil - This is a simple DAG. [] 2024-09-14 13:45:19,384 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sources. [] 2024-09-14 13:45:19,382 WARN org.apache.seatunnel.api.configuration.util.ConfigUtil - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. [] 2024-09-14 13:45:19,443 INFO org.apache.seatunnel.api.table.factory.FactoryUtil - get the CatalogTable from source FakeSource: FakeSource.null.fakedata [] 2024-09-14 13:45:19,457 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSource Plugin from /home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-common/connectors [] 2024-09-14 13:45:19,460 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all transforms. [] 2024-09-14 13:45:19,460 INFO org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser - start generating all sinks. [] 2024-09-14 13:45:19,466 INFO org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery - Load SeaTunnelSink Plugin from /home/sudeep/projects/seatunnel-adls-connector-v2/seatunnel-common/connectors [] 2024-09-14 13:45:19,461 WARN org.apache.seatunnel.api.configuration.util.ConfigUtil - Option 'source_table_name' is a List, and it is recommended to configure it as ["string1","string2"]; we will only use ',' to split the String into a list. [] 2024-09-14 13:45:19,466 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-988403] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTTING_DOWN [] 2024-09-14 13:45:19,472 INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [localhost]:5801 [seatunnel-988403] [5.1] Connection[id=1, /127.0.0.1:5801->/127.0.0.1:35515, qualifier=null, endpoint=[127.0.0.1]:35515, remoteUuid=cf308803-a59d-4fc2-821e-9b6b8df1e8f8, alive=false, connectionType=JVM, planeIndex=-1] closed. Reason: Connection closed by the other side [] 2024-09-14 13:45:19,494 DEBUG com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-988403] [5.1] Removed connection to [127.0.0.1]:35515 [] 2024-09-14 13:45:19,496 INFO com.hazelcast.client.impl.connection.ClientConnectionManager - hz.client_1 [seatunnel-988403] [5.1] Removed connection to endpoint: [localhost]:5801:d77c7224-1706-4981-8785-81fa6c671cab, connection: ClientConnection{alive=false, connectionId=1, channel=NioChannel{/127.0.0.1:35515->localhost/127.0.0.1:5801}, remoteAddress=[localhost]:5801, lastReadTime=2024-09-14 13:45:19.130, lastWriteTime=2024-09-14 13:45:18.997, closedTime=2024-09-14 13:45:19.467, connected server version=5.1} [] 2024-09-14 13:45:19,497 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-988403] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED [] 2024-09-14 13:45:19,529 DEBUG com.hazelcast.internal.server.tcp.LocalAddressRegistry - [localhost]:5801 [seatunnel-988403] [5.1] LinkedAddresses{primaryAddress=[127.0.0.1]:35515, allLinkedAddresses=[[127.0.0.1]:35515]} previously registered for the instance uuid=cf308803-a59d-4fc2-821e-9b6b8df1e8f8 are removed from the registry [] 2024-09-14 13:45:19,529 INFO com.hazelcast.client.impl.ClientEndpointManager - [localhost]:5801 [seatunnel-988403] [5.1] Destroying ClientEndpoint{connection=Connection[id=1, /127.0.0.1:5801->/127.0.0.1:35515, qualifier=null, endpoint=[127.0.0.1]:35515, remoteUuid=cf308803-a59d-4fc2-821e-9b6b8df1e8f8, alive=false, connectionType=JVM, planeIndex=-1], clientUuid=cf308803-a59d-4fc2-821e-9b6b8df1e8f8, clientName=hz.client_1, authenticated=true, clientVersion=5.1, creationTime=1726301718792, latest clientAttributes=lastStatisticsCollectionTime=1726301718942,enterprise=false,clientType=JVM,clientVersion=5.1,clusterConnectionTimestamp=1726301718756,clientAddress=127.0.0.1,clientName=hz.client_1,credentials.principal=null,os.committedVirtualMemorySize=5810511872,os.freePhysicalMemorySize=167219200,os.freeSwapSpaceSize=1776254976,os.maxFileDescriptorCount=1048576,os.openFileDescriptorCount=185,os.processCpuTime=6130000000,os.systemLoadAverage=2.2744140625,os.totalPhysicalMemorySize=832 7184384,os.totalSwapSpaceSize=4294963200,runtime.availableProcessors=4,runtime.freeMemory=325666080,runtime.maxMemory=1851260928,runtime.totalMemory=509607936,runtime.uptime=4397,runtime.usedMemory=183941856, labels=[]} [] 2024-09-14 13:45:19,541 INFO com.hazelcast.core.LifecycleService - hz.client_1 [seatunnel-988403] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN [] 2024-09-14 13:45:19,547 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed SeaTunnel client...... [] 2024-09-14 13:45:19,547 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5801 is SHUTTING_DOWN [] 2024-09-14 13:45:19,592 DEBUG com.hazelcast.internal.crdt.CRDTReplicationMigrationService - [localhost]:5801 [seatunnel-988403] [5.1] Skipping replication since all CRDTs are replicated [] 2024-09-14 13:45:19,592 INFO com.hazelcast.internal.partition.impl.MigrationManager - [localhost]:5801 [seatunnel-988403] [5.1] Shutdown request of Member [localhost]:5801 - d77c7224-1706-4981-8785-81fa6c671cab this master is handled [] 2024-09-14 13:45:19,592 DEBUG com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Graceful shutdown completed for CRDTReplicationMigrationService{} [] 2024-09-14 13:45:19,593 DEBUG com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Graceful shutdown completed for com.hazelcast.cp.internal.session.ProxySessionManagerService@6a9f78a4 [] 2024-09-14 13:45:19,593 DEBUG com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Graceful shutdown completed for com.hazelcast.cp.internal.RaftService@10895b16 [] 2024-09-14 13:45:19,600 DEBUG com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Graceful shutdown completed for InternalPartitionService {stamp: -8661523421455686299, migrationQ: 0} [] 2024-09-14 13:45:19,603 DEBUG com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-988403] [5.1] Setting master address to null [] 2024-09-14 13:45:19,607 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Shutting down connection manager... [] 2024-09-14 13:45:19,628 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Shutting down node engine... [] 2024-09-14 13:45:19,666 INFO org.apache.seatunnel.engine.core.classloader.DefaultClassLoaderService - close classloader service [] 2024-09-14 13:45:19,701 INFO org.apache.seatunnel.engine.server.EventService - Event forward thread interrupted [] 2024-09-14 13:45:19,702 DEBUG com.hazelcast.internal.cluster.ClusterService - [localhost]:5801 [seatunnel-988403] [5.1] Setting master address to null [] 2024-09-14 13:45:20,057 INFO com.hazelcast.instance.impl.NodeExtension - [localhost]:5801 [seatunnel-988403] [5.1] Destroying node NodeExtension. [] 2024-09-14 13:45:20,058 INFO com.hazelcast.instance.impl.Node - [localhost]:5801 [seatunnel-988403] [5.1] Hazelcast Shutdown is completed in 468 ms. [] 2024-09-14 13:45:20,059 INFO com.hazelcast.core.LifecycleService - [localhost]:5801 [seatunnel-988403] [5.1] [localhost]:5801 is SHUTDOWN [] 2024-09-14 13:45:20,059 INFO org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand - Closed HazelcastInstance ...... [] 2024-09-14 13:45:20,059 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== [] 2024-09-14 13:45:20,059 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Fatal Error, [] 2024-09-14 13:45:20,059 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Please submit bug report in https://github.com/apache/seatunnel/issues [] 2024-09-14 13:45:20,059 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Reason:SeaTunnel job executed failed [] 2024-09-14 13:45:20,061 ERROR org.apache.seatunnel.core.starter.SeaTunnel - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:213) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.example.engine.SeaTunnelEngineExample.main(SeaTunnelEngineExample.java:43) Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='LocalFile'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:237) at org.apache.seatunnel.engine.core.parse.ConnectorInstanceLoader.loadSinkInstance(ConnectorInstanceLoader.java:77) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSink(JobConfigParser.java:161) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSinks(JobConfigParser.java:137) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:560) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:221) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160) ... 2 more [] 2024-09-14 13:45:20,061 ERROR org.apache.seatunnel.core.starter.SeaTunnel - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:213) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.example.engine.SeaTunnelEngineExample.main(SeaTunnelEngineExample.java:43) Caused by: java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='sink', pluginName='LocalFile'} not found. at org.apache.seatunnel.plugin.discovery.AbstractPluginDiscovery.createPluginInstance(AbstractPluginDiscovery.java:237) at org.apache.seatunnel.engine.core.parse.ConnectorInstanceLoader.loadSinkInstance(ConnectorInstanceLoader.java:77) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSink(JobConfigParser.java:161) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSinks(JobConfigParser.java:137) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:560) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:221) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160) ... 2 more Process finished with exit code 1 ``` -- 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, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
