David Moravek

Hints should not be runtime specific and should describe data only

1

The current implementation of hints is not portable among runtimes. We should move hints to euphoria-core and they should describe dataset, not the operator implementation. Eg. `JoinHint.BroadcastHashJoin` should become something...

Local executor checkpointing

1

For streaming apps, we should implement simple checkpointing for LocalExecutor. Eg. when reading from kafka, we want to resume from last commited offset, so we can restart the app.

Broadcast Hash Join (aka Map Side Join) is currently missing in the Flink Runtime. We should implement this as introduces significant performance gain.

This test seems to be flipping ``` :euphoria-flink:test cz.seznam.euphoria.flink.testkit.FlinkOperatorsTest > cz.seznam.euphoria.operator.test.SumByKeyTest.testSumByKey[UNBOUNDED] FAILED java.lang.AssertionError at SumByKeyTest.java:39 147 tests completed, 1 failed :euphoria-flink:test FAILED ```

Tests covering implementation of any hint should pass on all executors, and results must be the same for case when the hint is applied and when isn't - hint cannot...

ClusterMesh: NodePort services are accessible across the cluster boundaries

1

### Is there an existing issue for this? - [X] I have searched the existing issues ### What happened? Based on the slack discussion: https://cilium.slack.com/archives/C53TG4J4R/p1662627177377429 In the multi-cluster (ClusterMesh) scenario,...

WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

5

WIP

[FLINK-33976] AdaptiveScheduler cooldown period should be taken from JobManager's configuration

2

https://issues.apache.org/jira/browse/FLINK-33976

[BP-1.18][FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.

1

Backport of https://github.com/apache/flink/pull/24079

[FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.

3

https://issues.apache.org/jira/browse/FLINK-34063