Gyula Fora comments

Results 61 comments of


                                            Gyula Fora

[FLINK-27805][Connectors/ORC] bump orc version to 1.7.5

Sure, we will take a look :)

[FLINK-34906] Only scale when all tasks are running

This issue only affects the standalone autoscaler as the kubernetes operator has this logic already in place for setting the RUNNING state. Can we somehow deduplicate this logic?

[FLINK-34906] Only scale when all tasks are running

sounds good @1996fanrui

Update StreamingDemo to use flatMapWithState

No hurry, we have more important things with the checkpointing :+1:

[FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API

Thanks @dmvk strange as we had a passed CI run, @pvary is taking a look

[FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API

@dmvk we reverted that commit, seems like there was some mess-up with the passing CI / rebasing. Sorry about that

[FLINK-33268][rest] Skip unknown fields in REST response deserialization

I think the approach makes sense 👍

[FLINK-33268][rest] Skip unknown fields in REST response deserialization

Looks good @gaborgsomogyi 🚢

[FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks

Thanks @1996fanrui for the PR , I will try to allocate some time to review this in the next few days. I need some extra time to familiarise myself with...

[FLINK-34441] Add guide to submit flink SQL scripts via the operator (using flink-sql-runner-example)

Closing this due to inactivity, please re-open if needed