我目前看了下，有一定规律但也还是不完全懂。
比如我目前有部分公司内部用到的，希望基于1.15.1的release上加的话，我需要基于哪个分支？还是tag做更改呢？
哪个branch、or tag是对应官方download页面提供的下载链接的包中一模一样的源码呢，就是不包含新增开发但未发布代码的版本。
Hi user mail list,
I'm also forwarding this thread to you. Please let me know if you have any
comments or feedback!
Best,
Gen
On Wed, Jul 20, 2022 at 4:25 PM Zhu Zhu wrote:
> Thanks for starting this discussion, Gen!
> I agree it is confusing or even troublesome to show an attempt id that is
Sorry, pressed send too early.
What is the unit of measure for "count" and does this tell me I have too little
Direct Memory and if so, what do I do to specifically increase this number?
Many thanks,
John
From: John Tipper
Sent: 20 July 2022 17:52
To:
Hi all,
I can't find mention of what the columns mean for the "Outside JVM Memory' for
the Task Manager in the Flink console.
I have:
Count UsedCapacity
Direct4,203 227 MB 227MB
Mapped0 0 B 0 B
Hello again,
I just performed a test
using OffsetsInitializer.committedOffsets(OffsetResetStrategy.LATEST). I
did a few tests in the following order, and I noticed a few weird things.
Note that our job uses Processing Time windows, so watermarks are
irrelevant.
1. After the job had been running
Hi Dian,
Thanks very much - I suppose the concept I'm struggling with is understanding
how parallelism works when using SQL. I understand that in the Datastream world
parallelism means each slot will get a subset of events. However, how does that
work in the SQL world where you need to do
