-
HTTP Connector
HTTP 异步写入 Apache StreamPark™ 方式写入 http异步写入支持类型 http异步写入配置参数列表 http异步写入数据 其他配置 一些后台服务通过 HTTP 请求接收数据，这种场景下 Apache Flink 可以通过 HTTP 请求写入结果数据，目前 Apache Flink 官方未提供通过 HTTP 请求写入 数据... -
Telegraf
Telegraf 是 InfluxData 公司开源的一款采集器，内置非常多的采集插件，不过 Telegraf 是面向 InfluxDB 生态的，采集的监控数据推给 InfluxDB 非常合适，推给 Prometheus、Victoriametrics、Thanos 这些时序库，可能会带来问题。主要是两点： 有些数据是 string 类型的，Prome... -
告警组件向导
如何创建告警插件以及告警组 如何创建告警插件以及告警组 在 2.0.0 版本中，用户需要创建告警实例，在创建告警实例时，需要选择告警策略，有三个选项，成功发、失败发，以及成功和失败都发。在执行完工作流或任务时，如果触发告警，调用告警实例发送方法会进行逻辑判断，将告警实例与任务状态进行匹配，匹配则执行该告警实例发送逻辑，不匹配则过滤。创建完告警实例后，需... -
6. 安装、配置和部署集群
使用浏览器中运行的 Ambari 集群安装向导来安装、配置和部署集群，如下所示： 启动 Ambari 服务器 登录 Apache Ambari 启动 Ambari 群集安装向导 为集群命名 选择版本 安装选项 确认主机 选择服务 分配主节点 分配子节点和客户端 定制服务 回顾 安装、启动和测试 完成 -
为 Ranger 配置 MySQL
先决条件 使用 MySQL 时，用于 Ranger 管理策略存储表的存储引擎必须支持事务。 InnoDB 是支持事务的引擎的一个例子。不支持事务的存储引擎不适合作为策略存储。 操作步骤 如果您使用 Amazon RDS，请参阅 Amazon RDS 要求 。 应使用 MySQL 数据库管理员来创建 Ranger 数据库。 以下一系列命令可用于... -
Docker Compose 方式
使用Docker Compose一键启动夜莺，快速尝试。更多Docker Compose相关知识请参考Docker官网 操作演示 $ git clone https : //gitlink.org.cn/ccfos/nightingale.git $ cd nightingale / docker # docker compose V2版本执... -
事前必读
各种环境的选型建议： 快速体验测试，使用 Docker compose 方式 公司大规模使用了 Kubernetes，可以选中 Helm 方式 最稳定的部署方式，还是二进制 小规模使用，比如 1000 台机器以下，用 Prometheus 做存储即可，超过 1000 台机器，选择 VictoriaMetrics 可能更合适 后面章节会讲解各种方式如何... -
报警配置
新增报警配置 E-mail(邮件) DingTalk(钉钉) Wechat(企微) Lark(飞书) 测试报警配置 修改报警配置 使用报警配置 删除报警配置 目前 StreamPark 中支持配置多种报警方式，主要有以下几种： E-mail ：邮件通知 DingTalk ：钉钉自定义群机器人 Wechat ：企业微信自定义群机器人 ... -
变量管理
背景介绍 创建变量 在Flink SQL中引用变量 在Flink JAR作业的args中引用变量 背景介绍 在实际生产环境中，Flink作业一般很复杂，会依赖多个外部组件，例如，从Kafka中消费数据时要从HBase或Redis中去获取相关数据，然后将关联好的数据写入到外部组件，这样的情况下会导致如下问题： Flink作业想要关联这些组件，需... -
安装、启动和测试
下一步 安装进度显示在屏幕上。 Ambari 安装、启动并对每个组件运行简单的测试。进程的总体状态显示在屏幕顶部的进度栏中，逐个主机的状态显示在主要部分中。在此过程中请勿刷新浏览器。刷新浏览器可能会中断进度指示器。 要查看有关每个主机已完成哪些任务的具体信息，请单击相应主机的 Message 列中的链接。在 Tasks 弹出窗口中，单击单个任务以查...