Maximilian Michels

icon indicating a website link https://maximilianmichels.com icon indicating an email [email protected]

icon company @apache icon location Berlin icon location Distributed systems and open-source communities. Committer at Apache Beam / Apache Flink. ASF Member.

Results 43 comments of Maximilian Michels

Flink: Migrate Flink `TableSchema` to `Schema`/`ResolvedSchema`

Thanks for elaborating! I've responded in the thread. If we can, it would be great to completely get rid of `TableSchema` in this PR. We can add the steps as...

[FLINK-36527][autoscaler] Introduce a parameter to support autoscaler adopt a more radical strategy when source vertex or upstream shuffle is keyBy

Thanks! Let's get the PR ready to be merged then.

[FLINK-36527][autoscaler] Introduce a parameter to support autoscaler adopt a more radical strategy when source vertex or upstream shuffle is keyBy

Thanks @huyuanfeng2018!

MapSerializer fails to serialize custom Map implementation

Thanks for the quick response! I did a minimal repro and figured out what causes this: Flink configures ``` setInstantiatorStrategy(new org.objenesis.strategy.StdInstantiatorStrategy()); ``` and also loads the Twitter Chill library. In...

MapSerializer fails to serialize custom Map implementation

I've opened https://issues.apache.org/jira/browse/FLINK-37546.

BIGTOP-2526: Upgrade Flink version to 1.1.3.

+1

Flink: Fix flaky test in testTwoSinksInDisjointedDAG

We might have to change the test setup to checkpoint explicitly, then tear down the Flink cluster.

[FLINK-37900][rocksdb] configurable jitter in rocksdb state uploader

@davidradl Could you explain how the checkpoints would be processed out of order? How would one checkpoint overtake the other? IMHO this would merely slow down or time out checkpointing,...

[FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling

The idea of the JobResourceRequirements API is to allow changing the resource profile of jobs. Users expect lower resource requirements to result in fewer TaskManagers, which isn't the case with...

[FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling

Folks, let's wrap this up soon, ideally after this review round.