- 30 11月, 2017 3 次提交
-
-
由 Cristian 提交于
This closes #5075.
-
由 Till Rohrmann 提交于
Instead of storing the JobID and the JobStatus in a Tuple2 which is serialized as an array of values in JSON, this commit introduces the JobIdWithStatus which is serialized as a proper JSON object with an id and a status field.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #4734.
-
- 29 11月, 2017 17 次提交
-
-
由 Gyula Fora 提交于
Closes #5096
-
由 Nico Kruber 提交于
We always add the dist.jar ourselves, but it could also be inside a shipped folder such as the "lib/" folder and was then distributed multiple times. This closes #4951.
-
由 gyao 提交于
Migrate logic in org.apache.flink.runtime.rest.handler.legacy.metrics.JobMetrisHandler to new handler, and add new handler to DispatcherRestEndpoint. [FLINK-7694][flip6] Use jobid path parameter constant in JobMetricsHandlerTest This closes #5084.
-
由 gyao 提交于
-
由 gyao 提交于
-
由 gyao 提交于
Migrate logic from org.apache.flink.runtime.rest.handler.legacy.metrics.SubtaskMetricsHandler to new handler. Add new handler to DispatcherRestEndpoint. [FLINK-8143][flip6] Assert that SubtaskIndexPathParameter is mandatory [FLINK-8143][flip6] Use path parameter constants in SubtaskMetricsHandlerTest This closes #5082.
-
由 gyao 提交于
-
由 gyao 提交于
Migrate logic in org.apache.flink.runtime.rest.handler.legacy.metrics.JobManagerMetricsHandler to new handler and add new handler to DispatcherRestEndpoint. [FLINK-7716][Javadoc] Deprecate method MetricStore#getJobManager(). There is a semantically equivalent method in MetricStore. This closes #5083.
-
由 gyao 提交于
Migrate logic in org.apache.flink.runtime.rest.handler.legacy.metrics.TaskManagerMetricsHandler to new handler, and add new handler to DispatcherRestEndpoint. [FLINK-7717][flip6] Use taskmanagerid constant in TaskManagerMetricsHandlerTest This closes #5081.
-
由 gyao 提交于
-
由 Till Rohrmann 提交于
Before, the TaskExecutor's InstanceID was exposed as TaskExecutor id. This was wrong since the InstanceID is bound the registration of a TaskExecutor whereas the ResourceID is bound to the lifetime of the TaskExecutor. Thus, it is better to identify the TaskExecutor by its ResourceID which does not change. This commit changes the behaviour accordingly on the ResourceManager and the TaskManagerDetailsHandler. This closes #5093.
-
由 yew1eb 提交于
This closes #5001.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Till Rohrmann 提交于
-
由 zjureel 提交于
This closes #4574
-
由 Greg Hogan 提交于
When printing the job plan the operator description is typically formatted as the operator name followed by the user given or generated function name in parenthesis. For example, "Reduce (My Function)". This normalizes the node names to include a space between the operator and function names. This closes #4383
-
- 28 11月, 2017 6 次提交
-
-
由 Till Rohrmann 提交于
Add "Remote connection to [null] failed with java.nio.channels.NotYetConnectedException" to the list of whitelisted log statements in YarnTestBase. This logging statement seems to appear since we moved from Flakka to Akka 2.4.0. This closes #5085.
-
由 Piotr Nowojski 提交于
This closes #4748
-
由 zhangminglei 提交于
This closes #4946
-
由 yew1eb 提交于
This closes #5034
-
由 yew1eb 提交于
This closes #5067
-
由 Greg Hogan 提交于
This closes #5061
-
- 27 11月, 2017 5 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Raycee 提交于
This closes #5077.
-
由 zentol 提交于
This closes #5049.
-
由 Piotr Nowojski 提交于
Increasing timeout for reading the records from 30s to 60s seems to solve the issue for failing at-least-one tests.
-
- 25 11月, 2017 1 次提交
-
-
由 gyao 提交于
Migrate logic in org.apache.flink.runtime.rest.handler.legacy.metrics.JobVertexMetricsHandler to new handler and add new handler to DispatcherRestEndpoint. Add common classes for remaining implementations of org.apache.flink.runtime.rest.handler.legacy.metrics.AbstractMetricsHandler, which require migration as well. [FLINK-7718] [flip6] Clean up JobVertexMetricsHandlerHeaders [FLINK-7718] [flip6] Assert that HTTP code is 404 if metric is unknown [FLINK-7718] [flip6] Minor fixes in Javadocs [FLINK-7718] [flip6] Add unit test for AbstractMetricsHandlerHeaders [FLINK-7718] [flip6] Let unit tests inherit from TestLogger [FLINK-7718] [flip6] Re-format Metric constructor [FLINK-7718] [flip6] Fix mistake in Javadoc of AbstractMetricsHandlerHeaders [FLINK-7718] [flip6] Rename AbstractMetricsHandlerHeaders to AbstractMetricsHeaders Strip the term Handler from the Header class. Also rename its subclasses. [FLINK-7718] [flip6] No longer return HTTP 404 if metric is unknown [FLINK-7718] [flip6] Make JobVertexMetricsHeaders class final [FLINK-7718] [flip6] Introduce MetricsHandlerTestBase for future MetricHandlers [FLINK-7718] [flip6] Always return same MessageParameter objects in JobVertexMetricsMessageParameters This closes #5055.
-
- 24 11月, 2017 5 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Nico Kruber 提交于
This is another step at using or own (off-heap) buffers for network communication that we pass through netty in order to avoid unnecessary buffer copies. This closes #4481.
-
由 Aljoscha Krettek 提交于
This was causing the snapshot deployment to fail.
-
- 23 11月, 2017 3 次提交
-
-
由 Stefan Richter 提交于
[FLINK-5465] [streaming] Wait for pending timer threads to finish or to exceed a time limit in exceptional stream task shutdown. This closes #5058.
-
由 Piotr Nowojski 提交于
-
由 twalthr 提交于
-