- 30 7月, 2019 13 次提交
-
-
由 Gao Yun 提交于
-
由 Gao Yun 提交于
-
由 Gao Yun 提交于
-
由 Timo Walther 提交于
-
由 Dawid Wysakowicz 提交于
This closes #9229.
-
由 Dawid Wysakowicz 提交于
-
由 Dawid Wysakowicz 提交于
-
由 Dawid Wysakowicz 提交于
-
由 Dawid Wysakowicz 提交于
-
由 HuangXingBo 提交于
[hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module (#9270)
-
由 Jark Wu 提交于
This closes #9203
-
由 godfreyhe 提交于
This closes #9227.
-
由 Seth Wiesman 提交于
-
- 29 7月, 2019 13 次提交
-
-
由 ifndef-SleePy 提交于
-
由 Jark Wu 提交于
This closes #9249
-
由 Yu Li 提交于
Currently test cases will fail when trying to close the output stream if all data written but ClosedByInterruptException occurs at the ending phase. This commit fixes it. This closes #9235
-
由 Timo Walther 提交于
This closes #9257.
-
由 疯琴 提交于
-
由 Zhijiang 提交于
-
由 Zhijiang 提交于
-
由 Zhijiang 提交于
On producer side the netty handler receives the CancelPartitionRequest for releasing the SubpartitionView resource. In previous implementation we try to find the corresponding view via available queue in PartitionRequestQueue. But in reality the view is not always available to stay in this queue, then the view would never be released. Furthermore the release of ResultPartition/ResultSubpartitions is based on the reference counter in ReleaseOnConsumptionResultPartition, but while handling the CancelPartitionRequest in PartitionRequestQueue, the ReleaseOnConsumptionResultPartition is never notified of consumed subpartition. That means the reference counter would never decrease to 0 to trigger partition release, which would bring file resource leak in the case of BoundedBlockingSubpartition. In order to fix above two issues, the corresponding view is released via all reader queue instead, and then it would call ReleaseOnConsumptionResultPartition#onConsumedSubpartition meanwhile to solve this bug.
-
由 Chesnay Schepler 提交于
-
由 Timo Walther 提交于
This closes #9241.
-
由 Stephan Ewen 提交于
The method Unsafe.defineClass() is removed in Java 11. To support Java 11, we rework the method "CommonTestUtils.createClassNotInClassPath()" to use a different mechanism. This commit now writes the class byte code out to a temporary file and create a new URLClassLoader that loads the class from that file. That solution is not a complete drop-in replacement, because it cannot add the class to an existing class loader, but can only create a new pair of (classloader & new-class-in-that-classloader). Because of that, the commit also adjusts the existing tests to work with that new mechanism. This closes #9251
-
由 Rui Li 提交于
This closes #9088
-
由 Rui Li 提交于
This closes #9223
-
- 27 7月, 2019 4 次提交
-
-
由 Stephan Ewen 提交于
FLINK-13249 was a bug where a deadlock occurred when the network thread got blocked on a lock while requesting partitions to be read by remote channels. The test mimicks that situation to guard the fix applied in an earlier commit.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 26 7月, 2019 10 次提交
-
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 vinoyang 提交于
-
由 tison 提交于
-
由 JingsongLi 提交于
-
由 JingsongLi 提交于
The reason is that blink-planner use TypeExtractor to extract class from TableSource, and use this class to DataFormatConverter. However, blink should use conversion class of DataType in TableSource#getProducedDataType. This closes #9211
-
由 Andrey Zagrebin 提交于
Get SlotManager.failUnfulfillableRequest in main thread of StandaloneResourceManager for verification in StandaloneResourceManagerTest This closes #9126.
-
由 Andrey Zagrebin 提交于
-