flink.git
8 hours ago  hequn8128[FLINK-11125] clean up useless imports master
12 hours ago  zhangzhanchun[hotfix] [docs] Fix typo in dynamic tables documentation
16 hours ago  zentol[FLINK-11080][ES] Rework shade-plugin filters
17 hours ago  zentol[hotfix][build] Add Aliyun FS dependency to flink-dist
18 hours ago  maqingxiang[hotfix][docs][table] Fix string concatenation in avro...
18 hours ago  zentol[hotfix][metrics][tests] Refactor MetricQueryServiceTest
18 hours ago  zentol[hotfix][metrics][tests] Ensure ActorSystem is terminated
18 hours ago  yanghua[FLINK-10252][metrics] Handle oversized metric messages
18 hours ago  yanghua[FLINK-10252][metrics] Pass akkaFrameSize to MetricQuer...
19 hours ago  hequn8128[FLINK-11090][streaming api] Remove unused parameter...
21 hours ago  Stefan Richter[FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamI...
21 hours ago  blueszheng[hotfix][test][streaming] Fix invalid testNotSideOutput...
22 hours ago  yanghua[FLINK-10359] [docs] Scala example in DataSet docs...
22 hours ago  KarmaGYZ[FLINK-11029] [docs] Fixed incorrect parameter in Worki...
22 hours ago  KarmaGYZ[hotfix] [docs] Correct the parameter in Operators...
22 hours ago  unknown[hotfix] [docs] Fix tEnv in tableApi docs
22 hours ago  zhangzhanchun[hotfix] [docs] Fix typo in Joining documentation
22 hours ago  Tzu-Li (Gordon... [FLINK-11087] [docs] Amend compatibility table to notif...
22 hours ago  Tzu-Li (Gordon... [FLINK-11087] [state] Incorrect broadcast state K/V...
22 hours ago  Tzu-Li (Gordon... [hotfix] Cleanup unused methods / appropriate method...
22 hours ago  Tzu-Li (Gordon... [hotfix] [tests] Remove unused enum from StateBackendTe...
22 hours ago  Tzu-Li (Gordon... [FLINK-11094] [state backends] State backends no longer...
22 hours ago  Tzu-Li (Gordon... [FLINK-11094] [state backends] Let meta infos always...
22 hours ago  Tzu-Li (Gordon... [FLINK-11094] [rocksdb] Eagerly create meta infos for...
22 hours ago  Tzu-Li (Gordon... [hotfix] [state backends, tests] Make StateBackendMigra...
22 hours ago  Tzu-Li (Gordon... [hotfix] [state backends] New namespace serializer...
22 hours ago  Tzu-Li (Gordon... [hotfix] [state backend, tests] Certain StateBackendMig...
22 hours ago  Ufuk Celebi[FLINK-10743] [runtime] Use 0 processExitCode for Appli...
31 hours ago  sunjincheng121[FLINK-11123][docs] fix the import of the class is...
41 hours ago  Nico Kruber[FLINK-9552][iterations] fix not syncing on checkpoint...
41 hours ago  KarmaGYZ[hotfix][docs] Add and update description of local...
45 hours ago  Gary Yao[hotfix] Rename keys-as-allowed-values-help-text to...
45 hours ago  Gary Yao[hotfix] Move code from nemesis to generator
45 hours ago  Gary Yao[hotfix] Remove redundant keyword conversion when valid...
45 hours ago  Gary Yao[FLINK-10986][tests] Add example on how to run a Jepsen...
45 hours ago  Gary Yao[FLINK-10986][tests] Implement DB to setup Apache Kafka
45 hours ago  Gary Yao[FLINK-10986][tests] Enable fine-grained configuration...
45 hours ago  Gary Yao[FLINK-10985][tests] Enable submission of multiple...
45 hours ago  jinhu.wjh[FLINK-10865] Add Aliyun OSS file systems without Hadoo...
2 days ago  hequn8128[FLINK-10543][table] Leverage efficient timer deletion...
4 days ago  Stefan Richter[hotfix][documentation] Mention limitation of local...
5 days ago  Andrey Zagrebin[FLINK-10482] Fix double counting of checkpoint stat
5 days ago  azagrebin[FLINK-11011][E2E][JM] Log error messages about null...
5 days ago  zentol[FLINK-10987] Add LICENSE & NOTICE files for flink...
5 days ago  zentol[FLINK-10997][formats] Bundle kafka-scheme-registry...
5 days ago  KarmaGYZ[hotfix][docs] Fix invalid link in schema_evolution doc
6 days ago  chensq[FLINK-9555][scala-shell] Support table api in scala...
6 days ago  KarmaGYZ[hotfix][docs] Fix typo in Windows documentation
6 days ago  Igal Shilman[hotfix] Fixing the broken code examples
6 days ago  Kostas Kloudas[FLINK-10522][fs-connector] Check if RecoverableWriter...
7 days ago  hequn8128[FLINK-11045][table] Set correct UserCodeClassLoader...
7 days ago  Kostas Kloudas[FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects...
7 days ago  Kostas Kloudas[hotfix] Method renaming in the RecoverableMultiPartUpl...
7 days ago  Kostas Kloudas[hotfix] Consolidated all S3 accesses under the S3Acces...
7 days ago  Kostas Kloudas[hotfix][s3-connector] Renamed S3MultiPartUploader...
7 days ago  Kostas Kloudas[hotfix][fs-connector] Refactor Bucket to statically...
7 days ago  Kostas Kloudas[hotfix][fs-connector] Refactor PartFileWriter to take...
7 days ago  kgorman[FLINK-11044] [docs] Fix registerTableSink docs
7 days ago  Shimin Yang[FLINK-6756][DataStream API] Provide Rich AsyncFunction...
8 days ago  Till Rohrmann[FLINK-11047] Fix CoGroupGroupSortTranslationTest by...
8 days ago  Dawid Wysakowicz[FLINK-7603] [docs] Update documentation with WITHIN...
8 days ago  Dawid Wysakowicz[FLINK-7603] [table] Support WITHIN clause in MATCH_REC...
8 days ago  Piotr Nowojski[FLINK-10874][kafka-docs] Document likely cause of...
8 days ago  Timo Walther[FLINK-10689] [table] Improve docs and fix bugs of...
8 days ago  xueyu[FLINK-10689] [table] Port UDF interfaces to flink...
8 days ago  Dian Fu[FLINK-11013] [table] Fix distinct aggregates for group...
9 days ago  Gary Yao[FLINK-10149][mesos] Simplify assertions in LaunchableM...
9 days ago  Gary Yao[FLINK-10149][mesos] Make returned port keys set immutable.
9 days ago  Gary Yao[FLINK-10149][mesos] Replace string concatenation with...
9 days ago  Rune Skou Larsen[FLINK-10149][mesos] Don't allocate extra mesos port...
9 days ago  yanghua[FLINK-10798] Add the version number of Flink 1.7 to...
11 days ago  Piotr Nowojski[hotfix][docs] Fix typo in StreamTableSoureFactory
11 days ago  Dawid Wysakowicz[FLINK-10597] Enabled UDFs support in MATCH_RECOGNIZE
11 days ago  Dawid Wysakowicz[hotfix][cep] Enabled distributed cache for CEP functions
11 days ago  yanghua[FLINK-11015] Remove deprecated code for format-specifi...
11 days ago  blueszheng[hotfix] [table] Fix the misuse of assertEquals
11 days ago  Matrix42[hotfix] [docs] Fix typos in MATCH_RECOGNIZE docs
11 days ago  Dawid Wysakowicz[FLINK-11017][table] Throw exception if constant with...
11 days ago  Dawid Wysakowicz[hotfix][table] Check if expected exception was thrown
11 days ago  Till Rohrmann[hotfix] Bump japicmp Flink reference version to 1.7.0
12 days ago  Till Rohrmann[hotfix] Add 1.7 to previous docs in docs/_config.yml
12 days ago  Till Rohrmann[hotfix] Add release notes 1.7 and 1.8 to documentation...
12 days ago  Till Rohrmann[hotfix] Let CoGroupGroupSortTranslationTest extend...
13 days ago  Till Rohrmann[hotfix] Remove flink-metrics-ganglia from flink-dist...
13 days ago  Till Rohrmann[FLINK-10987] Update source LICENSE & NOTICE files
13 days ago  Till Rohrmann[FLINK-10987] Add NOTICE & licenses for binary release
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Stephan Ewen[FLINK-10987] Add licenses and notice for flink-swift...
13 days ago  Stephan Ewen[FLINK-10987] Add license notices for flink-filesystems
13 days ago  zentol[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  zentol[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  zentol[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Till Rohrmann[FLINK-10987] Do not deploy flink-yarn-tests module...
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  Till Rohrmann[FLINK-10987] Add LICENSE & NOTICE files for flink...
13 days ago  zentol[FLINK-10987] Add LICENSE & NOTICE files for flink...
next