-
Notifications
You must be signed in to change notification settings - Fork 4
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.
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
add Serializable to AvroCoder and AvroSchemaRegistryClient #30
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think the only change that may be required here are the build.sbt
changes. The environment variable stuff definitely isn't required as there is already a built-in solution. Regarding the latest version change, can you show the error and location that requires this fix so I can evaluate if there's a better option? Thanks.
src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryContext.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/model/FlinkConfig.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/model/SinkConfig.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/model/SinkConfig.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/model/SinkConfig.scala
Outdated
Show resolved
Hide resolved
src/main/scala/io/epiphanous/flinkrunner/model/SourceConfig.scala
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not clear on a couple of the changes in build.sbt
and plugins.sbt
.
removed `sbt assembly` from plugins.sbt
No description provided.