-
认证方式
认证方式 修改认证方式 开发者LDAP测试 通过 Casdoor 实现 SSO 登录 步骤1. 部署 Casdoor 步骤2. 配置 Casdoor 步骤3. 配置 Dolphinscheduler 通过OAuth2授权认证登录 步骤1. 获取OAuth2客户端凭据 步骤2. 在api的配置文件中开启oauth2登录 步骤3.使用oauth2... -
Apache Kafka Connector
依赖 Kafka Source (Consumer) 基础消费示例 高级配置参数 消费多个Kafka实例 消费多个Topic Topic 发现 配置开始消费的位置 指定分区Offset 指定deserializer 返回记录KafkaRecord 指定strategy Kafka Sink (Producer) 容错和语义 多实例k... -
二进制方式
组件安装 安装夜莺 部署集群 MySQL Redis 时序库 n9e-webapi n9e-server 首先我们来看下面的架构图，夜莺的服务端有两个模块：n9e-webapi 和 n9e-server，n9e-webapi 用于提供 API 给前端 JavaScript 使用，n9e-server 的职责是告警引擎和数据转发器。依赖的组件... -
Alerts and Reports
Requirements Commons In your superset_config.py or superset_config_docker.py Disable dry-run mode In your Dockerfile Slack integration Kubernetes-specific Docker Compose s... -
All Configurations
Externalized Config File Hudi Table Config Hudi Table Basic Configs Spark Datasource Configs Read Options Write Options PreCommit Validator Configurations Flink Sql Configs ... -
Apache HBase Connector
HBase写入依赖 常规方式写入读取HBase 1.创建库表 2.写入读取demo Apache StreamPark™ 读写 HBase 1. 配置策略和连接信息 2. 读写入HBase 其他配置 Apache HBase 是一个高可靠性、高性能、面向列、可伸缩的分布式存储系统，利用 HBase 技术可在廉价服务器上搭建起大规模结构化存... -
任务结构
任务总体存储结构 各任务类型存储结构详解 Shell节点 SQL节点 PROCEDURE[存储过程]节点 SPARK节点 MapReduce(MR)节点 Python节点 Flink节点 HTTP节点 DataX节点 Sqoop节点 条件分支节点 子流程节点 依赖(DEPENDENT)节点 任务总体存储结构 在dolphin... -
Clickhouse Connector
JDBC 同步写入 常规方式写入 Apache StreamPark™ 方式写入 配置信息 写入clickhouse HTTP 异步写入 常规方式写入 Apache StreamPark™ 方式写入 异步写入配置及失败恢复组件配置 写入clickhouse 其他配置 ClickHouse 是一个用于联机分析（OLAP）的列式数据库管... -
MongoDB CDC
Support Those Engines Key Features Description Supported DataSource Info Availability Settings Data Type Mapping Source Options Tips: How to Create a MongoDB CDC Data Synch... -
参数传递
参数的引用 本地任务引用全局参数 上游任务传递给下游任务 任务样例 创建 SHELL 任务并设置参数 创建 SQL 任务并使用参数 保存工作流并设置全局参数 查看运行结果 Python 任务传递参数 SubProcess 任务传递参数 Kubernetes 任务传递参数 参数的引用 DolphinScheduler 提供参数间相互引...