GitHub user anukalp2804 added a comment to the discussion: [GSoC 2026] Flink connector for IoTDB table mode – prospective contributor
Hello , Following our previous discussion, I wanted to share a quick update on my progress with the IoTDB 2.0 Table Model integration. To better understand the new API, I built a functional Proof of Concept (PoC) that successfully connects Flink 1.18 to IoTDB in Table Mode. Key Findings: During implementation, I confirmed that the standard Session class defaults to the legacy Tree Model, which caused syntax errors when executing SQL (e.g., CREATE TABLE). I resolved this by switching to the TableSessionBuilder, which explicitly initializes the connection with the correct SQL dialect. I have implemented a custom Flink SourceFunction that executes SQL queries and streams the result rows into Flink. You can review the prototype code and execution logs here: https://github.com/anukalp2804/flink-iotdb-table-connector Next Steps for GSoC Proposal: Based on this PoC, my plan for the official proposal is to: 1. Upgrade from SourceFunction to the new FLIP-27 Source API to support parallelism. 2. Implement a Type Mapping utility to convert IoTDB types (INT32, FLOAT) to Flink RowData. 3. Develop the corresponding Sink for writing data back to IoTDB. I would love to hear your thoughts on this approach. Does this align with the project's vision? Thank you for your time. Sincerely, Anukalp Pandey GitHub link: https://github.com/apache/iotdb/discussions/17128#discussioncomment-15738336 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
