Commits

History for

Commits on Jul 25, 2022

[FLINK-24713][Runtime/Coordination] Postpone resourceManager serving after the recovery phase has finished

Aitozi
authored and
xintongsong
committedJul 25, 2022

Commits on Jul 24, 2022

[FLINK-28150][sql-gateway][hive] Introduce the hiveserver2 endpoint and factory
fsk119
committedJul 24, 2022

Commits on Jul 22, 2022

[FLINK-28586][runtime] Improve SourceCoordinator and SourceCoordinatorContext to support execution attempt level split requests and events
zhuzhurk
committedJul 22, 2022

Commits on Jul 20, 2022

[FLINK-27659][table-planner] Support to use jar that is registered by 'CREATE FUNCTION USING JAR' syntax

lsyldliu
authored and
fsk119
committedJul 20, 2022

Commits on Jul 18, 2022

[FLINK-28558][history] Improve log-url configuration usability.
xintongsong
committedJul 18, 2022

Commits on Jul 13, 2022

[FLINK-27884][connectors] Move OutputFormatBase to flink-core
echauchot
committedJul 13, 2022
[FLINK-28286][state] move 'enablechangelog' constant to flink-core module

fredia
authored and
rkhachatryan
committedJul 13, 2022

Commits on Jul 7, 2022

[FLINK-28312][rest] Introduce REST APIs for log URL retrieval
KarmaGYZ
committedJul 7, 2022

Commits on Jul 6, 2022

[FLINK-26979][core][tests] Add thread-safety test
zentol
committedJul 6, 2022
[FLINK-26979][core] Make Transformation#getNewNodeId() thread-safe

shba24
authored and
zentol
committedJul 6, 2022

Commits on Jul 1, 2022

[FLINK-28271][runtime] Add config options for speculative scheduler
zhuzhurk
committedJul 1, 2022
[FLINK-28142][runtime] Enrich TaskManagerLocation with node information

wanglijie95
authored and
zhuzhurk
committedJul 1, 2022
[FLINK-28136][runtime] Implement ExecutionTimeBasedSlowTaskDetector

hongli
authored and
zhuzhurk
committedJul 1, 2022

Commits on Jun 30, 2022

[FLINK-28213][runtime] StreamExecutionEnvironment configure method support override pipeline.jars option

lsyldliu
authored and
zhuzhurk
committedJun 30, 2022
[FLINK-28080][runtime] Introduce MutableURLClassLoader as parent class of FlinkUserClassLoader and SafetyNetWrapperClassLoader

lsyldliu
authored and
MartijnVisser
committedJun 30, 2022

Commits on Jun 28, 2022

[FLINK-28258][runtime] Introduce ExecutionHistory to host historical executions for each execution vertex
zhuzhurk
committedJun 28, 2022

Commits on Jun 23, 2022

[FLINK-27933][coordination] Fix/document RPC serializability violations
zentol
committedJun 23, 2022

Commits on Jun 22, 2022

[FLINK-28112][filesystems] Fix error message when directly supported file system not able to be handled

gaborgsomogyi
authored and
MartijnVisser
committedJun 22, 2022
[hotfix][javadoc] Misprint in javadoc at QuadFunction.java

snuyanzin
authored and
MartijnVisser
committedJun 22, 2022

Commits on Jun 21, 2022

[FLINK-28044][runtime][security] Make hadoop filesystems configuration available to all deployment targets

gaborgsomogyi
authored and
mbalassi
committedJun 21, 2022
[FLINK-26762][network] Add the overdraft buffer in ResultPartition

1996fanrui
authored and
pnowojski
committedJun 21, 2022

Commits on Jun 20, 2022

[FLINK-28105][Tests] test the copied object in GlobFilePathFilterTest#testGlobFilterSerializable

zhoulii
authored and
zhuzhurk
committedJun 20, 2022
[hotfix] Rework GlobFilePathFilterTest to be based on AssertJ & JUnit5

zhoulii
authored and
zhuzhurk
committedJun 20, 2022
[FLINK-27861][table] Introduce ResourceManager to manage JAR resources (apache#19859 )
lsyldliu
committedJun 20, 2022

Commits on Jun 15, 2022

[FLINK-28018][core] correct the start index for creating empty splits in BinaryInputFormat#createInputSplits

zhoulii
authored and
zhuzhurk
committedJun 15, 2022
[hotfix] Rework BinaryInputFormatTest to be based on AssertJ

zhoulii
authored and
zhuzhurk
committedJun 15, 2022

Commits on Jun 14, 2022

[hotfix][docs] Improve HA_MODE description
zentol
committedJun 14, 2022
[FLINK:27808][ha] Allow "kubernetes" as HA_MODE
zentol
committedJun 14, 2022
[FLINK-27658][runtime] SafetyNetWrapperClassLoader expose addURL method to allow registering jar dynamically

lsyldliu
authored and
zhuzhurk
committedJun 14, 2022

Commits on Jun 13, 2022

[Hotfix] fix typos

littleeleventhwolf
authored and
MartijnVisser
committedJun 13, 2022
[hotfix][network] Fix the typo about subpartition

1996fanrui
authored and
MartijnVisser
committedJun 13, 2022
[FLINK-27171][runtime][security] Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

gaborgsomogyi
authored and
gyfora
committedJun 13, 2022
[FLINK-27903][network] Introduce HYBRID result partition type.

reswqa
authored and
xintongsong
committedJun 13, 2022
[FLINK-27921][Runtime] Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

Aitozi
authored and
KarmaGYZ
committedJun 13, 2022

Commits on Jun 8, 2022

[FLINK-27457][cassandra] Implement flush() logic in output formats
echauchot
committedJun 8, 2022