You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/12/01 15:39:32 UTC
[ignite-3] branch ignite-15784 updated (1a3b262 -> f8be5a4)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15784
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard 1a3b262 Minor.
add 26d14a2 Minor.
add 98b08b5 IGNITE-15711 Implemented Loza.stop(). Fixes #446
add 258e06e IGNITE-15785 POJO validation. (#452)
add 24b18c9 Revert "IGNITE-15711 Implemented Loza.stop(). Fixes #446"
add 2c97228 IGNITE-15528 Fixed a thread leak in jraft, introduced shared pools mode.
add 41fcd5e IGNITE-15939 Fix GetAll wire format in thin clients (#479)
add dde01f1 IGNITE-15711 Implemented Loza.stop(). Fixes #482
add a42b6d6 IGNITE-15991 Remove whitespaces in empty lines. (#485)
add 4158830 Merge branch 'main' into ignite-15784
add f8be5a4 Minor.
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 (1a3b262)
\
N -- N -- N refs/heads/ignite-15784 (f8be5a4)
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:
.../ignite/example/rebalance/RebalanceExample.java | 58 +-
.../ignite/example/table/TableExamplesTest.java | 4 +-
.../table/PartialIndexConfigurationSchema.java | 2 +-
.../table/TableIndexConfigurationSchema.java | 8 +-
.../java/org/apache/ignite/table/RecordView.java | 4 +-
.../ignite/table/mapper/DefaultColumnMapper.java | 14 +-
.../org/apache/ignite/table/mapper/Mapper.java | 1 -
.../apache/ignite/table/mapper/MapperBuilder.java | 10 +-
.../processors/query/calcite/QueryCancel.java | 24 +-
.../query/calcite/exec/RuntimeSortedIndex.java | 2 +-
.../calcite/exec/exp/ExpressionFactoryImpl.java | 74 +-
.../query/calcite/exec/exp/agg/Accumulators.java | 8 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 4 +-
.../query/calcite/exec/rel/NestedLoopJoinNode.java | 18 +-
.../calcite/prepare/ResultSetMetadataImpl.java | 18 +-
.../query/calcite/rel/AbstractIgniteJoin.java | 2 +-
.../query/calcite/rel/IgniteMergeJoin.java | 46 +-
.../query/calcite/rel/IgniteTableFunctionScan.java | 14 +-
.../query/calcite/rel/set/IgniteMapSetOp.java | 24 +-
.../query/calcite/rel/set/IgniteReduceSetOp.java | 10 +-
.../query/calcite/rel/set/IgniteSetOp.java | 18 +-
.../query/calcite/rel/set/IgniteSingleSetOp.java | 20 +-
.../query/calcite/schema/IgniteTableImpl.java | 4 +-
.../query/calcite/schema/InternalIgniteTable.java | 6 +-
.../query/calcite/sql/IgniteSqlConformance.java | 2 +-
.../query/calcite/type/IgniteTypeFactory.java | 4 +-
.../query/calcite/util/BaseQueryContext.java | 94 +--
.../query/calcite/util/IgniteMethod.java | 4 +-
.../query/calcite/StopCalciteModuleTest.java | 6 +-
.../query/calcite/exec/rel/ExecutionTest.java | 8 +-
.../exec/rel/NestedLoopJoinExecutionTest.java | 4 +-
.../calcite/planner/MergeJoinPlannerTest.java | 856 ++++++++++-----------
.../query/calcite/sql/SqlDdlParserTest.java | 92 +--
.../org/apache/ignite/cli/spec/SpecAdapter.java | 2 +-
.../client/proto/query/event/JdbcColumnMeta.java | 82 +-
.../client/proto/ClientMessageUnpacker.java | 2 +-
.../client/proto/ClientMessagePackerBenchmark.java | 18 +-
.../client/proto/ClientMessagePackerTest.java | 54 +-
.../client/proto/ClientMessageUnpackerTest.java | 50 +-
.../ignite/client/handler/ItClientHandlerTest.java | 78 +-
.../ignite/client/handler/ClientHandlerModule.java | 12 +-
.../handler/ClientInboundMessageHandler.java | 2 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 108 +--
.../handler/requests/sql/JdbcMetadataCatalog.java | 94 +--
.../handler/requests/table/ClientTableCommon.java | 249 +++---
.../table/ClientTupleDeleteAllExactRequest.java | 2 +-
.../table/ClientTupleDeleteAllRequest.java | 2 +-
.../requests/table/ClientTupleGetAllRequest.java | 5 +-
.../table/ClientTupleGetAndDeleteRequest.java | 4 +-
.../table/ClientTupleGetAndReplaceRequest.java | 4 +-
.../ClientTupleGetAndReplaceSchemalessRequest.java | 3 +-
.../table/ClientTupleGetAndUpsertRequest.java | 4 +-
.../ClientTupleGetAndUpsertSchemalessRequest.java | 3 +-
.../requests/table/ClientTupleGetRequest.java | 3 +-
.../table/ClientTupleInsertAllRequest.java | 2 +-
.../ClientTupleInsertAllSchemalessRequest.java | 2 +-
.../internal/client/ProtocolBitmaskFeature.java | 2 +-
.../ignite/internal/client/ReliableChannel.java | 2 +-
.../io/netty/NettyClientConnectionMultiplexer.java | 2 +-
.../client/table/ClientKeyValueBinaryView.java | 2 +-
.../client/table/ClientRecordBinaryView.java | 2 +-
.../ignite/internal/client/table/ClientTable.java | 222 +++---
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 504 ++++++------
.../internal/jdbc/JdbcResultSetMetadata.java | 54 +-
.../apache/ignite/client/AbstractClientTest.java | 40 +-
.../java/org/apache/ignite/client/CustomTuple.java | 76 +-
.../org/apache/ignite/client/ReconnectTest.java | 30 +-
.../java/org/apache/ignite/client/TestServer.java | 26 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 18 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 2 +-
.../ignite/client/fakes/FakeIgniteTables.java | 58 +-
.../ErrorPolymorphic8ConfigurationSchema.java | 2 +-
.../configuration/processor/Processor.java | 236 +++---
.../internal/configuration/processor/Utils.java | 10 +-
.../configuration/processor/UtilsTest.java | 2 +-
.../configuration/ConfigurationChanger.java | 144 ++--
.../configuration/ConfigurationManager.java | 12 +-
.../configuration/ConfigurationRegistry.java | 106 +--
.../DirectConfigurationTreeWrapper.java | 4 +-
.../configuration/DirectDynamicProperty.java | 4 +-
.../configuration/DynamicConfiguration.java | 48 +-
.../internal/configuration/DynamicProperty.java | 34 +-
.../configuration/NamedListConfiguration.java | 44 +-
.../asm/ConfigurationAsmGenerator.java | 824 ++++++++++----------
.../hocon/HoconObjectConfigurationSource.java | 34 +-
.../configuration/tree/ConfigurationSource.java | 6 +-
.../internal/configuration/tree/NamedListNode.java | 198 ++---
.../configuration/util/ConfigurationFlattener.java | 92 +--
.../configuration/util/ConfigurationUtil.java | 240 +++---
.../util/KeysTrackingConfigurationVisitor.java | 48 +-
.../configuration/validation/ValidationUtil.java | 2 +-
.../configuration/ConfigurationChangerTest.java | 212 ++---
.../configuration/ConfigurationRegistryTest.java | 42 +-
.../configuration/DirectPropertiesTest.java | 68 +-
.../configuration/TestConfigurationChanger.java | 10 +-
.../asm/ConfigurationAsmGeneratorTest.java | 22 +-
.../configuration/hocon/HoconConverterTest.java | 230 +++---
.../ConfigurationAnyListenerTest.java | 212 ++---
.../notifications/ConfigurationListenerTest.java | 484 ++++++------
.../internal/configuration/sample/UsageTest.java | 44 +-
.../testframework/ConfigurationExtension.java | 86 +--
.../testframework/ConfigurationExtensionTest.java | 52 +-
.../configuration/tree/ConfigurationArrayTest.java | 22 +-
.../tree/ConstructableTreeNodeTest.java | 12 +-
.../configuration/tree/NamedListNodeTest.java | 96 +--
.../tree/TraversableTreeNodeTest.java | 8 +-
.../configuration/util/ConfigurationUtilTest.java | 380 ++++-----
.../validation/ValidationUtilTest.java | 22 +-
.../apache/ignite/internal/manager/Producer.java | 18 +-
.../ignite/internal/tostring/FieldDescriptor.java | 16 +-
.../apache/ignite/internal/util/ArrayUtils.java | 92 +--
.../ignite/internal/util/CollectionUtils.java | 70 +-
.../apache/ignite/internal/util/GridUnsafe.java | 16 +-
.../internal/util/IgniteSpinReadWriteLock.java | 16 +-
.../apache/ignite/internal/util/IgniteUtils.java | 166 ++--
.../java/org/apache/ignite/logger/NullLogger.java | 48 +-
.../internal/testframework/IgniteTestUtils.java | 2 +-
.../testframework/WorkDirectoryExtensionTest.java | 30 +-
.../tostring/CircularStringBuilderSelfTest.java | 2 +-
.../tostring/IgniteToStringBuilderSelfTest.java | 84 +-
.../tostring/SensitiveDataToStringTest.java | 20 +-
.../ignite/internal/util/CollectionUtilsTest.java | 42 +-
.../internal/util/IgniteIntListSelfTest.java | 6 +-
.../internal/util/IgniteSpinReadWriteLockTest.java | 88 +--
.../org/apache/ignite/lang/LoggerHelperTest.java | 10 +-
.../server/persistence/RocksDbKeyValueStorage.java | 414 +++++-----
.../internal/metastorage/MetaStorageManager.java | 26 +-
.../metastorage/watch/WatchAggregator.java | 4 +-
.../ItTransferableObjectProcessorTest.java | 2 +-
.../internal/network/processor/TypeUtils.java | 2 +-
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../network/recovery/ItRecoveryHandshakeTest.java | 8 +-
.../ignite/utils/ClusterServiceTestUtils.java | 32 +-
.../network/direct/DirectMessageWriter.java | 2 +-
.../stream/DirectByteBufferStreamImplV1.java | 68 +-
.../internal/network/netty/ConnectionManager.java | 88 +--
.../network/netty/NamedNioEventLoopGroup.java | 4 +-
.../ignite/network/NettyBootstrapFactory.java | 28 +-
.../scalecube/ScaleCubeMessagingService.java | 34 +-
.../netty/IoExceptionSuppressingHandlerTest.java | 2 +-
.../internal/network/netty/NettyClientTest.java | 4 +-
.../internal/network/netty/NettyServerTest.java | 76 +-
.../network/processor/InheritedMessageTest.java | 2 +-
.../processor/SerializationOrderMessage.java | 6 +-
.../network/processor/SerializationOrderTest.java | 2 +-
.../MessageSerializationRegistryImplTest.java | 6 +-
.../apache/ignite/network/TestMessageTypes.java | 6 +-
.../dotnet/Apache.Ignite.Tests/Table/TableTests.cs | 19 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 31 +-
.../dotnet/Apache.Ignite/Table/ITableView.cs | 6 +-
.../ignite/raft/jraft/core/ItCliServiceTest.java | 7 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 74 +-
.../raft/server/ItJraftCounterServerTest.java | 138 +++-
.../java/org/apache/ignite/internal/raft/Loza.java | 105 ++-
.../internal/raft/server/impl/JraftServerImpl.java | 40 +
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 52 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 392 ++++++----
.../raft/jraft/core/ReadOnlyServiceImpl.java | 2 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 2 +-
.../raft/jraft/core/StateMachineAdapter.java | 7 +
.../ignite/raft/jraft/option/NodeOptions.java | 212 +++--
.../ignite/raft/jraft/option/RpcOptions.java | 67 +-
.../ignite/raft/jraft/rpc/ClientService.java | 14 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 84 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 26 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 11 +-
.../raft/jraft/rpc/impl/PingRequestProcessor.java | 5 +
.../raft/jraft/storage/impl/LogManagerImpl.java | 2 +-
.../storage/snapshot/SnapshotExecutorImpl.java | 2 +-
.../ignite/raft/jraft/util/timer/DefaultTimer.java | 2 +-
.../ignite/disruptor/StripedDisruptorTest.java | 46 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 85 ++
.../internal/raft/server/impl/RaftServerImpl.java | 4 +-
.../ignite/raft/jraft/core/MockStateMachine.java | 5 -
.../raft/jraft/core/ReadOnlyServiceTest.java | 1 -
.../apache/ignite/raft/jraft/core/TestCluster.java | 100 +--
.../raft/jraft/storage/SnapshotExecutorTest.java | 2 +-
.../apache/ignite/raft/jraft/test/TestUtils.java | 13 +
.../ConfigurationPresentationTest.java | 44 +-
.../calcite/AbstractBasicIntegrationTest.java | 52 +-
.../ignite/internal/calcite/ItAggregatesTest.java | 52 +-
.../ignite/internal/calcite/ItDataTypesTest.java | 26 +-
.../ignite/internal/calcite/ItFunctionsTest.java | 50 +-
.../apache/ignite/internal/calcite/ItJoinTest.java | 4 +-
.../ignite/internal/calcite/ItMetadataTest.java | 16 +-
.../internal/calcite/ItMixedQueriesTest.java | 98 +--
.../internal/calcite/ItOrToUnionRuleTest.java | 18 +-
.../calcite/ItProjectScanMergeRuleTest.java | 26 +-
.../internal/calcite/ItSecondaryIndexTest.java | 32 +-
.../ignite/internal/calcite/util/QueryChecker.java | 118 +--
.../ItDistributedConfigurationPropertiesTest.java | 78 +-
.../runner/app/AbstractSchemaChangeTest.java | 70 +-
.../internal/runner/app/IgniteCliRunnerTest.java | 2 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 22 +-
.../runner/app/ItDynamicTableCreationTest.java | 92 +--
.../runner/app/ItIgniteNodeRestartTest.java | 2 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 4 +-
.../internal/runner/app/ItTableCreationTest.java | 34 +-
.../internal/runner/app/ItTablesApiTest.java | 154 ++--
.../runner/app/ItThinClientConnectionTest.java | 6 +-
.../internal/test/WatchListenerInhibitor.java | 14 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 15 +-
.../storage/DistributedConfigurationStorage.java | 114 +--
.../org/apache/ignite/internal/schema/Column.java | 25 +-
.../org/apache/ignite/internal/schema/Columns.java | 5 +-
.../apache/ignite/internal/schema/NativeType.java | 3 +-
.../ignite/internal/schema/SchemaDescriptor.java | 3 +-
.../ignite/internal/schema/SchemaRegistry.java | 2 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 32 +-
.../configuration/ColumnTypeValidatorImpl.java | 14 +-
.../schema/configuration/TableValidatorImpl.java | 34 +-
.../builder/TableDefinitionBuilderImpl.java | 46 +-
.../internal/schema/mapping/ColumnMapper.java | 3 +-
.../internal/schema/mapping/ColumnMapping.java | 3 +-
.../internal/schema/marshaller/KvMarshaller.java | 6 +-
.../schema/marshaller/MarshallerFactory.java | 6 +-
.../internal/schema/marshaller/MarshallerUtil.java | 1 -
.../schema/marshaller/RecordMarshaller.java | 6 +-
.../marshaller/asm/AsmSerializerGenerator.java | 118 +--
.../marshaller/asm/ColumnAccessCodeGenerator.java | 8 +-
.../marshaller/reflection/JavaSerializer.java | 64 +-
.../marshaller/reflection/KvMarshallerImpl.java | 7 +-
.../schema/marshaller/reflection/Marshaller.java | 42 +-
.../reflection/RecordMarshallerImpl.java | 4 +-
.../marshaller/schema/SchemaSerializerImpl.java | 12 +-
.../schema/registry/SchemaRegistryImpl.java | 7 +-
.../ignite/internal/schema/row/RowAssembler.java | 2 +-
.../internal/schema/SchemaDescriptorTest.java | 12 +-
.../schema/builder/TableDefinitionBuilderTest.java | 4 +-
.../SchemaDescriptorConverterTest.java | 48 +-
.../schema/marshaller/JavaSerializerTest.java | 4 +-
.../schema/marshaller/KvMarshallerTest.java | 33 +-
.../internal/schema/marshaller/MapperTest.java | 2 -
.../schema/marshaller/RecordMarshallerTest.java | 280 +++----
.../RecordMarshallerValidationsTest.java | 241 ++++++
.../marshaller/reflection/ColumnBindingTest.java | 2 -
.../schema/serializer/AbstractSerializerTest.java | 10 +-
.../schema/testobjects/TestObjectWithAllTypes.java | 166 ++--
.../TestObjectWithNoDefaultConstructor.java | 16 +-
.../TestObjectWithPrivateConstructor.java | 20 +-
.../schema/testobjects/TestSimpleObject.java | 22 +-
.../storage/AbstractPartitionStorageTest.java | 386 +++++-----
.../storage/rocksdb/RocksDbStorageTest.java | 2 +-
.../schema/marshaller/TupleMarshaller.java | 4 +-
.../schema/marshaller/TupleMarshallerImpl.java | 102 +--
.../ignite/internal/table/KeyValueViewImpl.java | 6 -
.../internal/table/distributed/TableManager.java | 132 ++--
.../internal/table/MutableRowTupleAdapterTest.java | 234 +++---
.../internal/table/SchemaValidationTest.java | 10 +-
.../ignite/internal/table/TableManagerTest.java | 41 +-
.../table/impl/DummySchemaManagerImpl.java | 8 +-
.../table/type/NumericTypesSerializerTest.java | 76 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 2 +-
253 files changed, 7357 insertions(+), 6584 deletions(-)
create mode 100644 modules/raft/src/test/java/org/apache/ignite/internal/raft/LozaTest.java
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/RecordMarshallerValidationsTest.java