Spark настраиваемая схема & jdb c неправильно отображает данные

Question

Код ниже печатает имена столбцов вместо данных.

    SparkConf sparkConf = new SparkConf().setAppName("SparkSQL-Analysis").setSparkHome("C:\\work\\spark-2.4.4-bin-hadoop2.7").setMaster("local[*]");

    JavaSparkContext javaSparkContext = new JavaSparkContext(sparkConf);

    SparkSession sparkSession = SparkSession.builder().sparkContext(javaSparkContext.sc()).appName("SparkSQL").getOrCreate();

    Dataset<Row> jdbcDF = sparkSession.read().format("jdbc")
              .option("url", "jdbc:mariadb://localhost:4406/cra")
              .option("dbtable", "rpm_user")
              .option("user", "root")
              .option("password", "XXXXXX")
              .option("customSchema", "RU_CRD string, RU_CONTACT_NUMBER string, RU_UPD string")
              .load();

    jdbcDF.show();

    javaSparkContext.close();

Чего мне не хватает?

Вывод

Answer 1

Нашел решение здесь Как читать данные из mariadb, используя Spark java

Переход с jdb c: mariadb: // localhost: 4406 / cra на jdb c: mysql: // localhost: 4406 / cra исправил мою проблему.