cloudflow
cloudflow copied to clipboard
lightbend
Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.
**Is your feature request related to a problem? Please describe.** Using CF 2.0.10 (both in application and CF operator on AKS). Some devs attempted to configure the Kafka topics used...
**Is your feature request related to a problem? Please describe.** Running `buildApp` in an sbt multi-project results in building all the Cloudflow applications contained in the entire build. Reproducible copy...
Hello! In the cloudflow 2.0.5 Flink Operator by default run Prometheus agent on port 2050 (https://github.com/lightbend/cloudflow/blob/v2.0.5/external/multi-base-images/flink/flink-entrypoint.sh), but lyft/flinkk8soperator v.0.4.0, that used in Cloudflow 2.0.5, use port 50101 for MetricsQueryDefaultPort (https://github.com/lyft/flinkk8soperator/blob/v0.4.0/pkg/controller/flink/config.go)...
Currently, Cloudflow relies on sbt-docker internally(e.g. the operator image) and for the `buildApp` task of the sbt plugin. This causes small issues, especially with caches, such as `buildApp` task needs...
This page: https://cloudflow.io/docs/current/get-started/prepare-development-environment.html Currently, you have to hunt for several commands(download file, move, uncompress, set permissions, etc) to download and install the Cloudflow kubectl CLI. This could be made much...
Would be quite useful when debugging a pod have access to all the internals of the jvm - open a port if necessary - only flags should be added -...
**Is your feature request related to a problem? Please describe.** From Oleg Myagkov @OBenner on Gitter: "Hi! I use RocksDB stateBackend, which storage in hdfs . I have error -...
More details are described in the related github issue:https://github.com/lightbend/cloudflow/issues/156
taskmanager.memory.flink.size is a new parameter introduced for the task manager in Flink 1.10. For details, refer to discussions under this PR:https://github.com/lightbend/cloudflow/pull/149. Relevant Github issue:https://github.com/lyft/flinkk8soperator/issues/185
**Is your feature request related to a problem? Please describe.** Currently in `AkkaStreamlet` we have a way to indicate that the streamlet is ready for processing after it starts :...
