| b8a1602 | Chesnay Schepler | 05 December 2019, 11:57:26 UTC | remove unnecessary licenses | 05 December 2019, 11:57:26 UTC |
| 9c349b0 | lamber-ken | 04 December 2019, 16:24:52 UTC | remove InterationTwoTone | 04 December 2019, 16:24:52 UTC |
| 0290a37 | lamber-ken | 02 December 2019, 10:02:28 UTC | remove angular license | 02 December 2019, 10:02:28 UTC |
| c350400 | lamber-ken | 02 December 2019, 10:00:31 UTC | remove dagre-d3 license | 02 December 2019, 10:00:31 UTC |
| d375a3a | lamber-ken | 02 December 2019, 09:58:59 UTC | remove jquery license | 02 December 2019, 09:58:59 UTC |
| b54b170 | lamber-ken | 02 December 2019, 09:54:50 UTC | remove old licenses | 02 December 2019, 09:54:50 UTC |
| 3a69dcf | lamber-ken | 02 December 2019, 09:35:49 UTC | update NOTICE | 02 December 2019, 09:35:49 UTC |
| adf938c | lamber-ken | 02 December 2019, 01:33:44 UTC | update NOTICE | 02 December 2019, 01:33:44 UTC |
| 4935a47 | lamber-ken | 02 December 2019, 01:23:40 UTC | update NOTICE | 02 December 2019, 01:23:40 UTC |
| 90d5933 | lamber-ken | 01 December 2019, 13:55:31 UTC | [FLINK-14984] Remove old WebUI | 01 December 2019, 13:55:31 UTC |
| 07b66b6 | Mads Chr. Olesen | 27 November 2019, 13:56:16 UTC | [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() | 29 November 2019, 17:59:14 UTC |
| daa2f95 | Zhu Zhu | 29 November 2019, 16:52:39 UTC | [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal This is necessary otherwise fractions can be summed up to be more than 1.0 due to the double precision issue, and the last operator may fail to allocate managed memory it is supposed to be able to acquire. The fraction scale is 16 which is large enough to make little managed memory unusable. | 29 November 2019, 16:52:39 UTC |
| 4ba834d | Chesnay Schepler | 21 November 2019, 15:34:00 UTC | [FLINK-14905][build] Unify Java8/11 packaging process | 29 November 2019, 15:56:48 UTC |
| 3898a4b | tison | 29 November 2019, 10:56:56 UTC | [FLINK-14762][client] Implement JobClient#getJobStatus This closes #10311 . | 29 November 2019, 13:52:47 UTC |
| f3df25d | tison | 29 November 2019, 10:50:45 UTC | [FLINK-14762][api] Move JobStatus to flink-core | 29 November 2019, 13:51:53 UTC |
| d8aa9b9 | tison | 29 November 2019, 02:47:31 UTC | [FLINK-14762][client] Implement JobClient#getAccumulators | 29 November 2019, 13:51:53 UTC |
| cf4de13 | tison | 29 November 2019, 01:55:23 UTC | [FLINK-14762][client] Implement JobClient#triggerSavepoint | 29 November 2019, 13:51:53 UTC |
| 0328fb6 | tison | 29 November 2019, 01:52:39 UTC | [FLINK-14762][client] Implement JobClient#stopWithSavepoint | 29 November 2019, 13:51:53 UTC |
| 318e406 | tison | 29 November 2019, 01:51:24 UTC | [FLINK-14762][client] Implement JobClient#cancel | 29 November 2019, 13:51:52 UTC |
| 7741eed | tison | 29 November 2019, 01:48:52 UTC | [FLINK-14762][tests] Introduce TestingJobClient | 29 November 2019, 13:51:52 UTC |
| 1266c88 | tison | 29 November 2019, 01:45:16 UTC | [FLINK-14762][client] ClusterClient#submitJob returns CompletableFuture of JobID | 29 November 2019, 13:51:52 UTC |
| c927e17 | tison | 29 November 2019, 01:37:47 UTC | [FLINK-14762][client] Handle clients close gracefully | 29 November 2019, 13:51:52 UTC |
| cf4e0f1 | Chesnay Schepler | 14 November 2019, 14:57:36 UTC | [FLINK-14503][coordination] Add partition report to heartbeat | 29 November 2019, 13:47:57 UTC |
| 7df7467 | Chesnay Schepler | 14 November 2019, 14:56:57 UTC | [FLINK-14503][coordination] Capture number of partitions | 29 November 2019, 13:47:57 UTC |
| 60067a8 | Chesnay Schepler | 27 November 2019, 14:50:58 UTC | [FLINK-14503][coordination] Simplify method signature | 29 November 2019, 13:47:57 UTC |
| acae782 | Chesnay Schepler | 14 November 2019, 14:23:40 UTC | [hotfix][tests] Expose full heartbeat payload | 29 November 2019, 13:47:57 UTC |
| 85905f8 | Gary Yao | 29 November 2019, 11:51:28 UTC | [FLINK-14834][tests] Disable flaky yarn_kerberos_docker (default input) test | 29 November 2019, 11:51:30 UTC |
| be3242d | Chesnay Schepler | 29 November 2019, 11:36:07 UTC | [hotfix][docs] Update REST API docs | 29 November 2019, 11:36:31 UTC |
| 070a9d9 | Jiayi Liao | 29 November 2019, 11:04:29 UTC | [FLINK-14957][yarn] Remove deprecated -yst option | 29 November 2019, 11:04:29 UTC |
| 3044753 | Gary Yao | 25 November 2019, 16:41:46 UTC | [FLINK-14859][runtime] Remove wrong checkState A slot that is assigned to an execution may be unreleased even if a deployment is outdated. However, this is safe, because the execution is responsible for releasing the slot. This closes #10351. | 28 November 2019, 20:02:54 UTC |
| 9c9ac52 | Piotr Nowojski | 28 November 2019, 17:39:12 UTC | Revert "[FLINK-14813][metrics] Provide `isBackPressured` Task metric" This reverts commit 2772cd02ed7fe611b9d04449cefd05d495db6ae0. | 28 November 2019, 17:39:12 UTC |
| 33f5e33 | Stefan Richter | 28 November 2019, 16:21:52 UTC | [FLINK-10377] Support checkpoint overtaking a savepoint in TwoPhaseCommitSink The precondition checkState(pendingTransactionIterator.hasNext(), "checkpoint completed, but no transaction pending"); in TwoPhaseCommitSinkFunction.notifyCheckpointComplete() seems too strict, because checkpoints can overtake checkpoints and will fail the precondition. In this case the commit was already performed by the first notification and subsumes the late checkpoint. I think the check can be removed. This can happen in the following scenario: # savepoint is triggered # checkpoint is triggered # checkpoint completes (but it doesn't subsume the savepoint, because checkpoints subsume only other checkpoints). # savepoint completes | 28 November 2019, 16:21:52 UTC |
| 7902947 | Zhu Zhu | 28 November 2019, 02:28:13 UTC | [FLINK-14909][runtime] Cleanup default scheduling strategies Extracted possible utils into SchedulingStrategyUtils. This closes #10309. | 28 November 2019, 15:13:28 UTC |
| 33d81cc | Zhu Zhu | 28 November 2019, 01:56:42 UTC | [FLINK-14909][runtime] Change default scheduling strategies to schedule vertices in topological order Vertices to deploy are orders before invoking #allocateSlotsAndDeploy on them. This would reduce #requestPartitionState RPCs to JobMaster since upstream tasks are more likely to get launched earlier than downstream tasks in this way. It also makes logs more readable. | 28 November 2019, 15:13:28 UTC |
| 24b77db | Zhu Zhu | 28 November 2019, 01:52:11 UTC | [FLINK-14909][runtime] Respect the scheduled vertex order from scheduling strategies This allows the topological ordering in default scheduling strategies to be effective. And the desired order from other scheduling strategies can also be respected, no matter it's in topological or any other order. The scheduling process, including state transition, slot allocation/assignment and tasks deployment are now conducted in the given order. | 28 November 2019, 15:13:28 UTC |
| 76d794b | Zhu Zhu | 27 November 2019, 12:41:50 UTC | [hotfix][tests] Avoid to add vertices to TestingSchedulingTopology when building edges using ProducerConsumerConnectionBuilder | 28 November 2019, 15:13:28 UTC |
| 2ba4a67 | Aljoscha Krettek | 28 November 2019, 14:33:33 UTC | [FLINK-13634] Add CompressWriterFactory to documentation | 28 November 2019, 14:35:30 UTC |
| 959cf62 | Joao Boto | 14 August 2019, 09:45:11 UTC | [FLINK-13634] Add compression format for use with StreamingFileSink | 28 November 2019, 14:35:30 UTC |
| 2772cd0 | lining | 28 November 2019, 14:34:13 UTC | [FLINK-14813][metrics] Provide `isBackPressured` Task metric Expose the recently implement mechanism of detecting back pressure in FLINK-14472 as a "isBackPressured" metric | 28 November 2019, 14:34:13 UTC |
| 2ac0dd0 | David Moravek | 11 November 2019, 16:20:25 UTC | [FLINK-14709] Dispose resources in ChainedDriver close method instead of closeTask. | 28 November 2019, 14:05:24 UTC |
| 09f2847 | David Moravek | 11 November 2019, 15:53:42 UTC | [FLINK-14709] Remove unused GroupCombineChainedDriver. | 28 November 2019, 14:05:24 UTC |
| e583a1c | David Moravek | 11 November 2019, 15:28:46 UTC | [FLINK-14709] Allow outputting elements in user defined close method, executed by chained driver. | 28 November 2019, 14:05:23 UTC |
| 981b054 | tison | 28 November 2019, 10:34:29 UTC | [FLINK-14969][tests] Refactor CliFrontendRunWithYarnTest reflect to new execution codepath (#10331) | 28 November 2019, 10:34:29 UTC |
| f381065 | Gary Yao | 27 November 2019, 11:08:29 UTC | [FLINK-14505][tests] Temporarily disable SQL Client end-to-end tests for Kafka This closes #10334. | 27 November 2019, 16:50:21 UTC |
| 8930f62 | Andrey Zagrebin | 27 November 2019, 10:50:47 UTC | [hotfix] Annotate interfaces in JavaGcCleanerWrapper with @FunctionalInterface | 27 November 2019, 14:30:33 UTC |
| 9f6b204 | Andrey Zagrebin | 21 November 2019, 14:38:10 UTC | [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection | 27 November 2019, 14:30:33 UTC |
| 3d657b4 | Chesnay Schepler | 27 November 2019, 13:46:44 UTC | [FLINK-14939][e2e] Set distDir property | 27 November 2019, 14:03:51 UTC |
| 4b1a9e4 | Chesnay Schepler | 27 November 2019, 13:48:39 UTC | [FLINK-14940][travis] Fix error code handling for maven calls | 27 November 2019, 13:58:25 UTC |
| 4c85821 | chunpinghe | 27 November 2019, 11:01:38 UTC | [FLINK-11835][tests] Wait until job was recovered before unblocking task | 27 November 2019, 11:01:38 UTC |
| 77bb81b | Chesnay Schepler | 27 November 2019, 10:57:45 UTC | [hotfix][coordination] Fix error message | 27 November 2019, 10:57:45 UTC |
| d79dbec | Konstantin Knauf | 22 November 2019, 21:00:32 UTC | [FLINK-14930][fs][oss] Document credential providers | 27 November 2019, 10:44:52 UTC |
| 17e7fe9 | Konstantin Knauf | 22 November 2019, 20:12:20 UTC | [FLINK-14930][fs][oss] Fix shading prefix The OSS filesystem only supports OSS credential providers, which use the "com.aliyun" relocation and not the hadoop one. | 27 November 2019, 10:44:52 UTC |
| 3466c22 | Zhu Zhu | 20 November 2019, 17:20:45 UTC | [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building | 27 November 2019, 10:22:55 UTC |
| 488c742 | Zhu Zhu | 20 November 2019, 17:18:23 UTC | [hotfix][runtime] Fix checkstyle violations in runtime classes which use ResourceProfile Including SlotSelectionStrategyTestBase, AvailableSlotsTest, SlotProtocolTest and TaskManagerReleaseInSlotManagerTest. | 27 November 2019, 10:22:55 UTC |
| 5374cfe | Aljoscha Krettek | 27 November 2019, 08:27:43 UTC | [FLINK-14968] Disable flaky yarn_kerberos_docker (custom fs plugin) test | 27 November 2019, 08:27:43 UTC |
| 4b21753 | Aljoscha Krettek | 27 November 2019, 07:53:51 UTC | [minor] Fix error logging in common yarn/docker test scripts We also now print the list of YARN applications to aid in debugging. | 27 November 2019, 07:54:00 UTC |
| 20c983c | Leonard Xu | 27 November 2019, 03:55:11 UTC | [FLINK-11491][e2e] Add TPC-DS queries to end to end tests This closes #10239 | 27 November 2019, 03:55:11 UTC |
| 3d94ba0 | Yang Wang | 27 November 2019, 02:36:41 UTC | [FLINK-10932][kubernetes] Initialize flink-kubernetes module This closes #9957 . | 27 November 2019, 02:36:41 UTC |
| 672cdb3 | tison | 27 November 2019, 01:30:26 UTC | [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient This closes #10320 . | 27 November 2019, 01:30:26 UTC |
| 9ffc2a2 | hpeter | 22 November 2019, 05:40:12 UTC | [FLINK-14913][table] refactor CatalogFunction to remove properties this closes #10294. | 26 November 2019, 17:02:39 UTC |
| e24681b | Victor Wong | 26 November 2019, 15:04:13 UTC | [FLINK-14817][doc] Fix misleading documentation using method chaining of Configuration (#10323) | 26 November 2019, 15:04:13 UTC |
| 0af4801 | Dawid Wysakowicz | 25 November 2019, 16:10:28 UTC | [FLINK-12996][table-common] Simplify type validators structure This closes #10312. | 26 November 2019, 14:47:53 UTC |
| 86038cd | Timo Walther | 25 November 2019, 11:00:58 UTC | [FLINK-12996][table-common] Add required type strategies for FLIP-65 | 26 November 2019, 14:47:53 UTC |
| 0a9e2bd | Timo Walther | 25 November 2019, 10:45:42 UTC | [FLINK-12996][table-common] Add required input type validators for FLIP-65 | 26 November 2019, 14:47:53 UTC |
| dac2cb8 | Timo Walther | 25 November 2019, 09:18:54 UTC | [FLINK-12996][table-common] Offer unified exception for type inference classes | 26 November 2019, 14:47:53 UTC |
| edf440a | Timo Walther | 25 November 2019, 09:17:32 UTC | [FLINK-12996][table-common] Require equals/hashCode for type inference classes | 26 November 2019, 14:47:53 UTC |
| e383414 | Timo Walther | 25 November 2019, 09:09:30 UTC | [hotfix][core] Make CoreMatchers.containsCause more flexible | 26 November 2019, 14:47:53 UTC |
| e6dae01 | Aljoscha Krettek | 26 November 2019, 13:06:30 UTC | [hotfix] Add more logging in YARN/docker test scripts | 26 November 2019, 13:06:30 UTC |
| 9505b0e | Timo Walther | 26 November 2019, 12:05:27 UTC | [hotfix][examples-table] Update registerDataSet to createTemporaryView | 26 November 2019, 12:06:09 UTC |
| d95e2c1 | Timo Walther | 23 November 2019, 06:49:57 UTC | [FLINK-14904][table] Rename ANY type to RAW type Note: "RAW" is a reserved keyword now. This closes #10308. | 26 November 2019, 11:49:42 UTC |
| 08f1f42 | Chesnay Schepler | 14 November 2019, 13:51:19 UTC | [FLINK-13995][legal] Properly exclude netty license directory | 26 November 2019, 10:47:15 UTC |
| 81b5d17 | Timo Walther | 25 November 2019, 08:18:43 UTC | [FLINK-14903][table] Relax structured types constraints In order to allow type extraction of structured types that are not registered in a catalog, we need to relax the structured type concept to "inline or anonymous structured types" that are not identified by an object identifier in a catalog but the fully qualified implementation class. This closes #10307. | 26 November 2019, 10:32:36 UTC |
| ffde750 | Timo Walther | 14 November 2019, 14:12:56 UTC | [hotfix][table] Move UnresolvedIdentifier to table-common and update UDT | 26 November 2019, 10:32:36 UTC |
| 20f6976 | Yun Tang | 24 November 2019, 18:00:40 UTC | [FLINK-14846][doc] Correct the default writerbuffer size documentation of RocksDB Correct the default write buffer size of RocksDB to '64MB' | 26 November 2019, 10:03:34 UTC |
| 6691894 | lz | 26 November 2019, 08:57:07 UTC | [hotfix] Correct wrong log level in TaskLocalStateStoreImpl#storeLocalState This closes #10321 . | 26 November 2019, 08:57:07 UTC |
| 5984d52 | Congxian Qiu | 26 November 2019, 06:35:41 UTC | [FLINK-14892][docs] Add documentation for checkpoint directory layout (#10305) | 26 November 2019, 06:35:41 UTC |
| 8f665be | Wei Zhong | 25 November 2019, 09:16:33 UTC | [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 This closes #10310. | 26 November 2019, 05:59:42 UTC |
| e08e29e | tison | 26 November 2019, 03:05:06 UTC | [FLINK-14885][client] YarnClusterDescriptor should not know about detached option * [FLINK-14885][client] YarnClusterDescriptor should not know about detached option * [hotfix] Add back testCorrectSettingOfDetachedMode testing for configuration propagated This closes #10276 . | 26 November 2019, 03:05:06 UTC |
| 9abe977 | huangxingbo | 06 November 2019, 08:41:37 UTC | [FLINK-14506][python][build] Improve the release script for Python API release package Use python virtual environment to build the python package. This closes #10103. | 26 November 2019, 01:52:02 UTC |
| 75427bf | godfrey he | 25 November 2019, 14:19:06 UTC | [FLINK-14874][table-planner-blink] add local aggregation to solve data skew for ROLLUP/CUBE This closes #10271 | 25 November 2019, 14:19:06 UTC |
| 89634d7 | yanghua | 25 November 2019, 05:50:09 UTC | [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc | 25 November 2019, 13:44:33 UTC |
| 0a62bc0 | Aljoscha Krettek | 25 November 2019, 13:38:21 UTC | [hotfix] Fix checkstyle error in ExecutionContext.java | 25 November 2019, 13:38:21 UTC |
| 6111170 | Aljoscha Krettek | 21 November 2019, 14:52:59 UTC | [hotfix] Add debug logging in MiniDispatcher | 25 November 2019, 12:32:16 UTC |
| a7987d4 | Aljoscha Krettek | 13 November 2019, 12:28:19 UTC | [hotfix] Don't set plan name after creation in SQL cli ExecutionContext | 25 November 2019, 12:32:08 UTC |
| 461d5af | yanghua | 15 November 2019, 09:47:38 UTC | [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation | 25 November 2019, 11:10:19 UTC |
| 38750f0 | tison | 21 November 2019, 02:11:27 UTC | [hotfix] Extract loadJarFile from PackageProgram#<init> | 25 November 2019, 09:09:18 UTC |
| 5be1e78 | tison | 21 November 2019, 02:01:31 UTC | [hotfix] Make parameter of PackagedProgram#<init> final | 25 November 2019, 09:09:18 UTC |
| a6d6778 | tison | 21 November 2019, 02:00:30 UTC | [FLINK-14873][client] Make PackagedProgram#savepointSettings final | 25 November 2019, 09:09:18 UTC |
| 320240e | Jingsong Lee | 25 November 2019, 03:17:24 UTC | [FLINK-14595][orc] Move flink-orc to flink-formats from flink-connectors (#10277) | 25 November 2019, 03:17:24 UTC |
| 3442189 | Congxian Qiu | 25 November 2019, 02:55:28 UTC | [FLINK-14928][docs] Fix the broken links in documentation (#10292) | 25 November 2019, 02:55:28 UTC |
| 39a2777 | Zhu Zhu | 17 November 2019, 17:55:32 UTC | [FLINK-14314][runtime] Remove SharedSlotOversubscribedException handling Now that a physical slot resources should always fulfill all possible children slots allocated in it. Therefore, slot oversubscribing only happens when there is a bug. Hence, there is no need to do partial releasing on oversubscribing or do retrying allocation for unfulfilled children slots. A simple sanity check is kept though. | 24 November 2019, 15:16:29 UTC |
| bc24186 | Zhu Zhu | 20 November 2019, 15:07:23 UTC | [FLINK-14314][runtime] Introduce physical slot ResourceProfile in SlotProfile physicalSlotResourceProfile can be used for allocating a physical slot for the task slot. If the task is not in a shared slot, it is the task resource profile. Otherwise it is the slot sharing group resource profile. The existing ResourceProfile in SlotProfile is renamed as taskResourceProfile for logical slot allocation. | 24 November 2019, 15:16:29 UTC |
| 50712da | Zhu Zhu | 20 November 2019, 14:43:58 UTC | [hotfix][runtime] Cleanup the SlotProfile constructors Spreading the usages of SlotProfile constructor directly makes it hard to track the intention of each argument. This hotfix makes the constructor private and forces SlotProfile to be built from the factory methods with clear semantics. @Nonnull annotation for arguments/fields are removed since arguments /fields should be non-null by default. Runtime non-check checking is added instead. | 24 November 2019, 15:16:29 UTC |
| 2bbcdab | Zhu Zhu | 18 November 2019, 08:26:09 UTC | [hotfix][runtime] Fix code style violations in SlotProfile, SchedulerTestBase, PreviousAllocationSlotSelectionStrategyTest and ScheduleWithCoLocationHintTest | 24 November 2019, 15:16:29 UTC |
| 33c4abf | Zhu Zhu | 07 November 2019, 09:26:50 UTC | [hotfix][runtime] Adding back the missing blacklisting information when refining SotProfile in allocateCoLocatedMultiTaskSlot | 24 November 2019, 15:16:29 UTC |
| ea721c8 | Dawid Wysakowicz | 23 November 2019, 12:22:33 UTC | [FLINK-14931][docs] Regenerated documentation | 23 November 2019, 12:22:33 UTC |
| c2f3af5 | Leonard Xu | 23 November 2019, 01:52:33 UTC | [FLINK-14924][connectorsi] Add treat empty field as null option to CsvTableSource This closes #10289 | 23 November 2019, 01:52:33 UTC |
| ec85f82 | zjuwangg | 20 November 2019, 15:07:23 UTC | [FLINK-14878][table] Add useCatalogOperation and support it both in flink/blink planner Support USE CATALOG catalogName through sqlUpdate() method in TableEnvironment this closes #10272. | 22 November 2019, 18:15:52 UTC |
| fb17587 | Liupengcheng | 20 November 2019, 11:03:48 UTC | [FLINK-14876]Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns to avoid conflicts | 22 November 2019, 17:33:29 UTC |
| 793f3b0 | Zhu Zhu | 22 November 2019, 15:44:58 UTC | [FLINK-14915][runtime] Remove unnecessary parameter JobGraph from SchedulingStrategyFactory#createInstance This closes #10287 . | 22 November 2019, 15:44:58 UTC |
