[jira] [Created] (FLINK-3362) Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes

Ted Yu created FLINK-3362: - Summary: Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes Key: FLINK-3362 URL: https://issues.apache.org/jira/browse/FLINK-3362 Project: Flink Issue Type:

[jira] [Created] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values

Stephan Ewen created FLINK-3361: --- Summary: Wrong error messages for execution retry delay and akka ask pause config values Key: FLINK-3361 URL: https://issues.apache.org/jira/browse/FLINK-3361 Project:

[jira] [Created] (FLINK-3360) Clear up StateBackend, AbstractStateBackend abstractions

Gyula Fora created FLINK-3360: - Summary: Clear up StateBackend, AbstractStateBackend abstractions Key: FLINK-3360 URL: https://issues.apache.org/jira/browse/FLINK-3360 Project: Flink Issue Type:

[jira] [Created] (FLINK-3359) Make RocksDB file copies asynchronous

Stephan Ewen created FLINK-3359: --- Summary: Make RocksDB file copies asynchronous Key: FLINK-3359 URL: https://issues.apache.org/jira/browse/FLINK-3359 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens

Stephan Ewen created FLINK-3358: --- Summary: Create constructors for FsStateBackend in RocksDBBackens Key: FLINK-3358 URL: https://issues.apache.org/jira/browse/FLINK-3358 Project: Flink Issue Ty

[jira] [Created] (FLINK-3357) Drop JobId.toShortString()

Stephan Ewen created FLINK-3357: --- Summary: Drop JobId.toShortString() Key: FLINK-3357 URL: https://issues.apache.org/jira/browse/FLINK-3357 Project: Flink Issue Type: Bug Components:

Re: [VOTE] Release Apache Flink 0.10.2 (RC1)

+1 (binding) - Checked checksums - No binaries in source release - Ran mvn clean verify - Build for Hadoop 2.7 - Checked version in POM files - Ran the start up scripts and examined log/out files - Ran tests on multi-node cluster - Tested with HDFS - Tested command line client - Ran examples on Y

[jira] [Created] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery

Matthias J. Sax created FLINK-3356: -- Summary: JobClientActorRecoveryITCase.testJobClientRecovery Key: FLINK-3356 URL: https://issues.apache.org/jira/browse/FLINK-3356 Project: Flink Issue Ty

Re: Tips for testing

Hi! I basically test with "mvn clean install" as well. Greetings, Stephan On Sat, Feb 6, 2016 at 10:31 PM, Stefano Baghino < stefano.bagh...@radicalbit.io> wrote: > Hi everybody, > > as I've recently started contributing to Flink, I'd like to ask you a few > tips on how you normally run the te

Re: Want Flink startup issues :-)

For the road map ideas, there are often no JIRAs created yet. Mostly, road map ideas are more complex things to get done, requiring design documents and discussions before the actual coding can be done. Usually, we create the JIRA (or multiple JIRAs) during the design phase. So just watch the mail

Re: Contributing

Hi, check out our "How to Contribute" guide: http://flink.apache.org/how-to-contribute.html On Sun, Feb 7, 2016 at 2:45 PM, Deepak Koli wrote: > Hi, > > I am new to Flink and want to contribute to its development. Can someone > please help me get started. > > Thanks >

Contributing

Hi, I am new to Flink and want to contribute to its development. Can someone please help me get started. Thanks

Re: Case style anonymous functions not supported by Scala API

It took me a little time but I was able to put together some code. In this commit I just added a few methods renamed to prevent overloading, thus usable with PartialFunction instead of functions: https://github.com/radicalbit/flink/commit/aacd59e0ce98cccb66d48a30d07990ac8f345748 In this other com