[jira] [Created] (FLINK-3332) Provide an exactly-once Cassandra connector

Robert Metzger created FLINK-3332: - Summary: Provide an exactly-once Cassandra connector Key: FLINK-3332 URL: https://issues.apache.org/jira/browse/FLINK-3332 Project: Flink Issue Type:

[jira] [Created] (FLINK-3333) Documentation about object reuse should be improved

Gabor Gevay created FLINK-: -- Summary: Documentation about object reuse should be improved Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK- Project: Flink Issue Type:

[jira] [Created] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp

Gyula Fora created FLINK-3334: - Summary: Change default log4j.properties Conversion pattern to include year-month-day in the timestamp Key: FLINK-3334 URL: https://issues.apache.org/jira/browse/FLINK-3334

[jira] [Created] (FLINK-3340) Fix object juggling in reduce drivers

Greg Hogan created FLINK-3340: - Summary: Fix object juggling in reduce drivers Key: FLINK-3340 URL: https://issues.apache.org/jira/browse/FLINK-3340 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3335) DataSourceTask object reuse when disabled

Greg Hogan created FLINK-3335: - Summary: DataSourceTask object reuse when disabled Key: FLINK-3335 URL: https://issues.apache.org/jira/browse/FLINK-3335 Project: Flink Issue Type: Bug

Re: [DISCUSS] Release 0.10.2

I've created the release candidate and started the vote thread. This is the document to coordinate testing: https://docs.google.com/document/d/1oCOHwHwZNjHb7MX-qLvA61akEBOAxSIYo53MoygUqxQ/ On Wed, Feb 3, 2016 at 7:31 PM, Ufuk Celebi wrote: > > > On 02 Feb 2016, at 17:30,

[jira] [Created] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka

Shikhar Bhushan created FLINK-3341: -- Summary: Kafka connector's 'auto.offset.reset' inconsistent with Kafka Key: FLINK-3341 URL: https://issues.apache.org/jira/browse/FLINK-3341 Project: Flink

[jira] [Created] (FLINK-3339) Checkpointing NPE when using filterWithState

Shikhar Bhushan created FLINK-3339: -- Summary: Checkpointing NPE when using filterWithState Key: FLINK-3339 URL: https://issues.apache.org/jira/browse/FLINK-3339 Project: Flink Issue Type:

[VOTE] Release Apache Flink 0.10.2 (RC1)

Dear Flink community, Please vote on releasing the following candidate as Apache Flink version 0.10.2. Shared document to coordinate testing: https://docs.google.com/document/d/1oCOHwHwZNjHb7MX-qLvA61akEBOAxSIYo53MoygUqxQ/ The commit to be voted on: 3fcb91641118ba362b29a55e9102539e96852172

[jira] [Created] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream

Aljoscha Krettek created FLINK-3336: --- Summary: Add Semi-Rebalance Data Shipping for DataStream Key: FLINK-3336 URL: https://issues.apache.org/jira/browse/FLINK-3336 Project: Flink Issue

[jira] [Created] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found

Greg Hogan created FLINK-3337: - Summary: mvn test fails on flink-runtime because curator classes not found Key: FLINK-3337 URL: https://issues.apache.org/jira/browse/FLINK-3337 Project: Flink

[jira] [Created] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException

Shikhar Bhushan created FLINK-3338: -- Summary: Kafka deserialization issue - ClassNotFoundException Key: FLINK-3338 URL: https://issues.apache.org/jira/browse/FLINK-3338 Project: Flink Issue

[jira] [Created] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers

Robert Metzger created FLINK-3331: - Summary: Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers Key: FLINK-3331 URL: https://issues.apache.org/jira/browse/FLINK-3331