Alex Sergeenko

**Is your feature request related to a problem? Please describe.** `Application Descriptor` is very useful since it contains almost any pipeline-related info. Currently the `taskKey applicationDescriptor` at `CloudflowKeys.scala` marked as...

**Is your feature request related to a problem? Please describe.** There is a great apache Flink feature called "savepoints" (see [here](https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/savepoints.html)). In a nutshell this feature allows to manually trigger...

**Is your feature request related to a problem? Please describe.** There is a handy option that available for inlets called `withUniqueGroupId`. It forces a consumer to generate random Kafka group...

Hi, We use Lightbend Cloudflow which internally uses Lyft operator to manage Apache Flink based pipelines. There is a problem occurs when a job manager fails due to any problems...