检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
“分配策略类型”参数选择“加权轮询算法”，并开启“会话保持”，单击“下一步：添加后端服务器”。 添加后端服务器。 在“云服务器”界面，单击“添加云服务器”，添加所有Doris FE所在节点，并单击“确定”。
使用具有Hive管理员权限的用户在Hive客户端创建全局的UDF算法： 创建CheckSum函数（在default数据库下执行）： create function checksum_aggregate as 'com.huawei.hive.checksum.ChecksumUdaf
找到待调优的并处于非运行中的作业，在“操作”列单击“开发”进入作业开发界面。 在作业开发界面的“自定义参数”项中，根据实际需求添加如下参数并保存，热数据（常用及使用中数据）可参考表1，冷数据（不常用、较长时间未使用的数据）可参考表2。
在运维管理或应用开发的场景中，需要在客户端认证用户身份后才能连接到集群服务端。系统操作运维与业务场景中主要使用的用户分为“人机”用户和“机机”用户。二者主要区别在于“机机”用户密码由系统随机生成。
- 在作业开发界面进行作业开发，输入如下语句，可以单击上方“语义校验”对输入内容校验。
所以可以选择一种压缩率非常高的压缩算法。 编解码器可配置为Snappy，Benchmark测试结果显示Snappy是非常平衡以及高效的编码器。 mapreduce.map.output.compress.codec 参数解释：指定用于压缩的编解码器。
所以可以选择一种压缩率非常高的压缩算法。 编解码器可配置为Snappy，Benchmark测试结果显示Snappy是非常平衡以及高效的编码器。
操作步骤 在开发应用程序时，添加如下代码，将“testArr”数据广播到各个节点。 def main(args: Array[String]) { ...
开发Flink应用程序时，优化DataStream的数据分区或分组操作。 当分区导致数据倾斜时，需要考虑优化分区。 避免非并行度操作，有些对DataStream的操作会导致无法并行，例如WindowAll。 keyBy尽量不要使用String。 父主题： Flink性能调优
开发Flink应用程序时，优化DataStream的数据分区或分组操作。 当分区导致数据倾斜时，需要考虑优化分区。 避免非并行度操作，有些对DataStream的操作会导致无法并行，例如WindowAll。 keyBy尽量不要使用String。 父主题： Flink性能调优
使用作业管理可以新建、查看、启动、开发、编辑、停止和删除作业等。 父主题： 创建FlinkServer作业前准备
操作步骤 在开发应用程序时，添加如下代码，将“testArr”数据广播到各个节点。 def main(args: Array[String]) { ...
参考如何创建FlinkServer作业，新建Flink SQL流作业，在作业开发界面进行作业开发，配置完成后启动作业。 需勾选“基础参数”中的“开启CheckPoint”，“时间间隔（ms）”可设置为“60000”，“模式”可使用默认值。
样例代码 以下为UDF示例代码： 其中，xxx通常为程序开发的组织名称。
例如您的员工中有负责应用开发的人员，您希望开发人员拥有MapReduce服务的使用权限，但是不希望其拥有删除MRS集群等高危操作的权限，那么您可以使用IAM为开发人员创建用户，通过授予仅能使用MRS但是不允许删除MRS集群的权限策略，控制用户对MRS集群资源的使用范围。
当然您也可以获取MRS服务样例代码工程，参考Flink开发指南开发其他Flink流作业程序。 操作流程 本实践操作流程如下所示： 步骤1：创建MRS集群：创建一个包含有Flink组件的MRS集群。 步骤2：准备测试数据：准备用于进行分析的源数据及程序，并上传至OBS。
样例代码 以下为UDF示例代码： 其中，xxx通常为程序开发的组织名称。
使用作业管理可以新建、查看、启动、开发、编辑、停止和删除作业等。 父主题： 创建FlinkServer作业前准备
参考如何创建FlinkServer作业，新建Flink SQL流作业，参考如下内容在作业开发界面进行作业开发，配置完成后启动作业。 需勾选“基础参数”中的“开启CheckPoint”，“时间间隔（ms）”可设置为“60000”，“模式”可使用默认值。
参考如何创建FlinkServer作业，新建Flink SQL流作业，参考如下内容在作业开发界面进行作业开发，配置完成后启动作业。 需勾选“基础参数”中的“开启CheckPoint”，“时间间隔（ms）”可设置为“60000”，“模式”可使用默认值。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
