- 01 7月, 2017 16 次提交
-
-
由 zjureel 提交于
This closes #4022.
-
由 Lim Chee Hau 提交于
This closes #4178.
-
由 zentol 提交于
This closes #3951.
-
由 zentol 提交于
This closes #4109.
-
由 zentol 提交于
This closes #4035.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #4211.
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 zentol 提交于
This closes #6575.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #3776.
-
由 z00376786 提交于
Previously, YARN log aggregation fails because it depoends on the HDFS delegation token, which we do not upload if Kerberos keytabs are used. We did not include HDFS delegation tokens when keytabs are used because the UGI would prioritize the delegation token (which expires) if both are present. To address this, changes include: 1. Change Flink YARN client to always upload delegation tokens when security is enabled. This would then allow log aggregation. 2. Filter out HDFS delegation token from the tokens fetched from HDFS when populating the UGI. This allows the UGI to always use Kerberos tickets instead of the HDFS delegation token.
-
由 zentol 提交于
This closes #3855.
-
由 zhangminglei 提交于
This closes #4216.
-
由 Tzu-Li (Gordon) Tai 提交于
The root cause for the instability in ES 1.x is that we're testing both embedded client mode and transport client mode against the same Elasticsearch environment. This commit removes the embedded mode testing, as that method is generally discouraged anyways. This closes #4191.
-
由 Tzu-Li (Gordon) Tai 提交于
The testStartFromKafkaCommitOffsets ITCases are covering too much within one single test. The case verifies that whatever offset was committed to Kafka, Flink rreads it correctly and can uses that as the correct starting point for exactly-once. This over-engineered test was instable that we needed to first read some records and wait until some records is committed. This wait is hard to define. It is in fact sufficient to have 2 separate tests to cover the tested behaviour: - test that committed Kafka offsets are correct (there is already a ITCase for this, i.e. `runCommitOffsetsToKafka`) - test that committed offsets are correctly picked up and used correctly (there is actually also a test for this, i.e. `runStartFromGroupOffsets`) Hence, this test can be removed without harming test coverage. This closes #4190.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #3746.
-
由 rtudoran 提交于
This closes #3889.
-
- 30 6月, 2017 4 次提交
-
-
由 zentol 提交于
-
由 sunjincheng121 提交于
This closes #4212.
-
由 Lim Chee Hau 提交于
- Move Java example tests into a single ITCase - Add ITCase for Scala examples This closes #2761.
-
由 Dian Fu 提交于
This closes #4195.
-
- 29 6月, 2017 6 次提交
-
-
由 Greg Hogan 提交于
The current organization of the Gelly examples retains full flexibility by handling the Graph input to the algorithm Driver and having the Driver overload interfaces for the various output types. The outputs must be made independent in order to support Transforms which are applied between the Driver and Output (and also between the Input and Driver). This closes #4179
-
由 Till Rohrmann 提交于
Some internal methods which are required for the interplay between the TaskMonitor, LaunchCoordinator and the MesosResourceManager were exposed as RPC methods. In order to keep the RPC interface as lean as possible, these methods have been removed. Fix checkstyle violations
-
由 Till Rohrmann 提交于
The MesosResourceManagerTest#testAdapter tests the AkkaAdapter class. The tests are executed asynchronously and thus it is necessary to introduce timeouts for the verify calls. This commit fixes the test instability by introducing timeouts.
-
由 Wright, Eron 提交于
- Make the RPC gateway of the ResourceManager extensible to allow for framework-specific RPC methods - Introduce FLIP-6 MesosResourceManager w/ tests - Introduce a Mesos-specific RPC gateway for callbacks from child actors and from the Mesos scheduler client - Enhance the persistent Mesos worker store to track the resource profile associated with a worker - Convert RegisteredMesosWorkerNode to Java - Decline TE registration if framework doesn’t recognize the worker This closes #3942.
-
由 Xpray 提交于
This closes #4200
-
由 zentol 提交于
- enable sudo for more memory - increase java heap size - replace usage of oraclejdk7 since it is no longer supporter - manually install maven 3.2.5 This closes #4182.
-
- 27 6月, 2017 3 次提交
-
-
由 twalthr 提交于
This closes #4186.
-
由 sunjincheng121 提交于
This closes #4161.
-
由 Dawid Wysakowicz 提交于
This closes #4143.
-
- 26 6月, 2017 2 次提交
- 25 6月, 2017 7 次提交
-
-
由 sunjincheng121 提交于
This closes #4152
-
由 Greg Hogan 提交于
This closes #4177
-
由 Nico Kruber 提交于
This closes #4017.
-
由 zhangminglei 提交于
This closes #4151.
-
由 zentol 提交于
This closes #4034.
-
由 zentol 提交于
This closes #4148.
-
由 zentol 提交于
This closes #4159.
-
- 23 6月, 2017 2 次提交
-
-
由 Dawid Wysakowicz 提交于
This closes #4140.
-
由 zhangminglei 提交于
-