ka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 本地新建文件“input_data1.txt”，将“log1.txt”的内容复制保存到“input_data1.txt”。 在客户端安装节点下创

查看更多 →

ka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 本地新建文件“input_data1.txt”，将“log1.txt”的内容复制保存到“input_data1.txt”。 在客户端安装节点下创

查看更多 →

rsize 每次向 服务器 读取文件的最大字节数。实际数据小于或等于此值。rsize必须是1024倍数的正整数，小于1024时自动设为4096，大于1048576时自动设为1048576。默认时，服务器和客户端进行协商后设置。 建议设置为最大值1048576。 wsize 每次向服务器写入文件

查看更多 →

已安装云容灾网关。若客户端为linux，云容灾网关为24.6.0及更高版本；若客户端为windows，则要求云容灾网关为24.9.0及更高版本。 需要日志收集的生产站点服务器已安装代理客户端，若生产站点服务器为Linux操作系统，代理客户端为24.6.0及更高版本，若生产站点服务器为Windows操作系统，代理客户端为24

查看更多 →

application_name参数的回退值。 keepalives 控制是否客户端TCP保持连接，默认为1，表示打开；值为0，表示关闭。若UNIX域套接字连接，则忽略。 options 连接开始时发送给服务器的命令行选项。 keepalives_idle 控制向服务器发送keepalive消息之前不活动的描述，若

查看更多 →

application_name参数的回退值。 keepalives 控制是否客户端TCP保持连接，默认为1，表示打开；值为0时，表示关闭。若UNIX域套接字连接，则忽略。 options 连接开始时发送给服务器的命令行选项。 keepalives_idle 控制向服务器发送keepalive消息之前不活动的描述，若

查看更多 →

application_name参数的回退值。 keepalives 控制是否客户端TCP保持连接，默认为1，表示打开；值为0时，表示关闭。若UNIX域套接字连接，则忽略。 options 连接开始时发送给服务器的命令行选项。 keepalives_idle 控制向服务器发送keepalive消息之前不活动的描述，若

查看更多 →

application_name参数的回退值。 keepalives 控制是否客户端TCP保持连接，默认为1，表示打开；值为0时，表示关闭。若UNIX域套接字连接，则忽略。 options 连接开始时发送给服务器的命令行选项。 keepalives_idle 控制向服务器发送keepalive消息之前不活动的描述，若

查看更多 →

是否支持通过EDNS获取客户端真实IP地址实现精准调度？ 华为云云解服务支持通过EDNS，使权威DNS能够获取到客户端的真实IP地址，从而实现精准调度。 一般情况下，当客户端需要请求某个 域名 时，通常是向运营商本地递归服务器或是自主配置的递归服务器查询，由递归服务器向权威DNS服务器发送域名解析请

查看更多 →

后把单词记录分类统计，得到每个单词记录数。 数据规划 StructuredStreaming样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 创建Topic。 {zkQ

查看更多 →

Redis 是一个请求/响应模型的服务，通常执行一个命令的流程为： 图1 Redis 命令执行流程 客户端发送命令到 Redis 服务器。 Redis 服务器收到命令，排队等待处理。 Redis 服务器执行命令。 Redis 服务器返回结果给客户端。 上述4个步骤中，步骤1和4是IO操作，

查看更多 →

后把单词记录分类统计，得到每个单词记录数。 数据规划 StructuredStreaming样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 将Kafka的Broker配置参数“allow

查看更多 →

后把单词记录分类统计，得到每个单词记录数。 数据规划 StructuredStreaming样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 将Kafka的Broker配置参数“allow

查看更多 →

setBusMessageCallback 设置消息总线回调，用于对设备上报的数据进行处理。 sendBusMessage 向总线发送设备数据，用于将处理后的设备数据发送到总线。 callDeviceCommand 调用设备命令。 getDevicesStatus 查询设备状态。 getDevicesInfos 查询子设备列表。

查看更多 →

后，如果尚未从客户端接收到任何数据，则sshd将通过加密的通道发送消息以请求客户端的响应。默认值为0，表示这些消息将不会发送到客户端。此选项仅适用于协议版本2。 ClientAliveCountMax设置客户端活动消息的数量，该消息可以在sshd接收不到来自客户端的任何消息的情况

查看更多 →

查询设备命令 应用服务器向设备下发命令后，可调用此接口在物联网平台查询下发命令的状态及内容信息，以了解命令的执行情况。 修改设备命令 应用服务器向设备下发命令后，如果由于命令排队、设备不在线等原因，物联网平台还未把命令下发给设备执行，此时应用服务器可调用此接口修改该命令的状态信息

查看更多 →

后把单词记录分类统计，得到每个单词记录数。 数据规划 StructuredStreaming样例工程的数据存储在Kafka组件中。向Kafka组件发送数据（需要有Kafka权限用户）。 确保集群安装完成，包括HDFS、Yarn、Spark和Kafka。 创建Topic。 {zkQ

查看更多 →

在beeline客户端执行dfs -put命令报错 问题现象 执行命令： dfs -put /opt/kv1.txt /tmp/kv1.txt 报以下错误： Permission denied. Principal [name=admin, type=USER] does not

查看更多 →

隐私保护通话 平台（服务端） 客户应用（客户端） 若要接收呼叫事件通知，客户添加应用时需设置呼叫状态接收地址，并确保提供的地址能够正常处理隐私保护通话平台发送的通知消息。 X模式话单通知接口 隐私保护通话平台向客户推送通话的话单信息 隐私保护通话平台（服务端） 客户应用（客户端） 若要接收话单通知，

查看更多 →

使用Yarn客户端命令查询历史作业报错 问题现象 执行Yarn客户端命令查询历史作业报错，进程被终止。具体错误如下: 原因分析 客户端分配内存不足，导致提交命令报错。 处理步骤 以root用户登录HDFS客户端安装节点。 执行以下命令编辑文件。 vim /opt/client/HDFS/component_env

查看更多 →

DisConnect：关闭与压测网站的连接。 Pong：向压测网站发送pong。 Ping&Pong：向压测网站发送pong期望返回ping。 Request：向压测网站发送请求并接收响应。 ReadOnly：仅接收压测网站发送的信息。 WriteOnly：仅向压测网站发送信息。 请求连接地址 WebSo

查看更多 →