Kezhu Wang created FLINK-22108:
--
Summary: Ephemeral socket address was checkpointed to state and
restored back in CollectSinkOperatorCoordinator
Key: FLINK-22108
URL:
Kezhu Wang created FLINK-21821:
--
Summary: StreamTask.cancelables was closed concurrent between task
canceler and task thread
Key: FLINK-21821
URL: https://issues.apache.org/jira/browse/FLINK-21821
Kezhu Wang created FLINK-21817:
--
Summary: FLIP-27 Source might break subtask and split assignment
upon rescale
Key: FLINK-21817
URL: https://issues.apache.org/jira/browse/FLINK-21817
Project: Flink
Kezhu Wang created FLINK-21806:
--
Summary: ContinuousEventTimeTrigger should register its first
timer base on current watermark
Key: FLINK-21806
URL: https://issues.apache.org/jira/browse/FLINK-21806
Kezhu Wang created FLINK-21753:
--
Summary: Cycle references between memory manager and gc cleaner
action
Key: FLINK-21753
URL: https://issues.apache.org/jira/browse/FLINK-21753
Project: Flink
Kezhu Wang created FLINK-21635:
--
Summary: Driver name is optional for DriverManager.getConnection
but a must in JdbcConnectionOptions
Key: FLINK-21635
URL: https://issues.apache.org/jira/browse/FLINK-21635
Kezhu Wang created FLINK-21626:
--
Summary: Consider shaping newly introduced RuntimeContext.getJobId
to return JobID with no Optional wrapper
Key: FLINK-21626
URL: https://issues.apache.org/jira/browse/FLINK-21626
Kezhu Wang created FLINK-21578:
--
Summary: Closeable Sink Committer/GlobalCommitter were created to
function in onestep during job graph composition
Key: FLINK-21578
URL:
Kezhu Wang created FLINK-21564:
--
Summary: CommonTestUtils.waitUntilCondition could fail with
condition meets before
Key: FLINK-21564
URL: https://issues.apache.org/jira/browse/FLINK-21564
Project: Flink
Kezhu Wang created FLINK-21522:
--
Summary: Iterative stream could not work with stop-with-savepoint
Key: FLINK-21522
URL: https://issues.apache.org/jira/browse/FLINK-21522
Project: Flink
Issue
Kezhu Wang created FLINK-21467:
--
Summary: Document possible recommended usage of
Bounded{One/Multi}Input.endInput and emphasize that they could be called
multiple times
Key: FLINK-21467
URL:
Kezhu Wang created FLINK-21320:
--
Summary: Stream from FlinkKafkaShuffle.persistentKeyBy does not
end if upstream ends
Key: FLINK-21320
URL: https://issues.apache.org/jira/browse/FLINK-21320
Project:
Kezhu Wang created FLINK-21317:
--
Summary: Downstream keyed state not work after FlinkKafkaShuffle
Key: FLINK-21317
URL: https://issues.apache.org/jira/browse/FLINK-21317
Project: Flink
Issue
Kezhu Wang created FLINK-21133:
--
Summary: FLIP-27 Source does not work with synchronous savepoint
Key: FLINK-21133
URL: https://issues.apache.org/jira/browse/FLINK-21133
Project: Flink
Issue
Kezhu Wang created FLINK-21132:
--
Summary: BoundedOneInput.endInput is called when taking
synchronous savepoint
Key: FLINK-21132
URL: https://issues.apache.org/jira/browse/FLINK-21132
Project: Flink
Kezhu Wang created FLINK-20658:
--
Summary: Make sure jdbc connection is established by target driver
Key: FLINK-20658
URL: https://issues.apache.org/jira/browse/FLINK-20658
Project: Flink
Issue
Kezhu Wang created FLINK-20657:
--
Summary: Migrate jdbc connection code of JdbcInputFormat,
JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider
Key: FLINK-20657
URL:
Kezhu Wang created FLINK-20614:
--
Summary: Registered sql drivers not deregistered after task
finished in session cluster
Key: FLINK-20614
URL: https://issues.apache.org/jira/browse/FLINK-20614
Project:
Kezhu Wang created FLINK-19717:
--
Summary: SourceReaderBase.pollNext may return END_OF_INPUT if
SplitReader.fetch throws
Key: FLINK-19717
URL: https://issues.apache.org/jira/browse/FLINK-19717
Project:
Kezhu Wang created FLINK-14793:
--
Summary: Add SPI interface to discovery state backend and
establish well-known names
Key: FLINK-14793
URL: https://issues.apache.org/jira/browse/FLINK-14793
Project:
Kezhu Wang created FLINK-14790:
--
Summary: Custom state backend in job graph composition without
depending on concrete state backend implementation
Key: FLINK-14790
URL:
Kezhu Wang created FLINK-12491:
--
Summary: Incorrect documentation for directory path separators of
CoreOptions.TMP_DIRS
Key: FLINK-12491
URL: https://issues.apache.org/jira/browse/FLINK-12491
Project:
Kezhu Wang created FLINK-11409:
--
Summary: Make `ProcessFunction`, `ProcessWindowFunction` and etc.
pure interfaces
Key: FLINK-11409
URL: https://issues.apache.org/jira/browse/FLINK-11409
Project: Flink
23 matches
Mail list logo
