This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.apache.maven.plugins-maven-compiler-plugin-3.14.0
in repository https://gitbox.apache.org/repos/asf/storm.git
discard 344f261fa Bump org.apache.maven.plugins:maven-compiler-plugin
add 6103494d5 Bump testcontainers.version from 1.21.1 to 1.21.2 (#8134)
add 71ec0aa45 Bump byte-buddy.version from 1.17.5 to 1.17.6 (#8136)
add c0b1534ef Bump org.codehaus.mojo:license-maven-plugin from 2.5.0 to
2.6.0 (#8135)
add ade5456da Bump org.apache.logging.log4j:log4j-bom from 2.24.3 to
2.25.0 (#8138)
add 93d6ca36a Bump activemq.version from 6.1.6 to 6.1.7 (#8133)
add 0d6903e31 Bump metrics.version from 4.2.32 to 4.2.33 (#8132)
add 6c3eb3bd5 Bump org.junit:junit-bom from 5.13.1 to 5.13.3 (#8155)
add 9f8ec1a95 Bump testcontainers.version from 1.21.2 to 1.21.3 (#8149)
add c727bf29b Bump org.apache.maven.plugins:maven-pmd-plugin from 3.26.0
to 3.27.0 (#8148)
add 439e0b0c3 Bump com.google.errorprone:error_prone_annotations from
2.38.0 to 2.39.0 (#8146)
add 66144d79a Bump maven-resolver.version from 1.9.23 to 1.9.24 (#8154)
add e6b0ac717 Bump prometheus.client.version from 1.3.8 to 1.3.9 (#8153)
add be00cbd34 Bump org.checkerframework:checker-qual from 3.49.4 to 3.49.5
(#8152)
add f2b705f0c Bump org.apache.thrift:libthrift from 0.19.0 to 0.22.0
(#8147)
add e21699452 Summarized Dependency Updates (Prometheus, Lang3, Caffeine)
(#8169)
add 9628cd278 Updates Dependencies (Jackson 2.19.2, Spring 6.2.9, Resolver
2.19.11, Commons IO 2.20.0, Netty 4.2.3.Final, Hbase 2.6.3, Hikari 6.3.1)
(#8184)
add 84828defc Drop User & URL from VersionInfo (#8189)
add 8ea26f1da Bump org.junit:junit-bom from 5.13.3 to 5.13.4
add dda23bb92 [maven-release-plugin] prepare release v2.8.2
add d7b1d2a4d [maven-release-plugin] prepare for next development iteration
add 8ab256c5f Update doap_Storm.rdf
add aa6f418aa Bump curator.version from 5.8.0 to 5.9.0 (#8202)
add efb42e665 Drop storm-sql-* modules (#8174)
add f9930f45d Pin versions, fixes #8139
add 33f0479bb Bump org.apache.maven.plugins:maven-compiler-plugin
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 (344f261fa)
\
N -- N -- N
refs/heads/dependabot/maven/org.apache.maven.plugins-maven-compiler-plugin-3.14.0
(33f0479bb)
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/maven.yaml | 12 +-
.github/workflows/nightlies.yaml | 14 +-
.github/workflows/snapshots.yaml | 12 +-
DEPENDENCY-LICENSES | 279 ++---
LICENSE-binary | 237 ++--
bin/storm.py | 65 -
doap_Storm.rdf | 6 +-
docs/Implementation-docs.md | 1 -
docs/Project-ideas.md | 2 +-
docs/State-checkpointing.md | 2 +-
docs/index.md | 12 -
docs/storm-sql-example.md | 289 -----
docs/storm-sql-internal.md | 59 -
docs/storm-sql-reference.md | 1314 --------------------
docs/storm-sql.md | 198 ---
examples/storm-hdfs-examples/pom.xml | 2 +-
examples/storm-jdbc-examples/pom.xml | 2 +-
examples/storm-jms-examples/pom.xml | 4 +-
examples/storm-kafka-client-examples/pom.xml | 2 +-
examples/storm-loadgen/pom.xml | 2 +-
examples/storm-perf/pom.xml | 2 +-
examples/storm-redis-examples/pom.xml | 2 +-
examples/storm-starter/pom.xml | 2 +-
external/storm-autocreds/pom.xml | 2 +-
external/storm-blobstore-migration/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-jdbc/pom.xml | 2 +-
external/storm-jms/pom.xml | 2 +-
external/storm-kafka-client/pom.xml | 2 +-
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 +-
pom.xml | 65 +-
sql/README.md | 28 -
sql/pom.xml | 59 -
sql/storm-sql-core/pom.xml | 331 -----
sql/storm-sql-core/src/codegen/config.fmpp | 23 -
sql/storm-sql-core/src/codegen/data/Parser.tdd | 80 --
.../src/codegen/includes/license.ftl | 17 -
.../src/codegen/includes/parserImpls.ftl | 113 --
.../apache/storm/sql/AbstractStreamsProcessor.java | 67 -
.../src/jvm/org/apache/storm/sql/StormSql.java | 45 -
.../jvm/org/apache/storm/sql/StormSqlContext.java | 169 ---
.../src/jvm/org/apache/storm/sql/StormSqlImpl.java | 123 --
.../jvm/org/apache/storm/sql/StormSqlRunner.java | 80 --
.../storm/sql/calcite/ParallelStreamableTable.java | 29 -
.../apache/storm/sql/calcite/ParallelTable.java | 28 -
.../storm/sql/calcite/StormStreamableTable.java | 26 -
.../org/apache/storm/sql/calcite/StormTable.java | 26 -
.../apache/storm/sql/compiler/CompilerUtil.java | 227 ----
.../sql/compiler/RexNodeToJavaCodeCompiler.java | 234 ----
.../sql/compiler/StormSqlTypeFactoryImpl.java | 42 -
.../storm/sql/javac/CompilingClassLoader.java | 227 ----
.../apache/storm/sql/parser/ColumnConstraint.java | 38 -
.../apache/storm/sql/parser/ColumnDefinition.java | 38 -
.../apache/storm/sql/parser/SqlCreateFunction.java | 88 --
.../apache/storm/sql/parser/SqlCreateTable.java | 164 ---
.../apache/storm/sql/parser/SqlDdlKeywords.java | 22 -
.../org/apache/storm/sql/parser/StormParser.java | 44 -
.../org/apache/storm/sql/parser/UnparseUtil.java | 54 -
.../storm/sql/planner/StormRelDataTypeSystem.java | 31 -
.../apache/storm/sql/planner/StormRelUtils.java | 62 -
.../sql/planner/UnsupportedOperatorsVisitor.java | 19 -
.../storm/sql/planner/rel/StormCalcRelBase.java | 25 -
.../storm/sql/planner/rel/StormFilterRelBase.java | 25 -
.../storm/sql/planner/rel/StormJoinRelBase.java | 29 -
.../storm/sql/planner/rel/StormProjectRelBase.java | 28 -
.../apache/storm/sql/planner/rel/StormRelNode.java | 18 -
.../sql/planner/rel/StormStreamInsertRelBase.java | 30 -
.../sql/planner/rel/StormStreamScanRelBase.java | 25 -
.../storm/sql/planner/streams/QueryPlanner.java | 158 ---
.../sql/planner/streams/StreamsPlanCreator.java | 126 --
.../sql/planner/streams/StreamsStormRuleSets.java | 109 --
.../sql/planner/streams/rel/StreamsCalcRel.java | 94 --
.../sql/planner/streams/rel/StreamsFilterRel.java | 66 -
.../streams/rel/StreamsLogicalConvention.java | 69 -
.../sql/planner/streams/rel/StreamsProjectRel.java | 69 -
.../storm/sql/planner/streams/rel/StreamsRel.java | 27 -
.../streams/rel/StreamsStreamInsertRel.java | 82 --
.../planner/streams/rel/StreamsStreamScanRel.java | 57 -
.../streams/rules/StreamsAggregateRule.java | 40 -
.../sql/planner/streams/rules/StreamsCalcRule.java | 46 -
.../planner/streams/rules/StreamsFilterRule.java | 47 -
.../sql/planner/streams/rules/StreamsJoinRule.java | 39 -
.../planner/streams/rules/StreamsModifyRule.java | 89 --
.../planner/streams/rules/StreamsProjectRule.java | 48 -
.../sql/planner/streams/rules/StreamsScanRule.java | 61 -
.../src/test/org/apache/storm/sql/SqlTestUtil.java | 59 -
.../apache/storm/sql/StormSqlLocalClusterImpl.java | 79 --
.../test/org/apache/storm/sql/TestStormSql.java | 297 -----
.../backends/streams/TestCompilerUtils.java | 217 ----
.../backends/streams/TestPlanCompiler.java | 231 ----
.../org/apache/storm/sql/parser/TestSqlParser.java | 50 -
sql/storm-sql-external/storm-sql-hdfs/pom.xml | 152 ---
.../storm/sql/hdfs/HdfsDataSourcesProvider.java | 131 --
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/hdfs/TestHdfsDataSourcesProvider.java | 88 --
sql/storm-sql-external/storm-sql-kafka/pom.xml | 107 --
.../storm/sql/kafka/KafkaDataSourcesProvider.java | 175 ---
.../sql/kafka/RecordTranslatorSchemeAdapter.java | 48 -
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/kafka/TestKafkaDataSourcesProvider.java | 59 -
sql/storm-sql-external/storm-sql-redis/pom.xml | 85 --
.../storm/sql/redis/RedisDataSourcesProvider.java | 213 ----
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/redis/TestRedisDataSourcesProvider.java | 78 --
sql/storm-sql-runtime/pom.xml | 169 ---
.../apache/calcite/interpreter/StormContext.java | 32 -
.../storm/sql/runtime/DataSourcesProvider.java | 46 -
.../storm/sql/runtime/DataSourcesRegistry.java | 75 --
.../org/apache/storm/sql/runtime/FieldInfo.java | 54 -
.../storm/sql/runtime/IOutputSerializer.java | 32 -
.../storm/sql/runtime/ISqlStreamsDataSource.java | 40 -
.../calcite/DebuggableExecutableExpression.java | 45 -
.../sql/runtime/calcite/ExecutableExpression.java | 32 -
.../sql/runtime/calcite/StormDataContext.java | 84 --
.../socket/SocketDataSourcesProvider.java | 90 --
.../runtime/datasource/socket/bolt/SocketBolt.java | 105 --
.../datasource/socket/spout/SocketSpout.java | 195 ---
.../storm/sql/runtime/serde/avro/AvroScheme.java | 80 --
.../sql/runtime/serde/avro/AvroSerializer.java | 79 --
.../sql/runtime/serde/avro/CachedSchemas.java | 47 -
.../storm/sql/runtime/serde/csv/CsvScheme.java | 72 --
.../storm/sql/runtime/serde/csv/CsvSerializer.java | 60 -
.../storm/sql/runtime/serde/json/JsonScheme.java | 60 -
.../sql/runtime/serde/json/JsonSerializer.java | 59 -
.../storm/sql/runtime/serde/tsv/TsvScheme.java | 60 -
.../storm/sql/runtime/serde/tsv/TsvSerializer.java | 55 -
.../runtime/streams/functions/EvaluationCalc.java | 85 --
.../streams/functions/EvaluationFilter.java | 61 -
.../streams/functions/EvaluationFunction.java | 64 -
.../functions/StreamInsertMapToPairFunction.java | 38 -
.../functions/StreamsScanTupleValueMapper.java | 51 -
.../storm/sql/runtime/utils/FieldInfoUtils.java | 41 -
.../apache/storm/sql/runtime/utils/SerdeUtils.java | 144 ---
.../org/apache/storm/sql/runtime/utils/Utils.java | 56 -
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../org/apache/storm/sql/TestAvroSerializer.java | 72 --
.../org/apache/storm/sql/TestCsvSerializer.java | 54 -
.../apache/storm/sql/TestJsonRepresentation.java | 52 -
.../org/apache/storm/sql/TestTsvSerializer.java | 46 -
.../src/test/org/apache/storm/sql/TestUtils.java | 363 ------
.../maven-shade-clojure-transformer/pom.xml | 2 +-
storm-buildtools/storm-maven-plugins/pom.xml | 2 +-
storm-checkstyle/pom.xml | 2 +-
storm-client/pom.xml | 2 +-
storm-client/src/genthrift.sh | 0
.../org/apache/storm/generated/AccessControl.java | 6 +-
.../apache/storm/generated/AccessControlType.java | 4 +-
.../storm/generated/AlreadyAliveException.java | 4 +-
.../jvm/org/apache/storm/generated/Assignment.java | 6 +-
.../storm/generated/AuthorizationException.java | 4 +-
.../storm/generated/BeginDownloadResult.java | 6 +-
.../src/jvm/org/apache/storm/generated/Bolt.java | 4 +-
.../apache/storm/generated/BoltAggregateStats.java | 6 +-
.../jvm/org/apache/storm/generated/BoltStats.java | 4 +-
.../org/apache/storm/generated/ClusterSummary.java | 4 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 4 +-
.../storm/generated/CommonAggregateStats.java | 6 +-
.../storm/generated/ComponentAggregateStats.java | 6 +-
.../apache/storm/generated/ComponentCommon.java | 6 +-
.../apache/storm/generated/ComponentObject.java | 4 +-
.../apache/storm/generated/ComponentPageInfo.java | 6 +-
.../org/apache/storm/generated/ComponentType.java | 4 +-
.../org/apache/storm/generated/Credentials.java | 6 +-
.../apache/storm/generated/DRPCExceptionType.java | 4 +-
.../storm/generated/DRPCExecutionException.java | 6 +-
.../org/apache/storm/generated/DRPCRequest.java | 4 +-
.../org/apache/storm/generated/DebugOptions.java | 6 +-
.../org/apache/storm/generated/DistributedRPC.java | 36 +-
.../storm/generated/DistributedRPCInvocations.java | 96 +-
.../jvm/org/apache/storm/generated/ErrorInfo.java | 6 +-
.../storm/generated/ExecutorAggregateStats.java | 6 +-
.../org/apache/storm/generated/ExecutorInfo.java | 4 +-
.../storm/generated/ExecutorSpecificStats.java | 4 +-
.../org/apache/storm/generated/ExecutorStats.java | 4 +-
.../apache/storm/generated/ExecutorSummary.java | 6 +-
.../org/apache/storm/generated/GetInfoOptions.java | 6 +-
.../org/apache/storm/generated/GlobalStreamId.java | 4 +-
.../jvm/org/apache/storm/generated/Grouping.java | 4 +-
.../storm/generated/HBAuthorizationException.java | 4 +-
.../storm/generated/HBExecutionException.java | 4 +-
.../jvm/org/apache/storm/generated/HBMessage.java | 6 +-
.../org/apache/storm/generated/HBMessageData.java | 4 +-
.../jvm/org/apache/storm/generated/HBNodes.java | 4 +-
.../jvm/org/apache/storm/generated/HBPulse.java | 4 +-
.../jvm/org/apache/storm/generated/HBRecords.java | 4 +-
.../storm/generated/HBServerMessageType.java | 4 +-
.../storm/generated/IllegalStateException.java | 4 +-
.../storm/generated/InvalidTopologyException.java | 4 +-
.../jvm/org/apache/storm/generated/JavaObject.java | 4 +-
.../org/apache/storm/generated/JavaObjectArg.java | 4 +-
.../storm/generated/KeyAlreadyExistsException.java | 4 +-
.../storm/generated/KeyNotFoundException.java | 4 +-
.../org/apache/storm/generated/KillOptions.java | 6 +-
.../apache/storm/generated/LSApprovedWorkers.java | 4 +-
.../storm/generated/LSSupervisorAssignments.java | 4 +-
.../org/apache/storm/generated/LSSupervisorId.java | 4 +-
.../org/apache/storm/generated/LSTopoHistory.java | 4 +-
.../apache/storm/generated/LSTopoHistoryList.java | 4 +-
.../apache/storm/generated/LSWorkerHeartbeat.java | 4 +-
.../apache/storm/generated/ListBlobsResult.java | 4 +-
.../apache/storm/generated/LocalAssignment.java | 6 +-
.../org/apache/storm/generated/LocalStateData.java | 4 +-
.../jvm/org/apache/storm/generated/LogConfig.java | 6 +-
.../jvm/org/apache/storm/generated/LogLevel.java | 6 +-
.../org/apache/storm/generated/LogLevelAction.java | 4 +-
.../src/jvm/org/apache/storm/generated/Nimbus.java | 1116 ++++++++++++-----
.../org/apache/storm/generated/NimbusSummary.java | 6 +-
.../jvm/org/apache/storm/generated/NodeInfo.java | 4 +-
.../apache/storm/generated/NotAliveException.java | 4 +-
.../jvm/org/apache/storm/generated/NullStruct.java | 4 +-
.../apache/storm/generated/NumErrorsChoice.java | 4 +-
.../storm/generated/OwnerResourceSummary.java | 6 +-
.../apache/storm/generated/PrivateWorkerKey.java | 4 +-
.../org/apache/storm/generated/ProfileAction.java | 4 +-
.../org/apache/storm/generated/ProfileRequest.java | 6 +-
.../apache/storm/generated/ReadableBlobMeta.java | 4 +-
.../apache/storm/generated/RebalanceOptions.java | 6 +-
.../apache/storm/generated/SettableBlobMeta.java | 6 +-
.../org/apache/storm/generated/SharedMemory.java | 6 +-
.../org/apache/storm/generated/ShellComponent.java | 4 +-
.../storm/generated/SpecificAggregateStats.java | 4 +-
.../storm/generated/SpoutAggregateStats.java | 6 +-
.../jvm/org/apache/storm/generated/SpoutSpec.java | 4 +-
.../jvm/org/apache/storm/generated/SpoutStats.java | 4 +-
.../org/apache/storm/generated/StateSpoutSpec.java | 4 +-
.../jvm/org/apache/storm/generated/StormBase.java | 6 +-
.../org/apache/storm/generated/StormTopology.java | 6 +-
.../jvm/org/apache/storm/generated/StreamInfo.java | 4 +-
.../org/apache/storm/generated/SubmitOptions.java | 6 +-
.../jvm/org/apache/storm/generated/Supervisor.java | 76 +-
.../storm/generated/SupervisorAssignments.java | 6 +-
.../org/apache/storm/generated/SupervisorInfo.java | 6 +-
.../apache/storm/generated/SupervisorPageInfo.java | 6 +-
.../apache/storm/generated/SupervisorSummary.java | 6 +-
.../storm/generated/SupervisorWorkerHeartbeat.java | 4 +-
.../generated/SupervisorWorkerHeartbeats.java | 4 +-
.../storm/generated/ThriftSerializedObject.java | 4 +-
.../storm/generated/TopologyActionOptions.java | 4 +-
.../storm/generated/TopologyHistoryInfo.java | 4 +-
.../org/apache/storm/generated/TopologyInfo.java | 6 +-
.../storm/generated/TopologyInitialStatus.java | 4 +-
.../apache/storm/generated/TopologyPageInfo.java | 6 +-
.../org/apache/storm/generated/TopologyStats.java | 6 +-
.../org/apache/storm/generated/TopologyStatus.java | 4 +-
.../apache/storm/generated/TopologySummary.java | 6 +-
.../apache/storm/generated/WorkerMetricList.java | 4 +-
.../apache/storm/generated/WorkerMetricPoint.java | 4 +-
.../org/apache/storm/generated/WorkerMetrics.java | 4 +-
.../apache/storm/generated/WorkerResources.java | 6 +-
.../org/apache/storm/generated/WorkerSummary.java | 6 +-
.../org/apache/storm/generated/WorkerToken.java | 4 +-
.../apache/storm/generated/WorkerTokenInfo.java | 4 +-
.../storm/generated/WorkerTokenServiceType.java | 4 +-
.../jvm/org/apache/storm/utils/IVersionInfo.java | 12 -
.../src/jvm/org/apache/storm/utils/Utils.java | 10 -
.../jvm/org/apache/storm/utils/VersionInfo.java | 29 -
storm-client/src/py/storm/DistributedRPC-remote | 2 +-
storm-client/src/py/storm/DistributedRPC.py | 11 +-
.../src/py/storm/DistributedRPCInvocations-remote | 2 +-
.../src/py/storm/DistributedRPCInvocations.py | 35 +-
storm-client/src/py/storm/Nimbus-remote | 2 +-
storm-client/src/py/storm/Nimbus.py | 425 +++++--
storm-client/src/py/storm/Supervisor-remote | 2 +-
storm-client/src/py/storm/Supervisor.py | 27 +-
storm-client/src/py/storm/constants.py | 3 +-
storm-client/src/py/storm/ttypes.py | 387 ++++--
.../resources/storm-client-version-info.properties | 2 -
storm-client/test/py/test_storm_cli.py | 18 -
storm-clojure-test/pom.xml | 2 +-
storm-clojure/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
.../resources/storm-core-version-info.properties | 2 -
storm-dist/binary/final-package/pom.xml | 2 +-
.../final-package/src/main/assembly/binary.xml | 15 -
storm-dist/binary/pom.xml | 4 +-
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 | 71 --
.../src/main/assembly/storm-sql-core.xml | 33 -
storm-dist/binary/storm-sql-runtime-bin/pom.xml | 71 --
.../src/main/assembly/storm-sql-runtime.xml | 33 -
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 +-
storm-shaded-deps/pom.xml | 2 +-
storm-submit-tools/pom.xml | 2 +-
storm-webapp/pom.xml | 2 +-
.../java/org/apache/storm/daemon/ui/UIHelpers.java | 2 -
304 files changed, 2238 insertions(+), 12217 deletions(-)
delete mode 100644 docs/storm-sql-example.md
delete mode 100644 docs/storm-sql-internal.md
delete mode 100644 docs/storm-sql-reference.md
delete mode 100644 docs/storm-sql.md
delete mode 100644 sql/README.md
delete mode 100644 sql/pom.xml
delete mode 100644 sql/storm-sql-core/pom.xml
delete mode 100644 sql/storm-sql-core/src/codegen/config.fmpp
delete mode 100644 sql/storm-sql-core/src/codegen/data/Parser.tdd
delete mode 100644 sql/storm-sql-core/src/codegen/includes/license.ftl
delete mode 100644 sql/storm-sql-core/src/codegen/includes/parserImpls.ftl
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/AbstractStreamsProcessor.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSql.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlContext.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlImpl.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlRunner.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/ParallelStreamableTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/ParallelTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/StormStreamableTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/StormTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/CompilerUtil.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/RexNodeToJavaCodeCompiler.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/StormSqlTypeFactoryImpl.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/javac/CompilingClassLoader.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/ColumnConstraint.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/ColumnDefinition.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/SqlCreateFunction.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/SqlCreateTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/SqlDdlKeywords.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/StormParser.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/UnparseUtil.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/StormRelDataTypeSystem.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/StormRelUtils.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/UnsupportedOperatorsVisitor.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormCalcRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormFilterRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormJoinRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormProjectRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormRelNode.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormStreamInsertRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormStreamScanRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/QueryPlanner.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/StreamsPlanCreator.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/StreamsStormRuleSets.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsCalcRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsFilterRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsLogicalConvention.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsProjectRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsStreamInsertRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsStreamScanRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsAggregateRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsCalcRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsFilterRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsJoinRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsModifyRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsProjectRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsScanRule.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/SqlTestUtil.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/StormSqlLocalClusterImpl.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/TestStormSql.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/compiler/backends/streams/TestCompilerUtils.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/compiler/backends/streams/TestPlanCompiler.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/parser/TestSqlParser.java
delete mode 100644 sql/storm-sql-external/storm-sql-hdfs/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-hdfs/src/jvm/org/apache/storm/sql/hdfs/HdfsDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-hdfs/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-hdfs/src/test/org/apache/storm/sql/hdfs/TestHdfsDataSourcesProvider.java
delete mode 100644 sql/storm-sql-external/storm-sql-kafka/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/jvm/org/apache/storm/sql/kafka/KafkaDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/jvm/org/apache/storm/sql/kafka/RecordTranslatorSchemeAdapter.java
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/test/org/apache/storm/sql/kafka/TestKafkaDataSourcesProvider.java
delete mode 100644 sql/storm-sql-external/storm-sql-redis/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-redis/src/jvm/org/apache/storm/sql/redis/RedisDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-redis/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-redis/src/test/org/apache/storm/sql/redis/TestRedisDataSourcesProvider.java
delete mode 100644 sql/storm-sql-runtime/pom.xml
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/calcite/interpreter/StormContext.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/DataSourcesProvider.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/DataSourcesRegistry.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/FieldInfo.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/IOutputSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/ISqlStreamsDataSource.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/calcite/DebuggableExecutableExpression.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/calcite/ExecutableExpression.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/calcite/StormDataContext.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/datasource/socket/SocketDataSourcesProvider.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/datasource/socket/bolt/SocketBolt.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/datasource/socket/spout/SocketSpout.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/AvroScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/AvroSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/CachedSchemas.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/csv/CsvScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/csv/CsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/json/JsonScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/json/JsonSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/tsv/TsvScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/tsv/TsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/EvaluationCalc.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/EvaluationFilter.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/EvaluationFunction.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/StreamInsertMapToPairFunction.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/StreamsScanTupleValueMapper.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/FieldInfoUtils.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/Utils.java
delete mode 100644
sql/storm-sql-runtime/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestAvroSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestCsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestJsonRepresentation.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestTsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestUtils.java
mode change 100644 => 100755 storm-client/src/genthrift.sh
delete mode 100644 storm-dist/binary/storm-sql-core-bin/pom.xml
delete mode 100644
storm-dist/binary/storm-sql-core-bin/src/main/assembly/storm-sql-core.xml
delete mode 100644 storm-dist/binary/storm-sql-runtime-bin/pom.xml
delete mode 100644
storm-dist/binary/storm-sql-runtime-bin/src/main/assembly/storm-sql-runtime.xml
