??if ??
Flink DDL的方式 写 Hive parquet 格式 ,是否支持 snappy压缩,如果支持 请问下参数是什么?
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压缩,如果支持 请问下参数是什么?
同一段代码,在main里面可以正常正常,在Test里面却直接结束
StreamExecutionEnvironment bsEnv =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings bsSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
StreamTableEnvironment bsTableEnv =
StreamTableE