请问如何贡献Flink Hologres连接器?

[casel.chen]

我们有使用阿里云商业版Hologres数据库，同时我们有自研的Flink实时计算平台，为了实现在Hologres上实时建仓，我们基于开源Apache 
Flink 1.17.1结合阿里云maven仓库的ververica-connector-hologres包[1]和开源的holo 
client[2]开发了hologres 
connector，修复了一些jar依赖问题。目前我们已经在生产环境使用了一段时间，暂时没有发现问题，现在想将它贡献给社区。


请问：
1. 贡献Flink Hologres连接器是否合规？
2. 如果合规的话，PR应该提到哪个项目代码仓库？
3. 还是说要像 https://flink-packages.org/categories/connectors 
这样链接到自己的github仓库？如果是的话要怎么在flink-packages.org上面注册呢？


[1] 
https://repo1.maven.org/maven2/com/alibaba/ververica/ververica-connector-hologres/1.17-vvr-8.0.4-1/
[2] 
https://github.com/aliyun/alibabacloud-hologres-connectors/tree/master/holo-client

Re: 使用Kafka记录自身的时间戳问题

[Biao Geng]

Hi,

>>> 那这个时间戳是kafka接收到数据自动生成的时间吗？还是说消息发送给kafka的时候需要怎么设置把业务时间附上去？
这个时间戳来自Kafka record里的时间戳，可以参考代码

。它的生成逻辑由Kafka配置决定，如果用户没有指定的话，默认是消息创建时间，可以参考Kafka的文档


>>> 感觉应该是发送数据到kafka的时候需要把业务时间给附上去，那在sink端怎么把时间附上去呢？
flink的Kafka connector里KafkaSink的实现是默认用input record里的时间戳，可以参考这里的实现

。


Best,
Biao Geng


ha.fen...@aisino.com  于2024年5月8日周三 10:59写道：

>
> DataStream stream = env.fromSource(
> kafkaSource,
> WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSeconds(20)),
> "mySource");
> 这样做使用的是Kafka记录自身的时间戳来定义watermark。
>
> 那这个时间戳是kafka接收到数据自动生成的时间吗？还是说消息发送给kafka的时候需要怎么设置把业务时间附上去？
> 感觉应该是发送数据到kafka的时候需要把业务时间给附上去，那在sink端怎么把时间附上去呢？
>

Re: use flink 1.19 JDBC Driver can find jdbc connector

[kellygeorg...@163.com]

退订



 Replied Message 
| From | abc15...@163.com |
| Date | 05/10/2024 12:26 |
| To | user-zh@flink.apache.org |
| Cc | |
| Subject | Re: use flink 1.19 JDBC Driver can find jdbc connector |
I've solved it. You need to register the number of connections in the jar of 
gateway. But this is inconvenient, and I still hope to improve it.
发自我的 iPhone

> 在 2024年5月10日，11:56，Xuyang  写道：
>
> Hi, can you print the classloader and verify if the jdbc connector exists in 
> it?
>
>
>
>
> --
>
>Best！
>Xuyang
>
>
>
>
>
> At 2024-05-09 17:48:33, "McClone"  wrote:
>> I put flink-connector-jdbc into flink\lib.use flink 1.19 JDBC Driver can not 
>>  find jdbc connector,but use sql-client is normal.