Browse Source

Fix makedata to hive: lowercase column name

StrayWarrior 1 month ago
parent
commit
6603a57147

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketDataFromOriginToHive_20250228.scala

@@ -538,7 +538,7 @@ object makedata_ad_33_bucketDataFromOriginToHive_20250228 {
     for ((columnName, value) <- map) {
       try {
         // 查找列名在表结构中的索引
-        val columnIndex = schema.getColumnIndex(columnName)
+        val columnIndex = schema.getColumnIndex(columnName.toLowerCase)
         // 获取列的类型
         val columnType = schema.getColumn(columnIndex).getTypeInfo
         try {

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketDataToHive_20250110.scala

@@ -117,7 +117,7 @@ object makedata_ad_33_bucketDataToHive_20250110 {
     for ((columnName, value) <- map) {
       try {
         // 查找列名在表结构中的索引
-        val columnIndex = schema.getColumnIndex(columnName)
+        val columnIndex = schema.getColumnIndex(columnName.toLowerCase())
         // 获取列的类型
         val columnType = schema.getColumn(columnIndex).getTypeInfo
         try {