Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: apache/storm
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v2.8.1
Choose a base ref
...
head repository: apache/storm
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: master
Choose a head ref
Loading
Showing with 996 additions and 505 deletions.
  1. +98 −97 DEPENDENCY-LICENSES
  2. +90 −93 LICENSE-binary
  3. +0 −1 dev-tools/release_notes.py
  4. +3 −3 doap_Storm.rdf
  5. +1 −1 examples/storm-hdfs-examples/pom.xml
  6. +1 −1 examples/storm-jdbc-examples/pom.xml
  7. +1 −1 examples/storm-jms-examples/pom.xml
  8. +1 −1 examples/storm-kafka-client-examples/pom.xml
  9. +1 −1 examples/storm-loadgen/pom.xml
  10. +1 −1 examples/storm-perf/pom.xml
  11. +1 −1 examples/storm-redis-examples/pom.xml
  12. +1 −1 examples/storm-starter/pom.xml
  13. +1 −1 external/storm-autocreds/pom.xml
  14. +1 −1 external/storm-blobstore-migration/pom.xml
  15. +1 −1 external/storm-hdfs-blobstore/pom.xml
  16. +1 −1 external/storm-hdfs-oci/pom.xml
  17. +1 −1 external/storm-hdfs/pom.xml
  18. +1 −1 external/storm-jdbc/pom.xml
  19. +1 −1 external/storm-jms/pom.xml
  20. +1 −1 external/storm-kafka-client/pom.xml
  21. +30 −29 external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
  22. +8 −5 ...rm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetMetricManager.java
  23. +46 −139 ...kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetPartitionMetrics.java
  24. +120 −62 ...orm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetTopicMetrics.java
  25. +92 −0 external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetUtil.java
  26. +27 −0 ...nal/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutReactivationTest.java
  27. +163 −0 ...ka-client/src/test/java/org/apache/storm/kafka/spout/metric2/KafkaOffsetPartitionMetricsTest.java
  28. +243 −0 ...-kafka-client/src/test/java/org/apache/storm/kafka/spout/metric2/KafkaOffsetTopicMetricsTest.java
  29. +1 −1 external/storm-kafka-migration/pom.xml
  30. +1 −1 external/storm-kafka-monitor/pom.xml
  31. +2 −2 external/storm-metrics-prometheus/pom.xml
  32. +1 −1 external/storm-metrics/pom.xml
  33. +1 −1 external/storm-redis/pom.xml
  34. +1 −1 flux/flux-core/pom.xml
  35. +1 −1 flux/flux-examples/pom.xml
  36. +1 −1 flux/flux-wrappers/pom.xml
  37. +1 −1 flux/pom.xml
  38. +1 −1 integration-test/pom.xml
  39. +17 −17 pom.xml
  40. +1 −1 sql/pom.xml
  41. +2 −2 sql/storm-sql-core/pom.xml
  42. +1 −1 sql/storm-sql-external/storm-sql-hdfs/pom.xml
  43. +1 −1 sql/storm-sql-external/storm-sql-kafka/pom.xml
  44. +1 −1 sql/storm-sql-external/storm-sql-redis/pom.xml
  45. +1 −1 sql/storm-sql-runtime/pom.xml
  46. +1 −1 storm-buildtools/maven-shade-clojure-transformer/pom.xml
  47. +1 −1 storm-buildtools/storm-maven-plugins/pom.xml
  48. +1 −1 storm-checkstyle/pom.xml
  49. +1 −1 storm-client/pom.xml
  50. +1 −1 storm-clojure-test/pom.xml
  51. +1 −1 storm-clojure/pom.xml
  52. +1 −1 storm-core/pom.xml
  53. +1 −1 storm-dist/binary/final-package/pom.xml
  54. +1 −1 storm-dist/binary/pom.xml
  55. +1 −1 storm-dist/binary/storm-autocreds-bin/pom.xml
  56. +1 −1 storm-dist/binary/storm-client-bin/pom.xml
  57. +1 −1 storm-dist/binary/storm-kafka-monitor-bin/pom.xml
  58. +1 −1 storm-dist/binary/storm-sql-core-bin/pom.xml
  59. +1 −1 storm-dist/binary/storm-sql-runtime-bin/pom.xml
  60. +1 −1 storm-dist/binary/storm-submit-tools-bin/pom.xml
  61. +1 −1 storm-dist/binary/storm-webapp-bin/pom.xml
  62. +1 −1 storm-dist/source/pom.xml
  63. +1 −1 storm-multilang/javascript/pom.xml
  64. +1 −1 storm-multilang/python/pom.xml
  65. +1 −1 storm-multilang/ruby/pom.xml
  66. +1 −1 storm-server/pom.xml
  67. +2 −2 storm-shaded-deps/pom.xml
  68. +1 −1 storm-submit-tools/pom.xml
  69. +1 −1 storm-webapp/pom.xml
Loading