[jira] [Created] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers

2018-06-17 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9608: -- Summary: Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers Key: FLINK-9608 URL: https://issues.apache.org/jira/br

Re: [DISCUSS] Flink 1.6 features

2018-06-17 Thread zhangminglei
But if we do hive on flink , I think it should be a very big project. > 在 2018年6月17日，下午9:36，Will Du 写道： > > Agree, two missing pieces I think could make Flink more competitive against > Spark SQL/Stream and Kafka Stream > 1. Flink over Hive or Flink SQL hive table source and sink > 2. Flink ML

[jira] [Created] (FLINK-9607) Support ParquetTableSink

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9607: --- Summary: Support ParquetTableSink Key: FLINK-9607 URL: https://issues.apache.org/jira/browse/FLINK-9607 Project: Flink Issue Type: New Feature Repo

[jira] [Created] (FLINK-9606) Support ParquetTableSource

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9606: --- Summary: Support ParquetTableSource Key: FLINK-9606 URL: https://issues.apache.org/jira/browse/FLINK-9606 Project: Flink Issue Type: New Feature Re

[jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9605: --- Summary: Support KafkaProtoBufTableSink Key: FLINK-9605 URL: https://issues.apache.org/jira/browse/FLINK-9605 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource

2018-06-17 Thread mingleizhang (JIRA)
mingleizhang created FLINK-9604: --- Summary: Support KafkaProtoBufTableSource Key: FLINK-9604 URL: https://issues.apache.org/jira/browse/FLINK-9604 Project: Flink Issue Type: New Feature

Re: [DISCUSS] Flink 1.6 features

2018-06-17 Thread zhangminglei
Actually, I have been an idea, how about support hive on flink ? Since lots of business are written by hive sql. And users wants to transform map reduce to fink without changing the sql. Zhangminglei > 在 2018年6月17日，下午8:11，zhangminglei <18717838...@163.com> 写道： > > Hi, Sagar > > There alread

Re: [DISCUSS] Flink 1.6 features

2018-06-17 Thread zhangminglei
Hi, Sagar There already has relative JIRAs for ORC and Parquet, you can take a look here: https://issues.apache.org/jira/browse/FLINK-9407 and https://issues.apache.org/jira/browse/FLINK-9411