Thank you very much. It solved my problem.
> 2020年4月22日 下午5:15，Jingsong Li [via Apache Flink User Mailing List archive.]
> 写道：
>
> Hi,
>
> Sorry for the mistake, [1] is related, but this bug has been fixed totally in
> [2], so the safe version should be 1.9.3+ and 1.10.1+, so there is
Hi,
Sorry for the mistake, [1] is related, but this bug has been fixed totally
in [2], so the safe version should be 1.9.3+ and 1.10.1+, so there is no
safe released version now.
1.10.1 will been released very soon.
[1]https://issues.apache.org/jira/browse/FLINK-13702
Hi,
Just like Jark said, it may be FLINK-13702[1]. Has been fixed in 1.9.2 and
later versions.
> Can it be a thread-safe problem or something else?
Yes, it is a thread-safe problem with lazy materialization.
[1]https://issues.apache.org/jira/browse/FLINK-13702
Best,
Jingsong Lee
On Tue, Apr
Hi Kurt：
I had the same mistake.
sql:
insertinto
dw_access_log select get_json_value(query_nor, query_nor_counter) as`value`from
ods_access_log_source groupby tumble (time_key, interval'1'MINUTE),
group_key
get_json_value
public class GetJsonValue extends AggregateFunction> {
Thanks, once you can reproduce this issue locally, please open a jira with
your testing program.
Best,
Kurt
On Tue, Apr 21, 2020 at 8:48 AM 刘建刚 wrote:
> Thank you. It is an online job and my input is huge. I check the trace and
> find that the array is resized when the array is not enough.
Thank you. It is an online job and my input is huge. I check the trace and find
that the array is resized when the array is not enough. The code is as below:
public void add (int value) {
int[] items = this.items;
if (size == items.length) items = resize(Math.max(8, (int)(size * 1.75f)));
Hi,
Are you using versions < 1.9.2? From the exception stack, it looks like
caused by FLINK-13702, which is already fixed in 1.9.2 and 1.10.0.
Could you try it using 1.9.2?
Best,
Jark
On Mon, 20 Apr 2020 at 21:00, Kurt Young wrote:
> Can you reproduce this in a local program with
Can you reproduce this in a local program with mini-cluster?
Best,
Kurt
On Mon, Apr 20, 2020 at 8:07 PM Zahid Rahman wrote:
> You can read this for this type error.
>
>
>
You can read this for this type error.
https://stackoverflow.com/questions/28189446/i-always-get-this-error-exception-in-thread-main-java-lang-arrayindexoutofbou#comment44747327_28189446
I would suggest you set break points in your code. Step through the code,
this method should show you which
I am using Roaring64NavigableMap to compute uv. It is ok to us flink
planner and not ok with blink planner. The SQL is as following:
SELECT toLong(TUMBLE_START(eventTime, interval '1' minute)) as curTimestamp, A,
B, C, D,
E, uv(bitmap(id)) as bmp
FROM person
GROUP BY
10 matches
Mail list logo
