James601232 commented on issue #3963: URL: https://github.com/apache/hudi/issues/3963#issuecomment-966696290
fully logs: /Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/bin/java -javaagent:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar=50622:/Applications/IntelliJ IDEA.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/ jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtu alMachines/jdk1.8.0_311.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home/lib/tools.jar:/Users/yangcailiang/Codes/HudiTest/target/classes:/Users/yangcailiang/.m2/repository/javax/servlet/javax.servlet-api/3.1.0/javax.servlet-api-3.1.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-java-client/0.9.0/hudi-java-client-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-client-common/0.9.0/hudi-client-common-0.9.0.jar:/Users/yangcailia ng/.m2/repository/joda-time/joda-time/2.9.9/joda-time-2.9.9.jar:/Users/yangcailiang/.m2/repository/io/dropwizard/metrics/metrics-graphite/4.1.1/metrics-graphite-4.1.1.jar:/Users/yangcailiang/.m2/repository/io/dropwizard/metrics/metrics-core/4.1.1/metrics-core-4.1.1.jar:/Users/yangcailiang/.m2/repository/io/dropwizard/metrics/metrics-jmx/4.1.1/metrics-jmx-4.1.1.jar:/Users/yangcailiang/.m2/repository/io/prometheus/simpleclient/0.8.0/simpleclient-0.8.0.jar:/Users/yangcailiang/.m2/repository/io/prometheus/simpleclient_httpserver/0.8.0/simpleclient_httpserver-0.8.0.jar:/Users/yangcailiang/.m2/repository/io/prometheus/simpleclient_common/0.8.0/simpleclient_common-0.8.0.jar:/Users/yangcailiang/.m2/repository/io/prometheus/simpleclient_dropwizard/0.8.0/simpleclient_dropwizard-0.8.0.jar:/Users/yangcailiang/.m2/repository/io/prometheus/simpleclient_pushgateway/0.8.0/simpleclient_pushgateway-0.8.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-hdfs/2.7.3/hadoop-hdfs-2.7.3-test s.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-common/2.7.3/hadoop-common-2.7.3-tests.jar:/Users/yangcailiang/.m2/repository/org/apache/curator/curator-framework/2.7.1/curator-framework-2.7.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-spark-bundle_2.12/0.9.0/hudi-spark-bundle_2.12-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-common/2.7.3/hadoop-common-2.7.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-annotations/2.7.3/hadoop-annotations-2.7.3.jar:/Users/yangcailiang/.m2/repository/com/google/guava/guava/11.0.2/guava-11.0.2.jar:/Users/yangcailiang/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/Users/yangcailiang/.m2/repository/org/apache/commons/commons-math3/3.1.1/commons-math3-3.1.1.jar:/Users/yangcailiang/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/Users/yangcailiang/.m2/repository/commons-httpclient/commons-httpclient/3.1/commons-httpclient-3.1.jar:/Users/yangcailiang/.m2/repo sitory/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/Users/yangcailiang/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/yangcailiang/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/Users/yangcailiang/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/yangcailiang/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/Users/yangcailiang/.m2/repository/org/mortbay/jetty/jetty/6.1.26/jetty-6.1.26.jar:/Users/yangcailiang/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26/jetty-util-6.1.26.jar:/Users/yangcailiang/.m2/repository/javax/servlet/jsp/jsp-api/2.1/jsp-api-2.1.jar:/Users/yangcailiang/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar:/Users/yangcailiang/.m2/repository/com/sun/jersey/jersey-json/1.9/jersey-json-1.9.jar:/Users/yangcailiang/.m2/repository/org/codehaus/jettison/jettison/1.1/jettison-1.1.jar:/Users/yangcailiang/.m2/repository/com/sun/xml/bind/jaxb-impl /2.2.3-1/jaxb-impl-2.2.3-1.jar:/Users/yangcailiang/.m2/repository/javax/xml/bind/jaxb-api/2.2.2/jaxb-api-2.2.2.jar:/Users/yangcailiang/.m2/repository/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar:/Users/yangcailiang/.m2/repository/javax/activation/activation/1.1/activation-1.1.jar:/Users/yangcailiang/.m2/repository/org/codehaus/jackson/jackson-jaxrs/1.8.3/jackson-jaxrs-1.8.3.jar:/Users/yangcailiang/.m2/repository/org/codehaus/jackson/jackson-xc/1.8.3/jackson-xc-1.8.3.jar:/Users/yangcailiang/.m2/repository/com/sun/jersey/jersey-server/1.9/jersey-server-1.9.jar:/Users/yangcailiang/.m2/repository/asm/asm/3.1/asm-3.1.jar:/Users/yangcailiang/.m2/repository/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/Users/yangcailiang/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/Users/yangcailiang/.m2/repository/net/java/dev/jets3t/jets3t/0.9.0/jets3t-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/httpcomponents/httpclient/4.1.2/httpclient-4.1.2.jar:/Users/yangca iliang/.m2/repository/org/apache/httpcomponents/httpcore/4.1.2/httpcore-4.1.2.jar:/Users/yangcailiang/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.4/java-xmlbuilder-0.4.jar:/Users/yangcailiang/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/yangcailiang/.m2/repository/commons-configuration/commons-configuration/1.6/commons-configuration-1.6.jar:/Users/yangcailiang/.m2/repository/commons-digester/commons-digester/1.8/commons-digester-1.8.jar:/Users/yangcailiang/.m2/repository/commons-beanutils/commons-beanutils/1.7.0/commons-beanutils-1.7.0.jar:/Users/yangcailiang/.m2/repository/commons-beanutils/commons-beanutils-core/1.8.0/commons-beanutils-core-1.8.0.jar:/Users/yangcailiang/.m2/repository/org/slf4j/slf4j-api/1.7.10/slf4j-api-1.7.10.jar:/Users/yangcailiang/.m2/repository/org/slf4j/slf4j-log4j12/1.7.10/slf4j-log4j12-1.7.10.jar:/Users/yangcailiang/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/yangcaili ang/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/Users/yangcailiang/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/Users/yangcailiang/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-auth/2.7.3/hadoop-auth-2.7.3.jar:/Users/yangcailiang/.m2/repository/org/apache/directory/server/apacheds-kerberos-codec/2.0.0-M15/apacheds-kerberos-codec-2.0.0-M15.jar:/Users/yangcailiang/.m2/repository/org/apache/directory/server/apacheds-i18n/2.0.0-M15/apacheds-i18n-2.0.0-M15.jar:/Users/yangcailiang/.m2/repository/org/apache/directory/api/api-asn1-api/1.0.0-M20/api-asn1-api-1.0.0-M20.jar:/Users/yangcailiang/.m2/repository/org/apache/directory/api/api-util/1.0.0-M20/api-util-1.0.0-M20.jar:/Users/yangcailiang/.m2/repository/com/jcraft/jsch/0.1.42/jsch-0.1.42.jar:/Users/yangcailiang/.m2/repository/org/apache/curator/curator-client/2.7.1/curator-client-2 .7.1.jar:/Users/yangcailiang/.m2/repository/org/apache/curator/curator-recipes/2.7.1/curator-recipes-2.7.1.jar:/Users/yangcailiang/.m2/repository/com/google/code/findbugs/jsr305/3.0.0/jsr305-3.0.0.jar:/Users/yangcailiang/.m2/repository/org/apache/htrace/htrace-core/3.1.0-incubating/htrace-core-3.1.0-incubating.jar:/Users/yangcailiang/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6.jar:/Users/yangcailiang/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-hdfs/2.7.3/hadoop-hdfs-2.7.3.jar:/Users/yangcailiang/.m2/repository/commons-daemon/commons-daemon/1.0.13/commons-daemon-1.0.13.jar:/Users/yangcailiang/.m2/repository/io/netty/netty/3.6.2.Final/netty-3.6.2.Final.jar:/Users/yangcailiang/.m2/repository/io/netty/netty-all/4.0.23.Final/netty-all-4.0.23.Final.jar:/Users/yangcailiang/.m2/repository/xerces/xercesImpl/2.9.1/xercesImpl-2.9.1.jar:/Users/yangcailiang/.m2/repository/x ml-apis/xml-apis/1.3.04/xml-apis-1.3.04.jar:/Users/yangcailiang/.m2/repository/org/fusesource/leveldbjni/leveldbjni-all/1.8/leveldbjni-all-1.8.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-examples/0.9.0/hudi-examples-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/scala-lang/scala-library/2.11.12/scala-library-2.11.12.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-common/0.9.0/hudi-common-0.9.0.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.6.7/jackson-annotations-2.6.7.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.6.7.3/jackson-databind-2.6.7.3.jar:/Users/yangcailiang/.m2/repository/org/apache/orc/orc-core/1.6.0/orc-core-1.6.0-nohive.jar:/Users/yangcailiang/.m2/repository/org/apache/orc/orc-shims/1.6.0/orc-shims-1.6.0.jar:/Users/yangcailiang/.m2/repository/io/airlift/aircompressor/0.15/aircompressor-0.15.jar:/Users/yangcailiang/.m2/repository/org/apache/hive/hive-storage-api /2.6.0/hive-storage-api-2.6.0.jar:/Users/yangcailiang/.m2/repository/org/jetbrains/annotations/17.0.0/annotations-17.0.0.jar:/Users/yangcailiang/.m2/repository/org/apache/httpcomponents/fluent-hc/4.4.1/fluent-hc-4.4.1.jar:/Users/yangcailiang/.m2/repository/org/rocksdb/rocksdbjni/5.17.2/rocksdbjni-5.17.2.jar:/Users/yangcailiang/.m2/repository/com/esotericsoftware/kryo-shaded/4.0.2/kryo-shaded-4.0.2.jar:/Users/yangcailiang/.m2/repository/com/esotericsoftware/minlog/1.3.0/minlog-1.3.0.jar:/Users/yangcailiang/.m2/repository/org/objenesis/objenesis/2.5.1/objenesis-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-server/1.2.3/hbase-server-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-common/1.2.3/hbase-common-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-annotations/1.2.3/hbase-annotations-1.2.3.jar:/Users/yangcailiang/.m2/repository/com/github/stephenc/findbugs/findbugs-annotations/1.3.9-1/findbugs-annotations-1.3.9-1.jar:/Us ers/yangcailiang/.m2/repository/org/apache/hbase/hbase-protocol/1.2.3/hbase-protocol-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-procedure/1.2.3/hbase-procedure-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-common/1.2.3/hbase-common-1.2.3-tests.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-client/1.2.3/hbase-client-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/jruby/jcodings/jcodings/1.0.8/jcodings-1.0.8.jar:/Users/yangcailiang/.m2/repository/org/jruby/joni/joni/2.1.2/joni-2.1.2.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-prefix-tree/1.2.3/hbase-prefix-tree-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-hadoop-compat/1.2.3/hbase-hadoop-compat-1.2.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hbase/hbase-hadoop2-compat/1.2.3/hbase-hadoop2-compat-1.2.3.jar:/Users/yangcailiang/.m2/repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/Users/yangcailiang/.m2/re pository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/Users/yangcailiang/.m2/repository/org/jamon/jamon-runtime/2.4.1/jamon-runtime-2.4.1.jar:/Users/yangcailiang/.m2/repository/com/lmax/disruptor/3.3.0/disruptor-3.3.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-client/2.5.1/hadoop-client-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-app/2.5.1/hadoop-mapreduce-client-app-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-common/2.5.1/hadoop-mapreduce-client-common-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-yarn-client/2.5.1/hadoop-yarn-client-2.5.1.jar:/Users/yangcailiang/.m2/repository/com/sun/jersey/jersey-client/1.9/jersey-client-1.9.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-yarn-server-common/2.5.1/hadoop-yarn-server-common-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-shuffle/2.5.1/ hadoop-mapreduce-client-shuffle-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-yarn-api/2.5.1/hadoop-yarn-api-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-jobclient/2.5.1/hadoop-mapreduce-client-jobclient-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-core/2.5.1/hadoop-mapreduce-client-core-2.5.1.jar:/Users/yangcailiang/.m2/repository/org/apache/hadoop/hadoop-yarn-common/2.5.1/hadoop-yarn-common-2.5.1.jar:/Users/yangcailiang/.m2/repository/com/google/inject/guice/3.0/guice-3.0.jar:/Users/yangcailiang/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/Users/yangcailiang/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/Users/yangcailiang/.m2/repository/com/sun/jersey/contribs/jersey-guice/1.9/jersey-guice-1.9.jar:/Users/yangcailiang/.m2/repository/com/google/inject/extensions/guice-servlet/3.0/guice-servlet-3.0.jar:/Users/yangcailiang/.m2/repository/junit /junit/4.12/junit-4.12.jar:/Users/yangcailiang/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-cli/0.9.0/hudi-cli-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-utilities-bundle_2.11/0.9.0/hudi-utilities-bundle_2.11-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/springframework/shell/spring-shell/1.2.0.RELEASE/spring-shell-1.2.0.RELEASE.jar:/Users/yangcailiang/.m2/repository/jline/jline/2.12/jline-2.12.jar:/Users/yangcailiang/.m2/repository/org/springframework/spring-context-support/4.2.4.RELEASE/spring-context-support-4.2.4.RELEASE.jar:/Users/yangcailiang/.m2/repository/org/springframework/spring-beans/4.2.4.RELEASE/spring-beans-4.2.4.RELEASE.jar:/Users/yangcailiang/.m2/repository/org/springframework/spring-context/4.2.4.RELEASE/spring-context-4.2.4.RELEASE.jar:/Users/yangcailiang/.m2/repository/org/springframework/spring-aop/4.2.4.RELEASE/spring-aop-4.2.4.RELEASE.jar:/Users/yangcailian g/.m2/repository/org/springframework/spring-expression/4.2.4.RELEASE/spring-expression-4.2.4.RELEASE.jar:/Users/yangcailiang/.m2/repository/org/springframework/spring-core/4.2.4.RELEASE/spring-core-4.2.4.RELEASE.jar:/Users/yangcailiang/.m2/repository/com/jakewharton/fliptables/fliptables/1.0.2/fliptables-1.0.2.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-spark-client/0.9.0/hudi-spark-client-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-utilities_2.11/0.9.0/hudi-utilities_2.11-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-hive-sync/0.9.0/hudi-hive-sync-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-spark-common_2.11/0.9.0/hudi-spark-common_2.11-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-spark2_2.11/0.9.0/hudi-spark2_2.11-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/kafka/kafka-clients/2.0.0/kafka-clients-2.0.0.jar:/Users/yangcailiang/.m2/repository/org/lz4/lz4-java/1.4.1/lz4-ja va-1.4.1.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/module/jackson-module-scala_2.11/2.6.7.1/jackson-module-scala_2.11-2.6.7.1.jar:/Users/yangcailiang/.m2/repository/org/scala-lang/scala-reflect/2.11.8/scala-reflect-2.11.8.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/module/jackson-module-paranamer/2.7.9/jackson-module-paranamer-2.7.9.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-csv/2.6.7/jackson-dataformat-csv-2.6.7.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-streaming_2.11/2.4.4/spark-streaming_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-core_2.11/2.4.4/spark-core_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/avro/avro-mapred/1.8.2/avro-mapred-1.8.2-hadoop2.jar:/Users/yangcailiang/.m2/repository/org/apache/avro/avro-ipc/1.8.2/avro-ipc-1.8.2.jar:/Users/yangcailiang/.m2/repository/com/twitter/chill_2.11/0.9.3/chill_2.11-0.9.3.jar:/Users/yangca iliang/.m2/repository/com/twitter/chill-java/0.9.3/chill-java-0.9.3.jar:/Users/yangcailiang/.m2/repository/org/apache/xbean/xbean-asm6-shaded/4.8/xbean-asm6-shaded-4.8.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-launcher_2.11/2.4.4/spark-launcher_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-kvstore_2.11/2.4.4/spark-kvstore_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-network-common_2.11/2.4.4/spark-network-common_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-network-shuffle_2.11/2.4.4/spark-network-shuffle_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-unsafe_2.11/2.4.4/spark-unsafe_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/commons/commons-lang3/3.5/commons-lang3-3.5.jar:/Users/yangcailiang/.m2/repository/org/slf4j/jul-to-slf4j/1.7.16/jul-to-slf4j-1.7.16.jar:/Users/yangcailiang/.m2/repository/org/slf4j/jcl-over-slf4j/1.7.16/jcl-over-slf4j- 1.7.16.jar:/Users/yangcailiang/.m2/repository/com/ning/compress-lzf/1.0.3/compress-lzf-1.0.3.jar:/Users/yangcailiang/.m2/repository/com/github/luben/zstd-jni/1.3.2-2/zstd-jni-1.3.2-2.jar:/Users/yangcailiang/.m2/repository/org/roaringbitmap/RoaringBitmap/0.7.45/RoaringBitmap-0.7.45.jar:/Users/yangcailiang/.m2/repository/org/roaringbitmap/shims/0.7.45/shims-0.7.45.jar:/Users/yangcailiang/.m2/repository/org/json4s/json4s-jackson_2.11/3.5.3/json4s-jackson_2.11-3.5.3.jar:/Users/yangcailiang/.m2/repository/org/json4s/json4s-core_2.11/3.5.3/json4s-core_2.11-3.5.3.jar:/Users/yangcailiang/.m2/repository/org/json4s/json4s-ast_2.11/3.5.3/json4s-ast_2.11-3.5.3.jar:/Users/yangcailiang/.m2/repository/org/json4s/json4s-scalap_2.11/3.5.3/json4s-scalap_2.11-3.5.3.jar:/Users/yangcailiang/.m2/repository/org/scala-lang/modules/scala-xml_2.11/1.0.6/scala-xml_2.11-1.0.6.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/core/jersey-client/2.22.2/jersey-client-2.22.2.jar:/Users/yangcailiang/.m2/r epository/javax/ws/rs/javax.ws.rs-api/2.0.1/javax.ws.rs-api-2.0.1.jar:/Users/yangcailiang/.m2/repository/org/glassfish/hk2/hk2-api/2.4.0-b34/hk2-api-2.4.0-b34.jar:/Users/yangcailiang/.m2/repository/org/glassfish/hk2/hk2-utils/2.4.0-b34/hk2-utils-2.4.0-b34.jar:/Users/yangcailiang/.m2/repository/org/glassfish/hk2/external/aopalliance-repackaged/2.4.0-b34/aopalliance-repackaged-2.4.0-b34.jar:/Users/yangcailiang/.m2/repository/org/glassfish/hk2/external/javax.inject/2.4.0-b34/javax.inject-2.4.0-b34.jar:/Users/yangcailiang/.m2/repository/org/glassfish/hk2/hk2-locator/2.4.0-b34/hk2-locator-2.4.0-b34.jar:/Users/yangcailiang/.m2/repository/org/javassist/javassist/3.18.1-GA/javassist-3.18.1-GA.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/core/jersey-common/2.22.2/jersey-common-2.22.2.jar:/Users/yangcailiang/.m2/repository/javax/annotation/javax.annotation-api/1.2/javax.annotation-api-1.2.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/bundles/repackaged/jersey-guav a/2.22.2/jersey-guava-2.22.2.jar:/Users/yangcailiang/.m2/repository/org/glassfish/hk2/osgi-resource-locator/1.0.1/osgi-resource-locator-1.0.1.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/core/jersey-server/2.22.2/jersey-server-2.22.2.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/media/jersey-media-jaxb/2.22.2/jersey-media-jaxb-2.22.2.jar:/Users/yangcailiang/.m2/repository/javax/validation/validation-api/1.1.0.Final/validation-api-1.1.0.Final.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/containers/jersey-container-servlet/2.22.2/jersey-container-servlet-2.22.2.jar:/Users/yangcailiang/.m2/repository/org/glassfish/jersey/containers/jersey-container-servlet-core/2.22.2/jersey-container-servlet-core-2.22.2.jar:/Users/yangcailiang/.m2/repository/com/clearspring/analytics/stream/2.7.0/stream-2.7.0.jar:/Users/yangcailiang/.m2/repository/io/dropwizard/metrics/metrics-jvm/3.1.5/metrics-jvm-3.1.5.jar:/Users/yangcailiang/.m2/repository/io/dropwizard/m etrics/metrics-json/3.1.5/metrics-json-3.1.5.jar:/Users/yangcailiang/.m2/repository/oro/oro/2.0.8/oro-2.0.8.jar:/Users/yangcailiang/.m2/repository/net/razorvine/pyrolite/4.13/pyrolite-4.13.jar:/Users/yangcailiang/.m2/repository/net/sf/py4j/py4j/0.10.7/py4j-0.10.7.jar:/Users/yangcailiang/.m2/repository/org/apache/commons/commons-crypto/1.0.0/commons-crypto-1.0.0.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-tags_2.11/2.4.4/spark-tags_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/spark-project/spark/unused/1.0.0/unused-1.0.0.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-streaming-kafka-0-10_2.11/2.4.4/spark-streaming-kafka-0-10_2.11-2.4.4.jar:/Users/yangcailiang/.m2/repository/org/apache/spark/spark-streaming-kafka-0-10_2.11/2.4.4/spark-streaming-kafka-0-10_2.11-2.4.4-tests.jar:/Users/yangcailiang/.m2/repository/org/antlr/stringtemplate/4.0.2/stringtemplate-4.0.2.jar:/Users/yangcailiang/.m2/repository/org/antlr/antlr-runtime/3.3/antlr-runtime-3. 3.jar:/Users/yangcailiang/.m2/repository/com/beust/jcommander/1.72/jcommander-1.72.jar:/Users/yangcailiang/.m2/repository/com/twitter/bijection-avro_2.11/0.9.3/bijection-avro_2.11-0.9.3.jar:/Users/yangcailiang/.m2/repository/com/twitter/bijection-core_2.11/0.9.3/bijection-core_2.11-0.9.3.jar:/Users/yangcailiang/.m2/repository/org/scoverage/scalac-scoverage-runtime_2.11/1.3.0/scalac-scoverage-runtime_2.11-1.3.0.jar:/Users/yangcailiang/.m2/repository/io/confluent/kafka-avro-serializer/5.3.4/kafka-avro-serializer-5.3.4.jar:/Users/yangcailiang/.m2/repository/io/confluent/common-config/5.3.4/common-config-5.3.4.jar:/Users/yangcailiang/.m2/repository/io/confluent/common-utils/5.3.4/common-utils-5.3.4.jar:/Users/yangcailiang/.m2/repository/com/101tec/zkclient/0.10/zkclient-0.10.jar:/Users/yangcailiang/.m2/repository/io/confluent/kafka-schema-registry-client/5.3.4/kafka-schema-registry-client-5.3.4.jar:/Users/yangcailiang/.m2/repository/com/amazonaws/aws-java-sdk-sqs/1.12.22/aws-java-sdk-sq s-1.12.22.jar:/Users/yangcailiang/.m2/repository/com/amazonaws/aws-java-sdk-core/1.12.22/aws-java-sdk-core-1.12.22.jar:/Users/yangcailiang/.m2/repository/software/amazon/ion/ion-java/1.0.2/ion-java-1.0.2.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-cbor/2.12.3/jackson-dataformat-cbor-2.12.3.jar:/Users/yangcailiang/.m2/repository/com/amazonaws/jmespath-java/1.12.22/jmespath-java-1.12.22.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-spark_2.11/0.9.0/hudi-spark_2.11-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-sync-common/0.9.0/hudi-sync-common-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-hadoop-mr/0.9.0/hudi-hadoop-mr-0.9.0.jar:/Users/yangcailiang/.m2/repository/org/apache/hudi/hudi-timeline-service/0.9.0/hudi-timeline-service-0.9.0.jar:/Users/yangcailiang/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.6.7/jackson-core-2.6.7.jar:/Users/yangcailiang/.m2/repository/io/javalin/ javalin/2.8.0/javalin-2.8.0.jar:/Users/yangcailiang/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk8/1.2.71/kotlin-stdlib-jdk8-1.2.71.jar:/Users/yangcailiang/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib/1.2.71/kotlin-stdlib-1.2.71.jar:/Users/yangcailiang/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-common/1.2.71/kotlin-stdlib-common-1.2.71.jar:/Users/yangcailiang/.m2/repository/org/jetbrains/kotlin/kotlin-stdlib-jdk7/1.2.71/kotlin-stdlib-jdk7-1.2.71.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-server/9.4.15.v20190215/jetty-server-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-http/9.4.15.v20190215/jetty-http-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-util/9.4.15.v20190215/jetty-util-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-io/9.4.15.v20190215/jetty-io-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-webapp/9.4.1 5.v20190215/jetty-webapp-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-xml/9.4.15.v20190215/jetty-xml-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-servlet/9.4.15.v20190215/jetty-servlet-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-security/9.4.15.v20190215/jetty-security-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/websocket/websocket-server/9.4.15.v20190215/websocket-server-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/websocket/websocket-common/9.4.15.v20190215/websocket-common-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/websocket/websocket-api/9.4.15.v20190215/websocket-api-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/websocket/websocket-client/9.4.15.v20190215/websocket-client-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/jetty-client/ 9.4.15.v20190215/jetty-client-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/eclipse/jetty/websocket/websocket-servlet/9.4.15.v20190215/websocket-servlet-9.4.15.v20190215.jar:/Users/yangcailiang/.m2/repository/org/apache/parquet/parquet-hadoop/1.10.1/parquet-hadoop-1.10.1.jar:/Users/yangcailiang/.m2/repository/org/apache/parquet/parquet-column/1.10.1/parquet-column-1.10.1.jar:/Users/yangcailiang/.m2/repository/org/apache/parquet/parquet-common/1.10.1/parquet-common-1.10.1.jar:/Users/yangcailiang/.m2/repository/org/apache/parquet/parquet-encoding/1.10.1/parquet-encoding-1.10.1.jar:/Users/yangcailiang/.m2/repository/org/apache/parquet/parquet-format/2.4.0/parquet-format-2.4.0.jar:/Users/yangcailiang/.m2/repository/org/apache/parquet/parquet-jackson/1.10.1/parquet-jackson-1.10.1.jar:/Users/yangcailiang/.m2/repository/commons-pool/commons-pool/1.6/commons-pool-1.6.jar:/Users/yangcailiang/.m2/repository/org/apache/avro/avro/1.8.2/avro-1.8.2.jar:/Users/yangcailiang/.m2/reposi tory/com/thoughtworks/paranamer/paranamer/2.7/paranamer-2.7.jar:/Users/yangcailiang/.m2/repository/org/xerial/snappy/snappy-java/1.1.1.3/snappy-java-1.1.1.3.jar:/Users/yangcailiang/.m2/repository/org/tukaani/xz/1.5/xz-1.5.jar:/Users/yangcailiang/.m2/repository/org/apache/ivy/ivy/2.4.0/ivy-2.4.0.jar:/Users/yangcailiang/.m2/repository/org/codehaus/groovy/groovy-all/2.4.5/groovy-all-2.4.5.jar com.tx.bigdata.HoodieJavaWriteClientExample 0 [main] WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 20607 [main] INFO org.apache.hadoop.ipc.Client - Retrying connect to server: tob23.bigdata.net/101.162.133.154:9000. Already tried 0 time(s); maxRetries=45 40622 [main] INFO org.apache.hadoop.ipc.Client - Retrying connect to server: tob23.bigdata.net/101.162.133.154:9000. Already tried 1 time(s); maxRetries=45 60626 [main] INFO org.apache.hadoop.ipc.Client - Retrying connect to server: tob23.bigdata.net/101.162.133.154:9000. Already tried 2 time(s); maxRetries=45 80709 [main] INFO org.apache.hadoop.ipc.Client - Retrying connect to server: tob23.bigdata.net/101.162.133.154:9000. Already tried 3 time(s); maxRetries=45 81136 [main] INFO org.apache.hudi.client.embedded.EmbeddedTimelineService - Starting Timeline service !! 81136 [main] WARN org.apache.hudi.client.embedded.EmbeddedTimelineService - Unable to find driver bind address from spark config 81147 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating View Manager with storage type :MEMORY 81147 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating in-memory based Table View 81160 [main] INFO org.apache.hudi.org.apache.jetty.util.log - Logging initialized @81966ms to org.apache.hudi.org.apache.jetty.util.log.Slf4jLog 81371 [main] INFO io.javalin.Javalin - __ __ _ / /____ _ _ __ ____ _ / /(_)____ __ / // __ `/| | / // __ `// // // __ \ / /_/ // /_/ / | |/ // /_/ // // // / / / \____/ \__,_/ |___/ \__,_//_//_//_/ /_/ https://javalin.io/documentation 81372 [main] INFO io.javalin.Javalin - Starting Javalin ... 81497 [main] INFO io.javalin.Javalin - Listening on http://localhost:50730/ 81497 [main] INFO io.javalin.Javalin - Javalin started in 128ms \o/ 81497 [main] INFO org.apache.hudi.timeline.service.TimelineService - Starting Timeline server on port :50730 81497 [main] INFO org.apache.hudi.client.embedded.EmbeddedTimelineService - Started embedded timeline server at 0.0.0.0:50730 81507 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 81557 [main] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 81833 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 81833 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading Active commit timeline for /home/work/hudi_catalog4 82094 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211111203048__commit__COMPLETED]} 82096 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating View Manager with storage type :REMOTE_FIRST 82096 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating remote first table view 82142 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 82191 [main] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 82313 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 82313 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading Active commit timeline for /home/work/hudi_catalog4 82435 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211111203048__commit__COMPLETED]} 82439 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 82482 [main] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 82638 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 82638 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading Active commit timeline for /home/work/hudi_catalog4 82679 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211111203048__commit__COMPLETED]} 82681 [main] INFO org.apache.hudi.client.AbstractHoodieWriteClient - Generate a new instant time: 20211112071954 action: commit 82682 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Creating a new instant [==>20211112071954__commit__REQUESTED] 82826 [main] INFO com.tx.bigdata.HoodieJavaWriteClientExample - Starting commit 20211112071954 82878 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 83122 [main] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 83201 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 83201 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading Active commit timeline for /home/work/hudi_catalog4 83246 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[==>20211112071954__commit__REQUESTED]} 83246 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating View Manager with storage type :REMOTE_FIRST 83246 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating remote first table view 83445 [main] INFO org.apache.hudi.client.AsyncCleanerService - Async auto cleaning is not enabled. Not running cleaner now 83619 [main] INFO org.apache.hudi.table.action.commit.BaseJavaCommitActionExecutor - Workload profile :WorkloadProfile {globalStat=WorkloadStat {numInserts=10, numUpdates=0}, partitionStat={2020/01/02=WorkloadStat {numInserts=5, numUpdates=0}, 2020/01/01=WorkloadStat {numInserts=4, numUpdates=0}, 2020/01/03=WorkloadStat {numInserts=1, numUpdates=0}}, operationType=null} 83658 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Checking for file exists ?/home/work/hudi_catalog4/.hoodie/20211112071954.commit.requested 84409 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Create new file for toInstant ?/home/work/hudi_catalog4/.hoodie/20211112071954.inflight 84869 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - AvgRecordSize => 1024 84873 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating remote view for basePath /home/work/hudi_catalog4. Server=0.0.0.0:50730, Timeout=300 84873 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating InMemory based view for basePath /home/work/hudi_catalog4 84879 [main] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Took 2 ms to read 0 instants, 0 replaced file groups 84949 [main] INFO org.apache.hudi.common.util.ClusteringUtils - Found 0 files in pending clustering operations 84960 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/datafiles/beforeoron/latest/?partition=2020%2F01%2F02&maxinstant=20211111203048&basepath=%2Fhome%2Fwork%2Fhudi_catalog4&lastinstantts=20211111203048&timelinehash=66173038ff0a2b772212dd1e06335c5c002d206bc91f381edacca9d5db467745) 85340 [qtp633079302-25] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 85399 [qtp633079302-25] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 85485 [qtp633079302-25] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 85485 [qtp633079302-25] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating InMemory based view for basePath /home/work/hudi_catalog4 85618 [qtp633079302-25] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[==>20211112071954__commit__INFLIGHT]} 85619 [qtp633079302-25] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Took 0 ms to read 0 instants, 0 replaced file groups 85671 [qtp633079302-25] INFO org.apache.hudi.common.util.ClusteringUtils - Found 0 files in pending clustering operations 85675 [qtp633079302-25] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Building file system view for partition (2020/01/02) 85766 [qtp633079302-25] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - addFilesToView: NumFiles=4, NumFileGroups=1, FileGroupsCreationTime=7, StoreTimeTaken=1 85800 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/datafiles/beforeoron/latest/?partition=2020%2F01%2F01&maxinstant=20211111203048&basepath=%2Fhome%2Fwork%2Fhudi_catalog4&lastinstantts=20211111203048&timelinehash=66173038ff0a2b772212dd1e06335c5c002d206bc91f381edacca9d5db467745) 85802 [qtp633079302-19] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Building file system view for partition (2020/01/01) 85882 [qtp633079302-19] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - addFilesToView: NumFiles=4, NumFileGroups=1, FileGroupsCreationTime=0, StoreTimeTaken=0 85885 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/datafiles/beforeoron/latest/?partition=2020%2F01%2F03&maxinstant=20211111203048&basepath=%2Fhome%2Fwork%2Fhudi_catalog4&lastinstantts=20211111203048&timelinehash=66173038ff0a2b772212dd1e06335c5c002d206bc91f381edacca9d5db467745) 85886 [qtp633079302-33] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Building file system view for partition (2020/01/03) 85965 [qtp633079302-33] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - addFilesToView: NumFiles=4, NumFileGroups=1, FileGroupsCreationTime=0, StoreTimeTaken=0 85967 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - For partitionPath : 2020/01/02 Small Files => [SmallFile {location=HoodieRecordLocation {instantTime=20211111203048, fileId=1cef849a-6dbe-4e4d-8894-1e196252a854-0}, sizeBytes=437290}] 85968 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Assigning 5 inserts to new update bucket 0 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Total insert buckets for partition path 2020/01/02 => [(InsertBucket {bucketNumber=0, weight=1.0},1.0)] 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - For partitionPath : 2020/01/01 Small Files => [SmallFile {location=HoodieRecordLocation {instantTime=20211111203048, fileId=10658ff8-0e7d-4da2-9455-6d76b80518d4-0}, sizeBytes=437106}] 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Assigning 4 inserts to new update bucket 1 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Total insert buckets for partition path 2020/01/01 => [(InsertBucket {bucketNumber=1, weight=1.0},1.0)] 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - For partitionPath : 2020/01/03 Small Files => [SmallFile {location=HoodieRecordLocation {instantTime=20211111203048, fileId=158308ae-8ac1-474c-85bc-6f0c4f88243d-0}, sizeBytes=436359}] 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Assigning 1 inserts to new update bucket 2 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Total insert buckets for partition path 2020/01/03 => [(InsertBucket {bucketNumber=2, weight=1.0},1.0)] 85969 [main] INFO org.apache.hudi.table.action.commit.JavaUpsertPartitioner - Total Buckets :3, buckets info => {0=BucketInfo {bucketType=UPDATE, fileIdPrefix=1cef849a-6dbe-4e4d-8894-1e196252a854-0, partitionPath=2020/01/02}, 1=BucketInfo {bucketType=UPDATE, fileIdPrefix=10658ff8-0e7d-4da2-9455-6d76b80518d4-0, partitionPath=2020/01/01}, 2=BucketInfo {bucketType=UPDATE, fileIdPrefix=158308ae-8ac1-474c-85bc-6f0c4f88243d-0, partitionPath=2020/01/03}}, Partition to insert buckets => {2020/01/02=[(InsertBucket {bucketNumber=0, weight=1.0},1.0)], 2020/01/01=[(InsertBucket {bucketNumber=1, weight=1.0},1.0)], 2020/01/03=[(InsertBucket {bucketNumber=2, weight=1.0},1.0)]}, UpdateLocations mapped to buckets =>{10658ff8-0e7d-4da2-9455-6d76b80518d4-0=1, 158308ae-8ac1-474c-85bc-6f0c4f88243d-0=2, 1cef849a-6dbe-4e4d-8894-1e196252a854-0=0} 85974 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/datafile/latest/partition?partition=2020%2F01%2F02&basepath=%2Fhome%2Fwork%2Fhudi_catalog4&fileid=1cef849a-6dbe-4e4d-8894-1e196252a854-0&lastinstantts=20211111203048&timelinehash=66173038ff0a2b772212dd1e06335c5c002d206bc91f381edacca9d5db467745) 85983 [main] INFO org.apache.hudi.io.HoodieMergeHandle - MaxMemoryPerPartitionMerge => 1073741824 85993 [main] INFO org.apache.hudi.common.util.collection.ExternalSpillableMap - Estimated Payload size => 728 85996 [main] INFO org.apache.hudi.common.util.collection.BitCaskDiskMap - Spilling to file location /tmp/hudi-BITCASK-8a6950c0-9295-48d7-a860-c3323564f437/cb95c4a4-74a6-4024-9c73-0fcb6ce98f64 in host (127.0.0.1) with hostname (qihoodeiMac.local) 85996 [main] INFO org.apache.hudi.io.HoodieMergeHandle - Number of entries in MemoryBasedMap => 5Total size in bytes of MemoryBasedMap => 3640Number of entries in BitCaskDiskMap => 0Size of file spilled to disk => 0 85996 [main] INFO org.apache.hudi.io.HoodieMergeHandle - partitionPath:2020/01/02, fileId to be merged:1cef849a-6dbe-4e4d-8894-1e196252a854-0 86343 [main] INFO org.apache.hudi.io.HoodieMergeHandle - Merging new data into oldPath /home/work/hudi_catalog4/2020/01/02/1cef849a-6dbe-4e4d-8894-1e196252a854-0_0-0-0_20211111203048.parquet, as newPath /home/work/hudi_catalog4/2020/01/02/1cef849a-6dbe-4e4d-8894-1e196252a854-0_0-0-0_20211112071954.parquet 86476 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - Creating Marker Path=/home/work/hudi_catalog4/.hoodie/.temp/20211112071954/2020/01/02/1cef849a-6dbe-4e4d-8894-1e196252a854-0_0-0-0_20211112071954.parquet.marker.MERGE 86882 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - [direct] Created marker file /home/work/hudi_catalog4/.hoodie/.temp/20211112071954/2020/01/02/1cef849a-6dbe-4e4d-8894-1e196252a854-0_0-0-0_20211112071954.parquet.marker.MERGE in 535 ms 87362 [main] INFO org.apache.hadoop.io.compress.CodecPool - Got brand-new compressor [.gz] 87851 [pool-5-thread-1] INFO org.apache.hudi.common.util.queue.IteratorBasedQueueProducer - starting to buffer records 87852 [pool-5-thread-2] INFO org.apache.hudi.common.util.queue.BoundedInMemoryExecutor - starting consumer thread 88931 [pool-5-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - RecordReader initialized will read a total of 15 records. 88931 [pool-5-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - at row 0. reading next block 89067 [pool-5-thread-1] INFO org.apache.hadoop.io.compress.CodecPool - Got brand-new decompressor [.gz] 89074 [pool-5-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - block read in memory in 143 ms. row count = 15 89103 [pool-5-thread-1] INFO org.apache.hudi.common.util.queue.IteratorBasedQueueProducer - finished buffering records 89108 [pool-5-thread-2] INFO org.apache.hudi.common.util.queue.BoundedInMemoryExecutor - Queue Consumption is done; notifying producer threads 89134 [main] INFO org.apache.parquet.hadoop.InternalParquetRecordWriter - Flushing mem columnStore to file. allocated memory: 3934 90533 [main] INFO org.apache.hudi.io.HoodieMergeHandle - MergeHandle for partitionPath 2020/01/02 fileID 1cef849a-6dbe-4e4d-8894-1e196252a854-0, took 4552 ms. 90534 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/datafile/latest/partition?partition=2020%2F01%2F01&basepath=%2Fhome%2Fwork%2Fhudi_catalog4&fileid=10658ff8-0e7d-4da2-9455-6d76b80518d4-0&lastinstantts=20211111203048&timelinehash=66173038ff0a2b772212dd1e06335c5c002d206bc91f381edacca9d5db467745) 90538 [main] INFO org.apache.hudi.io.HoodieMergeHandle - MaxMemoryPerPartitionMerge => 1073741824 90539 [main] INFO org.apache.hudi.common.util.collection.ExternalSpillableMap - Estimated Payload size => 728 90540 [main] INFO org.apache.hudi.common.util.collection.BitCaskDiskMap - Spilling to file location /tmp/hudi-BITCASK-23c3dfa4-00d3-425a-8b74-583d4b5a4f67/20756bf2-d7c3-4934-8c32-2262b97ea5b2 in host (127.0.0.1) with hostname (qihoodeiMac.local) 90541 [main] INFO org.apache.hudi.io.HoodieMergeHandle - Number of entries in MemoryBasedMap => 4Total size in bytes of MemoryBasedMap => 2912Number of entries in BitCaskDiskMap => 0Size of file spilled to disk => 0 90541 [main] INFO org.apache.hudi.io.HoodieMergeHandle - partitionPath:2020/01/01, fileId to be merged:10658ff8-0e7d-4da2-9455-6d76b80518d4-0 90581 [main] INFO org.apache.hudi.io.HoodieMergeHandle - Merging new data into oldPath /home/work/hudi_catalog4/2020/01/01/10658ff8-0e7d-4da2-9455-6d76b80518d4-0_0-0-0_20211111203048.parquet, as newPath /home/work/hudi_catalog4/2020/01/01/10658ff8-0e7d-4da2-9455-6d76b80518d4-0_0-0-0_20211112071954.parquet 90689 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - Creating Marker Path=/home/work/hudi_catalog4/.hoodie/.temp/20211112071954/2020/01/01/10658ff8-0e7d-4da2-9455-6d76b80518d4-0_0-0-0_20211112071954.parquet.marker.MERGE 91114 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - [direct] Created marker file /home/work/hudi_catalog4/.hoodie/.temp/20211112071954/2020/01/01/10658ff8-0e7d-4da2-9455-6d76b80518d4-0_0-0-0_20211112071954.parquet.marker.MERGE in 532 ms 91183 [main] INFO org.apache.hadoop.io.compress.CodecPool - Got brand-new compressor [.gz] 91238 [pool-6-thread-1] INFO org.apache.hudi.common.util.queue.IteratorBasedQueueProducer - starting to buffer records 91239 [pool-6-thread-2] INFO org.apache.hudi.common.util.queue.BoundedInMemoryExecutor - starting consumer thread 92624 [pool-6-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - RecordReader initialized will read a total of 12 records. 92624 [pool-6-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - at row 0. reading next block 92813 [pool-6-thread-1] INFO org.apache.hadoop.io.compress.CodecPool - Got brand-new decompressor [.gz] 92814 [pool-6-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - block read in memory in 190 ms. row count = 12 92817 [pool-6-thread-1] INFO org.apache.hudi.common.util.queue.IteratorBasedQueueProducer - finished buffering records 92818 [pool-6-thread-2] INFO org.apache.hudi.common.util.queue.BoundedInMemoryExecutor - Queue Consumption is done; notifying producer threads 92819 [main] INFO org.apache.parquet.hadoop.InternalParquetRecordWriter - Flushing mem columnStore to file. allocated memory: 3262 94360 [main] INFO org.apache.hudi.io.HoodieMergeHandle - MergeHandle for partitionPath 2020/01/01 fileID 10658ff8-0e7d-4da2-9455-6d76b80518d4-0, took 3822 ms. 94361 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/datafile/latest/partition?partition=2020%2F01%2F03&basepath=%2Fhome%2Fwork%2Fhudi_catalog4&fileid=158308ae-8ac1-474c-85bc-6f0c4f88243d-0&lastinstantts=20211111203048&timelinehash=66173038ff0a2b772212dd1e06335c5c002d206bc91f381edacca9d5db467745) 94365 [main] INFO org.apache.hudi.io.HoodieMergeHandle - MaxMemoryPerPartitionMerge => 1073741824 94366 [main] INFO org.apache.hudi.common.util.collection.ExternalSpillableMap - Estimated Payload size => 728 94368 [main] INFO org.apache.hudi.common.util.collection.BitCaskDiskMap - Spilling to file location /tmp/hudi-BITCASK-4eaafa7d-2820-48cd-8641-5f03c31b9ba4/435d474b-1beb-4ddc-b1bf-cb590d1db53a in host (127.0.0.1) with hostname (qihoodeiMac.local) 94368 [main] INFO org.apache.hudi.io.HoodieMergeHandle - Number of entries in MemoryBasedMap => 1Total size in bytes of MemoryBasedMap => 728Number of entries in BitCaskDiskMap => 0Size of file spilled to disk => 0 94368 [main] INFO org.apache.hudi.io.HoodieMergeHandle - partitionPath:2020/01/03, fileId to be merged:158308ae-8ac1-474c-85bc-6f0c4f88243d-0 94684 [main] INFO org.apache.hudi.io.HoodieMergeHandle - Merging new data into oldPath /home/work/hudi_catalog4/2020/01/03/158308ae-8ac1-474c-85bc-6f0c4f88243d-0_0-0-0_20211111203048.parquet, as newPath /home/work/hudi_catalog4/2020/01/03/158308ae-8ac1-474c-85bc-6f0c4f88243d-0_0-0-0_20211112071954.parquet 94796 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - Creating Marker Path=/home/work/hudi_catalog4/.hoodie/.temp/20211112071954/2020/01/03/158308ae-8ac1-474c-85bc-6f0c4f88243d-0_0-0-0_20211112071954.parquet.marker.MERGE 95208 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - [direct] Created marker file /home/work/hudi_catalog4/.hoodie/.temp/20211112071954/2020/01/03/158308ae-8ac1-474c-85bc-6f0c4f88243d-0_0-0-0_20211112071954.parquet.marker.MERGE in 524 ms 95289 [main] INFO org.apache.hadoop.io.compress.CodecPool - Got brand-new compressor [.gz] 95345 [pool-7-thread-1] INFO org.apache.hudi.common.util.queue.IteratorBasedQueueProducer - starting to buffer records 95345 [pool-7-thread-2] INFO org.apache.hudi.common.util.queue.BoundedInMemoryExecutor - starting consumer thread 96362 [pool-7-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - RecordReader initialized will read a total of 3 records. 96362 [pool-7-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - at row 0. reading next block 96477 [pool-7-thread-1] INFO org.apache.hadoop.io.compress.CodecPool - Got brand-new decompressor [.gz] 96478 [pool-7-thread-1] INFO org.apache.parquet.hadoop.InternalParquetRecordReader - block read in memory in 116 ms. row count = 3 96480 [pool-7-thread-1] INFO org.apache.hudi.common.util.queue.IteratorBasedQueueProducer - finished buffering records 96480 [pool-7-thread-2] INFO org.apache.hudi.common.util.queue.BoundedInMemoryExecutor - Queue Consumption is done; notifying producer threads 96481 [main] INFO org.apache.parquet.hadoop.InternalParquetRecordWriter - Flushing mem columnStore to file. allocated memory: 1250 97867 [main] INFO org.apache.hudi.io.HoodieMergeHandle - MergeHandle for partitionPath 2020/01/03 fileID 158308ae-8ac1-474c-85bc-6f0c4f88243d-0, took 3502 ms. 97868 [main] INFO org.apache.hudi.table.action.commit.BaseCommitActionExecutor - Auto commit enabled: Committing 20211112071954 97868 [main] INFO org.apache.hudi.table.action.commit.BaseJavaCommitActionExecutor - Committing 20211112071954, action Type commit 98378 [main] INFO org.apache.hudi.table.action.commit.BaseJavaCommitActionExecutor - Committing 20211112071954, action Type commit 98378 [main] INFO org.apache.hudi.common.util.CommitUtils - Creating metadata for INSERT numWriteStats:3numReplaceFileIds:0 98383 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Marking instant complete [==>20211112071954__commit__INFLIGHT] 98383 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Checking for file exists ?/home/work/hudi_catalog4/.hoodie/20211112071954.inflight 99035 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Create new file for toInstant ?/home/work/hudi_catalog4/.hoodie/20211112071954.commit 99035 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Completed [==>20211112071954__commit__INFLIGHT] 99035 [main] INFO org.apache.hudi.table.action.commit.BaseJavaCommitActionExecutor - Committed 20211112071954 99501 [main] INFO org.apache.hudi.table.marker.DirectWriteMarkers - Removing marker directory at /home/work/hudi_catalog4/.hoodie/.temp/20211112071954 99556 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211112071954__commit__COMPLETED]} 99557 [main] INFO org.apache.hudi.table.HoodieTimelineArchiveLog - No Instants to archive 99557 [main] INFO org.apache.hudi.client.AbstractHoodieWriteClient - Auto cleaning is enabled. Running cleaner now 99558 [main] INFO org.apache.hudi.client.AbstractHoodieWriteClient - Scheduling cleaning at instant time :20211112072011 99558 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 99594 [main] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 99923 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 99923 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading Active commit timeline for /home/work/hudi_catalog4 99965 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211112071954__commit__COMPLETED]} 99966 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating View Manager with storage type :REMOTE_FIRST 99966 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating remote first table view 99970 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating remote view for basePath /home/work/hudi_catalog4. Server=0.0.0.0:50730, Timeout=300 99971 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating InMemory based view for basePath /home/work/hudi_catalog4 99971 [main] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Took 0 ms to read 0 instants, 0 replaced file groups 100010 [main] INFO org.apache.hudi.common.util.ClusteringUtils - Found 0 files in pending clustering operations 100012 [main] INFO org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView - Sending request : (http://0.0.0.0:50730/v1/hoodie/view/compactions/pending/?basepath=%2Fhome%2Fwork%2Fhudi_catalog4&lastinstantts=20211112071954&timelinehash=531158aa753faba88dee696a03c6ca809cff47a29a8b9533422b1a7c9fa2c711) 100015 [qtp633079302-33] INFO org.apache.hudi.timeline.service.RequestHandler - Syncing view as client passed last known instant 20211112071954 as last known instant but server has the following last instant on timeline :Option{val=[20211111203048__commit__COMPLETED]} 100070 [qtp633079302-33] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211112071954__commit__COMPLETED]} 100071 [qtp633079302-33] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Took 0 ms to read 0 instants, 0 replaced file groups 100112 [qtp633079302-33] INFO org.apache.hudi.common.util.ClusteringUtils - Found 0 files in pending clustering operations 100116 [main] INFO org.apache.hudi.table.action.clean.CleanPlanner - No earliest commit to retain. No need to scan partitions !! 100116 [main] INFO org.apache.hudi.table.action.clean.CleanPlanner - Nothing to clean here. It is already clean 100134 [main] INFO org.apache.hudi.client.AbstractHoodieWriteClient - Cleaner started 100134 [main] INFO org.apache.hudi.client.AbstractHoodieWriteClient - Cleaned failed attempts if any 100135 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading HoodieTableMetaClient from /home/work/hudi_catalog4 100389 [main] INFO org.apache.hudi.common.table.HoodieTableConfig - Loading table properties from /home/work/hudi_catalog4/.hoodie/hoodie.properties 100467 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from /home/work/hudi_catalog4 100467 [main] INFO org.apache.hudi.common.table.HoodieTableMetaClient - Loading Active commit timeline for /home/work/hudi_catalog4 100520 [main] INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline - Loaded instants upto : Option{val=[20211112071954__commit__COMPLETED]} 100520 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating View Manager with storage type :REMOTE_FIRST 100520 [main] INFO org.apache.hudi.common.table.view.FileSystemViewManager - Creating remote first table view 100523 [main] INFO org.apache.hudi.client.AbstractHoodieClient - Stopping Timeline service !! 100523 [main] INFO org.apache.hudi.client.embedded.EmbeddedTimelineService - Closing Timeline server 100523 [main] INFO org.apache.hudi.timeline.service.TimelineService - Closing Timeline Service 100523 [main] INFO io.javalin.Javalin - Stopping Javalin ... 100531 [main] INFO io.javalin.Javalin - Javalin has stopped 100532 [main] INFO org.apache.hudi.common.table.view.AbstractTableFileSystemView - Took 0 ms to read 0 instants, 0 replaced file groups 100573 [main] INFO org.apache.hudi.common.util.ClusteringUtils - Found 0 files in pending clustering operations 100573 [main] INFO org.apache.hudi.timeline.service.TimelineService - Closed Timeline Service 100573 [main] INFO org.apache.hudi.client.embedded.EmbeddedTimelineService - Closed Timeline server Process finished with exit code 0 -- 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: commits-unsubscr...@hudi.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org