[
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
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: B
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163232#comment-17163232
]
Ori Popowski commented on FLINK-18637:
--
Great, thanks
> Key group is not in KeyGro
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162598#comment-17162598
]
Ori Popowski edited comment on FLINK-18587 at 7/22/20, 8:38 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162600#comment-17162600
]
Ori Popowski commented on FLINK-18589:
--
This is caused by a corruption of the state
[
https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162598#comment-17162598
]
Ori Popowski commented on FLINK-18587:
--
This is caused by a corruption of the state
[
https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162600#comment-17162600
]
Ori Popowski edited comment on FLINK-18589 at 7/22/20, 8:38 AM:
--
[
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&focusedCommentId=17162596#comment-17162596
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Looks like the issue is resolved.
[
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 readin
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161850#comment-17161850
]
Ori Popowski edited comment on FLINK-18637 at 7/21/20, 8:14 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161850#comment-17161850
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Unfortunately, removing the Gauge
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161460#comment-17161460
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Thanks, I'm going to try that and
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161431#comment-17161431
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 5:48 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161431#comment-17161431
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] Sure. The only place I use state i
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161237#comment-17161237
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 1:27 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161237#comment-17161237
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 1:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161237#comment-17161237
]
Ori Popowski commented on FLINK-18637:
--
[~yunta] I'm triggering once in every few h
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161150#comment-17161150
]
Ori Popowski commented on FLINK-18637:
--
[~yunta]
The max parallelism is 512. The j
[
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.apac
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160961#comment-17160961
]
Ori Popowski edited comment on FLINK-18637 at 7/20/20, 7:06 AM:
--
[
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: h
[
https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160961#comment-17160961
]
Ori Popowski commented on FLINK-18637:
--
[~yunta]
The error starts to happen after
[
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.apac
[
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.apac
[
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.apac
[
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.apac
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
En
[
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 (wa
[
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 inte
[
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 with
[
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 wh
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: B
[
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
{{ValueState[java.lan
[
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
callin
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
Is
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154484#comment-17154484
]
Ori Popowski commented on FLINK-9268:
-
[~aljoscha] Interesting solution. So if I do {
[
https://issues.apache.org/jira/browse/FLINK-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153250#comment-17153250
]
Ori Popowski commented on FLINK-9268:
-
I'm hitting this issue too. What would be the
[
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
stacktrace
[
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: java.la
[
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
stacktrace
[
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 Ho
[
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
stacktrace
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-18260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ori Popowski updated FLINK-18260:
-
Description:
Flink already supports [async
functions|https://ci.apache.org/projects/flink/flink
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: API
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076164#comment-17076164
]
Ori Popowski commented on FLINK-16929:
--
!image-2020-04-06-12-11-01-138.png|width=19
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076112#comment-17076112
]
Ori Popowski commented on FLINK-16929:
--
[~aljoscha]
Looking at discussions
([1|h
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=17075878#comment-17075878
]
Ori Popowski commented on FLINK-16929:
--
# {{SessionStartProcessFunction}} just oupu
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073548#comment-17073548
]
Ori Popowski edited comment on FLINK-16929 at 4/2/20, 9:38 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073548#comment-17073548
]
Ori Popowski edited comment on FLINK-16929 at 4/2/20, 9:32 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073548#comment-17073548
]
Ori Popowski commented on FLINK-16929:
--
Hi,
I've made some progress.
I've forgot
[
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
with
[
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: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:
-
Attachment: (was: image-2020-04-01-19-55-04-886.png)
> Session Window produces sessions rand
[
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:
-
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 rand
[
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 rand
[
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 rand
[
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 rand
[
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 rand
[
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 rand
[
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:
-
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: 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:
-
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: 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:
-
Attachment: image-2020-04-01-19-48-35-977.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
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-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897188#comment-16897188
]
Ori Popowski commented on FLINK-13406:
--
{quote}I'm not sure; it will never affect u
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: Bug
81 matches
Mail list logo
