检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
表3 请求Body参数 参数 是否必选 参数类型 描述 destination_type 是 String 转储任务类型。
CREATING：创建中 RUNNING：运行中 TERMINATING：删除中 TERMINATED：已删除 枚举值： CREATING RUNNING TERMINATING FROZEN stream_type String 通道类型。
descriptor.setAgencyName("dis_admin_agency"); // 可选，转储OBS的目标文件格式：默认text，可配置parquet、carbon descriptor.setDestinationFileType(DestinationFileTypeEnum.TEXT.getType
consumer_strategy','deliver_time_interval','agency_name','retry_duration'], value=['LATEST', 30, 'dis_admin_agency',1800]) obs_dump_task =['destination_file_type
(DestinationFileTypeEnum.TEXT.getType()); request.setObsDestinationDescriptor(descriptor); 配置“UpdateTransferTaskRequest”对象之后，通过调用updateTransferTask
': 'OBS', 'obs_destination_description': {'obs_bucket_path': '002', 'deliver_time_interval': 30, 'retry_duration': 0, 'agency_name': 'all', '
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 { "tasks":[ { "destination_type":"DLI", "task_name
"dis_admin_agency", DestinationFileType: &destinationFileTypeObsDestinationDescriptor, RecordDelimiter: &recordDelimiterObsDestinationDescriptor
":"DLI", "state":"RUNNING", "create_time":1552457808502, "last_transfer_timestamp":1552458085454, "dli_destination_description
响应示例如下： 1 2 200 {'total_number': 1, 'tasks': [{'last_transfer_timestamp': 1538018769241, 'state': 'RUNNING', 'create_time': 1537949648144, 'destination_type
自动提交策略由消费者协调器（Coordinator）每隔${auto.commit.interval.ms}毫秒执行一次偏移量的提交；手动提交需要由客户端自己控制偏移量的提交。 自动提交 在创建一个消费者时，默认是自动提交偏移量，默认的提交间隔是5000ms。
自动提交策略由消费者协调器（Coordinator）每隔${auto.commit.interval.ms}毫秒执行一次偏移量的提交；手动提交需要由客户端自己控制偏移量的提交。 自动提交 在创建一个消费者时，默认是自动提交偏移量，默认的提交间隔是5000ms。
OBS：转储到OBS MRS：转储到MRS DLI：转储到DLI CLOUDTABLE：转储到CloudTable DWS：转储到DWS 缺省值：NOWHERE 枚举值： MRS mrs_destination_descriptor 否 MRSDestinationDescriptorRequest
OBS：转储到OBS MRS：转储到MRS DLI：转储到DLI CLOUDTABLE：转储到CloudTable DWS：转储到DWS 缺省值：NOWHERE 枚举值： DLI dli_destination_descriptor 否 DliDestinationDescriptorRequest
OBS：转储到OBS MRS：转储到MRS DLI：转储到DLI CLOUDTABLE：转储到CloudTable DWS：转储到DWS 缺省值：NOWHERE 枚举值： DWS dws_destination_descriptor 否 DWSDestinationDescriptorRequest
dws_destination_descripton DWSDestinationDescriptorRequest object 转储目的地为DWS的参数列表。
Terminate batch job (Y/N)? 父主题： 使用Agent上传数据
[0]}} 09:42:58.488 INFO c.h.d.a.k.c.Coordinator - Heartbeat {"state":"STABLE"} 09:43:08.960 INFO c.h.d.a.k.c.Coordinator - Heartbeat {"state
[0]}} 09:42:58.488 INFO c.h.d.a.k.c.Coordinator - Heartbeat {"state":"STABLE"} 09:43:08.960 INFO c.h.d.a.k.c.Coordinator - Heartbeat {"state
Agent: Progress: [N1 records (B1 bytes) / N2 files (B2 bytes)] parsed, and [N3 records / N4 files] sent successfully to destinations.
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
