版本兼容 #7
Comments
|
有报错么？
Francis-X ***@***.***> 于2022年5月7日周六 17:30写道：
… 好像不支持flink1.14.4版本
—
Reply to this email directly, view it on GitHub
<#7>, or
unsubscribe
<https://github.com/notifications/unsubscribe-auth/AFNV7R7GXEB3W4BGVJX5FS3VIYZ3NANCNFSM5VKFCWPA>
.
You are receiving this because you are subscribed to this thread.Message
ID: ***@***.***>
|
|
测试了一下，是支持的。
只是flink1.14.4删除了blink相关的包，所以maven编译时会报错，直接使用下面引用运行不会有问题。
<dependency>
<groupId>io.github.jeff-zou</groupId>
<artifactId>flink-connector-redis</artifactId>
<version>1.0.11</version>
</dependency>
如果要自行编译的话请删除pom文件里的blink相关包引用。
jeff zou ***@***.***> 于2022年5月13日周五 13:56写道：
… 有报错么？
Francis-X ***@***.***> 于2022年5月7日周六 17:30写道：
> 好像不支持flink1.14.4版本
>
> —
> Reply to this email directly, view it on GitHub
> <#7>, or
> unsubscribe
> <https://github.com/notifications/unsubscribe-auth/AFNV7R7GXEB3W4BGVJX5FS3VIYZ3NANCNFSM5VKFCWPA>
> .
> You are receiving this because you are subscribed to this thread.Message
> ID: ***@***.***>
>
|
|
第一次跑报错了，后面好像没有报错了，然后我自己实现了一套sink |
|
新加了什么功能
Francis-X ***@***.***> 于2022年5月13日周五 15:05写道：
… 第一次跑报错了，后面好像没有报错了，然后我自己实现了一套sink
—
Reply to this email directly, view it on GitHub
<#7 (comment)>,
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/AFNV7R7KICWTAACZ5MTX5A3VJX5LZANCNFSM5VKFCWPA>
.
You are receiving this because you commented.Message ID:
***@***.***>
|
|
我底层用的Lettuce客户端 |
|
你好，我可以咨询你一些问题吗？ |
|
可以
Francis-X ***@***.***> 于2022年5月30日周一 20:59写道：
… 你好，我可以咨询你一些问题吗？
—
Reply to this email directly, view it on GitHub
<#7 (comment)>,
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/AFNV7R2K3IDZIVL5HYZW5UTVMS3TDANCNFSM5VKFCWPA>
.
You are receiving this because you commented.Message ID:
***@***.***>
|
|
请问你有过flink 大窗口checkpoint 超时问题经历吗？ |
|
有的，中间状态数据量太大了就会出现，你用的是flink哪个版本
Francis-X ***@***.***> 于2022年5月31日周二 11:49写道：
… 请问你有过flink 大窗口checkpoint 超时问题经历吗？
—
Reply to this email directly, view it on GitHub
<#7 (comment)>,
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/AFNV7R5NHKZ5TJILBQA4RETVMWD5VANCNFSM5VKFCWPA>
.
You are receiving this because you commented.Message ID:
***@***.***>
|
|
我用1.14.4和1.15.0都会有这个问题，超时达到次数就把taskmanager搞挂了，你是如何解决这个问题的呢？ |
|
是不是试了增量checkpoint也没用？ 如果没试过可以试一下，之前我的状态非常大用增量也没用，后面是调整业务实现方式，绕开了checkpoint, 大致思路是将任务拆分成两个，第一个任务先预处理，第二个任务做聚合计算时只需要对简单数据进行checkpoint. 可以加我v聊 zilong954224 |
|
对的，增量checkpoint也没用，我这边是因为窗口开了一个小时，数据来源频率是每10分钟会产生20多万数据 |
|
数据量不大呀，单条数据有多大，是其它问题吧，平常checkpoint能成功不？
Francis-X ***@***.***> 于2022年6月1日周三 13:56写道：
… 对的，增量checkpoint也没用，我这边是因为窗口开了一个小时，数据来源频率是每10分钟会产生20多万数据
—
Reply to this email directly, view it on GitHub
<#7 (comment)>,
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/AFNV7RZ7SLITLSHO57PE2M3VM33QVANCNFSM5VKFCWPA>
.
You are receiving this because you commented.Message ID:
***@***.***>
|
|
close |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
好像不支持flink1.14.4版本
The text was updated successfully, but these errors were encountered: