调优指南 独立部署模式（Standalone Deployment）下的内存配置 容器（Container）的内存配置 State Backend 的内存配置 Heap State Backend RocksDB State Backend 批处理作业的内存配置 调优指南 本文在的基本的配置指南 的基础上，介绍如何根据具体的使用场景调整内存...

语句组合 示例 分号复合语句 管道复合语句 语句组合 组合语句（或子查询）的方法有两种： 将多个语句放在一个语句中进行批处理，以英文分号（;）隔开，最后一个语句的结果将作为批处理的结果返回。 将多个语句通过运算符（|）连接在一起，类似于 shell 脚本中的管道。前一个语句得到的结果可以重定向到下一个语句作为输入。 注意复合语句并不能保...

语句组合 示例 分号复合语句 管道复合语句 语句组合 组合语句（或子查询）的方法有两种： 将多个语句放在一个语句中进行批处理，以英文分号（;）隔开，最后一个语句的结果将作为批处理的结果返回。 将多个语句通过运算符（|）连接在一起，类似于 shell 脚本中的管道。前一个语句得到的结果可以重定向到下一个语句作为输入。 注意复合语句并不能保证...

bboss性能基准测试（仅供参考） 测试环境 性能测试代码 bboss性能基准测试（仅供参考） 批量添加2万条数据耗时1.5秒 对大索引表文档统计计数耗时10毫秒 获取一条json文档耗时2毫秒 获取一条Object文档耗时3毫秒 scroll查询并处理2万条记录：0.6s scrollSlice 并行查询并处理2万条记录：0.1s 测试...

syslog 描述 属性 默认日志格式示例 插件元数据 重要 启用插件 测试插件 删除插件 syslog 描述 syslog 插件可用于将日志推送到 Syslog 服务器。 该插件还实现了将日志数据以 JSON 格式发送到 Syslog 服务的能力。 属性 名称 类型 必选项 默认值 有效值 描述 host string 是 ...

全链路灰度发布 主要功能 分批次发布 基于 Header 的匹配规则 全链路灰度 监控和回滚 使用手册 环境准备和配置 创建和管理发布版本 制定和配置灰度发布策略 进行灰度发布 监控和分析发布结果 全链路灰度发布 灰度发布是一种软件发布策略，通过在生产环境中逐步引入新版本的应用程序，以降低风险并获得更可控的发布过程。它允许在一小部...

Messages Producers 发送模式 压缩 批量处理 Consumers 接收模式 监听 确认 取消确认 确认超时 死信主题 Topic 不需要显式的创建topic 命名空间 Subscriptions 订阅-发布，队列，亦或两者都是 Exclusive Failover（灾备） Shared（共享） Shar...

Table API & SQL 依赖图 Table 程序依赖 扩展依赖 接下来？ Table API & SQL Apache Flink 有两种关系型 API 来做流批统一处理：Table API 和 SQL。Table API 是用于 Scala 和 Java 语言的查询API，它可以用一种非常直观的方式来组合使用选取、过滤、join 等...

Text files format Text files format Flink 支持使用 TextLineInputFormat 从文件中读取文本行。此 format 使用 Java 的内置 InputStreamReader 以支持的字符集编码来解码字节流。 要使用该 format，你需要将 Flink Connector Files 依赖项添...