检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
打印出SQL语句的逻辑计划和物理计划。 void printSchema() 打印schema信息到控制台。 registerTempTable 将DataFrame注册为一张临时表,其周期和SQLContext绑定在一起。 DataFrame toDF(java.lang.String... colNames)
若使用EIP公网通信,那么集群节点均需要绑定公网,尤其是分析节点,必须绑定公网才能保证作业正常运行。 sqoop实例一般分布在Master节点,但作业真正运行在分析节点,因此创建数据库连接,是和Master节点通信,作业是通过Yarn任务分发到分析节点执行。 检查Sqoop实例安装目录
对RPC的加密方式,有如下三种取值: “authentication”:普通模式默认值,指数据在鉴权后直接传输,不加密。这种方式能保证性能但存在安全风险。 “integrity”:指数据直接传输,即不加密也不鉴权。 为保证数据安全,请谨慎使用这种方式。 “privacy”:安全模
joboverview”相同,Job按状态进行分组,每个Job组都有一个小状态,但只包含当前运行的Job。 /joboverview/completed Job按状态进行分组,每个都有一个小状态的摘要。 与“/ joboverview”相同,但仅包含已完成,已取消或失败的Job。 /jobs/<jobid>
joboverview”相同,Job按状态进行分组,每个Job组都有一个小状态,但只包含当前运行的Job。 /joboverview/completed Job按状态进行分组,每个都有一个小状态的摘要。 与“/ joboverview”相同,但仅包含已完成,已取消或失败的Job。 /jobs/<jobid>
joboverview”相同,Job按状态进行分组,每个Job组都有一个小状态,但只包含当前运行的Job。 /joboverview/completed Job按状态进行分组,每个都有一个小状态的摘要。 与“/ joboverview”相同,但仅包含已完成,已取消或失败的Job。 /jobs/<jobid>
examples包的“HIndexExample”类的dropIndicesExample方法中。 dropIndices():从指定的表中删除指定的索引,但索引数据不会被删除。 public void dropIndicesExample() { LOG.info("Entering
对RPC的加密方式,有如下三种取值: “authentication”:普通模式默认值,指数据在鉴权后直接传输,不加密。这种方式能保证性能但存在安全风险。 “integrity”:指数据直接传输,即不加密也不鉴权。 为保证数据安全,请谨慎使用这种方式。 “privacy”:安全模
nf/flink-conf.yaml”中的参数。 图1 flink-conf.yaml配置 修改并刷新配置后,重新提交作业出现作业可以提交但报“log4j:ERROR setFile(null,true) call failed”的错误。 图2 log4j报错 查看log4j发现用户将“log4j
当源集群与目标集群部署在同一区域的不同VPC时,请创建两个VPC之间的网络连接,打通网络层面的数据传输通道。请参见VPC对等连接。 当源集群与目标集群部署在同一VPC但属于不同安全组时,在VPC管理控制台,为每个安全组分别添加安全组规则。规则的“协议”为“ANY”,“方向”为“入方向”,“源地址”为“安全组”且是对端集群的安全组。
plicationMaster内存会设定为2000MB。 对于计算后的调整值低于设定的“minMemory”值的情形,虽然此时配置不会生效但后台仍然会打印出这个调整值,用于为用户提供“minMemory”参数调整的依据,保证配置可以生效。 父主题: Yarn企业级能力增强
plicationMaster内存会设定为2000MB。 对于计算后的调整值低于设定的“minMemory”值的情形,虽然此时配置不会生效但后台仍然会打印出这个调整值,用于为用户提供“minMemory”参数调整的依据,保证配置可以生效。 父主题: Yarn企业级能力增强
wal Operate on WAL (write-ahead log) files kudu命令行工具不提供DDL、DML等操作,但提供针对cluster、master、tserver、fs、table等的细化查询功能。 常用操作: 查看当前集群下有哪些表。 kudu table
根据以上角色的设置,用户提交应用后,会在客户端打印WARN日志。出现WARN日志是由于Flink会去YARN获取资源剩余值并进行检测评估,但该操作需要admin操作权限,可用户并没有设置该权限。该问题不影响任务提交执行,可以忽略。WARN日志如下: Get node resource
wal Operate on WAL (write-ahead log) files kudu命令行工具不提供DDL、DML等操作,但提供针对cluster、master、tserver、fs、table等的细化查询功能。 常用操作: 查看当前集群下有哪些表。 kudu table
标签的key值可以包含任意语种字母、数字、空格和_.:=+-@,但首尾不能含有空格,不能以_sys_开头。 默认取值: 不涉及 values Array of strings 参数解释: 标签的值。 约束限制: 标签的value值可以包含任意语种字母、数字、空格和_.:=+-@,但首尾不能含有空格,不能以_sys_开头。
map[R: TypeInformation](fun: T => R): DataStream[R] 输入一个元素,生成另一个元素,元素类型不变。 def map[R: TypeInformation](mapper: MapFunction[T, R]): DataStream[R]
map[R: TypeInformation](fun: T => R): DataStream[R] 输入一个元素,生成另一个元素,元素类型不变。 def map[R: TypeInformation](mapper: MapFunction[T, R]): DataStream[R]
map[R: TypeInformation](fun: T => R): DataStream[R] 输入一个元素,生成另一个元素,元素类型不变。 def map[R: TypeInformation](mapper: MapFunction[T, R]): DataStream[R]
privacy:指数据在鉴权及加密后再传输。这种方式会降低性能。 authentication:指数据在鉴权后直接传输,不加密。这种方式能保证性能但存在安全风险。 integrity:指数据直接传输,即不加密也不鉴权。 为保证数据安全,请谨慎使用这种方式。 解决办法 重新下载客户端,如果是应用程序,更新应用程序中的配置文件。