Siddhesh Kalgaonkar
08/29/2023, 6:24 PMSiddhesh Kalgaonkar
08/30/2023, 7:17 AMpyflink -> lib is working fine . however, when I try to use below line instead of copying the jars, it doesn't work self.env.add_jars("file:///kafka-clients-3.4.0.jar", "file:///flink-sql-connector-kafka-1.17.1.jar")