V.Zaitsev

**Is your feature request related to a problem? Please describe.** The question is related to backward compatibility support when changing avro schemas. **Is your feature request related to a specific...

"Address already in use" for one of two AkkaServerStreamlets from separate modules in runLocal

1

**Describe the bug** When defining two streamlets extending AkkaServerStreamlet in separate pipeline modules, the same port(3000) is selected for both streamlets in runLocal mode. Accordingly, only one streamlet is running,...

Producer delivery semantic for Flink streamlets

4

**Is your feature request related to a problem? Please describe.** I noticed that when errors occurs in the Flink streamlet then some messages duplicates in the outlet Kafka topic. To...

Installation of mlflow is not working

3

Hi! I'm trying to install mlflow package in virtual environment, but installation process fails with error. ``` bin/pip install mlflow ``` ``` compile options: '-Inumpy/core/src/common -Inumpy/core/src -Inumpy/core -Inumpy/core/src/npymath -Inumpy/core/src/multiarray -Inumpy/core/src/umath...

Bump hadoop aws version to 3.2.0 for local launcher

2

Signed-off-by: breezzo **What this PR does / why we need it**: Bump hadoop aws version to 3.2.0 since the `fs.s3a.path.style.access` option is not available in 2.7.3 which makes it difficult...