Developed two production-ready features across apache/flink-cdc and TEN-framework/ten_framework, focusing on robust data integration and real-time interaction. Delivered an OceanBase pipeline connector for Flink CDC, enabling seamless end-to-end data synchronization to OceanBase databases with automatic table creation, schema evolution support, and at-least-once delivery semantics, all implemented in Java and YAML. Authored comprehensive documentation to support onboarding and maintenance. Additionally, integrated a Python extension for OceanBase PowerRAG within TEN-framework, allowing streamed chat responses via the PowerRAG Chat API and configurable interaction properties. Emphasized asynchronous programming, API integration, and extensible software architecture to enhance downstream workflow flexibility.