检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
The object probably contains or references non serializable fields.
The object probably contains or references non serializable fields.
“Status” 表示作业的状态，包含“RUNNING”、“SUCCEEDED”、“FAILED”和“KILLED”。 “User” 表示启动该作业的用户。 “Maps” 表示作业执行Map过程的进度。 “Reduces” 表示作业执行Reduce过程的进度。
start the workflow job String jobId = oozieClient.run(conf); logger.info("Workflow job submitted: {}" , jobId); // wait
public class FlinkSQLExecutor { public static void main(String[] args) throws IOException { System.out.println("-----------------
Error: Error while compiling statement: FAILED: HiveAccessControlException Permission denied: Principal [name=hive, type=USER] does not have
HDFS/hadoop/etc/hadoop vi log4j.properties 在文件中添加OBS日志级别配置： log4j.logger.org.apache.hadoop.fs.obs=WARN log4j.logger.com.obs=WARN 可执行以下命令查看： tail
',--普通模式集群不需要该参数 'properties.kerberos.domain.name' = 'hadoop.系统域名'--普通模式集群不需要该参数 ); insert into stream_mor select * from kafka; 作业2：FlinkSQL
Application Node Label Expression : <Not set> AM container Node Label Expression : <DEFAULT_PARTITION> 查看MapReduce日志获取应用运行情况。
{ public static void main(String[] args) throws Exception { String chkPath = ParameterTool.fromArgs(args).get("chkPath", "hdfs
JDBCServer中metastore session临时文件 否 任务运行失败 /tmp/sparkhive-scratch 固定目录 存放Spark2x cli方式运行metastore session临时文件 否 任务运行失败 /tmp/logs/ 固定目录 存放container
前提条件 例如有一个复杂的查询样例如下： select s_name, count(1) as numwait from ( select s_name from ( select s_name, t2.l_orderkey, l_suppkey, count_suppkey, max_suppkey
c1:string:1:REGULAR (1 row) -- 指定查询SQL整体对应的物化视图进行查询重写 EXPLAIN
DROP INDEX MY_IDX ON MY_TABLE; EXPLAIN 显示执行计划。 EXPLAIN SELECT name FROM MY_TABLE; CREATE SEQUENCE 创建序列。
对于价值数据，两种场景下建议Kafka数据目录磁盘配置raid1或者raid5，从而提高单个磁盘故障情况下数据可靠性。
前提条件 例如有一个复杂的查询样例如下： select s_name, count(1) as numwait from ( select s_name from ( select s_name, t2.l_orderkey, l_suppkey, count_suppkey, max_suppkey
DROP INDEX MY_IDX ON MY_TABLE; EXPLAIN 显示执行计划。 EXPLAIN SELECT name FROM MY_TABLE; CREATE SEQUENCE 创建序列。
principal="leoB@HADOOP.COM" useTicketCache=false storeKey=true debug=true; }; 在Spark on YARN模式下，jaas.conf和user.keytab通过YARN分发到Spark on YARN的container
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.hadoop.hbase.client.HBaseAdmin.
X86客户端： Oracle JDK：支持1.8版本 IBM JDK：支持1.8.5.11版本 TaiShan客户端： OpenJDK：支持1.8.0_272版本 说明： 基于安全考虑，服务端只支持TLS V1.2及以上的加密协议。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
