Lorenzo Nicora

Hi Marshall, This repo is intended to be an exercise, not a way of building a real Kubernetes cluster. So I have no plan for upgrading it, sorry. Lorenzo

@dannycranmer please review this PR when you have the chance

@z3d1k I addressed most of the comments. But I am not sure how to implement the IT, in particular for a *format* using an external registry. Any reference or example...

+1

Does this work on Amazon Managed Service for Apache Flink? I see the readme mention "copying `hive-site.xml` from your EMR cluster. Flink on EMR is a different service. This repo...

Thanks @cmoetzing. I did the same locally. But I guess a real upgrade would require moving away from the deprecated Sink API to the new one

@dannycranmer I rephrased the whole explanation, being more explicit, considering it was not clear which repo we were talking about. Let me know if it makes sense now

@dannycranmer this PR was closed for inactivity, but I think it was mergeable. The instructions suggest to re-open it but I do not have the permissions. It think this would...

@Lzgpom Building this locally and I've got a spotless-check format violation. `mvn spotless:apply` fixes it

I tested it locally, with a stream produced by KPL with aggregation enabled, and it worked fine.