检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
属于用户使用不当。对于本业务应用来说，若要解决此问题，可以参考如下几种办法： 方法1： 直接参考Hive组件的“jdbc-examples”样例工程，将core-site.xml配置文件放在classpath路径下。 方法2： 在代码中，显式加载配置文件core-site.xml，例如：
domain.socket.path”)，该目录默认权限是750。而当前Linux用户没有权限操作该目录。 上述问题可通过执行以下方法解决： 方法一：创建新用户(推荐使用)。 通过Manager页面创建新的用户，该用户属组中默认包含ficommon组。 [root@xxx-xxx-xxx-xxx
户端命令提交 * 2、远程方式提交，这种需要将应用程序的jar包打包好之后在IntelliJ IDEA中运行main方法提交 * 3、本地提交 ，在本地执行应用程序，一般用来测试 * 命令行方式和远程方式安全和普通模式都支持
p.abnorm.ALL。 columns 待导入数据的函数变换配置，目前 Stream Load支持的函数变换方法包含列的顺序变化以及表达式变换，其中表达式变换的方法与查询语句一致。 format 指定导入数据格式，支持CSV、JSON、Parquet、ORC等，默认是CSV。
Spark shuffle异常处理 问题 在部分场景Spark shuffle阶段会有如下异常 解决方法 JDBC应该： 登录FusionInsight Manager管理界面，修改JDBCServer的参数“spark.authenticate.enableSaslEncryp
Ranger鉴权的具体策略请参见鉴权策略。 OBS存算分离细粒度鉴权 对于OBS存算分离集群，如果您想对OBS上的资源进行细粒度的权限控制，可以通过MRS提供的基于IAM委托的细粒度权限控制方案进行配置，请参见配置MRS多用户访问OBS细粒度权限。 父主题： 安全
PU、数据以及应用程序逻辑的情况调整并行度参数。 算子层次 一个算子、数据源和sink的并行度可以通过调用setParallelism()方法来指定，例如 final StreamExecutionEnvironment env = StreamExecutionEnvironment
hbase\example”包的“TestZKSample”类中，用户主要需要关注“login”和“connectApacheZK”这两个方法。 private static void login(String keytabFile, String principal) throws
domain.socket.path”)，该目录默认权限是750。而当前Linux用户没有权限操作该目录。 上述问题可通过执行以下方法解决： 方法一：创建新用户(推荐使用)。 通过Manager页面创建新的用户，该用户属组中默认包含ficommon组。 [root@xxx-xxx-xxx-xxx
Application application_1619511926396_2586346 finished with failed status 解决方法 使用root用户登录Spark客户端节点，调高“spark-defaults.conf”文件中“spark.driver.memory”参数值。
访问页面失败，浏览器无法显示此页，如下图所示： 原因 IE 9、IE 10、IE 11浏览器的某些版本在处理SSL握手有问题导致访问失败。 解决方法 重新刷新页面即可。 父主题： HDFS常见问题
ect_id与集群的project_id不符合。 处理步骤 在使用AK/SK认证方式调用接口前，请参见表1收集对应信息，详细的签名方法和SDK使用方法请参见API签名指南。 在构造API请求前，需要获取以下信息，包括组成请求URL的Endpoint和URI，用于签名和认证的AK/SK，用于区分租户的项目ID。
Oozie Java接口介绍 Java API主要由org.apache.oozie.client.OozieClient提供。 表1 接口介绍 方法 说明 public String run(Properties conf) 运行Job。 public void start(String
Oozie Java接口介绍 Java API主要由org.apache.oozie.client.OozieClient提供。 表1 接口介绍 方法 说明 public String run(Properties conf) 运行job public void start(String
Functions)，用于操作单个输入行，产生多个输出行。 按使用方法，UDF有如下分类： 临时函数，只能在当前会话使用，重启会话后需要重新创建。 永久函数，可以在多个会话中使用，不需要每次创建。 下面以编写一个AddDoublesUDF为例，说明UDF的编写和使用方法。 功能介绍 AddDoublesUD
wlog_responses命令的使用方法： 查看请求信息 由于get_slowlog_responses和get_largelog_responses使用方法和支持的参数一致，这里主要介绍get_slowlog_responses的使用方法。 已登录HBase Shell命令行
x及后续版本。 前提条件 源分组和目标分组均存在。 当前用户具备源分组和目标分组的编辑“Group Edit”权限。 当前用户具备源分组的作业编辑“Jobs Edit”权限或待迁移作业的编辑“Edit”权限。 操作步骤 登录“Loader WebUI”界面。 登录FusionInsight M
Spark作业运行查看日志有些WARN日志，作业运行很慢，Caused by显示：UnknownScannerExeception。 解决方法 运行Spark作业前，调整hbase.client.scanner.timeout.period参数（例如从60秒调高到120秒）。 登录Manage界面，选择“集群
如何设置开源Flink中的znode存储目录 问题现象 如何将开源Flink中的znode存储目录设置为自定义目录。 解决方法 如设置目录为/flink_base/flink，在flink-conf.yaml配置文件中将“high-availability.zookeeper.path
main(TopicCommand.scala:51) at kafka.admin.TopicCommand.main(TopicCommand.scala) 解决方法参考1。 客户端查询命令。 kafka-topics.sh --list --zookeeper 192.168.0.122:2181/kafka
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
