[jira] [Created] (FLINK-6334) Refactoring UDTF interface

2017-04-19 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6334: - Summary: Refactoring UDTF interface Key: FLINK-6334 URL: https://issues.apache.org/jira/browse/FLINK-6334 Project: Flink Issue Type: Improvement Componen

[jira] [Created] (FLINK-6333) Utilize Bloomfilters in RocksDb

2017-04-19 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6333: - Summary: Utilize Bloomfilters in RocksDb Key: FLINK-6333 URL: https://issues.apache.org/jira/browse/FLINK-6333 Project: Flink Issue Type: Improvement Reporter:

Read from and Write to Kafka through flink

2017-04-19 Thread Pradeep Anumala
Hi, I am a beginner with Apache Flink. I am trying to write to Kafka through a file and read the data from kafka. I see there is an API to read from and write to kafka. The following writes to kafka FlinkKafkaProducer08 myProducer = new FlinkKafkaProducer08( "localhost:9092",

[jira] [Created] (FLINK-6332) Upgrade Scala version to 2.11.11

2017-04-19 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6332: - Summary: Upgrade Scala version to 2.11.11 Key: FLINK-6332 URL: https://issues.apache.org/jira/browse/FLINK-6332 Project: Flink Issue Type: Improvement Reporter

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

2017-04-19 Thread Henry Saputra
This should be the one: https://github.com/aljoscha/FliRTT On Wed, Apr 19, 2017 at 7:48 AM, Ted Yu wrote: > Till: > A bit curious: where can I find the Flirrt tool ? > > Thanks > > On Wed, Apr 19, 2017 at 5:24 AM, Till Rohrmann > wrote: > > > +1 (binding) for the release > > > > - checked check

[jira] [Created] (FLINK-6331) StreamingOperatorsITCase.testAsyncWaitOperator spuriously failing on Travis

2017-04-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6331: Summary: StreamingOperatorsITCase.testAsyncWaitOperator spuriously failing on Travis Key: FLINK-6331 URL: https://issues.apache.org/jira/browse/FLINK-6331 Project: Fl

[jira] [Created] (FLINK-6330) Improve Docker documentation

2017-04-19 Thread Patrick Lucas (JIRA)
Patrick Lucas created FLINK-6330: Summary: Improve Docker documentation Key: FLINK-6330 URL: https://issues.apache.org/jira/browse/FLINK-6330 Project: Flink Issue Type: Bug Componen

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

2017-04-19 Thread Ted Yu
Till: A bit curious: where can I find the Flirrt tool ? Thanks On Wed, Apr 19, 2017 at 5:24 AM, Till Rohrmann wrote: > +1 (binding) for the release > > - checked checksums and signature > - no dependencies added or removed > - build Flink with Hadoop 2.7.1 and Scala 2.11 from sources and ran al

[jira] [Created] (FLINK-6329) refactor name-addressable accessors in BlobService classes from returning a URL to a File or InputStream

2017-04-19 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6329: -- Summary: refactor name-addressable accessors in BlobService classes from returning a URL to a File or InputStream Key: FLINK-6329 URL: https://issues.apache.org/jira/browse/FLINK-6329

[jira] [Created] (FLINK-6328) Savepoints must not be counted as retained checkpoints

2017-04-19 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6328: --- Summary: Savepoints must not be counted as retained checkpoints Key: FLINK-6328 URL: https://issues.apache.org/jira/browse/FLINK-6328 Project: Flink Issue Type

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

2017-04-19 Thread Till Rohrmann
+1 (binding) for the release - checked checksums and signature - no dependencies added or removed - build Flink with Hadoop 2.7.1 and Scala 2.11 from sources and ran all tests - Ran Flirrt locally, on standalone cluster and Yarn with Hadoop 2.7.1 and Scala 2.10 Cheers, Till On Thu, Apr 13, 2017

[jira] [Created] (FLINK-6327) Bug in CommonCalc's estimateRowCount() method

2017-04-19 Thread godfrey he (JIRA)
godfrey he created FLINK-6327: - Summary: Bug in CommonCalc's estimateRowCount() method Key: FLINK-6327 URL: https://issues.apache.org/jira/browse/FLINK-6327 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6326) add ProjectMergeRule at logical optimization stage

2017-04-19 Thread godfrey he (JIRA)
godfrey he created FLINK-6326: - Summary: add ProjectMergeRule at logical optimization stage Key: FLINK-6326 URL: https://issues.apache.org/jira/browse/FLINK-6326 Project: Flink Issue Type: New Fe

[jira] [Created] (FLINK-6325) Refinement of slot reuse for task manager failure

2017-04-19 Thread zhijiang (JIRA)
zhijiang created FLINK-6325: --- Summary: Refinement of slot reuse for task manager failure Key: FLINK-6325 URL: https://issues.apache.org/jira/browse/FLINK-6325 Project: Flink Issue Type: Improvement