Re: Default Flink S3 FileSource timeout due to large file listing

退订 Replied Message | From | Eleanore Jin | | Date | 09/26/2023 01:50 | | To | user-zh | | Subject | Default Flink S3 FileSource timeout due to large file listing | Hello Flink Community, Flink Version: 1.16.1, Zookeeper for HA. My Flink Applications reads raw parquet files hosted in

Re:Re: Flink1.14 需求超大内存

退订 在 2023-06-20 11:16:18，"Yanfei Lei" 写道： >Hi, > >从 ResourceProfile{taskHeapMemory=1024.000gb (1099511627776 bytes), >taskOffHeapMemory=1024.000gb (1099511627776 bytes), >managedMemory=128.000mb (134217728 bytes), networkMemory=64.000mb >(67108864 bytes)}, numberOfRequiredSlots=1}]

回复：python 自定义sink

退订 回复的原邮件 | 发件人 | smq<374060...@qq.com.invalid> | | 发送日期 | 2023年05月30日 12:22 | | 收件人 | user-zh | | 主题 | python 自定义sink | java中可以继承richainkfunction和checkpointedfunction 两个类实现自定义sink。在python中如何实现这种功能呢

Re:Re: Re: sink mysql id自增表数据会丢失

退订 在 2023-04-19 09:15:09，"Shammon FY" 写道： >如果想让mysql生成自增主键，可以在flink ddl的table里不增加主键字段，然后flink作业直接写入数据到table就可以了 > >On Tue, Apr 18, 2023 at 5:38 PM Jeff wrote: > >> 在sink时指定字段不可以不包括自增主键的列。 >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> >> 在 2023-04-17 07:29:16，"Shammon FY" 写道： >>