search

xuchuanyin / workbench

0 stars 0 forks source link

2018-10-18 longstring load failed #66

Open xuchuanyin opened 5 years ago

xuchuanyin commented 5 years ago 
    prepareDF()
    longStringDF
      .write
      .format("carbon")
      .save(writerPath)
    sqlContext.read.format("carbon").load(writerPath).show(false)
  private def prepareDF(): Unit = {
    val schema = StructType(
      StructField("id", IntegerType, nullable = true) ::
      StructField("name", StringType, nullable = true) ::
      StructField("description", StringType, nullable = true) ::
      StructField("address", StringType, nullable = true) ::
      StructField("note", StringType, nullable = true) :: Nil
    )
    longStringDF = sqlContext.sparkSession.read
      .schema(schema)
      .csv(inputFile)
  }
xuchuanyin commented 5 years ago

2

    if (sqlContext.sparkSession.version.startsWith("2.1")) {
      sql(
        s"""
           | CREATE TABLE if not exists $longStringTable(
           | id INT, name STRING, description STRING, address STRING, note STRING
           | ) USING carbon
           | OPTIONS("LONG_STRING_COLUMNS" "description, note", "dictionary_include" "name",
           | "sort_columns" "id")
           |""".
          stripMargin)
    } else {
      sql(
        s"""
           | CREATE TABLE if not exists $longStringTable(
           | id INT, name STRING, description STRING, address STRING, note STRING
           | ) USING carbon
           | OPTIONS("LONG_STRING_COLUMNS"="description, note", "dictionary_include"="name",
           | "sort_columns"="id")
           |""".
          stripMargin)
    }

    sql("show tables").show(false)

    prepareDF()
    // the order of fields in dataframe is different from that in create table
    longStringDF.select("note", "address", "description", "name", "id")
      .write
      .format("carbondata")
      .option("tableName", longStringTable)
      .mode(SaveMode.Append)
      .save()
Testing started at 21:08 ...
"D:\Program Files\Java\jdk1.8.0_151\bin\java" "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2017.3\lib\idea_rt.jar=63005:C:\Program Files\JetBrains\IntelliJ IDEA 2017.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Users\x00251853\.IntelliJIdea2017.3\config\plugins\Scala\lib\runners.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\charsets.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\deploy.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\access-bridge-64.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\cldrdata.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\dnsns.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\jaccess.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\jfxrt.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\localedata.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\nashorn.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\sunec.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\sunjce_provider.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\sunmscapi.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\sunpkcs11.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\ext\zipfs.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\javaws.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\jce.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\jfr.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\jfxswt.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\jsse.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\management-agent.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\plugin.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\resources.jar;D:\Program Files\Java\jdk1.8.0_151\jre\lib\rt.jar;D:\01_workspace\carbondata2\integration\spark-common-test\target\test-classes;D:\01_workspace\carbondata2\integration\spark-common-test\target\classes;D:\01_workspace\carbondata2\integration\spark2\target\classes;D:\01_workspace\carbondata2\integration\spark-common\target\classes;D:\01_workspace\carbondata2\streaming\target\classes;D:\01_workspace\carbondata2\integration\spark-datasource\target\classes;D:\tools\apache-maven-3.5.0\repo\org\scala-lang\scala-compiler\2.11.8\scala-compiler-2.11.8.jar;D:\tools\apache-maven-3.5.0\repo\org\scala-lang\modules\scala-parser-combinators_2.11\1.0.4\scala-parser-combinators_2.11-1.0.4.jar;D:\01_workspace\carbondata2\store\search\target\classes;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-hive-thriftserver_2.11\2.2.1\spark-hive-thriftserver_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-hive_2.11\2.2.1\spark-hive_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\com\twitter\parquet-hadoop-bundle\1.6.0\parquet-hadoop-bundle-1.6.0.jar;D:\tools\apache-maven-3.5.0\repo\org\spark-project\hive\hive-exec\1.2.1.spark2\hive-exec-1.2.1.spark2.jar;D:\tools\apache-maven-3.5.0\repo\javolution\javolution\5.5.1\javolution-5.5.1.jar;D:\tools\apache-maven-3.5.0\repo\log4j\apache-log4j-extras\1.2.17\apache-log4j-extras-1.2.17.jar;D:\tools\apache-maven-3.5.0\repo\org\antlr\antlr-runtime\3.4\antlr-runtime-3.4.jar;D:\tools\apache-maven-3.5.0\repo\org\antlr\stringtemplate\3.2.1\stringtemplate-3.2.1.jar;D:\tools\apache-maven-3.5.0\repo\antlr\antlr\2.7.7\antlr-2.7.7.jar;D:\tools\apache-maven-3.5.0\repo\org\antlr\ST4\4.0.4\ST4-4.0.4.jar;D:\tools\apache-maven-3.5.0\repo\com\googlecode\javaewah\JavaEWAH\0.3.2\JavaEWAH-0.3.2.jar;D:\tools\apache-maven-3.5.0\repo\org\iq80\snappy\snappy\0.2\snappy-0.2.jar;D:\tools\apache-maven-3.5.0\repo\stax\stax-api\1.0.1\stax-api-1.0.1.jar;D:\tools\apache-maven-3.5.0\repo\net\sf\opencsv\opencsv\2.3\opencsv-2.3.jar;D:\tools\apache-maven-3.5.0\repo\org\spark-project\hive\hive-metastore\1.2.1.spark2\hive-metastore-1.2.1.spark2.jar;D:\tools\apache-maven-3.5.0\repo\com\jolbox\bonecp\0.8.0.RELEASE\bonecp-0.8.0.RELEASE.jar;D:\tools\apache-maven-3.5.0\repo\org\datanucleus\datanucleus-api-jdo\3.2.6\datanucleus-api-jdo-3.2.6.jar;D:\tools\apache-maven-3.5.0\repo\org\datanucleus\datanucleus-rdbms\3.2.9\datanucleus-rdbms-3.2.9.jar;D:\tools\apache-maven-3.5.0\repo\commons-pool\commons-pool\1.5.4\commons-pool-1.5.4.jar;D:\tools\apache-maven-3.5.0\repo\commons-dbcp\commons-dbcp\1.4\commons-dbcp-1.4.jar;D:\tools\apache-maven-3.5.0\repo\javax\jdo\jdo-api\3.0.1\jdo-api-3.0.1.jar;D:\tools\apache-maven-3.5.0\repo\javax\transaction\jta\1.1\jta-1.1.jar;D:\tools\apache-maven-3.5.0\repo\commons-httpclient\commons-httpclient\3.1\commons-httpclient-3.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\calcite\calcite-avatica\1.2.0-incubating\calcite-avatica-1.2.0-incubating.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\calcite\calcite-core\1.2.0-incubating\calcite-core-1.2.0-incubating.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\calcite\calcite-linq4j\1.2.0-incubating\calcite-linq4j-1.2.0-incubating.jar;D:\tools\apache-maven-3.5.0\repo\net\hydromatic\eigenbase-properties\1.1.5\eigenbase-properties-1.1.5.jar;D:\tools\apache-maven-3.5.0\repo\joda-time\joda-time\2.9.3\joda-time-2.9.3.jar;D:\tools\apache-maven-3.5.0\repo\org\jodd\jodd-core\3.5.2\jodd-core-3.5.2.jar;D:\tools\apache-maven-3.5.0\repo\org\datanucleus\datanucleus-core\3.2.10\datanucleus-core-3.2.10.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\thrift\libthrift\0.9.3\libthrift-0.9.3.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\thrift\libfb303\0.9.3\libfb303-0.9.3.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\derby\derby\10.12.1.1\derby-10.12.1.1.jar;D:\tools\apache-maven-3.5.0\repo\org\spark-project\hive\hive-cli\1.2.1.spark2\hive-cli-1.2.1.spark2.jar;D:\tools\apache-maven-3.5.0\repo\commons-cli\commons-cli\1.2\commons-cli-1.2.jar;D:\tools\apache-maven-3.5.0\repo\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;D:\tools\apache-maven-3.5.0\repo\org\spark-project\hive\hive-jdbc\1.2.1.spark2\hive-jdbc-1.2.1.spark2.jar;D:\tools\apache-maven-3.5.0\repo\org\spark-project\hive\hive-beeline\1.2.1.spark2\hive-beeline-1.2.1.spark2.jar;D:\tools\apache-maven-3.5.0\repo\commons-io\commons-io\2.4\commons-io-2.4.jar;D:\tools\apache-maven-3.5.0\repo\net\sf\supercsv\super-csv\2.2.0\super-csv-2.2.0.jar;D:\tools\apache-maven-3.5.0\repo\net\sf\jpam\jpam\1.1\jpam-1.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-repl_2.11\2.2.1\spark-repl_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-mllib_2.11\2.2.1\spark-mllib_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-graphx_2.11\2.2.1\spark-graphx_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\com\github\fommil\netlib\core\1.1.2\core-1.1.2.jar;D:\tools\apache-maven-3.5.0\repo\net\sourceforge\f2j\arpack_combined_all\0.1\arpack_combined_all-0.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-mllib-local_2.11\2.2.1\spark-mllib-local_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\scalanlp\breeze_2.11\0.13.2\breeze_2.11-0.13.2.jar;D:\tools\apache-maven-3.5.0\repo\org\scalanlp\breeze-macros_2.11\0.13.2\breeze-macros_2.11-0.13.2.jar;D:\tools\apache-maven-3.5.0\repo\com\github\rwl\jtransforms\2.4.0\jtransforms-2.4.0.jar;D:\tools\apache-maven-3.5.0\repo\org\spire-math\spire_2.11\0.13.0\spire_2.11-0.13.0.jar;D:\tools\apache-maven-3.5.0\repo\org\spire-math\spire-macros_2.11\0.13.0\spire-macros_2.11-0.13.0.jar;D:\tools\apache-maven-3.5.0\repo\org\typelevel\machinist_2.11\0.6.1\machinist_2.11-0.6.1.jar;D:\tools\apache-maven-3.5.0\repo\com\chuusai\shapeless_2.11\2.3.2\shapeless_2.11-2.3.2.jar;D:\tools\apache-maven-3.5.0\repo\org\typelevel\macro-compat_2.11\1.1.1\macro-compat_2.11-1.1.1.jar;D:\tools\apache-maven-3.5.0\repo\org\jpmml\pmml-model\1.2.15\pmml-model-1.2.15.jar;D:\tools\apache-maven-3.5.0\repo\org\jpmml\pmml-schema\1.2.15\pmml-schema-1.2.15.jar;D:\tools\apache-maven-3.5.0\repo\jline\jline\2.12.1\jline-2.12.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-streaming_2.11\2.2.1\spark-streaming_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-sql_2.11\2.2.1\spark-sql_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-sketch_2.11\2.2.1\spark-sketch_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-catalyst_2.11\2.2.1\spark-catalyst_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\janino\janino\3.0.0\janino-3.0.0.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\janino\commons-compiler\3.0.0\commons-compiler-3.0.0.jar;D:\tools\apache-maven-3.5.0\repo\org\antlr\antlr4-runtime\4.5.3\antlr4-runtime-4.5.3.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\parquet\parquet-column\1.8.2\parquet-column-1.8.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\parquet\parquet-common\1.8.2\parquet-common-1.8.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\parquet\parquet-encoding\1.8.2\parquet-encoding-1.8.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\parquet\parquet-hadoop\1.8.2\parquet-hadoop-1.8.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\parquet\parquet-format\2.3.1\parquet-format-2.3.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\parquet\parquet-jackson\1.8.2\parquet-jackson-1.8.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-sql-kafka-0-10_2.11\2.2.1\spark-sql-kafka-0-10_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\kafka\kafka-clients\0.10.0.1\kafka-clients-0.10.0.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-aws\2.7.2\hadoop-aws-2.7.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-common\2.7.2\hadoop-common-2.7.2.jar;D:\tools\apache-maven-3.5.0\repo\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;D:\tools\apache-maven-3.5.0\repo\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\tools\apache-maven-3.5.0\repo\org\mortbay\jetty\jetty\6.1.26\jetty-6.1.26.jar;D:\tools\apache-maven-3.5.0\repo\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;D:\tools\apache-maven-3.5.0\repo\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;D:\tools\apache-maven-3.5.0\repo\com\sun\jersey\jersey-json\1.9\jersey-json-1.9.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\jettison\jettison\1.1\jettison-1.1.jar;D:\tools\apache-maven-3.5.0\repo\com\sun\xml\bind\jaxb-impl\2.2.3-1\jaxb-impl-2.2.3-1.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\jackson\jackson-jaxrs\1.8.3\jackson-jaxrs-1.8.3.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\jackson\jackson-xc\1.8.3\jackson-xc-1.8.3.jar;D:\tools\apache-maven-3.5.0\repo\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar;D:\tools\apache-maven-3.5.0\repo\asm\asm\3.1\asm-3.1.jar;D:\tools\apache-maven-3.5.0\repo\commons-configuration\commons-configuration\1.6\commons-configuration-1.6.jar;D:\tools\apache-maven-3.5.0\repo\commons-digester\commons-digester\1.8\commons-digester-1.8.jar;D:\tools\apache-maven-3.5.0\repo\commons-beanutils\commons-beanutils\1.7.0\commons-beanutils-1.7.0.jar;D:\tools\apache-maven-3.5.0\repo\commons-beanutils\commons-beanutils-core\1.8.0\commons-beanutils-core-1.8.0.jar;D:\tools\apache-maven-3.5.0\repo\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-auth\2.7.2\hadoop-auth-2.7.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\directory\server\apacheds-kerberos-codec\2.0.0-M15\apacheds-kerberos-codec-2.0.0-M15.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\directory\server\apacheds-i18n\2.0.0-M15\apacheds-i18n-2.0.0-M15.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\directory\api\api-asn1-api\1.0.0-M20\api-asn1-api-1.0.0-M20.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\directory\api\api-util\1.0.0-M20\api-util-1.0.0-M20.jar;D:\tools\apache-maven-3.5.0\repo\com\jcraft\jsch\0.1.42\jsch-0.1.42.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\curator\curator-client\2.7.1\curator-client-2.7.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\htrace\htrace-core\3.1.0-incubating\htrace-core-3.1.0-incubating.jar;D:\tools\apache-maven-3.5.0\repo\com\amazonaws\aws-java-sdk\1.7.4\aws-java-sdk-1.7.4.jar;D:\tools\apache-maven-3.5.0\repo\net\java\dev\jets3t\jets3t\0.9.0\jets3t-0.9.0.jar;D:\tools\apache-maven-3.5.0\repo\commons-codec\commons-codec\1.4\commons-codec-1.4.jar;D:\tools\apache-maven-3.5.0\repo\commons-logging\commons-logging\1.1.1\commons-logging-1.1.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\httpcomponents\httpclient\4.1.2\httpclient-4.1.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\httpcomponents\httpcore\4.1.2\httpcore-4.1.2.jar;D:\tools\apache-maven-3.5.0\repo\com\jamesmurty\utils\java-xmlbuilder\0.4\java-xmlbuilder-0.4.jar;D:\01_workspace\carbondata2\datamap\lucene\target\classes;D:\01_workspace\carbondata2\core\target\classes;D:\01_workspace\carbondata2\format\target\classes;D:\01_workspace\carbondata2\common\target\classes;D:\tools\apache-maven-3.5.0\repo\com\google\code\gson\gson\2.4\gson-2.4.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-hdfs\2.7.2\hadoop-hdfs-2.7.2.jar;D:\tools\apache-maven-3.5.0\repo\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;D:\tools\apache-maven-3.5.0\repo\xerces\xercesImpl\2.9.1\xercesImpl-2.9.1.jar;D:\tools\apache-maven-3.5.0\repo\xml-apis\xml-apis\1.3.04\xml-apis-1.3.04.jar;D:\tools\apache-maven-3.5.0\repo\com\github\luben\zstd-jni\1.3.2-2\zstd-jni-1.3.2-2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\zookeeper\zookeeper\3.4.7\zookeeper-3.4.7.jar;D:\tools\apache-maven-3.5.0\repo\org\lz4\lz4-java\1.4.0\lz4-java-1.4.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\commons\commons-lang3\3.5\commons-lang3-3.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\lucene\lucene-core\6.3.0\lucene-core-6.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\lucene\lucene-analyzers-common\6.3.0\lucene-analyzers-common-6.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\lucene\lucene-queryparser\6.3.0\lucene-queryparser-6.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\lucene\lucene-sandbox\6.3.0\lucene-sandbox-6.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\solr\solr-core\6.3.0\solr-core-6.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\solr\solr-solrj\6.3.0\solr-solrj-6.3.0.jar;D:\01_workspace\carbondata2\datamap\bloom\target\classes;D:\01_workspace\carbondata2\processing\target\classes;D:\tools\apache-maven-3.5.0\repo\com\univocity\univocity-parsers\2.2.1\univocity-parsers-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\com\google\guava\guava\14.0.1\guava-14.0.1.jar;D:\01_workspace\carbondata2\store\sdk\target\classes;D:\01_workspace\carbondata2\hadoop\target\classes;D:\tools\apache-maven-3.5.0\repo\org\apache\avro\avro\1.8.1\avro-1.8.1.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\jackson\jackson-core-asl\1.9.13\jackson-core-asl-1.9.13.jar;D:\tools\apache-maven-3.5.0\repo\org\codehaus\jackson\jackson-mapper-asl\1.9.13\jackson-mapper-asl-1.9.13.jar;D:\tools\apache-maven-3.5.0\repo\com\thoughtworks\paranamer\paranamer\2.7\paranamer-2.7.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\commons\commons-compress\1.8.1\commons-compress-1.8.1.jar;D:\tools\apache-maven-3.5.0\repo\org\tukaani\xz\1.5\xz-1.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-core_2.11\2.2.1\spark-core_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\avro\avro-mapred\1.7.7\avro-mapred-1.7.7-hadoop2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\avro\avro-ipc\1.7.7\avro-ipc-1.7.7.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\avro\avro-ipc\1.7.7\avro-ipc-1.7.7-tests.jar;D:\tools\apache-maven-3.5.0\repo\com\twitter\chill_2.11\0.8.0\chill_2.11-0.8.0.jar;D:\tools\apache-maven-3.5.0\repo\com\esotericsoftware\kryo-shaded\3.0.3\kryo-shaded-3.0.3.jar;D:\tools\apache-maven-3.5.0\repo\com\esotericsoftware\minlog\1.3.0\minlog-1.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\objenesis\objenesis\2.1\objenesis-2.1.jar;D:\tools\apache-maven-3.5.0\repo\com\twitter\chill-java\0.8.0\chill-java-0.8.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\xbean\xbean-asm5-shaded\4.4\xbean-asm5-shaded-4.4.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-client\2.6.5\hadoop-client-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-mapreduce-client-app\2.6.5\hadoop-mapreduce-client-app-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-mapreduce-client-common\2.6.5\hadoop-mapreduce-client-common-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-yarn-client\2.6.5\hadoop-yarn-client-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-yarn-server-common\2.6.5\hadoop-yarn-server-common-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-mapreduce-client-shuffle\2.6.5\hadoop-mapreduce-client-shuffle-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-yarn-api\2.6.5\hadoop-yarn-api-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-mapreduce-client-core\2.7.2\hadoop-mapreduce-client-core-2.7.2.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-yarn-common\2.7.2\hadoop-yarn-common-2.7.2.jar;D:\tools\apache-maven-3.5.0\repo\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar;D:\tools\apache-maven-3.5.0\repo\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar;D:\tools\apache-maven-3.5.0\repo\javax\activation\activation\1.1\activation-1.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-mapreduce-client-jobclient\2.6.5\hadoop-mapreduce-client-jobclient-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\hadoop\hadoop-annotations\2.6.5\hadoop-annotations-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-launcher_2.11\2.2.1\spark-launcher_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-network-common_2.11\2.2.1\spark-network-common_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\fusesource\leveldbjni\leveldbjni-all\1.8\leveldbjni-all-1.8.jar;D:\tools\apache-maven-3.5.0\repo\com\fasterxml\jackson\core\jackson-annotations\2.6.5\jackson-annotations-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-network-shuffle_2.11\2.2.1\spark-network-shuffle_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-unsafe_2.11\2.2.1\spark-unsafe_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\curator\curator-recipes\2.6.0\curator-recipes-2.6.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\curator\curator-framework\2.6.0\curator-framework-2.6.0.jar;D:\tools\apache-maven-3.5.0\repo\javax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\commons\commons-math3\3.4.1\commons-math3-3.4.1.jar;D:\tools\apache-maven-3.5.0\repo\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\tools\apache-maven-3.5.0\repo\org\slf4j\slf4j-api\1.7.16\slf4j-api-1.7.16.jar;D:\tools\apache-maven-3.5.0\repo\org\slf4j\jul-to-slf4j\1.7.16\jul-to-slf4j-1.7.16.jar;D:\tools\apache-maven-3.5.0\repo\org\slf4j\jcl-over-slf4j\1.7.16\jcl-over-slf4j-1.7.16.jar;D:\tools\apache-maven-3.5.0\repo\log4j\log4j\1.2.17\log4j-1.2.17.jar;D:\tools\apache-maven-3.5.0\repo\org\slf4j\slf4j-log4j12\1.7.16\slf4j-log4j12-1.7.16.jar;D:\tools\apache-maven-3.5.0\repo\com\ning\compress-lzf\1.0.3\compress-lzf-1.0.3.jar;D:\tools\apache-maven-3.5.0\repo\org\xerial\snappy\snappy-java\1.1.2.6\snappy-java-1.1.2.6.jar;D:\tools\apache-maven-3.5.0\repo\net\jpountz\lz4\lz4\1.3.0\lz4-1.3.0.jar;D:\tools\apache-maven-3.5.0\repo\org\roaringbitmap\RoaringBitmap\0.5.11\RoaringBitmap-0.5.11.jar;D:\tools\apache-maven-3.5.0\repo\commons-net\commons-net\2.2\commons-net-2.2.jar;D:\tools\apache-maven-3.5.0\repo\org\scala-lang\scala-library\2.11.8\scala-library-2.11.8.jar;D:\tools\apache-maven-3.5.0\repo\org\json4s\json4s-jackson_2.11\3.2.11\json4s-jackson_2.11-3.2.11.jar;D:\tools\apache-maven-3.5.0\repo\org\json4s\json4s-core_2.11\3.2.11\json4s-core_2.11-3.2.11.jar;D:\tools\apache-maven-3.5.0\repo\org\json4s\json4s-ast_2.11\3.2.11\json4s-ast_2.11-3.2.11.jar;D:\tools\apache-maven-3.5.0\repo\org\scala-lang\scalap\2.11.8\scalap-2.11.8.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\core\jersey-client\2.22.2\jersey-client-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\javax\ws\rs\javax.ws.rs-api\2.0.1\javax.ws.rs-api-2.0.1.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\hk2\hk2-api\2.4.0-b34\hk2-api-2.4.0-b34.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\hk2\hk2-utils\2.4.0-b34\hk2-utils-2.4.0-b34.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\hk2\external\aopalliance-repackaged\2.4.0-b34\aopalliance-repackaged-2.4.0-b34.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\hk2\external\javax.inject\2.4.0-b34\javax.inject-2.4.0-b34.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\hk2\hk2-locator\2.4.0-b34\hk2-locator-2.4.0-b34.jar;D:\tools\apache-maven-3.5.0\repo\org\javassist\javassist\3.18.1-GA\javassist-3.18.1-GA.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\core\jersey-common\2.22.2\jersey-common-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\javax\annotation\javax.annotation-api\1.2\javax.annotation-api-1.2.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\bundles\repackaged\jersey-guava\2.22.2\jersey-guava-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\hk2\osgi-resource-locator\1.0.1\osgi-resource-locator-1.0.1.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\core\jersey-server\2.22.2\jersey-server-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\media\jersey-media-jaxb\2.22.2\jersey-media-jaxb-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\javax\validation\validation-api\1.1.0.Final\validation-api-1.1.0.Final.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\containers\jersey-container-servlet\2.22.2\jersey-container-servlet-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\org\glassfish\jersey\containers\jersey-container-servlet-core\2.22.2\jersey-container-servlet-core-2.22.2.jar;D:\tools\apache-maven-3.5.0\repo\io\netty\netty-all\4.0.43.Final\netty-all-4.0.43.Final.jar;D:\tools\apache-maven-3.5.0\repo\io\netty\netty\3.9.9.Final\netty-3.9.9.Final.jar;D:\tools\apache-maven-3.5.0\repo\com\clearspring\analytics\stream\2.7.0\stream-2.7.0.jar;D:\tools\apache-maven-3.5.0\repo\io\dropwizard\metrics\metrics-core\3.1.2\metrics-core-3.1.2.jar;D:\tools\apache-maven-3.5.0\repo\io\dropwizard\metrics\metrics-jvm\3.1.2\metrics-jvm-3.1.2.jar;D:\tools\apache-maven-3.5.0\repo\io\dropwizard\metrics\metrics-json\3.1.2\metrics-json-3.1.2.jar;D:\tools\apache-maven-3.5.0\repo\io\dropwizard\metrics\metrics-graphite\3.1.2\metrics-graphite-3.1.2.jar;D:\tools\apache-maven-3.5.0\repo\com\fasterxml\jackson\core\jackson-databind\2.6.5\jackson-databind-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\com\fasterxml\jackson\core\jackson-core\2.6.5\jackson-core-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\com\fasterxml\jackson\module\jackson-module-scala_2.11\2.6.5\jackson-module-scala_2.11-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\com\fasterxml\jackson\module\jackson-module-paranamer\2.6.5\jackson-module-paranamer-2.6.5.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\ivy\ivy\2.4.0\ivy-2.4.0.jar;D:\tools\apache-maven-3.5.0\repo\oro\oro\2.0.8\oro-2.0.8.jar;D:\tools\apache-maven-3.5.0\repo\net\razorvine\pyrolite\4.13\pyrolite-4.13.jar;D:\tools\apache-maven-3.5.0\repo\net\sf\py4j\py4j\0.10.4\py4j-0.10.4.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\spark\spark-tags_2.11\2.2.1\spark-tags_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\apache\commons\commons-crypto\1.0.0\commons-crypto-1.0.0.jar;D:\tools\apache-maven-3.5.0\repo\org\spark-project\spark\unused\1.0.0\unused-1.0.0.jar;D:\tools\apache-maven-3.5.0\repo\junit\junit\4.11\junit-4.11.jar;D:\tools\apache-maven-3.5.0\repo\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;D:\tools\apache-maven-3.5.0\repo\org\scalatest\scalatest_2.11\2.2.1\scalatest_2.11-2.2.1.jar;D:\tools\apache-maven-3.5.0\repo\org\scala-lang\scala-reflect\2.11.8\scala-reflect-2.11.8.jar;D:\tools\apache-maven-3.5.0\repo\org\scala-lang\modules\scala-xml_2.11\1.0.2\scala-xml_2.11-1.0.2.jar;D:\tools\apache-maven-3.5.0\repo\org\jmockit\jmockit\1.10\jmockit-1.10.jar" org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner -s org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase -testName "test spark file format table: write from dataframe with long_string datatype whose order of fields is not the same as that in table" -C org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestReporter -showProgressMessages true
Console output is saving to: D:\01_workspace\console.log
log4j:WARN custom level class [org.apache.carbondata.common.logging.AuditLevel] not found.
log4j:WARN No appenders could be found for logger (org.apache.spark.sql.test.TestQueryExecutor$).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties
18/10/18 06:08:09 INFO SparkContext: Running Spark version 2.2.1
18/10/18 06:08:09 INFO SparkContext: Submitted application: Spark2TestQueryExecutor
18/10/18 06:08:09 INFO SecurityManager: Changing view acls to: x00251853
18/10/18 06:08:09 INFO SecurityManager: Changing modify acls to: x00251853
18/10/18 06:08:09 INFO SecurityManager: Changing view acls groups to: 
18/10/18 06:08:09 INFO SecurityManager: Changing modify acls groups to: 
18/10/18 06:08:09 INFO SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users  with view permissions: Set(x00251853); groups with view permissions: Set(); users  with modify permissions: Set(x00251853); groups with modify permissions: Set()
18/10/18 06:08:10 INFO Utils: Successfully started service 'sparkDriver' on port 63030.
18/10/18 06:08:10 INFO SparkEnv: Registering MapOutputTracker
18/10/18 06:08:10 INFO SparkEnv: Registering BlockManagerMaster
18/10/18 06:08:10 INFO BlockManagerMasterEndpoint: Using org.apache.spark.storage.DefaultTopologyMapper for getting topology information
18/10/18 06:08:10 INFO BlockManagerMasterEndpoint: BlockManagerMasterEndpoint up
18/10/18 06:08:10 INFO DiskBlockManager: Created local directory at C:\Users\x00251853\AppData\Local\Temp\blockmgr-c2db99de-d88f-4f20-b8f9-39b40ef539be
18/10/18 06:08:10 INFO MemoryStore: MemoryStore started with capacity 1989.6 MB
18/10/18 06:08:10 INFO SparkEnv: Registering OutputCommitCoordinator
18/10/18 06:08:10 INFO Utils: Successfully started service 'SparkUI' on port 4040.
18/10/18 06:08:10 INFO SparkUI: Bound SparkUI to 0.0.0.0, and started at http://100.66.113.58:4040
18/10/18 06:08:10 INFO Executor: Starting executor ID driver on host localhost
18/10/18 06:08:10 INFO Utils: Successfully started service 'org.apache.spark.network.netty.NettyBlockTransferService' on port 63043.
18/10/18 06:08:10 INFO NettyBlockTransferService: Server created on 100.66.113.58:63043
18/10/18 06:08:10 INFO BlockManager: Using org.apache.spark.storage.RandomBlockReplicationPolicy for block replication policy
18/10/18 06:08:10 INFO BlockManagerMaster: Registering BlockManager BlockManagerId(driver, 100.66.113.58, 63043, None)
18/10/18 06:08:10 INFO BlockManagerMasterEndpoint: Registering block manager 100.66.113.58:63043 with 1989.6 MB RAM, BlockManagerId(driver, 100.66.113.58, 63043, None)
18/10/18 06:08:10 INFO BlockManagerMaster: Registered BlockManager BlockManagerId(driver, 100.66.113.58, 63043, None)
18/10/18 06:08:10 INFO BlockManager: Initialized BlockManager: BlockManagerId(driver, 100.66.113.58, 63043, None)
18/10/18 06:08:11 INFO SharedState: Setting hive.metastore.warehouse.dir ('null') to the value of spark.sql.warehouse.dir ('D:/01_workspace/carbondata2/integration/spark-common/target/warehouse').
18/10/18 06:08:11 INFO SharedState: Warehouse path is 'D:/01_workspace/carbondata2/integration/spark-common/target/warehouse'.
18/10/18 06:08:11 INFO HiveUtils: Initializing HiveMetastoreConnection version 1.2.1 using Spark classes.
18/10/18 06:08:12 INFO HiveMetaStore: 0: Opening raw store with implemenation class:org.apache.hadoop.hive.metastore.ObjectStore
18/10/18 06:08:12 INFO ObjectStore: ObjectStore, initialize called
18/10/18 06:08:12 INFO Persistence: Property hive.metastore.integral.jdo.pushdown unknown - will be ignored
18/10/18 06:08:12 INFO Persistence: Property datanucleus.cache.level2 unknown - will be ignored
18/10/18 06:08:14 INFO ObjectStore: Setting MetaStore object pin classes with hive.metastore.cache.pinobjtypes="Table,StorageDescriptor,SerDeInfo,Partition,Database,Type,FieldSchema,Order"
18/10/18 06:08:15 INFO Datastore: The class "org.apache.hadoop.hive.metastore.model.MFieldSchema" is tagged as "embedded-only" so does not have its own datastore table.
18/10/18 06:08:15 INFO Datastore: The class "org.apache.hadoop.hive.metastore.model.MOrder" is tagged as "embedded-only" so does not have its own datastore table.
18/10/18 06:08:15 INFO Datastore: The class "org.apache.hadoop.hive.metastore.model.MFieldSchema" is tagged as "embedded-only" so does not have its own datastore table.
18/10/18 06:08:15 INFO Datastore: The class "org.apache.hadoop.hive.metastore.model.MOrder" is tagged as "embedded-only" so does not have its own datastore table.
18/10/18 06:08:15 INFO Query: Reading in results for query "org.datanucleus.store.rdbms.query.SQLQuery@0" since the connection used is closing
18/10/18 06:08:15 INFO MetaStoreDirectSql: Using direct SQL, underlying DB is DERBY
18/10/18 06:08:15 INFO ObjectStore: Initialized ObjectStore
18/10/18 06:08:15 INFO HiveMetaStore: Added admin role in metastore
18/10/18 06:08:15 INFO HiveMetaStore: Added public role in metastore
18/10/18 06:08:15 INFO HiveMetaStore: No user is added in admin role, since config is empty
18/10/18 06:08:15 INFO HiveMetaStore: 0: get_all_databases
18/10/18 06:08:15 INFO audit: ugi=x00251853 ip=unknown-ip-addr  cmd=get_all_databases   
18/10/18 06:08:15 INFO HiveMetaStore: 0: get_functions: db=default pat=*
18/10/18 06:08:15 INFO audit: ugi=x00251853 ip=unknown-ip-addr  cmd=get_functions: db=default pat=* 
18/10/18 06:08:15 INFO Datastore: The class "org.apache.hadoop.hive.metastore.model.MResourceUri" is tagged as "embedded-only" so does not have its own datastore table.
18/10/18 06:08:18 INFO SessionState: Created local directory: C:/Users/X00251~1/AppData/Local/Temp/4db622fb-82f0-494e-8a5c-a1d95a86286c_resources
18/10/18 06:08:18 INFO SessionState: Created HDFS directory: /tmp/hive/x00251853/4db622fb-82f0-494e-8a5c-a1d95a86286c
18/10/18 06:08:18 INFO SessionState: Created local directory: C:/Users/X00251~1/AppData/Local/Temp/x00251853/4db622fb-82f0-494e-8a5c-a1d95a86286c
18/10/18 06:08:18 INFO SessionState: Created HDFS directory: /tmp/hive/x00251853/4db622fb-82f0-494e-8a5c-a1d95a86286c/_tmp_space.db
18/10/18 06:08:18 INFO HiveClientImpl: Warehouse location for Hive client (version 1.2.1) is D:/01_workspace/carbondata2/integration/spark-common/target/warehouse
18/10/18 06:08:18 INFO HiveMetaStore: 0: get_database: default
18/10/18 06:08:18 INFO audit: ugi=x00251853 ip=unknown-ip-addr  cmd=get_database: default   
18/10/18 06:08:18 INFO HiveMetaStore: 0: get_database: global_temp
18/10/18 06:08:18 INFO audit: ugi=x00251853 ip=unknown-ip-addr  cmd=get_database: global_temp   
18/10/18 06:08:18 WARN ObjectStore: Failed to get database global_temp, returning NoSuchObjectException
18/10/18 06:08:18 INFO SessionState: Created local directory: C:/Users/X00251~1/AppData/Local/Temp/0f0279d0-1e9c-477b-b0d5-ee33bcab7829_resources
18/10/18 06:08:18 INFO SessionState: Created HDFS directory: /tmp/hive/x00251853/0f0279d0-1e9c-477b-b0d5-ee33bcab7829
18/10/18 06:08:18 INFO SessionState: Created local directory: C:/Users/X00251~1/AppData/Local/Temp/x00251853/0f0279d0-1e9c-477b-b0d5-ee33bcab7829
18/10/18 06:08:18 INFO SessionState: Created HDFS directory: /tmp/hive/x00251853/0f0279d0-1e9c-477b-b0d5-ee33bcab7829/_tmp_space.db
18/10/18 06:08:18 INFO HiveClientImpl: Warehouse location for Hive client (version 1.2.1) is D:/01_workspace/carbondata2/integration/spark-common/target/warehouse
18/10/18 06:08:18 INFO StateStoreCoordinatorRef: Registered StateStoreCoordinator endpoint
18/10/18 06:08:22 INFO VarcharDataTypesBasicTestCase: ScalaTest-run-running-VarcharDataTypesBasicTestCase 

===== TEST OUTPUT FOR org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase: 'test spark file format table: write from dataframe with long_string datatype whose order of fields is not the same as that in table' =====

-chgrp: 'CHINA\Domain Users' does not match expected pattern for group
Usage: hadoop fs [generic options] -chgrp [-R] GROUP PATH...
+--------+-----------------+-----------+
|database|tableName        |isTemporary|
+--------+-----------------+-----------+
|default |long_string_table|false      |
+--------+-----------------+-----------+

18/10/18 06:08:24 INFO VarcharDataTypesBasicTestCase: ScalaTest-run-running-VarcharDataTypesBasicTestCase 

===== FINISHED org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase: 'test spark file format table: write from dataframe with long_string datatype whose order of fields is not the same as that in table' =====

Table or view 'long_string_table' not found in database 'default';
org.apache.spark.sql.catalyst.analysis.NoSuchTableException: Table or view 'long_string_table' not found in database 'default';
    at org.apache.spark.sql.hive.CarbonFileMetastore.lookupRelation(CarbonFileMetastore.scala:168)
    at org.apache.spark.sql.hive.CarbonFileMetastore.lookupRelation(CarbonFileMetastore.scala:143)
    at org.apache.spark.sql.execution.command.management.CarbonLoadDataCommand.processMetadata(CarbonLoadDataCommand.scala:117)
    at org.apache.spark.sql.execution.command.AtomicRunnableCommand.run(package.scala:90)
    at org.apache.spark.sql.CarbonDataFrameWriter.loadDataFrame(CarbonDataFrameWriter.scala:62)
    at org.apache.spark.sql.CarbonDataFrameWriter.writeToCarbonFile(CarbonDataFrameWriter.scala:46)
    at org.apache.spark.sql.CarbonDataFrameWriter.appendToCarbonFile(CarbonDataFrameWriter.scala:41)
    at org.apache.spark.sql.CarbonSource.createRelation(CarbonSource.scala:115)
    at org.apache.spark.sql.execution.datasources.DataSource.write(DataSource.scala:469)
    at org.apache.spark.sql.execution.datasources.SaveIntoDataSourceCommand.run(SaveIntoDataSourceCommand.scala:50)
    at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult$lzycompute(commands.scala:58)
    at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult(commands.scala:56)
    at org.apache.spark.sql.execution.command.ExecutedCommandExec.doExecute(commands.scala:74)
    at org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$1.apply(SparkPlan.scala:117)
    at org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$1.apply(SparkPlan.scala:117)
    at org.apache.spark.sql.execution.SparkPlan$$anonfun$executeQuery$1.apply(SparkPlan.scala:138)
    at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
    at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:135)
    at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:116)
    at org.apache.spark.sql.execution.QueryExecution.toRdd$lzycompute(QueryExecution.scala:92)
    at org.apache.spark.sql.execution.QueryExecution.toRdd(QueryExecution.scala:92)
    at org.apache.spark.sql.DataFrameWriter.runCommand(DataFrameWriter.scala:609)
    at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:233)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase$$anonfun$18.apply$mcV$sp(VarcharDataTypesBasicTestCase.scala:489)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase$$anonfun$18.apply(VarcharDataTypesBasicTestCase.scala:438)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase$$anonfun$18.apply(VarcharDataTypesBasicTestCase.scala:438)
    at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
    at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
    at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
    at org.scalatest.Transformer.apply(Transformer.scala:22)
    at org.scalatest.Transformer.apply(Transformer.scala:20)
    at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:166)
    at org.apache.spark.sql.test.util.CarbonFunSuite.withFixture(CarbonFunSuite.scala:41)
    at org.scalatest.FunSuiteLike$class.invokeWithFixture$1(FunSuiteLike.scala:163)
    at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175)
    at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175)
    at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
    at org.scalatest.FunSuiteLike$class.runTest(FunSuiteLike.scala:175)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase.org$scalatest$BeforeAndAfterEach$$super$runTest(VarcharDataTypesBasicTestCase.scala:39)
    at org.scalatest.BeforeAndAfterEach$class.runTest(BeforeAndAfterEach.scala:255)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase.runTest(VarcharDataTypesBasicTestCase.scala:39)
    at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208)
    at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208)
    at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413)
    at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
    at scala.collection.immutable.List.foreach(List.scala:381)
    at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
    at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396)
    at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483)
    at org.scalatest.FunSuiteLike$class.runTests(FunSuiteLike.scala:208)
    at org.scalatest.FunSuite.runTests(FunSuite.scala:1555)
    at org.scalatest.Suite$class.run(Suite.scala:1424)
    at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1555)
    at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212)
    at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212)
    at org.scalatest.SuperEngine.runImpl(Engine.scala:545)
    at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:212)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase.org$scalatest$BeforeAndAfterAll$$super$run(VarcharDataTypesBasicTestCase.scala:39)
    at org.scalatest.BeforeAndAfterAll$class.liftedTree1$1(BeforeAndAfterAll.scala:257)
    at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:256)
    at org.apache.carbondata.spark.testsuite.longstring.VarcharDataTypesBasicTestCase.run(VarcharDataTypesBasicTestCase.scala:39)
    at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:55)
    at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2563)
    at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2557)
    at scala.collection.immutable.List.foreach(List.scala:381)
    at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:2557)
    at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1044)
    at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1043)
    at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:2722)
    at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1043)
    at org.scalatest.tools.Runner$.run(Runner.scala:883)
    at org.scalatest.tools.Runner.run(Runner.scala)
    at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.runScalaTest2(ScalaTestRunner.java:131)
    at org.jetbrains.plugins.scala.testingSupport.scalaTest.ScalaTestRunner.main(ScalaTestRunner.java:28)

Process finished with exit code 0
xuchuanyin commented 5 years ago

3

after change the above carbondata to carbon in df.write.format, a new exception message:

Expected exactly one path to be specified, but got: 
java.lang.IllegalArgumentException: Expected exactly one path to be specified, but got: 
    at org.apache.spark.sql.execution.datasources.DataSource.writeInFileFormat(DataSource.scala:397)
    at org.apache.spark.sql.execution.datasources.DataSource.write(DataSource.scala:471)
    at org.apache.spark.sql.execution.datasources.SaveIntoDataSourceCommand.run(SaveIntoDataSourceCommand.scala:50)
    at org.apache.spark.sql.execution.command.ExecutedCommandExec.
xuchuanyin commented 5 years ago

4

  test("test spark file format table: write from dataframe with long_string datatype whose order of fields is not the same as that in table") {
    if (sqlContext.sparkSession.version.startsWith("2.1")) {
      sql(
        s"""
           | CREATE TABLE if not exists $longStringTable(
           | id INT, name STRING, description STRING, address STRING, note STRING
           | ) USING carbon
           | OPTIONS("LONG_STRING_COLUMNS" "description, note", "dictionary_include" "name",
           | "sort_columns" "id")
           |""".
          stripMargin)
    } else {
      sql(
        s"""
           | CREATE TABLE if not exists $longStringTable(
           | id INT, name STRING, description STRING, address STRING, note STRING
           | ) USING carbon
           | OPTIONS("LONG_STRING_COLUMNS"="description, note", "dictionary_include"="name",
           | "sort_columns"="id")
           |""".
          stripMargin)
    }

    sql("show tables").show(false)

    prepareDF()
    // the order of fields in dataframe is different from that in create table
    longStringDF.select("note", "address", "description", "name", "id")
      .write
      .format("carbon")
      .mode(SaveMode.Append)
      .saveAsTable(longStringTable)

    sql(s"SELECT * FROM $longStringTable limit 20").show(false)

    checkQuery()
  }
java.lang.NegativeArraySizeException
    at org.apache.carbondata.processing.loading.sort.SortStepRowHandler.unpackNoSortFromBytes(SortStepRowHandler.java:333)
    at org.apache.carbondata.processing.loading.sort.SortStepRowHandler.readRowFromMemoryWithNoSortFieldConvert(SortStepRowHandler.java:617)
    at org.apache.carbondata.processing.loading.sort.unsafe.UnsafeCarbonRowPage.getRow(UnsafeCarbonRowPage.java:100)
    at org.apache.carbondata.processing.loading.sort.unsafe.holder.UnsafeInmemoryHolder.readRow(UnsafeInmemoryHolder.java:62)
    at org.apache.carbondata.processing.loading.sort.unsafe.merger.UnsafeSingleThreadFinalSortFilesMerger.startSorting(UnsafeSingleThreadFinalSortFilesMerger.java:127)
    at org.apache.carbondata.processing.loading.sort.unsafe.merger.UnsafeSingleThreadFinalSortFilesMerger.startFinalMerge(UnsafeSingleThreadFinalSortFilesMerger.java:94)
    at org.apache.carbondata.processing.loading.sort.impl.UnsafeParallelReadMergeSorterImpl.sort(UnsafeParallelReadMergeSorterImpl.java:110)
xuchuanyin commented 5 years ago

java.lang.IllegalArgumentException: Can not create a Path from an empty string java.lang.RuntimeException: java.lang.IllegalArgumentException: Can not create a Path from an empty string