检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
o格式的数据导入到在DLI中创建的表。 将CSV格式数据导入分区表，需在数据源中将分区列放在最后一列。 导入数据的编码格式仅支持UTF-8。 数据导出 只支持将DLI表（表类型为“Managed”）中的数据导出到OBS桶中，且导出的路径必须指定到文件夹级别。 导出文件格式为json格式，且文本格式仅支持UTF-8。
image 否 String 自定义镜像。格式为：组织名/镜像名:镜像版本。 当用户设置“feature”为“custom”时，该参数生效。用户可通过与“feature”参数配合使用，指定作业运行使用自定义的Spark镜像。关于如何使用自定义镜像，请参考《数据湖探索用户指南》。 req_body
该方案需要用户自行编写java代码或scala代码。 方案2：先使用云数据迁移服务CDM将MySQL数据库中的数据导入OBS桶中，再通过Spark作业读取OBS桶中的数据，如果用户已有CDM集群，该方案比方案1简单，且不会对现有数据库造成压力。 父主题： 作业开发
如何在一个Flink作业中将数据写入到不同的Elasticsearch集群中？ 在对应的Flink作业中添加如下SQL语句。 create source stream ssource(xx); create sink stream es1(xx) with (xx); create
如何获取项目ID？ 项目ID是系统所在区域的ID。用户在调用API接口进行云资源管理（如创建集群）时，需要提供项目ID。 查看项目ID步骤如下： 注册并登录华为云管理控制台。 将鼠标移动到右上角用户名上，在下拉列表中单击“我的凭证”。 在“我的凭证”页面的项目列表中查看项目ID。
作业开发 如何合并小文件 DLI如何访问OBS桶中的数据 创建OBS表时正确指定OBS路径 关联OBS桶中嵌套的JSON格式数据如何创建表 count函数如何进行聚合 如何将一个区域中的DLI表数据同步到另一个区域中？ SQL作业如何指定表的部分字段进行表数据的插入 怎样删除表数据？
image 否 String 自定义镜像。格式为：组织名/镜像名:镜像版本。 当用户设置“feature”为“custom”时，该参数生效。用户可通过与“feature”参数配合使用，指定作业运行使用自定义的Flink镜像。关于如何使用自定义镜像，请参考《数据湖探索用户指南》。 feature
性能调优 Flink作业推荐配置指导 Flink作业如何进行性能调优 如何在一个Flink作业中将数据写入到不同的Elasticsearch集群中？ Flink作业重启后，如何保证不丢失数据？ 父主题： Flink作业相关问题
使用API相关问题 如何获取AK/SK？ 如何获取项目ID？ 提交SQL作业时，返回“unsupported media Type”信息 不同账号的调用API时的项目ID(Project ID)是固定的吗？ 创建SQL作业的API执行超过时间限制，运行超时报错 API接口返回的中文字符为乱码，如何解决？
0/{project_id}/jobs/submit-job 取消作业 cancelJob - DELETE /v1.0/{project_id}/jobs/{job_id} 查询所有作业 listAllJobs - GET /v1.0/{project_id}/jobs?page-size
使用SDK相关问题 使用SDK查询SQL作业结果，如何设置超时时间？ 服务器：请求dli.xxx,unable to resolve host address, 如何解决？
作业开发 Spark如何将数据写入到DLI表中 通用队列操作OBS表如何设置AK/SK 如何查看DLI Spark作业的实际资源使用情况 将Spark作业结果存储在MySQL数据库中，缺少pymysql模块，如何使用python脚本访问MySQL数据库？ 如何在DLI中运行复杂PySpark程序？
"); //调用SQLJob对象的exportResult接口导出查询结果，其中exportPath为导出数据的路径,JSON为导出格式，queueName为执行导出作业的队列，limitNum为导出作业结果条数，0表示全部导出 sqlJob.exportResult(exportPath
getResource("userData/fileName") 作业特性 队列为CCE队列时，显示该参数。 基础型 自定义镜像：选择镜像名称和镜像版本。用户可在“容器镜像服务”设置的镜像。具体操作请参考使用自定义镜像增强作业运行环境。 Flink版本 先选择所属的队列再选择Flink版本。 说明： 不建议长期混用不同版本的Flink引擎。
作业管理 如何获取DLI作业样例（Demo） 使用DLI运行几万个作业，如何管理？ DLI上已经创建好的表如何修改表字段名称？ 父主题： 产品咨询相关问题
跨源分析问题 如何实现跨数据源查询 如何实现跨区域访问数据 创建DLI关联RDS表时，如果RDS表有自增主键或者其他自动填充的字段时，在DLI中插入数据时，对应字段如何填写？ 父主题： 跨源连接相关问题
使用咨询 队列引擎版本升级后，在创建表时，提示权限不足怎么办？ 如何理解DLI分区表的列赋权 父主题： 授权相关问题
运维指导 SQL作业运行慢如何定位 查看DLI SQL日志 查看DLI的执行SQL记录 执行SQL作业时产生数据倾斜怎么办？ DLI控制台中无法查询到对应表 OBS表压缩率较高 如何避免字符码不一致导致的乱码 删除表后再重新创建同名的表，需要对操作该表的用户和项目重新赋权 DLI
使用咨询 DLI Flink作业支持哪些数据格式和数据源 如何给子用户授权查看Flink作业？ Flink作业设置“异常自动重启” Flink作业如何保存作业日志 如何查看Flink作业输出结果？ Flink作业管理界面对用户进行授权时提示用户不存在怎么办 手动停止了Flink作
配额相关问题 什么是用户配额？ 怎样查看我的配额 如何申请扩大配额 Failed to create the database. {"error_code":"DLI.1028";"error_msg":"Already reached the maximum quota of databases:XXX"
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
