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

2018-09-26 Thread Ted Yu (JIRA)
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

Handling burst I/O when using tumbling/sliding windows

2018-09-26 Thread Rong Rong
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

2018-09-26 Thread Nico Kruber (JIRA)
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:

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

2018-09-26 Thread Stephan Ewen (JIRA)
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

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

2018-09-26 Thread Nico Kruber (JIRA)
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

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

2018-09-26 Thread Nico Kruber (JIRA)
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:

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

2018-09-26 Thread Ufuk Celebi (JIRA)
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:

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

2018-09-26 Thread Benoit MERIAUX (JIRA)
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:

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

2018-09-26 Thread Ufuk Celebi (JIRA)
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

2018-09-26 Thread Piotr Nowojski (JIRA)
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

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

2018-09-26 Thread tison (JIRA)
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

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

2018-09-26 Thread Ufuk Celebi (JIRA)
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

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

2018-09-26 Thread Gary Yao (JIRA)
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

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

2018-09-26 Thread Piotr Szczepanek (JIRA)
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

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

2018-09-26 Thread Stefan Richter (JIRA)
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

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

2018-09-26 Thread Stefan Richter (JIRA)
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:

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

2018-09-26 Thread Stefan Richter (JIRA)
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

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

2018-09-26 Thread Stefan Richter (JIRA)
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

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

2018-09-26 Thread Stefan Richter (JIRA)
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:

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

2018-09-26 Thread Till Rohrmann (JIRA)
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