Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

scala examples do not work for packaging applications which use the TableAPI #80

Open
munkyboy opened this issue Jan 17, 2024 · 0 comments · May be fixed by #81
Open

scala examples do not work for packaging applications which use the TableAPI #80

munkyboy opened this issue Jan 17, 2024 · 0 comments · May be fixed by #81

Comments

@munkyboy
Copy link

Using scala/GettingStarted as a base, I added code to utilize the TableAPI and a kafka connector. Then received this error:

Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='kafka'

The example build.sbt does not support assembling an uber jar which preserves the Service Provider Interface required by Flink.

I suggest the build.sbt examples are updated or a new scala example is created which demonstrates how to use the TableAPI.
munkyboy added a commit to munkyboy/amazon-kinesis-data-analytics-examples that referenced this issue Jan 17, 2024
@munkyboy
preserve Service provider interface when building scala uber jars
c1a160f 
fixes aws-samples#80
@munkyboy munkyboy linked a pull request Jan 17, 2024 that will close this issue
Open
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
1 participant
@munkyboy