Rion Williams
09/16/2024, 6:38 PMNoClassDefFoundException
similar to the example below when referencing statically defined values:
class ExampleOperatiorn : KeyedCoProcessFunction<...>() {
override fun open(parameters: Configuration) {
...
}
companion object {
private val CANARY_LOGGER = CanaryLog()
}
}
Where CanaryLog
is the class that isn’t being found (despite all of this code working as expected in Flink 1.18.1).Rion Williams
09/16/2024, 6:55 PMorg.apache.flink.connector.base.source.reader.RecordEmitter