[jira] [Created] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set

2018-01-10 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8410: -- Summary: Kafka consumer's commitedOffsets gauge metric is prematurely set Key: FLINK-8410 URL: https://issues.apache.org/jira/browse/FLINK-8410 Project: F

Re: Using SQL with dynamic tables where rows are updated

2018-01-10 Thread Ghassan Yammine
Hello, No, I did not use Hequn’s work. I already had an implementation the pre-processed the stream before feeding it nto the (now modified) SQL expression. Basically the SQL, instead of computing the AVG, just computes the COUNT and SUM. I do the average computation on the resulting stream.

[jira] [Created] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

2018-01-10 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8409: -- Summary: Race condition in KafkaConsumerThread leads to potential NPE Key: FLINK-8409 URL: https://issues.apache.org/jira/browse/FLINK-8409 Project: Flink

[jira] [Created] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

2018-01-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8408: Summary: YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis Key: FLINK-8408 URL: https://issues.apache.org/jira/browse/FLINK-8408 Project: Fli

[jira] [Created] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden

2018-01-10 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8407: -- Summary: Setting the parallelism after a partitioning operation should be forbidden Key: FLINK-8407 URL: https://issues.apache.org/jira/browse/FLINK-8407 Project: Flink

[jira] [Created] (FLINK-8406) BucketingSink does not detect hadoop file systems

2018-01-10 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8406: --- Summary: BucketingSink does not detect hadoop file systems Key: FLINK-8406 URL: https://issues.apache.org/jira/browse/FLINK-8406 Project: Flink Issue T

[jira] [Created] (FLINK-8405) Keyed State in broadcasted data steam.

2018-01-10 Thread Marek Barak (JIRA)
Marek Barak created FLINK-8405: -- Summary: Keyed State in broadcasted data steam. Key: FLINK-8405 URL: https://issues.apache.org/jira/browse/FLINK-8405 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8404) Mark Flip-6 tests with Flip6 annotation

2018-01-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8404: Summary: Mark Flip-6 tests with Flip6 annotation Key: FLINK-8404 URL: https://issues.apache.org/jira/browse/FLINK-8404 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8403) Flink Gelly examples hanging without returning result

2018-01-10 Thread flora karniav (JIRA)
flora karniav created FLINK-8403: Summary: Flink Gelly examples hanging without returning result Key: FLINK-8403 URL: https://issues.apache.org/jira/browse/FLINK-8403 Project: Flink Issue Typ

[jira] [Created] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

2018-01-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8402: Summary: HadoopS3FileSystemITCase.testDirectoryListing fails on Travis Key: FLINK-8402 URL: https://issues.apache.org/jira/browse/FLINK-8402 Project: Flink

Re: Using SQL with dynamic tables where rows are updated

2018-01-10 Thread yinhua
Hi Ghassan, I have the same issue with you, not sure how you solve your problem now? Using Hequn's work around? -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-8401) Allow subclass to override write-failure behavior in CassandraOutputFormat

2018-01-10 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8401: - Summary: Allow subclass to override write-failure behavior in CassandraOutputFormat Key: FLINK-8401 URL: https://issues.apache.org/jira/browse/FLINK-8401 Project: Flink

[jira] [Created] (FLINK-8400) Use the lexicographic smallest attribute as the common group id when extract unique key

2018-01-10 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-8400: -- Summary: Use the lexicographic smallest attribute as the common group id when extract unique key Key: FLINK-8400 URL: https://issues.apache.org/jira/browse/FLINK-8400 Pro