| 74d5f1e | martijnvisser | 01 February 2022, 15:23:34 UTC | [FLINK-25880][docs] Add Matomo tracking code to base layout | 02 February 2022, 11:27:53 UTC |
| aa26f5c | martijnvisser | 31 January 2022, 12:39:12 UTC | [FLINK-25880][docs] Remove Google Analytics implementation | 02 February 2022, 11:27:53 UTC |
| b8647b1 | Colm O hEigeartaigh | 20 March 2020, 10:13:12 UTC | [FLINK-16697][metrics][jmx] Disable rebinding | 06 May 2020, 07:40:30 UTC |
| 0dda6fe | Congxian Qiu | 13 May 2019, 08:29:34 UTC | [FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators This closes #8338. | 13 May 2019, 08:29:34 UTC |
| c233ead | Kostas Kloudas | 26 February 2019, 15:53:14 UTC | [FLINK-11185] Fix StreamSourceOperatorWatermarksTest instability. The cause of the instability seems to be that due to a not-so-rare timing, the thread that calls the `interrupt()` on the main thread, runs still after its original test finishes and calls `interrupt()` during execution of the next test. This causes the normal execution (or `sleep()` in this case) to be interrupted. | 26 February 2019, 16:40:25 UTC |
| 950657b | Andrey Zagrebin | 25 February 2019, 13:24:06 UTC | [FLINK-11745][State TTL][E2E] Restore from the savepoint after the job cancellation. | 26 February 2019, 11:15:25 UTC |
| 9663323 | yanghua | 15 January 2019, 09:12:03 UTC | [FLINK-10964][sql-client] SQL Client throws exception when paging through finished batch query This closes #7265. | 19 February 2019, 13:12:30 UTC |
| de1560d | Chesnay Schepler | 16 February 2019, 08:41:23 UTC | [hotfix][travis] Remove stray slash | 16 February 2019, 08:41:23 UTC |
| a268ae1 | zentol | 15 February 2019, 10:33:36 UTC | [FLINK-11628][travis] Cache maven | 15 February 2019, 12:22:46 UTC |
| 1cfa90c | zentol | 12 February 2019, 14:16:47 UTC | [FLINK-11585][docs] Fix prefix matching | 13 February 2019, 09:47:04 UTC |
| 2840106 | zentol | 12 February 2019, 15:03:54 UTC | [FLINK-11584][docs][tests] Fix linebreak parsing | 12 February 2019, 15:06:24 UTC |
| b3f9dde | zentol | 12 February 2019, 15:03:32 UTC | [hotfix][docs] Add space in self-closing linebreak tag | 12 February 2019, 15:06:22 UTC |
| 4e78d58 | Kostas Kloudas | 31 January 2019, 12:36:09 UTC | [FLINK-11419][filesystem] Wait for lease to be revoked when truncating file in Hadoop. | 04 February 2019, 09:59:11 UTC |
| 7966c88 | EAlexRojas | 28 January 2019, 18:01:48 UTC | [FLINK-11419][filesystem] Wait until lease is revoked before truncating file in Hadoop. | 04 February 2019, 09:59:00 UTC |
| ea90666 | Till Rohrmann | 31 January 2019, 10:39:55 UTC | [FLINK-11389][tests] Refactor TaskDeploymentDescriptorTest This closes #7532. | 31 January 2019, 10:51:28 UTC |
| 941ed4d | park.yq | 18 January 2019, 08:40:30 UTC | [FLINK-11389] Fix Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor | 31 January 2019, 10:51:28 UTC |
| 1b9c464 | Till Rohrmann | 30 January 2019, 16:43:20 UTC | [FLINK-10774][tests] Refactor FlinkKafkaConsumerBaseTest#testConsumerLifeCycle Split #testConsumerLifeCycle into two methods which represent the two if-else branches. This closes #7606. | 31 January 2019, 08:13:41 UTC |
| c215064 | Tzu-Li (Gordon) Tai | 29 January 2019, 04:10:55 UTC | [FLINK-10774] [tests] Test that Kafka partition discoverer is wokeup before closed when concurrently accessed | 31 January 2019, 08:13:41 UTC |
| 2a5d97d | Tzu-Li (Gordon) Tai | 29 January 2019, 03:45:27 UTC | [FLINK-10774] [tests] Refactor Kafka tests to have consistent life cycle verifications | 31 January 2019, 08:13:40 UTC |
| 402f235 | Till Rohrmann | 05 November 2018, 02:04:32 UTC | [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase | 31 January 2019, 08:13:40 UTC |
| de3772b | junsheng.wu | 30 January 2019, 13:34:45 UTC | [FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State` This closes #7603. (cherry picked from commit 3abb3de79e36b04cf5a5012fc1062f4418b3597a) | 30 January 2019, 14:44:32 UTC |
| 01e3c72 | Dawid Wysakowicz | 30 January 2019, 10:42:22 UTC | [FLINK-10910][e2e] Hardened Kubernetes e2e test. Added check if minikube is running. If it is not we try to start it couple of times. If we do not succeed we fail with a descriptive message. | 30 January 2019, 10:54:28 UTC |
| bdc29b9 | Dawid Wysakowicz | 27 January 2019, 18:13:41 UTC | [FLINK-11071][core] Improved proxy class serialization test This closes #7436 | 29 January 2019, 13:04:48 UTC |
| 4321bd3 | eaglewatcherwb | 08 January 2019, 09:36:03 UTC | [FLINK-11071][core] add support for dynamic proxy classes resolution in job defination This closes #7436 | 29 January 2019, 13:04:43 UTC |
| 8e10177 | zentol | 09 January 2019, 15:20:51 UTC | [FLINK-11289][examples] Rework examples to account for licensing | 17 January 2019, 10:12:23 UTC |
| 4a97ac1 | zentol | 10 January 2019, 13:46:34 UTC | [hotfix][build] Append shade-plugin transformers in child modules | 17 January 2019, 10:12:20 UTC |
| 9b7af86 | sunjincheng121 | 16 January 2019, 07:05:32 UTC | [hotfix][docs] Fix complex Table API example bug | 16 January 2019, 07:05:32 UTC |
| c9c2fa4 | Timo Walther | 14 January 2019, 13:16:18 UTC | [FLINK-11304][docs][table] Fix typos in time attributes doc | 14 January 2019, 13:16:18 UTC |
| 4022836 | Till Rohrmann | 08 January 2019, 12:06:50 UTC | [FLINK-10848] Remove container requests after successful container allocation This commit removes container requests after containers have been allocated. This prevents that we will request more and more containers from Yarn in case of a recovery. Since we cannot rely on the reported container Resource, we remove the container request by using the requested Resource. This is due Yarn's DefaultResourceCalculator which neglects the number of vCores when allocating containers. | 11 January 2019, 15:12:31 UTC |
| 99a89d2 | Jeff Zhang | 11 January 2019, 09:20:02 UTC | [FLINK-11224][scala-shell] Log is missing in scala-shell Logging configuration was set only for scala-shell in yarn mode. This commit sets the configuration for local and remote mode in start-scala-shell.sh script as well. | 11 January 2019, 09:27:02 UTC |
| 0d3125d | Shimin Yang | 06 December 2018, 06:39:46 UTC | [FLINK-11084][datastream] Forbid using two consecutive split transformations This closes #7258 | 11 January 2019, 08:53:25 UTC |
| 03dc53c | zentol | 03 January 2019, 16:30:53 UTC | [hotfix][rest] Remove unnecessary instanceof check | 10 January 2019, 12:14:13 UTC |
| a698eec | zentol | 03 January 2019, 16:29:56 UTC | [hotfix][rest] Centralize REST error logging | 10 January 2019, 12:14:10 UTC |
| b346f8c | zentol | 20 December 2018, 13:18:46 UTC | [FLINK-11134][rest] Do not log stacktrace for handled exceptions | 10 January 2019, 12:14:06 UTC |
| 93c13f4 | Nico Kruber | 09 January 2019, 10:00:43 UTC | [FLINK-11207][build] Bump commons-compress to 1.18 This addresses CVE-2018-11771. | 09 January 2019, 10:04:02 UTC |
| eb1fcbc | Fokko Driesprong | 09 January 2019, 09:33:57 UTC | [FLINK-11262][py] Bump jython-standalone to 2.7.1 Bump the jython dependency because of a security issue. | 09 January 2019, 09:43:32 UTC |
| 5cd3090 | Till Rohrmann | 28 November 2018, 13:48:19 UTC | [FLINK-10987] Add NOTICE & licenses for binary release Adds a NOTICE-binary file and a licenses-binary directory containing all bundled licenses for the binary release. When creating the binary release the NOTICE-binary file and the licenses-binary directory will be copied and renamed to NOTICE and the licenses in the binary release. | 09 January 2019, 09:38:17 UTC |
| ed4835b | Till Rohrmann | 28 November 2018, 15:10:18 UTC | [FLINK-10987] Update source LICENSE & NOTICE files The source LICENSE and NOTICE files now follow the same pattern that the LICENSE file only contains the ASL 2.0 license and the dependencies are now listed in the NOTICE file. This closes #7191. | 09 January 2019, 09:38:17 UTC |
| 59daef2 | Till Rohrmann | 25 November 2018, 11:35:52 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-dist | 09 January 2019, 09:38:17 UTC |
| 69d9882 | Stephan Ewen | 23 November 2018, 16:49:43 UTC | [FLINK-10987] Add licenses and notice for flink-swift-fs-hadoop | 09 January 2019, 09:38:17 UTC |
| 8d4cbb9 | Stephan Ewen | 23 November 2018, 15:09:21 UTC | [FLINK-10987] Add license notices for flink-filesystems | 09 January 2019, 09:38:17 UTC |
| 7eda713 | zentol | 27 November 2018, 14:44:17 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-metrics-prometheus | 09 January 2019, 09:38:17 UTC |
| 9cdfedb | zentol | 27 November 2018, 14:41:05 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-metrics-graphite | 09 January 2019, 09:38:17 UTC |
| 3e7c628 | zentol | 27 November 2018, 14:37:13 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-metrics-datadog | 09 January 2019, 09:38:17 UTC |
| d128e53 | Till Rohrmann | 25 November 2018, 13:33:50 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-connector-twitter | 09 January 2019, 09:38:17 UTC |
| 263a0ef | Till Rohrmann | 23 November 2018, 22:39:31 UTC | [FLINK-10987] Do not deploy flink-yarn-tests module to repository | 09 January 2019, 09:38:17 UTC |
| fa9ecd9 | Till Rohrmann | 23 November 2018, 21:57:00 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-shaded-curator | 09 January 2019, 09:38:17 UTC |
| e981a2f | Till Rohrmann | 23 November 2018, 21:47:26 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-shaded-yarn-tests | 09 January 2019, 09:38:17 UTC |
| 5f00660 | Till Rohrmann | 23 November 2018, 21:15:24 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-shaded-hadoop2-uber | 09 January 2019, 09:38:17 UTC |
| 4ba940e | Till Rohrmann | 23 November 2018, 20:18:27 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-shaded-hadoop2 | 09 January 2019, 09:38:17 UTC |
| 5d6c78d | Till Rohrmann | 23 November 2018, 17:20:01 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-test-utils | 09 January 2019, 09:38:17 UTC |
| d3ef8d8 | zentol | 23 November 2018, 17:26:06 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-runtime | 09 January 2019, 09:38:17 UTC |
| 99619af | zentol | 23 November 2018, 17:04:03 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-runtime-web | 09 January 2019, 09:38:17 UTC |
| dca2f48 | zentol | 23 November 2018, 16:44:17 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-mesos | 09 January 2019, 09:38:17 UTC |
| fc01b5c | zentol | 23 November 2018, 16:44:06 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-table | 09 January 2019, 09:38:17 UTC |
| 1c8c9ca | zentol | 23 November 2018, 16:43:49 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-sql-client | 09 January 2019, 09:38:17 UTC |
| 3bd54ce | zentol | 23 November 2018, 15:32:23 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-streaming-python | 09 January 2019, 09:38:17 UTC |
| 928602a | Till Rohrmann | 25 November 2018, 12:02:26 UTC | [FLINK-10987] Exclude packaged LICENSEs from license check by the apache-rat-plugin | 09 January 2019, 09:38:17 UTC |
| add0a4e | Till Rohrmann | 23 November 2018, 10:54:01 UTC | [FLINK-10987] Deactive ApacheLicenseResourceTransformer to add vanilla LICENSE and NOTICE file to every module | 09 January 2019, 09:38:17 UTC |
| 8528524 | Matrix42 | 08 January 2019, 13:43:19 UTC | [FLINK-11140][fs-connector] Fix empty child path check in Buckets. | 09 January 2019, 09:30:21 UTC |
| fb9b15c | Tony Wei | 09 January 2019, 08:12:08 UTC | [FLINK-11251][metrics] Exclude variable values from logical scope of generic groups | 09 January 2019, 08:23:41 UTC |
| df8301b | Bo WANG | 09 January 2019, 08:05:13 UTC | [FLINK-11232][rest] Fix subtask start-time field name | 09 January 2019, 08:08:29 UTC |
| 8affc90 | Till Rohrmann | 08 January 2019, 10:25:51 UTC | Revert "[FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success" This reverts commit 7cc4c6f3e5e84efc067f2f2179648e31e5defa27. | 08 January 2019, 10:25:51 UTC |
| 7cc4c6f | Shuyi Chen | 10 November 2018, 08:42:49 UTC | [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success This closes #7078 | 05 January 2019, 08:46:27 UTC |
| 4682048 | wenhuitang | 25 December 2018, 12:16:27 UTC | [FLINK-11173][table] Fix the exception message of proctime attribute validation in TableSourceUtil#validateTableSource This closes #7374. | 04 January 2019, 13:58:02 UTC |
| 3b81265 | wenhuitang | 29 December 2018, 10:50:31 UTC | [FLINK-11119][docs] Correct Scala example for Table Function in User-defined Functions docs. This closes #7379. | 04 January 2019, 12:52:51 UTC |
| eeb1814 | EronWright | 31 December 2018, 03:59:47 UTC | [FLINK-11234] [table] Fix ExternalTableCatalogBuilder unable to build a batch-only table - fix the logic in supportsBatch to properly declare a batch-only table - adjust CommonTestData to provide batch-only or streaming-only tables This closes #7386. | 04 January 2019, 10:55:57 UTC |
| 437f06b | zentol | 20 December 2018, 11:48:33 UTC | [FLINK-11079][storm] Skip deployment of storm-examples | 03 January 2019, 18:28:27 UTC |
| cb85e62 | Chesnay Schepler | 03 January 2019, 17:13:48 UTC | [FLINK-10761][metrics] Do not acquire lock for getAllVariables() | 03 January 2019, 17:15:54 UTC |
| 1702c99 | 谢磊 | 02 January 2019, 11:31:59 UTC | [FLINK-11235][es] Close transportclient if no connection could be established | 02 January 2019, 11:34:28 UTC |
| 41f95a2 | zentol | 13 December 2018, 14:37:13 UTC | [FLINK-11151][rest] Create parent directories in FileUploadHandler | 18 December 2018, 12:02:37 UTC |
| 26b182c | blueszheng | 10 December 2018, 14:04:05 UTC | [FLINK-11083] [Table&SQL] CRowSerializerConfigSnapshot is not instantiable This closes #7267. | 18 December 2018, 01:54:50 UTC |
| 172875a | Maximilian Michels | 11 December 2018, 13:52:54 UTC | [FLINK-10566] Fix exponential planning time of large programs The traversal of the DAG is not efficient enough at some places which can lead to very long plan creation times. This introduces caching for the traversal to avoid traversing nodes multiple times. Caching is performed at two places: - when registering Kryo types - when determining the maximum parallelism | 14 December 2018, 13:25:47 UTC |
| a3c86df | Timo Walther | 13 December 2018, 13:00:48 UTC | [hotfix] [docs] Add notice about buggy DATE_FORMAT function | 13 December 2018, 13:00:48 UTC |
| fa75c9e | KarmaGYZ | 10 December 2018, 10:26:21 UTC | [hotfix] [docs] Improve DataSet.partitionCustom() documentation. This closes #7282. | 13 December 2018, 04:17:47 UTC |
| 5469fd1 | Dian Fu | 10 December 2018, 13:33:02 UTC | [FLINK-11136] [table] Fix the merge logic of DISTINCT aggregates. This closes #7284. | 13 December 2018, 04:17:25 UTC |
| dc2cd5f | yanghua | 18 October 2018, 05:07:53 UTC | [FLINK-10252][metrics] Handle oversized metric messages | 11 December 2018, 15:21:38 UTC |
| c78c465 | yanghua | 18 October 2018, 05:07:53 UTC | [FLINK-10252][metrics] Pass akkaFrameSize to MetricQueryService | 11 December 2018, 15:21:32 UTC |
| 89fdf65 | yanghua | 10 December 2018, 03:00:29 UTC | [FLINK-10359] [docs] Scala example in DataSet docs is broken This closes #7266. | 11 December 2018, 12:45:08 UTC |
| fd949b0 | KarmaGYZ | 29 November 2018, 13:02:54 UTC | [FLINK-11029] [docs] Fixed incorrect parameter in Working with state doc This closes #7198. | 11 December 2018, 12:45:08 UTC |
| fb8cacc | KarmaGYZ | 03 December 2018, 11:09:28 UTC | [hotfix] [docs] Correct the parameter in Operators Overview doc This closes #7219. | 11 December 2018, 12:45:08 UTC |
| 3c20d75 | unknown | 06 December 2018, 13:38:42 UTC | [hotfix] [docs] Fix tEnv in tableApi docs This closes #7254. | 11 December 2018, 12:45:08 UTC |
| e1b1b33 | zhangzhanchun | 11 December 2018, 03:00:49 UTC | [hotfix] [docs] Fix typo in Joining documentation This closes #7270. | 11 December 2018, 12:45:08 UTC |
| 3e70c63 | Tzu-Li (Gordon) Tai | 11 December 2018, 10:22:17 UTC | [FLINK-11087] [docs] Amend compatibility table to notify issue with restoring 1.5.x braodcast state in later versions | 11 December 2018, 12:45:08 UTC |
| 06f2064 | Tzu-Li (Gordon) Tai | 11 December 2018, 10:20:03 UTC | [FLINK-11087] [state] Incorrect broadcast state K/V serializer snapshot association when restoring from 1.5.x When restoring a broadcast state's meta information from a 1.5.x savepoint, the LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV2V3 incorrectly associates the first restored serializer as the value serializer, and the second restored serializer as the key serializer. The actual order of this should be the other way around. This bug prevents successful broadcast state restores from 1.5, both for Flink 1.6.x and 1.7.0. The commit also modifies the StatefulJobWBroadcastStateMigrationITCase to have different key / value types for its tested broadcast tests, which otherwise would not have caught this bug. | 11 December 2018, 12:45:08 UTC |
| d692666 | Stefan Richter | 10 December 2018, 15:52:02 UTC | [FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source should hold checkpointing lock | 11 December 2018, 11:02:49 UTC |
| d1a489f | sunjincheng121 | 11 December 2018, 00:37:27 UTC | [FLINK-11123][docs] fix the import of the class is missing in ml quick start document. This closes #7269 | 11 December 2018, 04:25:18 UTC |
| 2f47fd6 | Stefan Richter | 07 December 2018, 15:15:58 UTC | [hotfix][documentation] Mention limitation of local recovery with RocksDB in multi device setups. | 07 December 2018, 15:17:56 UTC |
| 0664e02 | Andrey Zagrebin | 15 November 2018, 17:51:43 UTC | [FLINK-10482] Fix double counting of checkpoint stat | 06 December 2018, 14:24:18 UTC |
| d9c1bf7 | azagrebin | 06 December 2018, 11:08:20 UTC | [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running (#7223) | 06 December 2018, 11:08:20 UTC |
| b3b969d | zentol | 27 November 2018, 15:07:33 UTC | [FLINK-10987] Add LICENSE & NOTICE files for flink-avro-confluent-registry | 06 December 2018, 10:55:38 UTC |
| 4b9b367 | zentol | 23 November 2018, 14:57:02 UTC | [FLINK-10997][formats] Bundle kafka-scheme-registry-client | 06 December 2018, 10:55:34 UTC |
| 19ea6c5 | hequn8128 | 02 December 2018, 11:05:49 UTC | [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor This closes #7213 | 05 December 2018, 09:27:14 UTC |
| fe967ac | Andrey Zagrebin | 30 November 2018, 13:06:49 UTC | [FLINK-10946] Silent checkpoint async failures in task executor if job is not runnning | 04 December 2018, 15:05:59 UTC |
| bf5f4be | Andrey Zagrebin | 30 November 2018, 15:04:55 UTC | [FLINK-10842][E2E tests] fix broken waiting loops in common.sh | 03 December 2018, 15:50:11 UTC |
| dbba9b0 | Gary Yao | 30 November 2018, 10:50:39 UTC | [FLINK-10149][mesos] Simplify assertions in LaunchableMesosWorkerTest Use Set equality to simplify test assertions. Change type of field LaunchableMesosWorker#TM_PORT_KEYS to Set<String>. | 03 December 2018, 07:08:27 UTC |
| bec8d7f | Gary Yao | 30 November 2018, 10:20:18 UTC | [FLINK-10149][mesos] Make returned port keys set immutable. | 03 December 2018, 07:08:24 UTC |
| 9b7b6af | Gary Yao | 30 November 2018, 10:17:14 UTC | [FLINK-10149][mesos] Replace string concatenation with slf4j placeholders | 03 December 2018, 07:08:21 UTC |
| b909d4d | Rune Skou Larsen | 15 August 2018, 10:33:54 UTC | [FLINK-10149][mesos] Don't allocate extra mesos port for TM unless configured to do so. | 03 December 2018, 07:08:16 UTC |
| 4d3574e | Dawid Wysakowicz | 30 November 2018, 08:11:12 UTC | [FLINK-11017][table] Throw exception if constant with YEAR TO MONTH resolution was used for group windows This closes #7200. | 30 November 2018, 12:20:26 UTC |
