检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
示例： 返回true： SELECT contains('10.0.0.0/8', IPADDRESS '10.255.255.255'); SELECT contains('2001:0db8:0:0:0:ff00:0042:8329/128', IPADDRESS '2001
connect jdbc:hive2://Zookeeper实例所在节点IP:Zookeeper Client的端口,Zookeeper实例所在节点IP:Zookeeper Client的端口,Zookeeper实例所在节点IP:Zookeeper Client的端口/;serviceDiscoveryMode
代理服务器是介于源端和云服务之间的一台服务器，有了代理服务器之后，源端服务器不是直接访问云服务，而是向代理服务器发出请求，由代理服务器从云服务取回所需要的信息并传送给源端。
功能介绍 基本概念 代理地址 购买数据库代理后，可以从数据库代理中查看代理地址，连接该地址可以执行读写操作，数据库代理会通过代理地址自动将写请求发送到主节点，将读请求发送到只读节点，降低主节点的压力。
即在使用HetuEngine客户端时，通过--session-user来指定代理用户。 创建认证用户或代理用户请参考创建HetuEngine权限角色。
如何选择代理服务器？ 代理服务器仅提供转接功能，因此对代理服务器的系统、配置无特别要求。只要确保同时连接这台代理服务器的主机数量不是特别多（超过百台），性能不会受到影响。我们建议使用CentOS系统作为代理服务器，配置华为yum源更方便。 父主题： 常见问题
解决办法 登录DBService主节点（绑定有DBService浮动IP的master节点）。
代理的URL地址类似于：https://<oms ip>:20026/Spark2x/JobHistory2x/xx/），单击某个应用，再单击“AggregatedLogs”，然后单击需要查看的其中一个Executor的“logs”，此时会报如图1所示的错误。
代理的URL地址类似于：https://<oms ip>:20026/Spark2x/JobHistory2x/xx/），单击某个应用，再单击“AggregatedLogs”，然后单击需要查看的其中一个Executor的“logs”，此时会报如图1所示的错误。
使用代理用户访问FlinkServer REST API样例程序（Java） 功能介绍 通过代理用户调用FlinkServer RestAPI。以FlinkServer管理员权限的用户访问API来获取普通用户权限。 本章节适用于MRS 3.3.0及以后版本。
使用代理用户访问FlinkServer REST API样例程序（Java） 功能介绍 通过代理用户调用FlinkServer RestAPI。以FlinkServer管理员权限的用户访问API来获取普通用户权限。 本章节适用于MRS 3.3.0及以后版本。
security.kerberos.login.principal:pippo 解决办法 修改“flink-conf.yaml”中配置，配置项名称和值之间存在一个空格。 security.kerberos.login.principal: pippo 父主题： 使用Flink
Job Pipeline流图结构 Pipeline是由Flink的多个Job通过TCP连接起来，上游Job可以直接向下游Job发送数据。这种发送数据的流图称为Job Pipeline，如图1所示。
com.huawei.bigdata.flink.examples.TestPipelineNettySink。 com.huawei.bigdata.flink.examples.TestPipelineNettySource1。
com.huawei.bigdata.flink.examples.TestPipeline_NettySink。 com.huawei.bigdata.flink.examples.TestPipeline_NettySource1。
com.huawei.bigdata.flink.examples.TestPipelineNettySink。 com.huawei.bigdata.flink.examples.TestPipelineNettySource1。
com.huawei.bigdata.flink.examples.TestPipeline_NettySink。 com.huawei.bigdata.flink.examples.TestPipeline_NettySource1。
Flink Job Pipeline样例程序（Java） 发布Job自定义Source算子产生数据 下面代码片段仅为演示，完整代码参见FlinkPipelineJavaExample样例工程下的com.huawei.bigdata.flink.examples.UserSource
com.huawei.bigdata.flink.examples.TestPipeline_NettySink。 com.huawei.bigdata.flink.examples.TestPipeline_NettySource1。
订阅者收到byte[]之后将其转化成String类型，并抽样打印输出 父主题： Flink Job Pipeline样例程序
父主题： Flink Job Pipeline样例程序
Flink Job Pipeline样例程序（Scala） 发送消息 下面代码片段仅为演示，完整代码参见FlinkPipelineScalaExample样例工程下的com.huawei.bigdata.flink.examples.Information： package com.huawei.bigdata.flink.examples
com.huawei.bigdata.flink.examples.TestPipeline_NettySink。 com.huawei.bigdata.flink.examples.TestPipeline_NettySource1。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
