[jira] [Created] (FLINK-10173) Elasticsearch 6 connector does not package Elasticsearch

2018-08-19 Thread Timo Walther (JIRA)
Timo Walther created FLINK-10173: Summary: Elasticsearch 6 connector does not package Elasticsearch Key: FLINK-10173 URL: https://issues.apache.org/jira/browse/FLINK-10173 Project: Flink Issu

Fwd: [DISCUSS] Rust add adapter for parquet

2018-08-19 Thread Renjie Liu
cc:Sunchao and Any -- Forwarded message - From: Uwe L. Korn Date: Sun, Aug 19, 2018 at 5:08 PM Subject: Re: [DISCUSS] Rust add adapter for parquet To: Hello, you might also want to raise this with the https://github.com/sunchao/parquet-rs project. The overlap between the devel

[jira] [Created] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

2018-08-19 Thread Rong Rong (JIRA)
Rong Rong created FLINK-10172: - Summary: Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc Key: FLINK-10172 URL: https://issues.apache.org/jira/browse/FLINK-10172 Project: Flink

[jira] [Created] (FLINK-10171) Allow for assemblePartPath override in the BucketingSink

2018-08-19 Thread Lakshmi Rao (JIRA)
Lakshmi Rao created FLINK-10171: --- Summary: Allow for assemblePartPath override in the BucketingSink Key: FLINK-10171 URL: https://issues.apache.org/jira/browse/FLINK-10171 Project: Flink Issue

[jira] [Created] (FLINK-10170) Support map types in descriptor-based Table API

2018-08-19 Thread Jun Zhang (JIRA)
Jun Zhang created FLINK-10170: - Summary: Support map types in descriptor-based Table API Key: FLINK-10170 URL: https://issues.apache.org/jira/browse/FLINK-10170 Project: Flink Issue Type: Improve

Re: [Proposal] Utilities for reading, transforming and creating Streaming savepoints

2018-08-19 Thread Gyula Fóra
Hi all! Thanks for the feedback and I'm happy there is some interest :) Tomorrow I will start improving the proposal based on the feedback and will get back to work. If you are interested working together in this please ping me and we can discuss some ideas/plans and how to share work. Cheers, G

[DISCUSS] Change the Keyed partitioning behavior of the Kafka Producer API

2018-08-19 Thread Niels Basjes
Hi, A while ago we had found that if you construct a Kafka Producer that it always uses the FlinkFixedPartitioner to spread the data across the Kafka partitions. Except when you give it a custom partitioner. Because we want all our elements to be partitioned by the key of the records we created