The call-record-aggregator example currently fails since it cannot download Spark 3.1.1 from https://downloads.apache.org/spark/spark-3.1.1/spark-3.1.1.tgz. The project should be updated with references to Spark 3.1.2.

Doers the doc have appropriate landing and flow.

Trying out a spark project with protobuf, when the executor runs:

Caused by: java.lang.NoSuchMethodError: com.google.protobuf.CodedInputStream.readStringRequireUtf8()Ljava/lang/String;
	at sensors.proto.Data$.parseFrom(Data.scala:140)
	at sensors.proto.Data$.parseFrom(Data.scala:126)
	at scalapb.GeneratedMessageCompanion.parseFrom(GeneratedMessageCompanion.scala:185)
	at scalapb.GeneratedMessageCompanion.parseFrom$(GeneratedMessageCompanion.scala:185)
	at sensors.proto.Data$.parseFrom(Data.scala:126)
	at cloudflow.streamlets.proto.ProtoCodec.$anonfun$decode$1(ProtoCodec.scala:27)

Probably because of many protobuf libs on the classpath,
looking at sparksql-scalapb, hadoop contains an outdated protobuf library that needs to be shaded:
https://scalapb.github.io/docs/sparksql/#setting-up-your-project
https://github.com/thesamet/sparksql-scalapb-test/blob/master/build.sbt
But cloudflow does not use sbt-assembly, so we need to find another way to ensure that the right protobuf library is used.
(could also have another reason, but we should be able to see from dependencies)
Should probably try https://github.com/coursier/sbt-shading to shade the dependencies.

Use Flink 1.13.2, and download from https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz instead.

I think it would be useful to have some explanation on how data is retrieved from the Cloudflow CR and the configuration.

As I understand the scripts work in two ways they read and then write. They read the current deployment from the CR and config from ConfigMaps. Based on that then they create a deployment to be executed with Flink CLI. The write side is Flink-related and requires reading Flink docs but not the read side.

I think there is value in making explicit through documentation how and what needs to be read from the Cloudflow CR and the configuration to learn what needs to be deployed.

Navigating the gh-pages: https://lightbend.github.io/cloudflow-contrib
the banner for cookies keeps popping up.

How does it work?
cc. @rasummer @rstento @thothmoses

The Flink Streamlet general tests which works on cloudflow 2.0.18 doesn't work on cloudflow-contrib 2.2.2 (with plugin ver 0.1.1). It seems like stream is empty.