检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
getExecutionEnvironment // 设置job的并发度为2 env.setParallelism(2) //设置Zookeeper为注册服务器 val zkRegisterServerHandler = new ZookeeperRegisterServerHandler
安全模式下在提交source.jar之前，请确保已经进行kerberos安全登录，并且keytab方式下，登录用户和所上传keytab所属用户必须是同一个用户。 因为示例中的HBaseBolt并没有建表功能，在提交之前确保hbase中存在相应的表，若不存在需要手动建表，hbase shell建表语句如下create
集群未启用Kerberos认证（普通模式）时用户密码默认永不过期，存在安全风险，建议创建用户时设置密码过期策略，强制定期修改用户密码。 密码过期后，该用户将不可用，必须使用具有Doris相同级别权限的用户修改该用户的密码。 父主题： Doris用户权限管理
nf, batchDuration); // 设置Streaming的CheckPoint目录，由于窗口概念存在，该参数必须设置 jssc.checkpoint("checkpoint"); // 组装Kafka的主题列表
执行命令后需输入LDAP管理员密码，请联系MRS集群管理员获取。 是，执行13。 否，执行15。 使用告警出现日期之前的备份文件进行LdapServer恢复和OMS恢复。 必须使用同一时间点的OMS和LdapServer备份数据进行恢复，否则可能造成业务和操作失败。当业务正常时需要恢复数据，建议手动备份最新管理数
getExecutionEnvironment // 设置job的并发度为2 env.setParallelism(2) //设置Zookeeper为注册服务器 val zkRegisterServerHandler = new ZookeeperRegisterServerHandler
getApplicationAttemptReport(GetApplicationAttemptReportRequest request) Client通过此接口从RM获取指定ApplicationAttempt的报告信息。 getApplicationAttempts(GetApplicationAttemptsRequest
reporter.alarm.job.alarm.rocksdb.background.jobs.multiplier，默认值2），如果大于线程数的指定倍数，可增加RocksDB线程数。 是：在Flink WebUI的作业开发界面，调整如下自定义参数的值并保存后执行8。 表1 调整自定义参数
reporter.alarm.job.alarm.rocksdb.background.jobs.multiplier，默认值2），如果大于线程数的指定倍数，可增加RocksDB线程数。 是：在Flink WebUI的作业开发界面，调整如下自定义参数的值并保存后执行8。 表1 调整自定义参数
(OBS)”。 “操作”勾选所有“写”、“列表”和“只读”权限。 “所有资源”选择“特定资源”，并配置以下参数： “object”选择“通过资源路径指定”，并单击“添加资源路径”添加路径，此处以/tmp目录为例，如需其他目录权限请参考该步骤添加对应目录及该目录下所有对象的资源路径。 例如，
set (0.01 sec) 可手动取消Broker Load作业状态不为“CANCELLED”或“FINISHED”的导入任务，取消时需要指定待取消导入任务的Label ，命令为： CANCEL LOAD FROM 数据库名称 WHERE LABEL = "Label名称"; 例如：撤销数据库demo上，
dataorigin失败，报错显示权限不足。 执行select name from dataorigin成功，符合预设的权限。 如果用户在执行命令时指定了HDFS路径，需要给该用户添加HDFS路径的读、写、执行权限，详情请参考添加HDFS的Ranger访问权限策略。也可以不配置HDFS的R
getApplicationAttemptReport(GetApplicationAttemptReportRequest request) Client通过此接口从RM获取指定ApplicationAttempt的报告信息。 getApplicationAttempts(GetApplicationAttemptsRequest
submitTopology(builder, SubmitType.REMOTE); } 修改userJarFilePath为Linux环境指定路径“/opt/test/lib/example.jar”。 private static void remoteSubmit(TopologyBuilder
Flink使用IoTDBSource从 IoTDB server读取数据。 要使用IoTDBSource，您需要构造一个IoTDBSource的实例，通过指定的IoTDBSourceOptions并在IoTDBSource中实现抽象方法convert()，convert()定义了您希望如何转换行数据。
getApplicationAttemptReport(GetApplicationAttemptReportRequest request) Client通过此接口从RM获取指定ApplicationAttempt的报告信息。 getApplicationAttempts(GetApplicationAttemptsRequest
“备份策略”：表示任务每次启动时备份的数据量。支持“首次全量备份，后续增量备份”、“每次都全量备份”和“每n次进行一次全量备份”。选择“每n次进行一次全量备份”时，需要指定n的值。 选择备份源。 在“备份配置”，勾选元数据选项，例如“OMS”和“LdapServer”。 设置备份参数。 在“OMS”和“Lda
har特性优化 OBS包升级 JDK版本升级 MRS 1.9.0.6 修复问题列表： MRS Manager MRS Manager支持包周期集群指定节点缩容 MRS大数据组件 解决Hivese提交sql卡顿问题 支持jobhistory查询失败信息接口 解决细粒度权限不生效问题 解决hive
定时间段（例如凌晨3点）进行批量分析，可能仅需要消耗2小时。 MRS提供的弹性伸缩能力，可以帮助用户在进行批量分析操作时，将分析节点扩容到指定规模，而计算完毕后，则自动释放计算节点，尽可能的降低使用成本。 平衡突发查询 大数据集群上，由于有大量的数据，企业会经常面临临时的分析任务
添加Oracle数据源 添加GBase数据源 使用跨源协同分析流程 参考快速使用HetuEngine访问Hive数据源登录HetuEngine客户端。 注册Hive、HBase、GaussDB A等数据源。 hetuengine> show catalogs; Catalog ----------
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
