This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch catalog-feature
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from d569920d10 IGNITE-20114 DistributionZoneManager should listen
CatalogService events instead of configuration (#2415)
add 2c1b153a22 IGNITE-20283: IDEA gradle run configurations improvements
(#2502)
add 4fd6b984d5 IGNITE-19898 Sql. Added ability to use different
transaction facades to start an implicit transaction (#2449)
add 5f5d592494 IGNITE-20054 Disabled tests in
ItIgniteDistributionZoneManagerNodeRestartTest were fixed. (#2425)
add 98a4c28bba IGNITE-20289: IDEA gradle run configurations fix (#2505)
add 59107180be IGNITE-19788 Sql. Change QueryBatchMessage serialization
(#2476)
add cba48c77ea IGNITE-20272 Clean up of
DistributionZoneManagerWatchListenerTest (#2490)
add acded3fc66 IGNITE-19227 Wait for schema availability outside JRaft
threads (#2450)
add e6d97f5b25 IGNITE-20291 Fix in-flight counts for backpressure (#2509)
new 9ff6c35a55 Merge branch 'ai-main' into catalog-feature
new 69b65cb061 catalog-feature after ai-merge
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
...l checks [PMD, modernizer, checkstyle].run.xml} | 12 +-
.run/All checks [check].run.xml | 4 +-
...check].run.xml => Fast build only java.run.xml} | 8 +-
.../ignite/internal/catalog/CatalogService.java | 2 -
.../internal/cli/CliIntegrationTestBase.java | 7 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 2 +
.../requests/sql/ClientSqlExecuteRequest.java | 4 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 8 +-
.../requests/jdbc/JdbcQueryCursorSelfTest.java | 15 +-
.../internal/client/table/ClientDataStreamer.java | 5 -
.../client/fakes/FakeIgniteQueryProcessor.java | 3 +-
.../ignite/internal/streamer/StreamerBuffer.java | 38 +---
.../ignite/internal/streamer/StreamerOptions.java | 8 -
.../internal/streamer/StreamerSubscriber.java | 53 +++--
.../org/apache/ignite/internal/util/ByteUtils.java | 2 +-
.../apache/ignite/internal/util/VarIntUtils.java | 103 ++++++++++
.../internal/streamer/StreamerSubscriberTest.java | 179 +++++++++++++++++
.../ignite/internal/util/VarIntUtilsTest.java | 94 +++++++++
.../testframework/TestIgnitionManager.java | 37 +++-
...butionZoneManagerLogicalTopologyEventsTest.java | 28 +++
.../DistributionZoneManagerWatchListenerTest.java | 109 ----------
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 2 +
.../java/org/apache/ignite/internal/raft/Loza.java | 13 +-
.../internal/raft/server/RaftGroupOptions.java | 23 +++
.../internal/raft/server/impl/JraftServerImpl.java | 30 ++-
.../internal/raft/util/OptimizedMarshaller.java | 14 +-
.../ignite/internal/raft/util/OptimizedStream.java | 2 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 1 +
.../ignite/raft/jraft/option/NodeOptions.java | 14 ++
.../jraft/rpc/impl/ActionRequestProcessor.java | 12 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 11 +-
...r.java => AppendEntriesRequestInterceptor.java} | 37 ++--
...InterceptingAppendEntriesRequestProcessor.java} | 39 ++--
...va => NullAppendEntriesRequestInterceptor.java} | 28 +--
.../apache/ignite/raft/jraft/core/TestCluster.java | 7 +
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 4 +-
.../replicator/message/ReplicaMessageGroup.java | 5 +-
.../internal/ClusterPerTestIntegrationTest.java | 2 +-
.../benchmark/AbstractOneNodeBenchmark.java | 2 +-
.../storage/ItRebalanceDistributedTest.java | 10 +-
...niteDistributionZoneManagerNodeRestartTest.java | 64 ++++--
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 79 +-------
.../app/ItIgniteInMemoryNodeRestartTest.java | 2 +
.../runner/app/ItIgniteNodeRestartTest.java | 14 +-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 177 ++++++++++++++++
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 48 +++--
.../internal/sql/api/ItSqlSynchronousApiTest.java | 22 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 7 +-
.../engine/datatypes/tests/BaseDataTypeTest.java | 6 +
.../ignite/internal/table/ItRoReadsTest.java | 8 +-
.../src/integrationTest/sql/sqlite/join/join1.test | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 16 +-
.../java/org/apache/ignite/internal/Cluster.java | 88 +++++++-
.../ignite/internal/ReplicationGroupsUtils.java} | 33 ++-
.../sql/engine/util/TestQueryProcessor.java | 13 +-
.../ignite/internal/sql/api/IgniteSqlImpl.java | 9 +-
.../internal/sql/api/SessionBuilderImpl.java | 8 +-
.../ignite/internal/sql/api/SessionImpl.java | 12 +-
.../internal/sql/engine/AsyncSqlCursorImpl.java | 21 +-
.../ignite/internal/sql/engine/QueryProcessor.java | 6 +-
.../sql/engine/QueryTransactionWrapper.java} | 45 +++--
.../internal/sql/engine/SqlQueryProcessor.java | 198 +++++++++---------
.../internal/sql/engine/exec/ArrayRowHandler.java | 14 ++
.../internal/sql/engine/exec/ExchangeService.java | 6 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 11 +-
.../sql/engine/exec/LogicalRelImplementor.java | 8 +-
.../internal/sql/engine/exec/RowHandler.java | 43 +++-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 4 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 2 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 16 +-
.../internal/sql/engine/exec/rel/Outbox.java | 12 +-
.../internal/sql/engine/externalize/RelJson.java | 4 +-
.../sql/engine/message/QueryBatchMessage.java | 5 +-
.../sql/engine/AsyncSqlCursorImplTest.java | 51 +++--
.../engine/QueryTransactionWrapperSelfTest.java | 131 ++++++++++++
.../sql/engine/exec/rel/AbstractExecutionTest.java | 7 +
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 3 +-
.../sql/engine/exec/rel/ExecutionTest.java | 27 +++
.../internal/sql/engine/util/QueryChecker.java | 9 +-
modules/table/build.gradle | 1 +
.../distributed/ItTxDistributedTestSingleNode.java | 4 +
.../ignite/internal/table/AbstractTableView.java | 2 +-
.../apache/ignite/internal/table/DataStreamer.java | 5 -
.../internal/table/distributed/TableManager.java | 38 ++--
.../distributed/command/CatalogVersionAware.java} | 16 +-
.../distributed/command/PartitionCommand.java | 8 +-
.../replicator/PartitionReplicaListener.java | 222 +++++++++++++--------
.../distributed/replicator/action/RequestType.java | 38 +---
.../schema/CheckCatalogVersionOnAppendEntries.java | 105 ++++++++++
...-info.java => PartitionCommandsMarshaller.java} | 19 +-
.../schema/PartitionCommandsMarshallerImpl.java | 73 +++++++
.../distributed/schema/SchemaSyncService.java | 8 -
.../distributed/schema/SchemaSyncServiceImpl.java | 11 +-
.../ThreadLocalPartitionCommandsMarshaller.java} | 18 +-
.../table/distributed/TableManagerTest.java | 2 +
.../PartitionReplicaListenerIndexLockingTest.java | 9 +-
.../replication/PartitionReplicaListenerTest.java | 182 ++++++++++++-----
.../PartitionCommandsMarshallerImplTest.java | 116 +++++++++++
.../schema/SchemaSyncServiceImplTest.java | 14 +-
.../replicator/action/RequestTypes.java} | 95 +++++----
.../table/impl/DummyInternalTableImpl.java | 4 +
101 files changed, 2281 insertions(+), 919 deletions(-)
copy .run/{All checks [check].run.xml => All checks [PMD, modernizer,
checkstyle].run.xml} (61%)
copy .run/{All checks [check].run.xml => Fast build only java.run.xml} (60%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/VarIntUtils.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/streamer/StreamerSubscriberTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/VarIntUtilsTest.java
delete mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneManagerWatchListenerTest.java
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/{GetFileRequestProcessor.java
=> AppendEntriesRequestInterceptor.java} (51%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/{TimeoutNowRequestProcessor.java
=> InterceptingAppendEntriesRequestProcessor.java} (55%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/{GetFileRequestProcessor.java
=> NullAppendEntriesRequestInterceptor.java} (55%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/schemasync/ItSchemaSyncAndReplicationTest.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadWriteMultiRowReplicaRequest.java
=>
runner/src/testFixtures/java/org/apache/ignite/internal/ReplicationGroupsUtils.java}
(54%)
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/decorators/SqlQueryResultDecorator.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryTransactionWrapper.java}
(50%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/QueryTransactionWrapperSelfTest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/MessageListener.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/command/CatalogVersionAware.java}
(70%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/CheckCatalogVersionOnAppendEntries.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/{package-info.java
=> PartitionCommandsMarshaller.java} (63%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/PartitionCommandsMarshallerImpl.java
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/util/ThreadLocalOptimizedMarshaller.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/schema/ThreadLocalPartitionCommandsMarshaller.java}
(67%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/schema/PartitionCommandsMarshallerImplTest.java
copy
modules/table/src/{main/java/org/apache/ignite/internal/table/distributed/replicator/action/RequestType.java
=>
testFixtures/java/org/apache/ignite/distributed/replicator/action/RequestTypes.java}
(51%)
