Commits

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Commits

Commits on Apr 8, 2021

[FLINK-21386][datastream] Postpone FromElementsFunction serialization to respect later type customization

[FLINK-21386][datastream] Assert that AbstractUdfStreamOperator redirects OutputTypeConfigurable to function

Commits on Mar 25, 2021

[FLINK-11408][datastream] Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger

Commits on Mar 10, 2021

[FLINK-19763][metrics][tests] Fine and extend memory metric tests

Commits on Mar 8, 2021

[FLINK-21635][jdbc] Support optional driverName in jdbc connection establishment

Commits on Mar 1, 2021

[FLINK-20658][jdbc] Establish connection through driver with given name (apache#15043 )

Commits on Feb 18, 2021

[FLINK-20580][core] Does not accept null value for SerializedValue

[FLINK-20580][rpc] Separate wire value class from user values

Commits on Feb 3, 2021

[FLINK-21132][runtime][tests] Stop with savepoint shouldn't end input

Commits on Dec 27, 2020

[FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to SimpleJdbcConnectionProvider for connection establishment

Commits on Dec 21, 2020

[FLINK-19435][connectors/jdbc] Fix deadlock when loading different sql driver classes concurrently using Class.forName

[FLINK-19435][connectors/jdbc] Add hang test case to reveal deadlock when loading different sql driver classes concurrently using Class.forName

Commits on Nov 23, 2020

[FLINK-19864][tests] Fix unpredictable Thread.getState in StreamTaskTestHarness due to concurrent class loading

Commits on Nov 10, 2020

[FLINK-19448][connector/common] Fix handling of finished splits and closing split fetchers in SourceReaderBase

Commits on Nov 9, 2020

[FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exception (apache#13776 )

Commits on Oct 2, 2020

[FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

Commits on Aug 13, 2020

[FLINK-18815] Close safety net guarded closeable iff it is still registered

[FLINK-18815] Change Thread.sleep(2) to Thread.sleep(0) to fail SafetyNetCloseableRegistryTest#testClose more often

Commits on Feb 6, 2019

[hotfix][javadocs] Fix typos and errors

Commits on Jan 30, 2019

[FLINK-11326] Allow negative offsets in window assigners

Branch selector

User selector

Commit History

Commits on Apr 8, 2021

Commits on Mar 25, 2021

Commits on Mar 10, 2021

Commits on Mar 8, 2021

Commits on Mar 1, 2021

Commits on Feb 18, 2021

Commits on Feb 3, 2021

Commits on Dec 27, 2020

Commits on Dec 21, 2020

Commits on Nov 23, 2020

Commits on Nov 10, 2020

Commits on Nov 9, 2020

Commits on Oct 2, 2020

Commits on Aug 13, 2020

Commits on Feb 6, 2019

Commits on Jan 30, 2019