[jira] [Created] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

Ted Yu created FLINK-7488: - Summary: TaskManagerHeapSizeCalculationJavaBashTest sometimes fails Key: FLINK-7488 URL: https://issues.apache.org/jira/browse/FLINK-7488 Project: Flink Issue Type: Test

Changing parallelism on BucketingSink

Hi, I'm implementing a custom sink. The job is reading a DataStream into this custom sink. I'd like to be able to maximize the parallelism to use all available slots in the cluster, but to write to a smaller sets of files in the final output. When I implement this sink with DataStream.writeAsTe

[jira] [Created] (FLINK-7487) test instability in ClassLoaderITCase (no resources available)

Nico Kruber created FLINK-7487: -- Summary: test instability in ClassLoaderITCase (no resources available) Key: FLINK-7487 URL: https://issues.apache.org/jira/browse/FLINK-7487 Project: Flink Iss

[jira] [Created] (FLINK-7486) flink-mesos: Support for adding unique attribute / group_by attribute constraints

Bhumika Bayani created FLINK-7486: - Summary: flink-mesos: Support for adding unique attribute / group_by attribute constraints Key: FLINK-7486 URL: https://issues.apache.org/jira/browse/FLINK-7486 Pro

[jira] [Created] (FLINK-7485) Using DataView interface to improve (MIN/MAX)WithRetractAggFunction.

sunjincheng created FLINK-7485: -- Summary: Using DataView interface to improve (MIN/MAX)WithRetractAggFunction. Key: FLINK-7485 URL: https://issues.apache.org/jira/browse/FLINK-7485 Project: Flink

[jira] [Created] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

Shashank Agarwal created FLINK-7484: --- Summary: com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5 Key: FLINK-7484 URL: https://issues.apache.org/jira/browse/FLINK-748

[jira] [Created] (FLINK-7483) BlobCache cleanup timer not reset after job re-registration

Nico Kruber created FLINK-7483: -- Summary: BlobCache cleanup timer not reset after job re-registration Key: FLINK-7483 URL: https://issues.apache.org/jira/browse/FLINK-7483 Project: Flink Issue

Re: Request for contributor permissions

Hi Till, I got the permissions. Thanks so much. I hoping to help out the community as much as possible. Regards, Hai Zhou > 在 2017年8月21日，15:29，Till Rohrmann 写道： > > Hi Hai Zhou, > > welcome to the Flink community :-) I've given you contributor permissions. > As a new contributor I highly reco

Re: Request for contributor permissions

Hi Hai Zhou, welcome to the Flink community :-) I've given you contributor permissions. As a new contributor I highly recommend you to read [1]. [1] http://flink.apache.org/how-to-contribute.html Cheers, Till On Mon, Aug 21, 2017 at 3:21 AM, Hai Zhou wrote: > Hi everyone, > My name is Hai Zho