检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
等待出现如下提示,则表示停止完成.输入“Y”,单击“回车”键即可正常关闭窗口。 Terminate batch job (Y/N)? 父主题: 使用Agent上传数据
Stream的方法删除通道。 1 dic.deleteStream(deleteStreamRequest); 父主题: 使用SDK(Java)
Stream的方法创建通道。 1 dic.createStream(createStreamRequest); 父主题: 使用SDK(Java)
PROPERTY_PRODUCER_EXCEPTION_RETRIES, "-1") .build(); 若使用JAVA SDK加密上传数据,读取数据也需要使用JAVA SDK配置相同的密钥。 使用配置文件初始化DIS SDK客户端实例。 在“dis-sdk-demo\src\m
Flume 确认使用的Java版本为1.8.0及以上版本。执行如下命令查看java版本。 java -version 检查DIS通道 使用注册账户登录DIS控制台。 单击管理控制台左上角的,选择区域和项目。 在左侧列表栏中选择“通道管理”。 确认有通道用于数据上传且通道状态为“运行中”。
getCheckpoint: {"sequence_number": "10", "metadata": "metadata"} 父主题: 使用SDK(Java)
13288589]'}], hasMorePartitions=false, updatePartitionCounts=null] 父主题: 使用SDK(Java)
[currentPartitionCount=2, streamName=mystream, targetPartitionCount=2] 父主题: 使用SDK(Java)
none 如果在消费者组中没有发现前一个偏移量,就向消费者抛出一个异常; 其他参数 参数 不支持 - 父主题: 使用Kafka Adapter上传与下载数据
LoggerFactory; import java.util.Collection; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.regex.Pattern;
配置APP名称之后,通过调用deleteApp的方法删除APP。 dic.deleteApp(myApp); 父主题: 使用SDK(Java)
监控页面查看数据是否上传成功。 在本地运行作业验证无误之后,请把pom.xml中的<scope>provided</scope>解除注释(防止以后打包会把flink依赖也打进来),然后停止数据上传程序。 父主题: 使用DIS Flink Connector上传与下载数据
ansferTask的方法删除转储任务。 1 dic.deleteTransferTask(request); 父主题: 使用SDK(Java)
提交checkpoint。 dic.commitCheckpoint(commitCheckpointRequest); 父主题: 使用SDK(Java)
配置APP名称之后,通过调用createApp的方法创建APP。 dic.createApp(myApp); 父主题: 使用SDK(Java)
equest); String cursor = response.getPartitionCursor(); 父主题: 使用SDK(Java)
none 如果在消费者组中没有发现前一个偏移量,就向消费者抛出一个异常; 其他参数 参数 不支持 - 父主题: 使用Kafka Adapter上传与下载数据
has_more_streams Boolean 是否还有更多满足条件的通道。 是:true。 否:false。 父主题: 使用SDK(Java)
Logstash Output上传数据是否正常。 向Logstash的input端输入数据,如果Logstash没有报错数据可以正常上传到指向的通道,表示上传正常。 登录DIS控制台,等待2分钟后,查看表2中“streamName”配置的通道的监控。如果显示有数据上传(绿色线条),表示DIS
vel配置的的值,则日志也不会输出。 OFF maxBufferAgeMillis 否 最长上传等待时间。单位:毫秒 记录队列满则立即上传。 记录队列未满,等待此配 置项配置的时间后上传。 5000 connectionTimeOutSeconds 否 连接DIS接口超时时间。 单位:秒。