[jira] [Created] (FLINK-11395) Support for Avro StreamingFileSink

2019-01-18 Thread Elango Ganesan (JIRA)
Elango Ganesan created FLINK-11395: -- Summary: Support for Avro StreamingFileSink Key: FLINK-11395 URL: https://issues.apache.org/jira/browse/FLINK-11395 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-11394) Job UI is not rendered in case of slow back-end

2019-01-18 Thread Oleksandr Nitavskyi (JIRA)
Oleksandr Nitavskyi created FLINK-11394: --- Summary: Job UI is not rendered in case of slow back-end Key: FLINK-11394 URL: https://issues.apache.org/jira/browse/FLINK-11394 Project: Flink

Re: [DISCUSS] Towards a leaner flink-dist

2019-01-18 Thread Jamie Grier
I'm not sure if this is required. It's quite convenient to be able to just grab a single tarball and you've got everything you need. I just did this for the latest binary release and it was 273MB and took about 25 seconds to download. Of course I know connection speeds vary quite a bit but I don

Re: [FLINK-6626] Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

2019-01-18 Thread Gary Yao
Hi Tarush, If nobody is assigned, you can assign yourself. Best, Gary On Fri, Jan 18, 2019 at 6:42 AM tarush grover wrote: > Hi Team, > > Anyone working on this jira ticket? > > Regards, > Tarush >

[jira] [Created] (FLINK-11393) Activate default shuffle implementation and remove legacy code

2019-01-18 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-11393: --- Summary: Activate default shuffle implementation and remove legacy code Key: FLINK-11393 URL: https://issues.apache.org/jira/browse/FLINK-11393 Project: Flink

[jira] [Created] (FLINK-11392) Introduce ShuffleService in Task Executor

2019-01-18 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-11392: --- Summary: Introduce ShuffleService in Task Executor Key: FLINK-11392 URL: https://issues.apache.org/jira/browse/FLINK-11392 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11391) Introduce ShuffleMaster in Job Master

2019-01-18 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-11391: --- Summary: Introduce ShuffleMaster in Job Master Key: FLINK-11391 URL: https://issues.apache.org/jira/browse/FLINK-11391 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-11390) Port YARNSessionCapacitySchedulerITCase to new code base

2019-01-18 Thread Gary Yao (JIRA)
Gary Yao created FLINK-11390: Summary: Port YARNSessionCapacitySchedulerITCase to new code base Key: FLINK-11390 URL: https://issues.apache.org/jira/browse/FLINK-11390 Project: Flink Issue Type:

Re: [DISCUSS] Towards a leaner flink-dist

2019-01-18 Thread Fabian Hueske
Hi Chesnay, Thank you for the proposal. I think this is a good idea. We follow a similar approach already for Hadoop dependencies and connectors (although in application space). +1 Fabian Am Fr., 18. Jan. 2019 um 10:59 Uhr schrieb Chesnay Schepler < ches...@apache.org>: > Hello, > > the binary

[DISCUSS] Towards a leaner flink-dist

2019-01-18 Thread Chesnay Schepler
Hello, the binary distribution that we release by now contains quite a lot of optional components, including various filesystems, metric reporters and libraries. Most users will only use a fraction of these, and as such pretty much only increase the size of flink-dist. With Flink growing mor

[jira] [Created] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-18 Thread yuqi (JIRA)
yuqi created FLINK-11389: Summary: Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor Key: FLINK-11389 URL: https://issues.apache.org/jira/browse/FLINK-11389