jdiff-workaround.patch 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  1. diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/MetricsSystem.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/MetricsSystem.java
  2. index fef8c4b7e4b..8d2b9339706 100644
  3. --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/MetricsSystem.java
  4. +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/MetricsSystem.java
  5. @@ -42,18 +42,6 @@
  6. @InterfaceAudience.Private
  7. public abstract MetricsSystem init(String prefix);
  8. - /**
  9. - * Register a metrics source
  10. - * @param <T> the actual type of the source object
  11. - * @param source object to register
  12. - * @param name of the source. Must be unique or null (then extracted from
  13. - * the annotations of the source object.)
  14. - * @param desc the description of the source (or null. See above.)
  15. - * @return the source object
  16. - * @exception MetricsException Metrics Exception.
  17. - */
  18. - public abstract <T> T register(String name, String desc, T source);
  19. -
  20. /**
  21. * Unregister a metrics source
  22. * @param name of the source. This is the name you use to call register()
  23. @@ -79,16 +67,16 @@
  24. public abstract MetricsSource getSource(String name);
  25. /**
  26. - * Register a metrics sink
  27. - * @param <T> the type of the sink
  28. - * @param sink to register
  29. - * @param name of the sink. Must be unique.
  30. - * @param desc the description of the sink
  31. - * @return the sink
  32. + * Register a metrics source
  33. + * @param <T> the actual type of the source object
  34. + * @param source object to register
  35. + * @param name of the source. Must be unique or null (then extracted from
  36. + * the annotations of the source object.)
  37. + * @param desc the description of the source (or null. See above.)
  38. + * @return the source object
  39. * @exception MetricsException Metrics Exception.
  40. */
  41. - public abstract <T extends MetricsSink>
  42. - T register(String name, String desc, T sink);
  43. + public abstract <T> T register(String name, String desc, T source);
  44. /**
  45. * Register a callback interface for JMX events
  46. diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl/MetricsSystemImpl.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl/MetricsSystemImpl.java
  47. index a6edf08e5a7..5b87be1ec67 100644
  48. --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl/MetricsSystemImpl.java
  49. +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/impl/MetricsSystemImpl.java
  50. @@ -269,31 +269,6 @@ void registerSource(String name, String desc, MetricsSource source) {
  51. LOG.debug("Registered source "+ name);
  52. }
  53. - @Override public synchronized <T extends MetricsSink>
  54. - T register(final String name, final String description, final T sink) {
  55. - LOG.debug(name +", "+ description);
  56. - if (allSinks.containsKey(name)) {
  57. - if(sinks.get(name) == null) {
  58. - registerSink(name, description, sink);
  59. - } else {
  60. - LOG.warn("Sink "+ name +" already exists!");
  61. - }
  62. - return sink;
  63. - }
  64. - allSinks.put(name, sink);
  65. - if (config != null) {
  66. - registerSink(name, description, sink);
  67. - }
  68. - // We want to re-register the sink to pick up new config
  69. - // when the metrics system restarts.
  70. - register(name, new AbstractCallback() {
  71. - @Override public void postStart() {
  72. - register(name, description, sink);
  73. - }
  74. - });
  75. - return sink;
  76. - }
  77. -
  78. synchronized void registerSink(String name, String desc, MetricsSink sink) {
  79. checkNotNull(config, "config");
  80. MetricsConfig conf = sinkConfigs.get(name);
  81. diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/metrics2/impl/TestGangliaMetrics.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/metrics2/impl/TestGangliaMetrics.java
  82. index 7bc772f062a..f012c877d18 100644
  83. --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/metrics2/impl/TestGangliaMetrics.java
  84. +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/metrics2/impl/TestGangliaMetrics.java
  85. @@ -139,8 +139,8 @@ public void testTagsForPrefix() throws Exception {
  86. GangliaMetricsTestHelper.setDatagramSocket(gsink31, mockds31);
  87. // register the sinks
  88. - ms.register("gsink30", "gsink30 desc", gsink30);
  89. - ms.register("gsink31", "gsink31 desc", gsink31);
  90. + //ms.register("gsink30", "gsink30 desc", gsink30);
  91. + //ms.register("gsink31", "gsink31 desc", gsink31);
  92. ms.publishMetricsNow(); // publish the metrics
  93. ms.stop();