退订
> 下面是被转发的邮件：
>
> 发件人: Biao Geng
> 主题: 回复：申请退订邮件申请，谢谢
> 日期: 2024年4月2日 GMT+8 10:17:20
> 收件人: user-zh@flink.apache.org
> 回复－收件人: user-zh@flink.apache.org
>
> Hi，
>
> 退订请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org
> .
>
>
> Best,
> Biao Geng
>
> 于2024年3月31日周日 22:20写道：
>
>> 申请退订邮件申请，谢谢
> 下面是被转发的邮件：
>
> 发件人: "史鹏飞" <904148...@qq.com.INVALID>
> 主题: (无主题)
> 日期: 2024年4月17日 GMT+8 16:33:48
> 收件人: "user-zh"
> 回复－收件人: user-zh@flink.apache.org
>
> 退订
> 下面是被转发的邮件：
>
> 发件人: "王广邦"
> 主题: HBase SQL连接器为啥不支持ARRAY/MAP/ROW类型
> 日期: 2024年4月1日 GMT+8 19:37:57
> 收件人: "Flink"
> 回复－收件人: user-zh@flink.apache.org
>
> HBase SQL 连接器（flink-connector-hbase_2.11） 为啥不支持数据类型：ARRAY、MAP / MULTISET、ROW
> 不支持？
> https://nightlies.apache.org/flink/flink-docs-release-1.11/zh/dev/table/connectors/hbase.html
> 另外这3种类型的需求处理思路是什么？
>
>
>
>
> 发自我的iPhone
> 下面是被转发的邮件：
>
> 发件人: willluzheng
> 主题: 回复：退订
> 日期: 2024年4月14日 GMT+8 15:43:24
> 收件人: user-zh
> 抄送: user-zh
> 回复－收件人: user-zh@flink.apache.org
>
> 退订
> 回复的原邮件
> | 发件人 | jimandlice |
> | 发送日期 | 2024年04月13日 19:50 |
> | 收件人 | user-zh |
> | 主题 | 退订 |
> 退订
>
>
>
>
> jimandlice
> jimandl...@163.com
>
>
>
>
> 下面是被转发的邮件：
>
> 发件人:
> 主题: 申请退订邮件申请，谢谢
> 日期: 2024年3月31日 GMT+8 22:20:09
> 收件人: "user-zh"
> 回复－收件人: user-zh@flink.apache.org
>
> 申请退订邮件申请，谢谢
> 下面是被转发的邮件：
>
> 发件人: "ha.fen...@aisino.com"
> 主题: ProcessWindowFunction中使用per-window state
> 日期: 2024年4月12日 GMT+8 14:31:41
> 收件人: user-zh
> 回复－收件人: user-zh@flink.apache.org
>
> 文档中关于窗口里面有一部分描述 在 ProcessWindowFunction 中使用 per-window
> state。这一部分没有看懂，如果有迟到数据会再次触发窗口计算，就是全部重新算一遍吧，存状态是为了不重新计算？有没有关于这方面的参考资料？
> 下面是被转发的邮件：
>
> 发件人: "casel.chen"
> 主题: flink cdc metrics 问题
> 日期: 2024年4月8日 GMT+8 11:59:27
> 收件人: "user-zh@flink.apache.org"
> 回复－收件人: user-zh@flink.apache.org
>
> 请问flink cdc对外有暴露一些监控metrics么？
> 我希望能够监控到使用flink cdc的实时作业当前未消费的binlog数据条数，类似于kafka topic消费积压监控。
> 想通过这个监控防止flink cdc实时作业消费慢而被套圈（最大binlog条数如何获取？）
> 下面是被转发的邮件：
>
> 发件人: "995626544" <995626...@qq.com.INVALID>
> 主题: 退订
> 日期: 2024年4月7日 GMT+8 16:06:11
> 收件人: "user-zh"
> 回复－收件人: user-zh@flink.apache.org
>
> 退订
>
>
>
>
> 995626544
> 995626...@qq.com
>
>
>
>
> 下面是被转发的邮件：
>
> 发件人: "bai年" <827931...@qq.com.INVALID>
> 主题: (无主题)
> 日期: 2024年4月1日 GMT+8 17:03:12
> 收件人: "user-zh@flink.apache.org"
> 回复－收件人: user-zh@flink.apache.org
>
> 退订
> 下面是被转发的邮件：
>
> 发件人: Biao Geng
> 主题: 回复：配置hadoop依赖问题
> 日期: 2024年4月2日 GMT+8 10:52:15
> 收件人: user-zh@flink.apache.org, ha.fen...@aisino.com
> 回复－收件人: user-zh@flink.apache.org
>
> Hi fengqi,
>
> “Hadoop is not in the
> classpath/dependencies.”报错说明org.apache.hadoop.conf.Configuration和org.apache.hadoop.fs.FileSystem这些hdfs所需的类没有找到。
>
> 如果你的系统环境中有hadoop的话，通常是用这种方式来设置classpath：
> export HADOOP_CLASSPATH=`hadoop classpath`
>
> 如果你的提交方式是提交到本地一个standalone的flink集群的话，可以检查下flink生成的日志文件，里面会打印classpath，可以看下是否有Hadoop相关的class。
>
> Best,
> Biao Geng
>
>
> ha.fen...@aisino.com 于2024年4月2日周二 10:24写道：
>
>> 1、在开发环境下，添加的有hadoop-client依赖，checkpoint时可以访问到hdfs的路径
>> 2、flink1.19.0,hadoop3.3.1,jar提交到单机flink系统中，提示如下错误
>> Caused by: java.lang.RuntimeException:
>> org.apache.flink.runtime.client.JobInitializationException: Could not start
>> the JobMaster.
>> at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
>> at
>> org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75)
>> at
>> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602)
>> at
>> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
>> at
>> java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:443)
>> at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
>> at
>> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
>> at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
>> at
>> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
>> Caused by: org.apache.flink.runtime.client.JobInitializationException:
>> Could not start the JobMaster.
>> at
>> org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
>> at
>> java.uti
