Re: Handling burst I/O when using tumbling/sliding windows

Hi, Thanks for the proposal. Could you provide more background/explanation/motivation why do you need such feature? What do you mean by “network I/O” degradation? On it’s own burst writes shouldn’t cause problems within Flink. If they do, we might want to fix the original underlying problem a

[jira] [Created] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

Ted Yu created FLINK-10446: -- Summary: Use the "guava beta checker" plugin to keep off of @Beta API Key: FLINK-10446 URL: https://issues.apache.org/jira/browse/FLINK-10446 Project: Flink Issue Type:

Handling burst I/O when using tumbling/sliding windows

Hi Dev, I was wondering if there's any previous discussion regarding how to handle burst network I/O when deploying Flink applications with window operators. We've recently see some significant network I/O degradation when trying to use sliding window to perform rolling aggregations. The pattern

[jira] [Created] (FLINK-10445) CLI stuck with (potentially incorrect) SSL config

Nico Kruber created FLINK-10445: --- Summary: CLI stuck with (potentially incorrect) SSL config Key: FLINK-10445 URL: https://issues.apache.org/jira/browse/FLINK-10445 Project: Flink Issue Type: B

[jira] [Created] (FLINK-10444) Make S3 entropy injection work with FileSystem safety net

Stephan Ewen created FLINK-10444: Summary: Make S3 entropy injection work with FileSystem safety net Key: FLINK-10444 URL: https://issues.apache.org/jira/browse/FLINK-10444 Project: Flink Iss

[jira] [Created] (FLINK-10443) Flink Yarn CLI hanging after unsuccessful deployment

Nico Kruber created FLINK-10443: --- Summary: Flink Yarn CLI hanging after unsuccessful deployment Key: FLINK-10443 URL: https://issues.apache.org/jira/browse/FLINK-10443 Project: Flink Issue Type

[jira] [Created] (FLINK-10442) Make declined savepoints visible in WebUI

Nico Kruber created FLINK-10442: --- Summary: Make declined savepoints visible in WebUI Key: FLINK-10442 URL: https://issues.apache.org/jira/browse/FLINK-10442 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-10441) Don't log warning when creating upload directory

Ufuk Celebi created FLINK-10441: --- Summary: Don't log warning when creating upload directory Key: FLINK-10441 URL: https://issues.apache.org/jira/browse/FLINK-10441 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

Benoit MERIAUX created FLINK-10440: -- Summary: Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch Key: FLINK-10440 URL: https://issues.apache.org/jira/browse/FLINK-10440 Project: Fl

[jira] [Created] (FLINK-10439) Race condition during job suspension

Ufuk Celebi created FLINK-10439: --- Summary: Race condition during job suspension Key: FLINK-10439 URL: https://issues.apache.org/jira/browse/FLINK-10439 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10438) Built in functions should document the returned types

Piotr Nowojski created FLINK-10438: -- Summary: Built in functions should document the returned types Key: FLINK-10438 URL: https://issues.apache.org/jira/browse/FLINK-10438 Project: Flink Iss

[jira] [Created] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

tison created FLINK-10437: - Summary: Some of keys under withDeprecatedKeys aren't marked as @depreacted Key: FLINK-10437 URL: https://issues.apache.org/jira/browse/FLINK-10437 Project: Flink Issue T

[jira] [Created] (FLINK-10436) Example config uses deprecated key jobmanager.rpc.address

Ufuk Celebi created FLINK-10436: --- Summary: Example config uses deprecated key jobmanager.rpc.address Key: FLINK-10436 URL: https://issues.apache.org/jira/browse/FLINK-10436 Project: Flink Issue

[jira] [Created] (FLINK-10435) Client sporadically hangs after Ctrl + C

Gary Yao created FLINK-10435: Summary: Client sporadically hangs after Ctrl + C Key: FLINK-10435 URL: https://issues.apache.org/jira/browse/FLINK-10435 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-10434) Blob file not removed after job execution.

Piotr Szczepanek created FLINK-10434: Summary: Blob file not removed after job execution. Key: FLINK-10434 URL: https://issues.apache.org/jira/browse/FLINK-10434 Project: Flink Issue Type

[jira] [Created] (FLINK-10433) Stepwise creation of the ExecutionGraph sub-structures

Stefan Richter created FLINK-10433: -- Summary: Stepwise creation of the ExecutionGraph sub-structures Key: FLINK-10433 URL: https://issues.apache.org/jira/browse/FLINK-10433 Project: Flink Is

[jira] [Created] (FLINK-10432) Introduce bulk/group-aware scheduling

Stefan Richter created FLINK-10432: -- Summary: Introduce bulk/group-aware scheduling Key: FLINK-10432 URL: https://issues.apache.org/jira/browse/FLINK-10432 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-10431) Extract scheduling-related code from SlotPool

Stefan Richter created FLINK-10431: -- Summary: Extract scheduling-related code from SlotPool Key: FLINK-10431 URL: https://issues.apache.org/jira/browse/FLINK-10431 Project: Flink Issue Type:

[jira] [Created] (FLINK-10430) Extract scheduling-related code from Executions

Stefan Richter created FLINK-10430: -- Summary: Extract scheduling-related code from Executions Key: FLINK-10430 URL: https://issues.apache.org/jira/browse/FLINK-10430 Project: Flink Issue Typ

[jira] [Created] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component

Stefan Richter created FLINK-10429: -- Summary: Redesign Flink Scheduling, introducing dedicated Scheduler component Key: FLINK-10429 URL: https://issues.apache.org/jira/browse/FLINK-10429 Project: Fli

[jira] [Created] (FLINK-10428) AbstractServerBase should bind to any address per default

Till Rohrmann created FLINK-10428: - Summary: AbstractServerBase should bind to any address per default Key: FLINK-10428 URL: https://issues.apache.org/jira/browse/FLINK-10428 Project: Flink I