flink.git
27 hours ago  Lijie Wang[FLINK-28143][runtime] Introduce BlocklistHandler. master
30 hours ago  lijiewang.wlj[FLINK-28143][runtime] Introduce BlockListTracker.
30 hours ago  Zhu Zhu[FLINK-28271][runtime] Add config options for speculati...
30 hours ago  Zhu Zhu[FLINK-28134][runtime] Wait for all the executions...
30 hours ago  Zhu Zhu[FLINK-28134][runtime] Rework TaskDeploymentDescriptorF...
30 hours ago  Zhu Zhu[FLINK-28134][runtime] Introduce SpeculativeExecutionJo...
33 hours ago  Zichen Liu[FLINK-28169][e2e-test/glue,kinesis] Re-enabled integra...
38 hours ago  Mingde Peng[FLINK-28140][python][docs] Improve the documentation...
38 hours ago  Luning (Lucas... [FLINK-28288][table][python] Support decode and encode...
38 hours ago  Juntao Hu[FLINK-28323][python][kafka] Support KafkaSource in...
40 hours ago  Lijie Wang[FLINK-28142][runtime] Enrich TaskExecutorRegistration...
40 hours ago  Lijie Wang[FLINK-28142][runtime] Enrich TaskManagerLocation with...
40 hours ago  Lijie Wang[hotfix][runtime][tests] Migrate TaskManagerLocationTes...
40 hours ago  hongli[FLINK-28136][runtime] Implement ExecutionTimeBasedSlow...
40 hours ago  hongli[FLINK-28135][runtime] Introduce SlowTaskDetector
40 hours ago  Yangze Guo[FLINK-28309][rest] Introduce metrics of the duration...
40 hours ago  Yangze Guo[FLINK-28308] Introduce metrics of the accumulated...
40 hours ago  Yangze Guo[hotfix][rest] Remove the stale items in rest_v1_dispatcher
41 hours ago  yuxia Luo[FLINK-26361][hive] Create LogicalFilter with Correlati...
42 hours ago  Juntao Hu[FLINK-28182][python][avro] Support Avro generic record...
2 days ago  fredia[FLINK-25872][state] Support restore from non-changelog...
2 days ago  frediaRevert "[FLINK-26079][state/changelog] Disallow recover...
2 days ago  Anton Kalashnikov[FLINK-27031][runtime] Assign even empty old state...
2 days ago  Shengkai[FLINK-28290][sql-gateway] Set lastAccessTime when...
2 days ago  Weijie Guo[FLINK-27906][runtime] Introduce HsDataIndex.
2 days ago  Weijie Guo[hotfix] Add Extension META-INF for flink-runtime modul...
2 days ago  Ada Wang[hotfix][docs] Remove a unuseful space
2 days ago  fengli[FLINK-28213][runtime] StreamExecutionEnvironment confi...
2 days ago  Robert Metzger[FLINK-28259][flink-parquet] Bump protoc version to...
2 days ago  Alexander Fedulov[FLINK-28047][api] Deprecate StreamExecutionEnvironment...
2 days ago  fengli[FLINK-28080][runtime] Introduce MutableURLClassLoader...
2 days ago  Juntao Hu[FLINK-27586][python] Support non-keyed co-broadcast...
3 days ago  MartijnVisser[FLINK-28269][Kubernetes] Install cri-dockerd and crict...
3 days ago  fanrui[FLINK-27789][network] Disable overdraft buffer for...
3 days ago  fanrui[hotfix] Fix the generic of RecordWriter
3 days ago  Juntao Hu[FLINK-28043][formats][parquet] Fix "Invalid lambda...
3 days ago  Bobby Richard[FLINK-19869][connectors/jdbc] Add support for postgres...
3 days ago  Mingde Peng[FLINK-27964][python] Support Cassandra connector in...
3 days ago  Ada Wang[FLINK-28092][table] Support ASCII and CHR built-in...
4 days ago  MartijnVisser[FLINK-28263][TPCDS][Tests] Clean-up generated data...
4 days ago  nieyingping[hotfix][docs] Remove redundant "." from sample code
4 days ago  liujia10[FLINK-28173][formats] Specify guava version explicitly...
4 days ago  luoyuxia[FLINK-27116][hive] Support read Hive table partitioned...
4 days ago  yuxia Luo[FLINK-23995][hive] Fix bug of table name parser when...
4 days ago  SteNicholas[FLINK-27392][cep] CEP Pattern supports definition...
4 days ago  luoyuxia[FLINK-27304][hive] Calcite's varbinary type should...
4 days ago  LuNing (Lucas... [hotfix][docs] Add a chinese doc of first_value/last_va...
4 days ago  luoyuxia[FLINK-28036][hive] HiveInspectors should use correct...
4 days ago  dependabot... [FLINK-28217] Bumps [mysql-connector-java](https:/...
4 days ago  huangxingbo[FLINK-28195][python] Fix the build wheels
4 days ago  Zhu Zhu[FLINK-28258][runtime] Introduce ExecutionHistory to...
5 days ago  zhengyunhong.zyh[FLINK-25097][table-planner] Fix bug in inner join...
5 days ago  fanrui[FLINK-26762][docs-zh] Translate the doc of overdraft...
5 days ago  lincoln.lil[hotfix][runtime] Cleanup for the temporary fix of...
5 days ago  huangxingbo[FLINK-28195][python] Annotate Python3.6 as deprecated...
7 days ago  JustDoDT[FLINK-16078] [docs-zh] Translate "Tuning Checkpoints...
7 days ago  HuangXingBo[FLINK-28226][python] Limit grpcio<1.47 (#20058)
8 days ago  Ahmed Hamdy[FLINK-28169] Disabling Flaky GlueSchemaRegistryJsonKi...
8 days ago  Chesnay Schepler[FLINK-28239][table] Add commons-math3 to owner classpath
8 days ago  dusukang[FLINK-27794][connectors/jdbc] Fix the wrong primary...
8 days ago  zhuzhu.zz[FLINK-28193][runtime] Enable to identify whether a...
8 days ago  Zhu Zhu[FLINK-28133][runtime] Rework DefaultScheduler to direc...
9 days ago  Chesnay Schepler[FLINK-27933][coordination][tests] Force serialization...
9 days ago  Chesnay Schepler[FLINK-27933][coordination] Fix/document RPC serializab...
9 days ago  Chesnay Schepler[FLINK-27933][coordination] OperationResult is serializable
9 days ago  Chesnay Schepler[hotfix][tests] Clarify interface
9 days ago  Chesnay Schepler[FLINK-27466][jdbc][docs] Clarify metaspace leak fix
9 days ago  Chesnay Schepler[FLINK-28175][ci] Improve license checker output
9 days ago  Chengkai Yang[FLINK-27290][docs-zh] Translate the "Data Type" sectio...
9 days ago  coderap[hotfix][table-api-java][javadoc]fix and unified the...
9 days ago  饶紫轩[FLINK-27926][Docs] Translating the `Upgrading Applicat...
9 days ago  Qingsheng Ren[FLINK-27865][docs] Add example for configuring SASL...
9 days ago  Shengkai[FLINK-27766][sql-gateway] Introduce the OperationManag...
9 days ago  Shengkai[FLINK-27766][sql-gateway] Introduce the basic componen...
9 days ago  Chesnay Schepler[FLINK-28194][python] Remove avro sql jar workaround...
10 days ago  Chesnay Schepler[FLINK-28196][build] Rename hadoop.version property
10 days ago  gabor.g.somogyi[FLINK-28112][filesystems] Fix error message when direc...
10 days ago  Sergey Nuyanzin[hotfix][javadoc] Misprint in javadoc at QuadFunction...
10 days ago  Chesnay Schepler[hotfix][legal] Correct module name in NOTICE
10 days ago  liuzhuang2017[hotfix][docs] Fix the Intellij key nouns.
10 days ago  MartijnVisser[hotfix][ci] Update libssl download link
10 days ago  liuzhuang2017[hotfix][docs] Fix the inaccessible documentation link
10 days ago  Ferenc Csaky[FLINK-27667][yarn-tests] Stabilize flaky YARN integrat...
10 days ago  Chesnay Schepler[FLINK-27972][tests] Forbid multiple state transitions
10 days ago  Chesnay Schepler[FLINK-27972][coordination] Wait until savepoint operat...
10 days ago  Chesnay Schepler[hotfix][tests] Cleanup StopWithSavepointTest
11 days ago  Piotr Nowojskifixup! fixup! [FLINK-26762][docs] Document overdraft... 20047/head
11 days ago  Piotr Nowojskifixup! [FLINK-26762][docs] Document overdraft buffers
11 days ago  Piotr Nowojski[FLINK-26762][docs] Document overdraft buffers
11 days ago  gabor.g.somogyi[FLINK-28044][runtime][security] Make hadoop filesystem...
11 days ago  1996fanrui[FLINK-28077][checkpoint] Allow buffers to be discarded...
11 days ago  Nie yingping[hotfix] Removed foul language. This closes #18722
11 days ago  fanrui[FLINK-26762][network] Add the overdraft buffer in...
11 days ago  Martijn Visser[FLINK-28147][Python] Update httplib2 to at least 0...
12 days ago  huangxingbo[FLINK-28002][python] Fixes the issue that add_jars...
12 days ago  zhouli[FLINK-28105][Tests] test the copied object in GlobFile...
12 days ago  zhouli[hotfix] Rework GlobFilePathFilterTest to be based...
12 days ago  shuiqiangchen[FLINK-27159][table] Support firstValue/lastValue in...
12 days ago  Ron[FLINK-27861][table] Introduce ResourceManager to manag...
12 days ago  Ada Wang[FLINK-28107][python][connector/elasticsearch] Support...
next