This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a change to branch fix/logviewer-resolve-links
in repository https://gitbox.apache.org/repos/asf/storm.git
discard 0087e32c4 Answer a file removed before the open like a missing file
and drop unused helpers
discard 38d582db4 Leave symbolic links out of the log list and answer a late
link like a missing file
discard 8d5c96014 Serve only worker files that resolve inside the log root
add c2995fe7a Regenerate license files after dependency changes
add e93d1009f Merge pull request #9147 from apache/update-license-files
add 42147bda4 Log at error level when the kafka spout gives up on a tuple;
document max-retry give-up semantics (#9093)
add 3459de05f Correct class names in the codebase, cgroup, metrics and
Kafka docs
add 8453c7a8e Merge pull request #9156 from Zir0-93/docs-stale-class-names
add 118240016 Throw a typed exception for tuples with unknown task or
stream ids and add a deserialization strict mode (#9094)
add 9d5b266cb build(deps): bump actions/download-artifact from 8.0.1 to
8.0.2 (#9162)
add 726ff59af build(deps): bump actions/upload-artifact from 7.0.1 to
7.0.2 (#9161)
add 04e59031b build(deps): bump actions/setup-node from 7.0.0 to 7.1.0
(#9160)
add 77dfd0620 build(deps): bump postcss-selector-parser in /storm-webapp
(#9164)
add e55b322c4 build(deps-dev): bump joi from 18.2.5 to 18.2.9 in
/storm-webapp (#9166)
add 329d3f0b7 Add a Prometheus reporter for the V2 topology metrics
add b03f38f54 Address review comments on the Prometheus reporter
add a0d9915b4 Merge pull request #9158 from apache/prometheus-reporter
add 69f7bfe14 Make strict deserialization mode fatal for
IOException-wrapped failures (#9159)
add 4fe5a57f4 build(deps-dev): bump proxy-addr from 2.0.7 to 2.0.8 in
/storm-webapp (#9165)
add bb8b63677 build(deps): bump source-map-js from 1.2.1 to 1.2.2 in
/storm-webapp
add 1b39f116c Merge pull request #9163 from
apache/dependabot/npm_and_yarn/storm-webapp/source-map-js-1.2.2
add 807939a63 Formally mark Pacemaker subsystem and configs for removal
(#9171)
add be45c93b4 Add checkstyle auto-fix tooling (#9017)
add 512b7382c Checkstyle auto-fix of examples/storm-perf (#9176)
add ae671a50d Checkstyle auto-fix of external/storm-metrics (#9177)
add 015b6ba6a Remove deprecated NIMBUS_SUPERVISOR_TIMEOUT_SECS and
defaults entry (#8994) (#9170)
add 5d38707d4 build(deps): bump burnett01/rsync-deployments from 9.0.1 to
9.0.2
add 01dff0514 Merge pull request #9181 from
apache/dependabot/github_actions/burnett01/rsync-deployments-9.0.2
add 2e36995c9 build(deps): bump actions/upload-artifact from 7.0.1 to 7.0.2
add 5536f46bf Merge pull request #9179 from
apache/dependabot/github_actions/actions/upload-artifact-7.0.2
add 7af5b85c3 build(deps): bump actions/setup-java from 6.0.1 to 6.1.0
add 7fd101352 Merge pull request #9180 from
apache/dependabot/github_actions/actions/setup-java-6.1.0
add ccebfb16e Fix the indentation the checkstyle auto-fix gets wrong
add 3e933c553 Merge pull request #9178 from
sercuzz8/checkstyle-autofix-indentation
add d93c7cbf3 build(deps-dev): bump follow-redirects in /storm-webapp
(#9185)
add 4a4d17bb8 Fix the worker-launcher build with gcc 15 and glibc 2.43
(#9187)
add a99434153 Serve only worker files that resolve inside the log root
add 065c10cab Leave symbolic links out of the log list and answer a late
link like a missing file
add 9de2d0919 Answer a file removed before the open like a missing file
and drop unused helpers
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0087e32c4)
\
N -- N -- N refs/heads/fix/logviewer-resolve-links (9de2d0919)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/checkstyle-autofix.yaml | 121 ++
.github/workflows/cypress-tests.yml | 2 +-
.github/workflows/maven.yaml | 8 +-
.github/workflows/nightlies.yaml | 4 +-
.github/workflows/snapshots.yaml | 2 +-
.github/workflows/update-license-files.yml | 2 +-
.mvn/.gitkeep | 0
.mvn/jvm.config | 11 +
DEPENDENCY-LICENSES | 203 +--
LICENSE-binary | 143 +-
conf/defaults.yaml | 4 +-
dev-tools/gitact/checkstyle-report.sh | 61 +
docs/Metrics.md | 2 +-
docs/Serialization.md | 1 +
docs/Structure-of-the-codebase.md | 2 +-
docs/cgroups_in_storm.md | 12 +-
docs/metrics_v2.md | 4 +-
docs/storm-kafka-client.md | 4 +-
examples/storm-hdfs-examples/pom.xml | 10 +
examples/storm-jdbc-examples/pom.xml | 10 +
examples/storm-jms-examples/pom.xml | 10 +
examples/storm-kafka-client-examples/pom.xml | 10 +
examples/storm-loadgen/pom.xml | 10 +
examples/storm-perf/pom.xml | 10 +
.../org/apache/storm/perf/BackPressureTopo.java | 10 +-
.../storm/perf/ConstSpoutIdBoltNullBoltTopo.java | 15 +-
.../apache/storm/perf/ConstSpoutNullBoltTopo.java | 13 +-
.../org/apache/storm/perf/ConstSpoutOnlyTopo.java | 1 -
.../FileReadWordCountSpoutCompressionTopo.java | 10 +-
.../apache/storm/perf/FileReadWordCountTopo.java | 10 +-
.../apache/storm/perf/HdfsSpoutNullBoltTopo.java | 21 +-
.../storm/perf/JitterAwareGroupingTopology.java | 87 +-
.../org/apache/storm/perf/KafkaClientHdfsTopo.java | 41 +-
.../storm/perf/KafkaClientSpoutNullBoltTopo.java | 33 +-
.../org/apache/storm/perf/LowThroughputTopo.java | 7 +-
.../apache/storm/perf/SimplifiedWordCountTopo.java | 7 +-
.../apache/storm/perf/StrGenSpoutHdfsBoltTopo.java | 29 +-
.../org/apache/storm/perf/ThroughputMeter.java | 1 +
.../java/org/apache/storm/perf/bolt/CountBolt.java | 1 -
.../org/apache/storm/perf/bolt/DevNullBolt.java | 4 +-
.../java/org/apache/storm/perf/bolt/IdBolt.java | 3 +-
.../apache/storm/perf/bolt/SplitSentenceBolt.java | 1 -
.../org/apache/storm/perf/queuetest/Acker.java | 1 -
.../storm/perf/queuetest/JCQueuePerfTest.java | 29 +-
.../org/apache/storm/perf/spout/ConstSpout.java | 3 +-
.../org/apache/storm/perf/spout/FileReadSpout.java | 1 -
.../apache/storm/perf/spout/StringGenSpout.java | 7 +-
.../org/apache/storm/perf/spout/WordGenSpout.java | 1 -
.../storm/perf/toolstest/JCToolsPerfTest.java | 4 +-
.../storm/perf/utils/BasicMetricsCollector.java | 31 +-
.../java/org/apache/storm/perf/utils/Helper.java | 14 +-
.../org/apache/storm/perf/utils/IdentityBolt.java | 3 +-
.../org/apache/storm/perf/utils/MetricsSample.java | 4 +-
examples/storm-redis-examples/pom.xml | 10 +
examples/storm-starter/pom.xml | 10 +
external/storm-autocreds/pom.xml | 10 +
external/storm-blobstore-migration/pom.xml | 10 +
external/storm-hdfs-blobstore/pom.xml | 10 +
external/storm-hdfs-oci/pom.xml | 10 +
external/storm-hdfs/pom.xml | 10 +
external/storm-jdbc/pom.xml | 10 +
external/storm-jms/pom.xml | 10 +
external/storm-kafka-client/pom.xml | 10 +
.../org/apache/storm/kafka/spout/KafkaSpout.java | 3 +-
.../spout/KafkaSpoutRetryExponentialBackoff.java | 6 +-
.../storm/kafka/spout/KafkaTupleListener.java | 4 +-
.../kafka/spout/KafkaSpoutRetryLimitTest.java | 9 +
external/storm-kafka-migration/pom.xml | 10 +
external/storm-kafka-monitor/pom.xml | 10 +
external/storm-metrics-prometheus/README.md | 76 +-
external/storm-metrics-prometheus/pom.xml | 15 +
.../prometheus/PrometheusStormReporter.java | 198 +++
.../metrics/prometheus/StormMetricsCollector.java | 400 +++++
.../prometheus/PrometheusStormReporterTest.java | 199 +++
.../prometheus/StormMetricsCollectorTest.java | 97 ++
external/storm-metrics/pom.xml | 10 +
.../metrics/hdrhistogram/HistogramMetric.java | 26 +-
.../org/apache/storm/metrics/sigar/CPUMetric.java | 2 -
external/storm-redis/pom.xml | 10 +
flux/flux-core/pom.xml | 10 +
flux/flux-examples/pom.xml | 10 +
flux/flux-wrappers/pom.xml | 10 +
flux/pom.xml | 10 +
integration-test/pom.xml | 10 +
pom.xml | 150 +-
rewrite.yml | 192 +++
storm-checkstyle/README.md | 147 ++
.../main/resources/storm/checkstyle-autofix.groovy | 1723 ++++++++++++++++++++
.../storm/normalize-license-headers.groovy | 176 ++
.../src/main/resources/storm/storm_checkstyle.xml | 9 +
storm-client/pom.xml | 10 +
storm-client/src/jvm/org/apache/storm/Config.java | 21 +-
.../storm/cluster/PaceMakerStateStorage.java | 2 +-
.../cluster/PaceMakerStateStorageFactory.java | 2 +-
.../messaging/DeserializingConnectionCallback.java | 14 +-
.../FatalDeserializationException.java} | 22 +-
.../org/apache/storm/messaging/netty/IServer.java | 2 +
.../netty/NettyUncaughtExceptionHandler.java | 6 +-
.../org/apache/storm/messaging/netty/Server.java | 6 +
.../storm/messaging/netty/StormServerHandler.java | 34 +-
.../apache/storm/pacemaker/PacemakerClient.java | 2 +-
.../storm/pacemaker/PacemakerClientHandler.java | 2 +-
.../storm/pacemaker/PacemakerClientPool.java | 2 +-
.../pacemaker/PacemakerConnectionException.java | 2 +-
.../storm/pacemaker/codec/ThriftDecoder.java | 2 +-
.../storm/pacemaker/codec/ThriftEncoder.java | 2 +-
.../pacemaker/codec/ThriftNettyClientCodec.java | 2 +-
.../storm/serialization/KryoTupleDeserializer.java | 5 +-
.../storm/serialization/SerializationFactory.java | 3 +-
...zer.java => TupleDeserializationException.java} | 11 +-
.../src/jvm/org/apache/storm/utils/Utils.java | 18 +
.../DeserializingConnectionCallbackTest.java | 104 +-
.../messaging/netty/StormServerHandlerTest.java | 104 ++
.../serialization/SerializationFactoryTest.java | 12 +
storm-core/pom.xml | 10 +
.../native/worker-launcher/impl/configuration.c | 4 +-
storm-core/src/native/worker-launcher/impl/main.c | 34 +-
.../src/native/worker-launcher/impl/oci/oci.c | 2 +-
.../src/native/worker-launcher/impl/oci/oci_reap.c | 3 +-
.../native/worker-launcher/impl/worker-launcher.c | 2 +-
.../worker-launcher/test/test-worker-launcher.c | 8 +-
storm-multilang/javascript/pom.xml | 10 +
storm-multilang/ruby/pom.xml | 10 +
storm-server/pom.xml | 10 +
.../main/java/org/apache/storm/DaemonConfig.java | 18 +-
.../storm/pacemaker/IServerMessageHandler.java | 2 +-
.../java/org/apache/storm/pacemaker/Pacemaker.java | 2 +-
.../apache/storm/pacemaker/PacemakerServer.java | 2 +-
.../pacemaker/codec/PacemakerServerHandler.java | 2 +-
.../pacemaker/codec/ThriftNettyServerCodec.java | 2 +-
storm-submit-tools/pom.xml | 10 +
storm-webapp/package-lock.json | 34 +-
storm-webapp/pom.xml | 10 +
133 files changed, 4743 insertions(+), 482 deletions(-)
create mode 100644 .github/workflows/checkstyle-autofix.yaml
create mode 100644 .mvn/.gitkeep
create mode 100644 .mvn/jvm.config
create mode 100755 dev-tools/gitact/checkstyle-report.sh
create mode 100644
external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusStormReporter.java
create mode 100644
external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/StormMetricsCollector.java
create mode 100644
external/storm-metrics-prometheus/src/test/java/org/apache/storm/metrics/prometheus/PrometheusStormReporterTest.java
create mode 100644
external/storm-metrics-prometheus/src/test/java/org/apache/storm/metrics/prometheus/StormMetricsCollectorTest.java
create mode 100644 rewrite.yml
create mode 100644 storm-checkstyle/README.md
create mode 100644
storm-checkstyle/src/main/resources/storm/checkstyle-autofix.groovy
create mode 100644
storm-checkstyle/src/main/resources/storm/normalize-license-headers.groovy
copy storm-client/src/jvm/org/apache/storm/{multilang/NoOutputException.java
=> messaging/FatalDeserializationException.java} (62%)
copy
storm-client/src/jvm/org/apache/storm/serialization/{ITupleDeserializer.java =>
TupleDeserializationException.java} (74%)
create mode 100644
storm-client/test/jvm/org/apache/storm/messaging/netty/StormServerHandlerTest.java
