问题在hive中插入数据创建小部分文件

Question

我正在处理超过1000000条记录的json文件我正在逐行读取文件并提取所需的键值（json是混合结构不能修复。所以我正在解析并生成需要的json元素）并生成json字符串simillar到json_string变量和push to hive table数据存储正确，但在hadoop apps / hive / warehouse / jsondb.myjson_table文件夹中包含小部分文件。每个插入查询将创建新的（.1到.20 kb）零件文件。如果我在蜂巢上运行简单查询，因为它需要超过30分钟。显示我的逻辑的示例代码，这会在hive.中将新记录的倍数乘以inesrt


  import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder().appName("SparkSessionZipsExample").enableHiveSupport().getOrCreate()

var json_string = """{"name":"yogesh_wagh","education":"phd" }"""

val df = spark.read.json(Seq(json_string).toDS)

//df.write.format("orc").saveAsTable("bds_data1.newversion");

df.write.mode("append").format("orc").insertInto("bds_data1.newversion");

我也尝试添加hive属性来合并文件，但它不会工作，

我也尝试从现有表创建表，将小部分文件合并到一个256 MB文件中。请分享示例代码以插入多个记录并在部分文件中追加记录。