退订
回复的原邮件
| 发件人 | 张胜军<15910621...@139.com> |
| 发送日期 | 2024年6月28日 12:57 |
| 收件人 | user-zh |
| 主题 | 退订 |
退订
扫一扫,
快速添加名片到手机
The following is the content of the forwarded em
退订
回复的原邮件
| 发件人 | jwfktv |
| 发送日期 | 2024年8月1日 14:20 |
| 收件人 | user-zh@flink.apache.org |
| 主题 | 请问BackPressure是否影响Watermarks机制 |
Hi:
各位好，最近使用PyFlink 1.18.0的Window
deduplication能力来获取每分钟最后一条记录，输出到数据库中。数据来源是kafka，事件时间使用的是kafka记录的metadata中的timestamp字段。
日常计算没有问题，但是一旦我想要回拉当天
退订
回复的原邮件
| 发件人 | wjw_bigdata |
| 发送日期 | 2024年8月1日 14:21 |
| 收件人 | user-zh@flink.apache.org |
| 抄送人 | user-zh@flink.apache.org |
| 主题 | 回复：请问BackPressure是否影响Watermarks机制 |
退订
回复的原邮件
| 发件人 | jwfktv |
| 发送日期 | 2024年8月1日 14:20 |
| 收件人 | user-zh@flink.apache.org |
| 主
退订
回复的原邮件
| 发件人 | wjw_bigdata |
| 发送日期 | 2024年8月1日 14:22 |
| 收件人 | user-zh@flink.apache.org |
| 主题 | 回复：请问BackPressure是否影响Watermarks机制 |
退订
回复的原邮件
| 发件人 | wjw_bigdata |
| 发送日期 | 2024年8月1日 14:21 |
| 收件人 | user-zh@flink.apache.org |
| 抄送人 | user-zh@flink.apache.org
退订
回复的原邮件
| 发件人 | Lei Wang |
| 发送日期 | 2024年8月1日 14:08 |
| 收件人 | |
| 主题 | Re: flink on yarn 模式，在jar任务中，怎么获取rest port |
在 flink-conf.yaml 中可以指定 rest.port， 可指定一个范围
On Wed, Jul 31, 2024 at 8:44 PM melin li wrote:
flink on yarn 模式, rest port 是随机的，需要获取rest port，有什么好办法？
