BlackHole结果表 功能描述 BlackHole Connector允许接收所有输入记录，常用于高性能测试和UDF 输出，其不是实质性Sink。Blackhole结果表是系统内置的Connector。 例如，如果您在注册其他类型的Connector结果表时报错，但您不确定是

查看更多 →

要创建的ClickHouse的表名。 connector.driver 否 ru.yandex.clickhouse.ClickHouseDriver String 连接数据库所需要的驱动。 如果建表时不指定该参数，驱动会自动通过ClickHouse的url提取。 如果建表时指定该参数，则该参数值固定为“ru

查看更多 →

pe，表示使用两个array字段，第一个字段为set中的值，第二个字段表示相应值所对应的score。fields-scores用于sorted-set的data-type，表示从定义的字段中获取score，该类型表示除主键外的奇数字段表示set中的值，该字段的下一个字段表示该字段

查看更多 →

pe，表示使用两个array字段，第一个字段为set中的值，第二个字段表示相应值所对应的score。fields-scores用于sorted-set的data-type，表示从定义的字段中获取score，该类型表示除主键外的奇数字段表示set中的值，该字段的下一个字段表示该字段

查看更多 →

Redis结果表 功能描述 DLI 将Flink作业的输出数据输出到Redis中。Redis是一种支持Key-Value等多种数据结构的存储系统。可用于缓存、事件发布或订阅、高速队列等场景，提供字符串、哈希、列表、队列、集合结构直接存取，基于内存，可持久化。有关Redis的详细信息

查看更多 →

"xxxx", "format.type" = 'csv' ); 创建ClickHouse结果表clickhouse，将disSource表数据插入到clickhouse结果表中。 create table clickhouse( attr0 string, attr1

查看更多 →

pe，表示使用两个array字段，第一个字段为set中的值，第二个字段表示相应值所对应的score。fields-scores用于sorted-set的data-type，表示从定义的字段中获取score，该类型表示除主键外的奇数字段表示set中的值，该字段的下一个字段表示该字段

查看更多 →

使用限制：当前统计信息收集不支持针对分区表的分区级别的统计信息。 在Spark客户端的“spark-defaults.conf”配置文件中进行表1设置。 表1 参数介绍 参数 描述 默认值 spark.sql.cbo.enabled CBO总开关。 true表示打开， false表示关闭。 要使用该功

查看更多 →

开启双因子认证失败，怎么办？ 问题现象 在双因子认证列表下，没有待开启双因子认证的主机，怎么办？ 开启双因子认证后，不生效，怎么办？ 开启双因子认证失败，怎么办？ 可能原因 主机未开启防护。 开启双因子认证不会立即生效，需要等大约5分钟才生效。 Linux主机没有关闭“密钥对”登录方式。

查看更多 →

开启双因子认证失败，怎么办？ 问题现象 在双因子认证列表下，没有待开启双因子认证的主机。 开启双因子认证后，不生效。 开启双因子认证失败。 可能原因 主机未开启防护。 开启双因子认证不会立即生效，需要等大约5分钟才生效。 Linux主机没有关闭“密钥对”登录方式。 与“网防G01

查看更多 →

如何合并小文件 使用SQL过程中，生成的小文件过多时，会导致作业执行时间过长，且查询对应表时耗时增大，建议对小文件进行合并。 设置配置项。 spark.sql.shuffle.partitions = 分区数量（即此场景下最终生成的文件数量） 执行SQL。 INSERT OVERWRITE

查看更多 →

utf8mb4_bin默认字符集，可以后续确保同库内新增表、列与迁移表、列的排序规格一致，从而避免因表、列的排序规则不一致时进行关联查询，执行计划中因索引数据排序不同而无法利用索引的情况。 2. 可在实例级设置参数collation_server = utf8mb4_bin，该设

查看更多 →

开启流水线门禁：默认不勾选。 合并人：默认为空。 审核人：默认为空。 检视人：默认为空。 表4 字段说明 字段 说明 分支 可针对所有分支或某一分支进行设置策略。 最小检视人数 设置最少检视通过的人数，当检视通过的人数满足“最小检视人数”时，审核门禁通过。“0” 表示无需检视人检视通过，

查看更多 →

PO收货打印【合并】 【功能说明】 用于PC端采集点收并打印供应商到货物料的合并批次，并自动创建采购送货单及送货单明细 【操作步骤】 物料批次打印：选择供应商，选择采购单号，根据采购单号过滤产品料号，选择产品料号 -> 依次输入生产日期、生产批次、启动数量、备品启动数量、每包标准个数、每箱标准包数

查看更多 →

什么是单主/双主灾备 实时迁移、实时同步和实时灾备有什么区别 MySQL迁移出现数据膨胀怎么办 DRS对源数据库和目标数据库有什么影响 DRS需要源数据库停止业务吗 什么是SMN主题 DRS任务的双AZ和单AZ有什么区别 DRS是否支持只迁移表结构不迁移数据 MySQL迁移、同步、灾备任务怎么迁移账号，是否支持修改密码

查看更多 →

对一级分区表合并分区 使用ALTER TABLE MERGE PARTITIONS可以将多个分区合并为一个分区。 例如，将范围分区表range_sales的分区date_202001和date_202002合并为一个新的分区，并更新Global索引。 ALTER TABLE range_sales

查看更多 →

/*in包括两个值，其中第一个值为布尔型，为true或false，当true时表示插入或更新操作，为false时表示删除操作，若对接的sink端不支持删除等操作，当为false时，可不进行任何操作。第二个值表示实际的数据值*/ public void invoke(Tuple2<Boolean

查看更多 →

Sink将以append模式工作，该模式只能消费INSERT消息。 在Elasticsearch结果表中，主键用于计算Elasticsearch的文档ID。文档ID为最多512个字节不包含空格的字符串。Elasticsearch结果表通过使用“document-id.key-delimiter”参数指定的

查看更多 →

Upsert Kafka结果表 功能描述 DLI将Flink作业的输出数据以upsert的模式输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。

查看更多 →

.security.protocol' = 'SASL_PLAINTEXT' 示例 从Kafka源表获取Kafka source topic数据，通过Upsert Kafka结果表将Kafka source topic数据写入到Kafka sink topic中。 参考增强型跨源

查看更多 →

WITH表达式 WITH表达式用于定义在大型查询中使用的辅助语句，这些辅助语句通常被称为公共表达式或CTE（即common table expr），可以理解为一个带名称的子查询，之后该子查询可以以其名称在查询中被多次引用。 WITH表达式中的辅助语句可以是SELECT、INSER

查看更多 →