使用Spark执行Hudi样例程序（Java） 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieWriteClientExample。 创建客户端对象来操作Hudi： String tablePath = args[0];

查看更多 →

使用Spark执行Hudi样例程序（Java） 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieWriteClientExample 创建客户端对象来操作Hudi： String tablePath = args[0];

查看更多 →

取值范围：整型，1～8，单位为天。 默认值：8 wdr_snapshot_query_timeout 参数说明：系统执行数据库监控快照操作时，设置快照操作相关的sql语句的执行超时时间。如果语句超过设置的时间没有执行完并返回结果，则本次快照操作失败。 该参数属于SIGHUP类型参数，请参考表1中对应设置方法进行设置。

查看更多 →

取值范围：整型，1～30，单位为天。 默认值：8 wdr_snapshot_query_timeout 参数说明：系统执行数据库监控快照操作时，设置快照操作相关的sql语句的执行超时时间。如果语句超过设置的时间没有执行完并返回结果，则本次快照操作失败。 该参数属于SIGHUP类型参数，请参考表1中对应设置方法进行设置，0代表该参数不生效。

查看更多 →

取值范围：整型，1～8。 默认值：8 wdr_snapshot_query_timeout 参数说明：系统执行数据库监控快照操作时，设置快照操作相关的sql语句的执行超时时间。如果语句超过设置的时间没有执行完并返回结果，则本次快照操作失败。 该参数属于SIGHUP类型参数，请参考表2中对应设置方法进行设置。

查看更多 →

使用Spark执行Hudi样例程序（Scala） 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieDataSourceExample。 插入数据： def insertData(spark: SparkSession

查看更多 →

使用Spark执行Hudi样例程序（Python） 下面代码片段仅为演示，具体代码参见：HudiPythonExample.py。 插入数据： #insert inserts = sc._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(dataGen

查看更多 →

使用Spark执行Hudi样例程序（Java） 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieWriteClientExample。 创建客户端对象来操作Hudi： String tablePath = args[0];

查看更多 →

使用Spark执行Hudi样例程序（Python） 下面代码片段仅为演示，具体代码参见：HudiPythonExample.py。 插入数据： #insert inserts = sc._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(dataGen

查看更多 →

更新警报通知 操作场景 使用存储过程更新警报通知的通知方法。 前提条件 成功连接RDS for SQL Server实例。通过SQL Server客户端连接目标实例，具体操作请参见通过公网连接RDS for SQL Server实例。 操作步骤 执行以下命令，更新警报通知。 EXEC

查看更多 →

conf上传到 MRS 客户端所在节点。 步骤2-3仅启用Kerberos认证的集群执行，普通集群请直接从步骤4开始执行。 根据业务情况，准备好客户端，并登录安装客户端的节点。 例如在Master2节点更新客户端，则登录该节点使用客户端，具体参见使用MRS客户端。 执行以下命令切换用户。

查看更多 →

Hive客户端执行SQL报错连接超时 现象描述 Hive客户端执行SQL失败，报错：Timed out waiting for a free available connection。 可能原因 DBService连接较多，获取连接超时。 操作步骤 客户端是否使用Spark-SQL客户端执行SQL。

查看更多 →

取值范围：整型，1～30。 默认值：8 wdr_snapshot_query_timeout 参数说明：系统执行数据库监控快照操作时，设置快照操作相关的sql语句的执行超时时间。如果语句超过设置的时间没有执行完并返回结果，则本次快照操作失败。 该参数属于SIGHUP类型参数，请参考表1中对应设置方法进行设置，0代表该参数不生效。

查看更多 →

设置警报通知 操作场景 使用存储过程设置警报通知。 前提条件 成功连接RDS for SQL Server实例。通过SQL Server客户端连接目标实例，具体操作请参见通过公网连接RDS for SQL Server实例。 操作步骤 执行以下命令，设置警报通知。 EXEC [msdb]

查看更多 →

PATH_TO_KEYTAB); } 通过MRS集群客户端以kinit方式获取。 登录MRS集群客户端所在节点，进入客户端安装目录。 cd {客户端安装目录} 执行以下命令配置环境变量。 source bigdata_env 执行以下命令进行用户认证。 kinit MRS集群业务用户

查看更多 →

编包并运行Spark程序。 运行Python样例代码无需通过Maven打包。 将打包生成的jar包上传到Spark客户端所在 服务器 的任意目录（例如“ /opt/example/” ）下。 运行任务 登录Spark客户端节点，执行如下命令： source 客户端安装目录/bigdata_env

查看更多 →

保障业务正常运行。 生命周期管理 生命周期管理是用于在特定阶段执行调用的方法。本章节介绍如何通过CAE提供的两种生命周期管理（启动后处理、停止前处理）来处理事件。 发送事件告警到企业微信 本章节介绍如何通过设置事件通知规则，可以帮助您及时了解组件运行时的状态，快速定位问题。 对接

查看更多 →

安装客户端时编译并运行程序 操作场景 HBase应用程序支持在安装HBase客户端的Linux环境中运行。在程序代码完成开发后，您可以上传Jar包至Linux环境中运行应用。 前提条件 已安装HBase客户端。 Linux环境已安装JDK，版本号需要和Eclipse导出Jar包使用的JDK版本一致。

查看更多 →

将打包生成的jar包上传到Spark客户端所在服务器的任意目录（例如“ /opt/example/” ）下。 运行任务 登录Spark客户端节点，执行如下命令： source 客户端安装目录/bigdata_env source 客户端安装目录/Hudi/component_env kinit

查看更多 →

。 将打包生成的jar包上传到Spark客户端所在服务器的任意目录（例如“ /opt/example/” ）下。 运行任务 登录Spark客户端节点，执行如下命令： source 客户端安装目录/bigdata_env source 客户端安装目录/Hudi/component_env

查看更多 →

登录Spark客户端节点，执行如下命令： source 客户端安装目录/bigdata_env source 客户端安装目录/Hudi/component_env kinit Hudi开发用户 编译构建样例代码后可以使用spark-submit提交命令，执行命令后会依次执行写入、更新、查询、删除等操作：

查看更多 →