Spark usage help

2021-09-01 Thread yinghua...@163.com
Hi: I found that the following methods are used when setting parameters to create a sparksession access hive table 1) hive.execution.engine:spark spark = SparkSession.builder() .appName("get data from hive") .config("hive.execution.engine", "spark") .enableHiveSupport() .getOrCreate()

Flink 1.11.3从Kafka提取数据到Hive问题求助

2021-02-03 Thread yinghua...@163.com
目前在官网上没看到Flink SQL中从kafka到Hive的样例?翻了下测试代码,但是需要自己在代码中特殊处理下,求助能给一个在Flink SQL中直接使用Hive Connector的样例吗? yinghua...@163.com