Would like feedback on Apache Flink based data pipeline platform: Braineous

Open Source High-Scale Data Pipeline Platform for Enterprise Data, Analytics, and Machine Learning Applications. Documentation: https://bugsbunnyshah.github.io/braineous/guides/developer-guide Get Started: https://bugsbunnyshah.github.io/braineous/get-started/ GitHub: https://github.com/bugsbunn

Flink 1.18.1 cannot read from Kafka

Hi Phil, if __name__ == "__main__": process_table() error: link_app | Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. flink_app | flink_app | A

RE: Flink 1.18.1 cannot read from Kafka

Hi Phil, if __name__ == "__main__": process_table() error: link_app | Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. flink_app | flink_app | A

Re: Table Source from Parquet Bug

Hello David, Since this is a ClassNotFoundException, you maybe missing a dependency. Could you share your pom.xml. Thanks -Sohil Project: Braineous https://bugsbunnyshah.github.io/braineous/ On Tue, Apr 16, 2024 at 11:25 AM David Silva via user wrote: > Hi, > > Our team would like to leverage

RE: Table Source from Parquet Bug

Hi David, Since this is a ClassNotFoundException, you may be missing a dependency. Could you share your pom.xml. Thanks -Sohil Project: Braineous https://bugsbunnyshah.github.io/braineous/ On 2024/04/16 15:22:34 David Silva via user wrote: > Hi, > > Our team would like to leverage Flink but we'r