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
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
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/
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
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
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
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
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
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
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
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
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.
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
13 matches
Mail list logo