Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-8368] [REST] Migrate SubtaskExecutionAttemptDetailsHandler to new a REST handler #5270

Closed
wants to merge 2 commits into from

Conversation

ifndef-SleePy
Copy link
Contributor

What is the purpose of the change

  • Migrate org.apache.flink.runtime.rest.handler.legacy.SubtaskExecutionAttemptDetailsHandler to flip-6 WebMonitorEndpoint.

Brief change log

  • Make some abstraction about JobVertexHandler and SubtaskAttemptHandler.
  • Add SubtaskExecutionAttemptDetailsHandler in flip-6 REST framework.
  • Rename inner class JobVertexMetrics to public class IOMetricsInfo, make it more reusable.

Verifying this change

  • This change added unit tests.

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): (no)
  • The public API, i.e., is any changed class annotated with @Public(Evolving): (no)
  • The serializers: (no)
  • The runtime per-record code paths (performance sensitive): (no)
  • Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (no)
  • The S3 file system connector: (no)

Documentation

  • Does this pull request introduce a new feature? (no)
  • If yes, how is the feature documented? (not applicable)

biao.liub added 2 commits January 12, 2018 16:44
…taskExecutionAttemptDetailsHandler to new a REST handler that registered in WebMonitorEndpoint
Copy link
Contributor

@tillrohrmann tillrohrmann left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for your contribution @ifndef-SleePy. Changes look really good. Will merge this PR.

}

return new JobVertexAccumulatorsInfo(jobVertex.getJobVertexId().toString(), userAccumulatorList);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Very nice refinement :-)

private final MetricFetcher<?> metricFetcher;

/**
* Instantiates a new Abstract job vertex handler.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

wrong java docs: Should be SubtaskExecutionAttemptDetailsHandler.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
3 participants