- 11 11月, 2017 3 次提交
-
-
由 Aljoscha Krettek 提交于
Before, we had it in places that require it. This doesn't work when running mvn javadoc:aggregate because this will only run for the root pom and can then not find the "bundle" dependencies.
-
由 Aljoscha Krettek 提交于
genjavadoc generated some Java code that was making Javadoc fail.
-
由 Piotr Nowojski 提交于
Previously it was pointing to flink-dev
-
- 10 11月, 2017 7 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Piotr Nowojski 提交于
Previously mvn javadoc:aggregate goal was failing
-
由 Till Rohrmann 提交于
We have to distinguish between the slot request and the slot allocation because slot allocations are reused across multiple slot requests. Therefore we cannot use the AllocationID to identify individual slot requests which might be cancelled. Introducing a separate SlotRequestID solves the problem.
-
由 Till Rohrmann 提交于
-
由 shuai.xus 提交于
Summary: This fix flink jira #6434 1. Let the ProviderAndOwner generate the allcation id before calling allocateSlot to slot pool. 2. If the allocateSlot call timed out, ProviderAndOwner cancel the previos allocation to slot pool. Test Plan: UnitTest Reviewers: haitao.w Differential Revision: https://aone.alibaba-inc.com/code/D323990 This closes #4937.
-
由 Michael Fong 提交于
This closes #4605.
-
由 gyao 提交于
During checkpointing, user code may dynamically load classes from the user code jar. This is a problem if the thread invoking the snapshot callbacks does not have the user code class loader set as its context class loader. This commit makes sure that the correct class loader is set.
-
- 09 11月, 2017 14 次提交
-
-
由 Piotr Nowojski 提交于
Disable it in most modules.
-
由 Piotr Nowojski 提交于
-
由 Aljoscha Krettek 提交于
-
由 Dan Kelley 提交于
-
由 Till Rohrmann 提交于
This closes #4984.
-
由 Till Rohrmann 提交于
This closes #4983.
-
由 Till Rohrmann 提交于
This closes #4982.
-
由 Till Rohrmann 提交于
Introduce special RestHandlerUrlComparator to sort REST URLs such that URLs with path parameters are sorted after those without or fewer. E.g. the following order would be established /jobs /jobs/overview /jobs/:jobid /jobs/:jobid/config /:* This closes #4958.
-
由 yew1eb 提交于
This closes #4978.
-
由 Fabian Hueske 提交于
This closes #4962.
-
由 Fabian Hueske 提交于
This closes #4974.
-
由 Xingcan Cui 提交于
This closes #4977.
-
由 Rong Rong 提交于
This closes #4929.
-
由 Xpray 提交于
This closes #4941.
-
- 08 11月, 2017 12 次提交
-
-
由 Till Rohrmann 提交于
[FLINK-7076] [tests] Harden YarnResourcemanagerTest#testStopWorker to properly wait for concurrent operations
-
由 Shuyi Chen 提交于
This closes #4729.
-
由 Till Rohrmann 提交于
Move all mocking code before the actual testing code in UtilsTest#testYarnFlinkResourceManagerJobManagerLostLeadership. Hopefully, this will fix the unfinished stubbing exception which still occurs spuriously. This closes #4957.
-
由 zentol 提交于
This closes #4972.
-
由 zentol 提交于
This closes #4971.
-
由 zentol 提交于
This closes #4965.
-
由 Piotr Nowojski 提交于
Previously transactional ids to use and to abort could clash between subtasks. This could lead to a race condition between initialization and writting the data, where one subtask is still initializing/aborting some transactional id while different subtask is already trying to write the data using the same transactional id.
-
由 Piotr Nowojski 提交于
This is pure refactor without any functional changes.
-
由 Tzu-Li (Gordon) Tai 提交于
Prior to this commit, a bug exists such that if a Kafka consumer subtask initially marks itself as idle because it didn't have any partitions to subscribe to, that idleness status will be violated when the PeriodicWatermarkEmitter is fired. The problem is that the PeriodicWatermarkEmitter incorrecty yields a Long.MAX_VALUE watermark even when there are no partitions to subscribe to. This commit fixes this by additionally ensuring that the aggregated watermark in the PeriodicWatermarkEmitterr is an effective one (i.e., is really aggregated from some partition).
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Aljoscha Krettek 提交于
-
- 07 11月, 2017 4 次提交
-
-
由 Till Rohrmann 提交于
Adds the SlotPoolTest#testSlotRequestCancellationUponFailingRequest.
-
由 shuai.xus 提交于
Summary: slot pool cancel slot request to resource manager if timeout Test Plan: unit test Reviewers: haitao.w Differential Revision: https://aone.alibaba-inc.com/code/D320749 This closes #4887.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
This closes #4930.
-