我们已经安装了新的gpdb数据库。但是,当尝试连接template0数据库时。
[gpadmin@mdw~]$ psql -d template0
psql: FATAL: database "template0" is not currently accepting connections
[gpadmin@mdw~]$
Run Code Online (Sandbox Code Playgroud)
我们试图更新旗帜
template1=# UPDATE pg_database SET datallowconn = TRUE WHERE datname = 'template0';
ERROR: permission denied: "pg_database" is a system catalog
template1=#
Run Code Online (Sandbox Code Playgroud)
但是,不允许更新FLAG
当我尝试使用 Intellij IDEA 访问 Spark 流应用程序时
环境
Spark核心版本2.2.0 Intellij IDEA 2017.3.5版本
附加信息:Spark 正在 Yarn 模式下运行。
出现错误:
Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties
Exception in thread "main" java.lang.ExceptionInInitializerError
at kafka_stream.kafka_stream.main(kafka_stream.scala)
Caused by: org.apache.spark.SparkException: A master URL must be set in your configuration
at org.apache.spark.SparkContext.<init>(SparkContext.scala:376)
at org.apache.spark.SparkContext$.getOrCreate(SparkContext.scala:2509)
at org.apache.spark.sql.SparkSession$Builder$$anonfun$6.apply(SparkSession.scala:909)
at org.apache.spark.sql.SparkSession$Builder$$anonfun$6.apply(SparkSession.scala:901)
at scala.Option.getOrElse(Option.scala:121)
at org.apache.spark.sql.SparkSession$Builder.getOrCreate(SparkSession.scala:901)
at kafka_stream.InitSpark$class.$init$(InitSpark.scala:15)
at kafka_stream.kafka_stream$.<init>(kafka_stream.scala:6)
at kafka_stream.kafka_stream$.<clinit>(kafka_stream.scala)
... 1 more
Process finished with exit code 1
Run Code Online (Sandbox Code Playgroud)
试过这个
val spark: SparkSession = SparkSession.builder()
.appName("SparkStructStream")
.master("spark://127.0.0.1:7077")
//.master("local[*]")
.getOrCreate()
Run Code Online (Sandbox Code Playgroud)
仍然遇到相同的 MASTER …