Flink Table API跨应用表引用异常：CI/CD部署App2找不到App1创建的表
问题描述
我们有两个Kinesis Data Analytics应用：
- App1：创建基于Kafka Topic的
sourceTable和targetTable1，执行select * from sourceTable将数据写入targetTable1 - App2：基于
targetTable1对应的Kafka Topic创建sourceTable2，再创建targetTable2，执行select * from targetTable1将数据写入targetTable2
这些逻辑在AWS Kinesis Data Analytics的Zeppelin Notebook中以SQL形式编写，通过Zeppelin构建部署时运行完全正常。但当我们从S3构建包中取出Python代码，通过CI/CD流程构建部署时，App1运行正常，App2却抛出**"object targetTable1 is not found"**错误——该表实际由App1创建。我们尝试在App2中重新创建targetTable1后部署可正常运行，仅在跨应用访问表时出现问题，求分析原因。
原因分析
1. 应用级别的元数据隔离
Kinesis Data Analytics的每个独立应用都维护自己的专属元数据空间，默认情况下，一个应用创建的表定义（即使底层关联的是同一个Kafka Topic）不会自动对其他应用可见。这是平台为了保证应用独立性、避免元数据冲突设计的机制。
2. Zeppelin与CI/CD部署的上下文差异
在Zeppelin Notebook环境中，你编写的所有SQL逻辑本质是在同一个临时应用上下文内执行的——相当于把App1和App2的逻辑合并成了一个整体，targetTable1的定义在这个共享上下文里存在，所以后续的逻辑能直接访问。但通过CI/CD部署时，App1和App2是两个完全独立的应用实例，各自的元数据空间相互隔离，App2的元数据中没有targetTable1的注册信息，自然会触发找不到对象的错误。
3. 显式创建表的本质
当你在App2中重新创建targetTable1时，并非复用App1的表定义，而是在App2自己的元数据空间里注册了一个关联相同Kafka Topic的新表。此时App2能识别这个本地注册的表，进而正常读取底层Kafka的数据，本质是绕开了跨应用的元数据隔离限制。
解决方案建议
- 遵循应用独立性原则：App2直接使用自身创建的
sourceTable2（关联目标Kafka Topic）编写处理逻辑，不要尝试访问其他应用创建的表 - 统一表定义脚本：如果需要多个应用访问同一个Kafka Topic对应的表，可将表的创建SQL抽离为公共脚本，在每个需要访问的应用部署时执行，确保每个应用的元数据空间都有对应表的注册
- 弱化跨应用依赖：Kinesis Data Analytics的设计初衷是让独立应用处理流数据，跨应用直接依赖表元数据会增加系统耦合度，建议通过底层Kafka Topic传递数据，每个应用自行定义关联Topic的表
内容的提问来源于stack exchange，提问作者Kapil More
