This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a change to branch
dependabot/maven/org.apache.commons-commons-compress-1.27.1
in repository https://gitbox.apache.org/repos/asf/storm.git
from debb05d09 License
add a03b466e2 STORM-4070 mTls support (#3678)
add 6c49ccfc0 STORM-4070 mTls support - fix LICENSE-binary
add f9f3f47b4 STORM-4070 mTls support - fix LICENSE-binary
add 664142c78 Update license files after latest merge
add 9434c7d42 [maven-release-plugin] prepare release v2.6.4
add 0c564d289 [maven-release-plugin] prepare for next development iteration
add e7eb179c4 Updating doap_Storm.rdf for Apache Storm 2.6.4
add 14f09446f STORM-4055 Kafka Consumer ConcurrentModificationException
fix (#3691)
add 9227ad9b6 STORM-4076 KafkaTridentSpoutEmitters can poll all partitions
at once instead of one at a time (#3679)
add 43e81dac8 STORM-4081 - Bump metrics.version from 4.2.26 to 4.2.27
(#3689)
add 8132aa066 STORM-4082 - Bump prometheus.client.version from 1.3.0 to
1.3.1 (#3687)
add 52641f78e Merge remote-tracking branch 'origin/master' into
dependabot/maven/org.apache.commons-commons-compress-1.27.1
add 94aaa197a License
No new revisions were added by this update.
Summary of changes:
DEPENDENCY-LICENSES | 53 ++--
LICENSE-binary | 31 +--
conf/defaults.yaml | 8 +
doap_Storm.rdf | 6 +-
docs/FAQ.md | 2 +-
examples/storm-elasticsearch-examples/pom.xml | 2 +-
examples/storm-hdfs-examples/pom.xml | 2 +-
.../apache/storm/hdfs/spout/HdfsSpoutTopology.java | 2 +-
examples/storm-hive-examples/pom.xml | 2 +-
examples/storm-jdbc-examples/pom.xml | 2 +-
examples/storm-jms-examples/pom.xml | 2 +-
examples/storm-kafka-client-examples/pom.xml | 2 +-
examples/storm-loadgen/pom.xml | 2 +-
.../java/org/apache/storm/loadgen/CaptureLoad.java | 2 +-
.../apache/storm/loadgen/EstimateThroughput.java | 2 +-
.../java/org/apache/storm/loadgen/GenLoad.java | 2 +-
.../apache/storm/loadgen/ThroughputVsLatency.java | 2 +-
examples/storm-perf/pom.xml | 2 +-
.../java/org/apache/storm/perf/utils/Helper.java | 4 +-
examples/storm-redis-examples/pom.xml | 2 +-
examples/storm-starter/pom.xml | 2 +-
.../storm/starter/FastWordCountTopology.java | 2 +-
.../apache/storm/starter/InOrderDeliveryTest.java | 2 +-
external/storm-autocreds/pom.xml | 18 +-
external/storm-blobstore-migration/pom.xml | 2 +-
external/storm-elasticsearch/pom.xml | 2 +-
external/storm-hdfs-blobstore/pom.xml | 2 +-
external/storm-hdfs-oci/pom.xml | 2 +-
external/storm-hdfs/pom.xml | 2 +-
external/storm-hive/pom.xml | 10 +-
external/storm-jdbc/pom.xml | 2 +-
external/storm-jms/pom.xml | 2 +-
external/storm-kafka-client/pom.xml | 2 +-
.../org/apache/storm/kafka/spout/KafkaSpout.java | 21 +-
.../{ConsumerFactory.java => ClientFactory.java} | 6 +-
...ctoryDefault.java => ClientFactoryDefault.java} | 12 +-
.../spout/metrics2/KafkaOffsetMetricManager.java | 10 +-
.../metrics2/KafkaOffsetPartitionMetrics.java | 50 +++-
.../trident/KafkaTridentOpaqueSpoutEmitter.java | 10 +-
.../trident/KafkaTridentSpoutCoordinator.java | 11 +-
.../spout/trident/KafkaTridentSpoutEmitter.java | 76 +++---
.../KafkaTridentTransactionalSpoutEmitter.java | 11 +-
.../storm/kafka/spout/KafkaSpoutAbstractTest.java | 26 +-
.../kafka/spout/KafkaSpoutReactivationTest.java | 14 +-
.../storm/kafka/spout/KafkaSpoutRebalanceTest.java | 31 ++-
.../kafka/spout/MaxUncommittedOffsetTest.java | 4 +-
.../spout/SpoutWithMockedConsumerSetupHelper.java | 24 +-
.../trident/KafkaTridentSpoutEmitterEmitTest.java | 56 ++--
.../KafkaTridentSpoutEmitterPartitioningTest.java | 57 ++++-
.../KafkaTridentSpoutOpaqueCoordinatorTest.java | 36 ++-
external/storm-kafka-migration/pom.xml | 2 +-
external/storm-kafka-monitor/pom.xml | 2 +-
external/storm-metrics-prometheus/pom.xml | 4 +-
external/storm-metrics/pom.xml | 2 +-
external/storm-redis/pom.xml | 2 +-
flux/flux-core/pom.xml | 2 +-
flux/flux-examples/pom.xml | 2 +-
flux/flux-wrappers/pom.xml | 2 +-
flux/pom.xml | 2 +-
integration-test/pom.xml | 2 +-
.../org/apache/storm/st/wrapper/StormCluster.java | 2 +-
pom.xml | 13 +-
sql/pom.xml | 2 +-
sql/storm-sql-core/pom.xml | 2 +-
sql/storm-sql-external/storm-sql-hdfs/pom.xml | 2 +-
sql/storm-sql-external/storm-sql-kafka/pom.xml | 2 +-
sql/storm-sql-external/storm-sql-redis/pom.xml | 2 +-
sql/storm-sql-runtime/pom.xml | 2 +-
.../maven-shade-clojure-transformer/pom.xml | 2 +-
storm-buildtools/storm-maven-plugins/pom.xml | 2 +-
storm-checkstyle/pom.xml | 2 +-
storm-client/pom.xml | 7 +-
storm-client/src/jvm/org/apache/storm/Config.java | 281 ++++++++++++++++++++-
.../src/jvm/org/apache/storm/StormSubmitter.java | 6 +-
.../apache/storm/blobstore/NimbusBlobStore.java | 2 +-
.../apache/storm/daemon/common/FileWatcher.java | 0
.../jvm/org/apache/storm/daemon/worker/Worker.java | 5 +-
.../org/apache/storm/generated/NimbusSummary.java | 104 +++++++-
.../org/apache/storm/messaging/netty/Client.java | 5 +-
.../storm/messaging/netty/NettyTlsUtils.java | 101 ++++++++
.../org/apache/storm/messaging/netty/Server.java | 6 +-
.../netty/StormClientPipelineFactory.java | 11 +-
.../netty/StormServerPipelineFactory.java | 10 +-
.../jvm/org/apache/storm/nimbus/NimbusInfo.java | 40 ++-
.../storm/security/auth/ClientAuthUtils.java | 10 +-
.../storm/security/auth/MultiThriftServer.java | 95 +++++++
.../apache/storm/security/auth/ThriftClient.java | 112 +++++++-
.../storm/security/auth/ThriftConnectionType.java | 111 +++++++-
.../apache/storm/security/auth/ThriftServer.java | 16 ++
.../auth/X509CertOrKerberosPrincipalToLocal.java | 55 ++++
.../security/auth/X509CertPrincipalToLocal.java | 73 ++++++
.../auth/tls/ReloadableTsslTransportFactory.java | 73 ++++++
.../auth/tls/ReloadableX509KeyManager.java | 136 ++++++++++
.../auth/tls/ReloadableX509TrustManager.java | 117 +++++++++
.../security/auth/tls/TlsTransportPlugin.java | 179 +++++++++++++
.../spout/IOpaquePartitionedTridentSpout.java | 11 +-
.../trident/spout/IPartitionedTridentSpout.java | 8 +-
.../OpaquePartitionedTridentSpoutExecutor.java | 14 +-
.../spout/PartitionedTridentSpoutExecutor.java | 47 ++--
.../jvm/org/apache/storm/utils/NimbusClient.java | 109 ++++++--
.../{ServiceRegistry.java => SecurityUtils.java} | 39 ++-
.../org/apache/storm/utils/SupervisorClient.java | 117 +++++++++
.../src/jvm/org/apache/storm/utils/Utils.java | 3 +-
storm-client/src/py/storm/ttypes.py | 14 +-
storm-client/src/storm.thrift | 1 +
.../org/apache/storm/nimbus/NimbusInfoTest.java | 58 +++++
.../storm/security/auth/MultiThriftServerTest.java | 60 +++++
.../security/auth/TestingITransportPlugin.java} | 37 ++-
.../security/auth/TlsTransportPluginTest.java | 68 +++++
.../auth/X509CertPrincipalToLocalTest.java | 49 ++++
.../org/apache/storm/utils/SecurityUtilsTest.java | 49 ++++
.../test/jvm/org/apache/storm/utils/UtilsTest.java | 8 -
storm-client/test/resources/ssl/README.md | 10 +
storm-client/test/resources/ssl/testKeyStore.jks | Bin 0 -> 2250 bytes
storm-client/test/resources/ssl/testTrustStore.jks | Bin 0 -> 960 bytes
storm-clojure-test/pom.xml | 2 +-
storm-clojure/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
.../org/apache/storm/command/ShellSubmission.java | 2 +-
.../apache/storm/command/UploadCredentials.java | 11 +-
.../test/clj/org/apache/storm/nimbus_test.clj | 10 +-
storm-dist/binary/final-package/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/binary/storm-autocreds-bin/pom.xml | 2 +-
storm-dist/binary/storm-client-bin/pom.xml | 2 +-
storm-dist/binary/storm-kafka-monitor-bin/pom.xml | 2 +-
storm-dist/binary/storm-sql-core-bin/pom.xml | 2 +-
storm-dist/binary/storm-sql-runtime-bin/pom.xml | 2 +-
storm-dist/binary/storm-submit-tools-bin/pom.xml | 2 +-
storm-dist/binary/storm-webapp-bin/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
storm-multilang/javascript/pom.xml | 2 +-
storm-multilang/python/pom.xml | 2 +-
storm-multilang/ruby/pom.xml | 2 +-
storm-server/pom.xml | 2 +-
.../org/apache/storm/blobstore/BlobStoreUtils.java | 9 +-
.../org/apache/storm/daemon/nimbus/Nimbus.java | 54 +++-
.../apache/storm/daemon/supervisor/Supervisor.java | 24 +-
.../supervisor/timer/ReportWorkerHeartbeats.java | 2 +-
.../supervisor/timer/SynchronizeAssignments.java | 29 +--
.../storm/metricstore/NimbusMetricProcessor.java | 2 +-
.../nimbus/AssignmentDistributionService.java | 8 +-
.../storm/nimbus/NimbusHeartbeatsPressureTest.java | 2 +-
.../org/apache/storm/daemon/nimbus/NimbusTest.java | 2 +-
.../org/apache/storm/security/auth/AuthTest.java | 21 +-
storm-shaded-deps/pom.xml | 79 +++++-
storm-submit-tools/pom.xml | 2 +-
storm-webapp/pom.xml | 2 +-
.../daemon/ui/filters/AuthorizedUserFilter.java | 2 +-
.../daemon/ui/resources/StormApiResource.java | 60 ++---
150 files changed, 2801 insertions(+), 503 deletions(-)
rename
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/{ConsumerFactory.java
=> ClientFactory.java} (84%)
rename
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/{ConsumerFactoryDefault.java
=> ClientFactoryDefault.java} (74%)
rename {storm-webapp/src/main/java =>
storm-client/src/jvm}/org/apache/storm/daemon/common/FileWatcher.java (100%)
create mode 100644
storm-client/src/jvm/org/apache/storm/messaging/netty/NettyTlsUtils.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/MultiThriftServer.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/X509CertOrKerberosPrincipalToLocal.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/X509CertPrincipalToLocal.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableTsslTransportFactory.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509KeyManager.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509TrustManager.java
create mode 100644
storm-client/src/jvm/org/apache/storm/security/auth/tls/TlsTransportPlugin.java
copy storm-client/src/jvm/org/apache/storm/utils/{ServiceRegistry.java =>
SecurityUtils.java} (52%)
create mode 100644
storm-client/test/jvm/org/apache/storm/nimbus/NimbusInfoTest.java
create mode 100644
storm-client/test/jvm/org/apache/storm/security/auth/MultiThriftServerTest.java
copy
storm-client/{src/jvm/org/apache/storm/security/auth/kerberos/NoOpTTrasport.java
=> test/jvm/org/apache/storm/security/auth/TestingITransportPlugin.java} (61%)
create mode 100644
storm-client/test/jvm/org/apache/storm/security/auth/TlsTransportPluginTest.java
create mode 100644
storm-client/test/jvm/org/apache/storm/security/auth/X509CertPrincipalToLocalTest.java
create mode 100644
storm-client/test/jvm/org/apache/storm/utils/SecurityUtilsTest.java
create mode 100644 storm-client/test/resources/ssl/README.md
create mode 100644 storm-client/test/resources/ssl/testKeyStore.jks
create mode 100644 storm-client/test/resources/ssl/testTrustStore.jks
