Re: Flink Connector类冲突问题

2022-01-25 文章 Ada Wong
https://issues.apache.org/jira/browse/FLINK-15786 Ada Wong 于2022年1月25日周二 19:40写道: > > 目前多个Connector出现无法shade的类冲突是没办法解决的。 > 我提了个issue,里面写了大致的解决方案。有老哥再这块熟悉一点的嘛?可以再issue里讨论下。 > https://issues.apache.org/jira/browse/FLINK-25804

Flink Connector类冲突问题

2022-01-25 文章 Ada Wong
目前多个Connector出现无法shade的类冲突是没办法解决的。 我提了个issue,里面写了大致的解决方案。有老哥再这块熟悉一点的嘛?可以再issue里讨论下。 https://issues.apache.org/jira/browse/FLINK-25804

Re: sql-gateway和jdbc-driver还维护吗?

2022-01-11 文章 Ada Wong
thub.com/ververica/flink-jdbc-driver > https://github.com/ververica/flink-sql-gateway > > Ada Wong > 我看这俩项目一两年没更新了。想用Flink彻底替换到Spark,这俩项目是刚需,用来替换SparkThriftServer。

Re: sql-gateway和jdbc-driver还维护吗?

2022-01-10 文章 Ada Wong
https://github.com/ververica/flink-jdbc-driver https://github.com/ververica/flink-sql-gateway Ada Wong 于2022年1月10日周一 19:32写道: > > 我看这俩项目一两年没更新了。想用Flink彻底替换到Spark,这俩项目是刚需,用来替换SparkThriftServer。

sql-gateway和jdbc-driver还维护吗?

2022-01-10 文章 Ada Wong
我看这俩项目一两年没更新了。想用Flink彻底替换到Spark,这俩项目是刚需,用来替换SparkThriftServer。

邮件归档访问不了

2021-12-31 文章 Ada Wong
想看当时的讨论情况,但是这个访问不了。 http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Move-Flink-ML-pipeline-API-and-library-code-to-a-separate-repository-named-flink-ml-tc49420.html

Re: flink-1.14.0 chk提交kafka offset问题

2021-12-30 文章 Ada Wong
你说的偏移量提交是指提交给Kafka Broker当前group的offset? Guo Thompson 于2021年12月30日周四 15:36写道: > > 应该是checkpoint的时候就会提交kafka 的offset > > kcz <573693...@qq.com.invalid> 于2021年12月30日周四 14:54写道: > > > 有一个问题请教下大佬们,学迷糊了, > > 用了flink-1.14.0版本,开启了chk(500ms做一次),精准一次消费,事件时间 > > source(kafka)- (1min的window,到时之后开始做count计算)

Re: Flink机器学习扩展文档在哪?

2021-12-28 文章 Ada Wong
https://nightlies.apache.org/flink/flink-docs-release-1.8/dev/libs/ml/ Ada Wong 于2021年12月28日周二 13:52写道: > > 以前Flink官方有个机器学习库的文档,新版文档我发现已经没了 > https://github.com/apache/flink-ml

Flink机器学习扩展文档在哪?

2021-12-27 文章 Ada Wong
以前Flink官方有个机器学习库的文档,新版文档我发现已经没了 https://github.com/apache/flink-ml

Flink SQL DECIMAL精度问题

2021-12-23 文章 Ada Wong
最大精度为38,这个是有什么说法吗,为什么不是1000。如果我需要更高精度的DECIMAL我改怎么做?例如我需要DECIMAL(50, 18)