在海豚调度器（Dolphin Scheduler）1.3.5 中，你可以通过以下步骤设置工作流中的任务，以检查 Hive 表是否为空，并根据结果决定是否执行后续任务。以下是详细步骤：

步骤 1: 创建 Hive 表检查任务

1. 创建一个 Shell 脚本任务：该任务将执行 Hive 查询以检查指定表是否为空。
   • 在 Dolphin Scheduler 中，创建一个新的任务，选择 Shell 作为任务类型。
   • 编写脚本如下：

#!/bin/bash
# 检查 Hive 表是否为空
HIVE_TABLE_NAME="your_hive_table_name"  # 替换为你的 Hive 表名

COUNT=$(hive -S -e "SELECT COUNT(*) FROM ${HIVE_TABLE_NAME};")

if [ "$COUNT" -eq 0 ]; then
    echo "Table is empty"
    exit 1  # 返回非零值表示表为空
else
    echo "Table is not empty"
    exit 0  # 返回零值表示表不为空
fi

1. 保存并命名该任务，例如命名为 check_hive_table_empty。

步骤 2: 创建后续任务

1. 创建后续的任务：这些任务将根据 Hive 表是否为空而决定是否执行。例如，创建一个新的任务，命名为 run_after_check。
2. 设置相应的任务逻辑。这些可以是任何你需要执行的操作，比如数据处理、报告生成等。

步骤 3: 设置任务依赖关系

1. 创建一个工作流：在 Dolphin Scheduler 中创建一个新的工作流。
2. 添加任务：
   • 将 check_hive_table_empty 任务添加到工作流中。
   • 将 run_after_check 任务也添加到工作流中。
3. 设置依赖关系：
   • 选择 run_after_check 任务，设置其依赖于 check_hive_table_empty 任务。
   • 在依赖配置中，选择“成功”状态。这意味着只有当 check_hive_table_empty 任务成功运行且表不为空时，run_after_check 才会被执行。

步骤 4: 测试和验证工作流

1. 启动工作流：手动启动工作流，观察任务的执行情况。
2. 查看日志：检查 check_hive_table_empty 的日志，确认其正确判断了 Hive 表是否为空。
3. 验证后续任务：根据 Hive 表的状态，确认后续任务是否被正确执行或跳过。

注意事项

• 确保 Hive 和 Dolphin Scheduler 的连接正常。
• 检查权限设置，确保你有权限访问 Hive 表。
• 可以根据需要调整任务超时时间和重试策略，以确保工作流的稳定性。

通过以上步骤，你能够在 Dolphin Scheduler 中实现根据 Hive 表内容动态控制工作流的执行。