使用StreamTableEnvironment.createTemporarySystemFunction注册UD(T)F异常

k.table.types.extraction.ExtractionUtils.extractionError(ExtractionUtils.java:313) at org.apache.flink.table.types.extraction.ExtractionUtils.extractionError(ExtractionUtils.java:305) at org.apache.flink.table.types.extraction.DataTypeExtractor.checkForCommonErrors(DataTypeExtractor.java:343) at org.apache.flink.table.types.extraction.DataTypeExtractor.extractDataTypeOrError(DataTypeExtractor.java:277) at org.apache.flink.table.types.extraction.DataTypeExtractor.extractDataTypeOrRawWithTemplate(DataTypeExtractor.java:238) ... 45 more Process finished with exit code 1 -- Best, zz zhang

Re: metrics influxdb reporter 不支持https及jar放置路径问题

>感谢你的反馈，你可以创建两个 issue 来分别跟进反馈的这两个问题。如果你有兴趣的话，也可以尝试对这两个问题进行共享的 > > Best, > Congxian > > > zz zhang 于2020年7月23日周四 下午5:02写道： > > > hello，目前Flink1.11.1 > > > > 发布的org.apache.flink.metrics.influxdb.InfluxdbReporter默认是上报是http协议，并不支持https协议，源码参考[2] > &

metrics influxdb reporter 不支持https及jar放置路径问题

/metrics.html#influxdb-orgapacheflinkmetricsinfluxdbinfluxdbreporter [2] https://github.com/apache/flink/blob/release-1.11/flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporter.java#L84 -- Best, zz zhang

Re: Kafka Consumer反序列化错问题

haded.org.apache.kafka.common.serialization.ByteArrayDeserializer > is not an instance of org.apache.kafka.common.serialization.Deserializer > at > org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:304) > at > org.apache.kafka.clients.consumer.KafkaConsumer. ... 15 more -- Best, zz zhang

Re: sinktable更新部分字段问题

naturalfree 写道： > > > > 现在有一个es索引，想通过flink sql根据主键更新部分字段。不知是否有可行方案 > > > > > > | | > > naturalfree > > | > > | > > 邮箱：naturalf...@126.com > > | > > > > 签名由 网易邮箱大师 定制 > -- Best, zz zhang