[
https://issues.apache.org/jira/browse/FLINK-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897188#comment-16897188
]
Ori Popowski commented on FLINK-13406:
--
{quote}I'm not sure; it will never affect users running
Ori Popowski created FLINK-13406:
Summary: MetricConfig.getInteger() always returns null
Key: FLINK-13406
URL: https://issues.apache.org/jira/browse/FLINK-13406
Project: Flink
Issue Type:
Ori Popowski created FLINK-16003:
Summary: ShardConsumer errors cannot be logged
Key: FLINK-16003
URL: https://issues.apache.org/jira/browse/FLINK-16003
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-56-27-720.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Description:
We have a Flink job which keyBys session ID (sId), and uses a session window
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-56-00-239.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17075878#comment-17075878
]
Ori Popowski commented on FLINK-16929:
--
# {{SessionStartProcessFunction}} just ouputs to side
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076112#comment-17076112
]
Ori Popowski commented on FLINK-16929:
--
[~aljoscha]
Looking at discussions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17075878#comment-17075878
]
Ori Popowski edited comment on FLINK-16929 at 4/6/20, 7:17 AM:
---
#
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076164#comment-17076164
]
Ori Popowski commented on FLINK-16929:
--
!image-2020-04-06-12-11-01-138.png|width=197,height=271!
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-06-12-11-01-138.png
> Session Window produces sessions randomly
>
Ori Popowski created FLINK-16929:
Summary: Session Window produces sessions randomly
Key: FLINK-16929
URL: https://issues.apache.org/jira/browse/FLINK-16929
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-50-23-954.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-50-06-326.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-48-35-977.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-49-08-016.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: screenshot-1.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Description:
We have a Flink job which keyBys session ID (sId), and uses a session window
with
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-50-23-954.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-55-04-886.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: screenshot-1.png)
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: image-2020-04-01-19-55-04-886.png
> Session Window produces sessions randomly
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Description:
We have a Flink job which keyBys session ID (sId), and uses a session window
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Description:
We have a Flink job which keyBys session ID (sId), and uses a session window
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-48-35-977.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-43-07-288.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-50-06-326.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-49-08-016.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Attachment: (was: image-2020-04-01-19-44-35-714.png)
> Session Window produces sessions
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-16929:
-
Description:
We have a Flink job which keyBys session ID (sId), and uses a session window
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073548#comment-17073548
]
Ori Popowski commented on FLINK-16929:
--
Hi,
I've made some progress.
I've forgot to mention that
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073548#comment-17073548
]
Ori Popowski edited comment on FLINK-16929 at 4/2/20, 9:32 AM:
---
Hi,
I've
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073548#comment-17073548
]
Ori Popowski edited comment on FLINK-16929 at 4/2/20, 9:38 AM:
---
Hi,
I've
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18637:
-
Description:
I'm getting this error when creating a savepoint. I've read in
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18637:
-
Description:
I'm getting this error when creating a savepoint. I've read in
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18637:
-
Description:
I'm getting this error when creating a savepoint. I've read in
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18637:
-
Description:
I'm getting this error when creating a savepoint. I've read in
Ori Popowski created FLINK-18637:
Summary: Key group is not in KeyGroupRange
Key: FLINK-18637
URL: https://issues.apache.org/jira/browse/FLINK-18637
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161431#comment-17161431
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Sure. The only place I use state is in
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161431#comment-17161431
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 5:48 PM:
[~yunta]
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161460#comment-17161460
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Thanks, I'm going to try that and will report. By
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162598#comment-17162598
]
Ori Popowski edited comment on FLINK-18587 at 7/22/20, 8:38 AM:
This is
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162600#comment-17162600
]
Ori Popowski commented on FLINK-18589:
--
This is caused by a corruption of the state, caused by
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162598#comment-17162598
]
Ori Popowski commented on FLINK-18587:
--
This is caused by a corruption of the state, caused by
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162600#comment-17162600
]
Ori Popowski edited comment on FLINK-18589 at 7/22/20, 8:38 AM:
This is
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski closed FLINK-18587.
Resolution: Not A Problem
> java.lang.IllegalArgumentException: Position out of bounds when
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski closed FLINK-18589.
Resolution: Not A Problem
> java.io.EOFException when reading integer
>
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski closed FLINK-18637.
Resolution: Not A Problem
> Key group is not in KeyGroupRange
> -
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162596#comment-17162596
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Looks like the issue is resolved. I don't get
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153250#comment-17153250
]
Ori Popowski commented on FLINK-9268:
-
I'm hitting this issue too. What would be the way to limit the
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154484#comment-17154484
]
Ori Popowski commented on FLINK-9268:
-
[~aljoscha] Interesting solution. So if I do
Ori Popowski created FLINK-18587:
Summary: java.lang.IllegalArgumentException: Position out of bounds
Key: FLINK-18587
URL: https://issues.apache.org/jira/browse/FLINK-18587
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18587:
-
Description:
Getting {{java.lang.IllegalArgumentException: Position out of bounds}} when
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18589:
-
Summary: java.io.EOFException when reading integer state with TTL (was:
java.io.EOFException
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18587:
-
Summary: java.lang.IllegalArgumentException: Position out of bounds when
reading Long state
Ori Popowski created FLINK-18589:
Summary: java.io.EOFException when reading integer state
Key: FLINK-18589
URL: https://issues.apache.org/jira/browse/FLINK-18589
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18589:
-
Description:
Getting {{java.io.EOFException}} when calling {{value()}} on
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18587:
-
Summary: java.lang.IllegalArgumentException: Position out of bounds when
reading Long state
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18589:
-
Summary: java.io.EOFException when reading integer (was:
java.io.EOFException when reading
Ori Popowski created FLINK-18489:
Summary: java.lang.ArrayIndexOutOfBoundsException
Key: FLINK-18489
URL: https://issues.apache.org/jira/browse/FLINK-18489
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Description:
Getting {{java.lang.ArrayIndexOutOfBoundsException}} with the following
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Environment:
{code:java}
OS current user: yarn
Current Hadoop/Kerberos user: hadoop
JVM: Java
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Description:
Getting {{java.lang.ArrayIndexOutOfBoundsException}} with the following
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Description:
Getting {{java.lang.ArrayIndexOutOfBoundsException}} with the following
[
https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18489:
-
Summary: java.lang.ArrayIndexOutOfBoundsException from
DataOutputSerializer.write (was:
[
https://issues.apache.org/jira/browse/FLINK-18260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18260:
-
Description:
Flink already supports [async
Ori Popowski created FLINK-18260:
Summary: Asynchronous Sinks
Key: FLINK-18260
URL: https://issues.apache.org/jira/browse/FLINK-18260
Project: Flink
Issue Type: Wish
Components:
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163232#comment-17163232
]
Ori Popowski commented on FLINK-18637:
--
Great, thanks
> Key group is not in KeyGroupRange
>
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18637:
-
Description:
I'm getting this error when creating a savepoint. I've read in
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161850#comment-17161850
]
Ori Popowski edited comment on FLINK-18637 at 7/21/20, 8:14 AM:
[~yunta]
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161850#comment-17161850
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Unfortunately, removing the Gauge on
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160961#comment-17160961
]
Ori Popowski commented on FLINK-18637:
--
[~yunta]
The error starts to happen after the job has ran
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18637:
-
Environment:
Version: 1.10.0, Rev:, Date:
OS current user: yarn
Current Hadoop/Kerberos user:
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160961#comment-17160961
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 7:06 AM:
[~yunta]
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161150#comment-17161150
]
Ori Popowski commented on FLINK-18637:
--
[~yunta]
The max parallelism is 512. The job's parallelism
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161237#comment-17161237
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 1:26 PM:
[~yunta]
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161237#comment-17161237
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 1:27 PM:
[~yunta]
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161237#comment-17161237
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] I'm triggering once in every few hours/days. I do
Ori Popowski created FLINK-24941:
Summary: Cannot report backpressure with DatadogReporter
Key: FLINK-24941
URL: https://issues.apache.org/jira/browse/FLINK-24941
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-25007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-25007:
-
Description:
I am creating a simple application with events firing every 15 seconds. I
created
Ori Popowski created FLINK-25007:
Summary: Session window with dynamic gap doesn't work
Key: FLINK-25007
URL: https://issues.apache.org/jira/browse/FLINK-25007
Project: Flink
Issue Type: Bug
81 matches
Mail list logo
