I’d like to note a trivial code improvement that can be made to
StreamExecutionEnvironment.java:1597. Neither is this worthy of its own Jira,
nor of a pull request. It should probably be incorporated in some general code
clean-up being done.
While the code strictly works as it stands, it is
Fabian Hueske created FLINK-8331:
Summary: FieldParsers do not correctly set EMPT_COLUMN error state
Key: FLINK-8331
URL: https://issues.apache.org/jira/browse/FLINK-8331
Project: Flink
Issue
I have a use case for non-static Session Window gaps.
For example, given a stream of IoT events, each device type could have a
different gap, and that gap could change while sessions are in flight.
I didn't want to have to run a stream processor for each potential gap
length, not to mention the h
Till Rohrmann created FLINK-8330:
Summary: Remove FlinkYarnCLI
Key: FLINK-8330
URL: https://issues.apache.org/jira/browse/FLINK-8330
Project: Flink
Issue Type: Improvement
Component
Till Rohrmann created FLINK-8329:
Summary: Move YarnClient out of YarnClusterClient
Key: FLINK-8329
URL: https://issues.apache.org/jira/browse/FLINK-8329
Project: Flink
Issue Type: Improvemen
Till Rohrmann created FLINK-8328:
Summary: Pull Yarn ApplicationStatus polling out of
YarnClusterClient
Key: FLINK-8328
URL: https://issues.apache.org/jira/browse/FLINK-8328
Project: Flink
I
