flink??????DDL????????????????????????????

2020-09-25 Thread kcz
??if ??

Flink DDL 写 Hive parquet 是否支持 snappy压缩

2020-08-03 Thread lydata
Flink DDL的方式 写 Hive parquet 格式 ，是否支持 snappy压缩，如果支持 请问下参数是什么？

Re: Flink DDL 写 Hive parquet 是否支持 snappy压缩

2020-08-03 Thread godfrey he
parquet.compression=SNAPPY，更多信息可参考[1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/formats/parquet.html#format-options lydata 于2020年8月4日周二 上午11:39写道： > Flink DDL的方式 写 Hive parquet 格式 ，是否支持 snappy压缩，如果支持 请问下参数是什么？

Flink ddl sql 在 Test和在Main里面执行结果不同

2021-01-20 Thread HunterXHunter
同一段代码，在main里面可以正常正常，在Test里面却直接结束 StreamExecutionEnvironment bsEnv = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings bsSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); StreamTableEnvironment bsTableEnv = StreamTableE