Stefan Richter created FLINK-8385:
-
Summary: Fix exceptions in
AbstractEventTimeWindowCheckpointingITCase
Key: FLINK-8385
URL: https://issues.apache.org/jira/browse/FLINK-8385
Project: Flink
Dyana Rose created FLINK-8384:
-
Summary: Session Window Assigner with Dynamic Gaps
Key: FLINK-8384
URL: https://issues.apache.org/jira/browse/FLINK-8384
Project: Flink
Issue Type: Improvement
Hi,
I want to find the number of events happened so far in last 5 minutes and
make that as a Queryable state. Is it possible? It will be of great help if
someone provide some sample code for the same.
Thanks,
Velu.
Timo Walther created FLINK-8386:
---
Summary: Scala API cannot create type information for Tuple
interface
Key: FLINK-8386
URL: https://issues.apache.org/jira/browse/FLINK-8386
Project: Flink
Iss
Timo Walther created FLINK-8387:
---
Summary: Do not allow filter(false)
Key: FLINK-8387
URL: https://issues.apache.org/jira/browse/FLINK-8387
Project: Flink
Issue Type: Improvement
Comp
Hi ,
i have this scenario of applications that streaming logs to kafka .
I want to use flink in order to aggregate the stream and calculate some
data
i have a guid that i can correlate the stream to single event and i have
a field that i can use to understand if is the last stream of the event
Chesnay Schepler created FLINK-8388:
---
Summary: Snapshot documentation redirects to 1.4
Key: FLINK-8388
URL: https://issues.apache.org/jira/browse/FLINK-8388
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-8389:
Summary: Release all slots upon closing of JobMaster connection
Key: FLINK-8389
URL: https://issues.apache.org/jira/browse/FLINK-8389
Project: Flink
Issue Ty
Shuyi Chen created FLINK-8390:
-
Summary: Refactor Hadoop kerberos integration test code
Key: FLINK-8390
URL: https://issues.apache.org/jira/browse/FLINK-8390
Project: Flink
Issue Type: Bug
