This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-28971
in repository https://gitbox.apache.org/repos/asf/ignite.git
from ef714001968 IGNITE-28971 Wip
add 7cd8ad1c7c1 IGNITE-28972 Generation must fail Message to byte[]
marshalling (#13461)
add 060c46d1f93 IGNITE-28961 TcpDiscoveryNode should not implement
SelfMarshallingMessage (#13450)
add 77e08e5debb Bump org.apache.maven.plugins:maven-shade-plugin from
3.6.1 to 3.6.2 (#13441)
add 009946c769d IGNITE-28724 Calcite engine. Support SELECT ... FOR UPDATE
query (#13366)
add 341b2557a01 IGNITE-28920 Reduce MarshallableMessage scope:
GridCacheEntryInfo uses marshal hooks only to rebase expireTime (#13447)
add f83f8a55305 IGNITE-28790 Use MessageSerializer to transfer continuous
query DTO's in DataBag. (#13426)
add ec42c2273f2 IGNITE-28947 Handle recursive CTE planning gracefully
(#13429)
add fb0a892ab6f IGNITE-28975 Added ClassNotFoundException handling for
ObjectInputStream.GetField#get method on JDK 21 (#13469)
add 4aaecc77230 IGNITE-28977 Remove SelfMarshallingMessage implementation
by ColocationGroup (#13468)
add 05f03f64837 IGNITE-28978 Make MDC-aware discovery ring mode testable
in a single JVM (#13471)
add 6105e021b6c IGNITE-28919 Add communication and discovery IO test
commands (#13399)
add 270a71f03b3 IGNITE-28270 Investigate possibity to use
MessageSerializer for ComputeJobSibling (#13445)
add dda84bf0603 IGNITE-28983 Fixed thin client hanging if the remote
endpoint stops responding during the SSL handshake without closing the socket
(#13477)
add 23b393d476f IGNITE-28987 ContinousRoutineLocalInfo should use same
marshaller as ContinousRoutineDiscoveryDataItem (#13478)
add 373d56dc41d [MINOR ] Add comment about Message indexes reserved for
plugins (#13480)
add 9eb92c4f444 IGNITE-28984 Fix compilation after bump org.apache:apache
version (#13476)
add 3c6463f1ec2 IGNITE-28940 Choose the marshaller by transport, not by
message class (#13462)
add 94c6d921df4 IGNITE-28989 update log4j dependency (#13484)
add 86943b54d24 IGNITE-28990 Extended IgniteClusterNode API with Ignite
Features getter (#13488)
add 7cb7b6cb807 Bump org.openjdk.jol:jol-core from 0.9 to 0.17 (#13473)
add 822971b5e06 IGNITE-28957 Calcite SELECT FOR UPDATE may cause OOM by
materializing the entire result set (#13482)
add 54df6eb0549 IGNITE-28739 SQL Calcite: Add expression support for FETCH
(#13464)
add daed75d7136 Merge branch 'master' into ignite-28971
No new revisions were added by this update.
Summary of changes:
.github/workflows/commit-check.yml | 2 +-
docs/_docs/tools/control-script.adoc | 50 +
modules/benchmarks/pom.xml | 2 +-
.../direct/JmhDirectMessageReaderBenchmark.java | 3 +-
.../jol/GridAffinityAssignmentJolBenchmark.java | 5 +-
modules/calcite/pom.xml | 8 +
modules/calcite/src/main/codegen/config.fmpp | 16 +-
.../src/main/codegen/includes/parserImpls.ftl | 131 +
.../processors/query/calcite/RootQuery.java | 37 +
.../query/calcite/exec/ExecutionServiceImpl.java | 445 +
.../query/calcite/exec/LogicalRelImplementor.java | 12 +-
.../query/calcite/message/GenericValueMessage.java | 2 -
.../query/calcite/message/MessageServiceImpl.java | 4 +-
.../query/calcite/message/QueryStartRequest.java | 6 +-
.../query/calcite/metadata/ColocationGroup.java | 35 +-
.../calcite/metadata/FragmentDescription.java | 35 +-
.../query/calcite/metadata/IgniteMdCollation.java | 4 +-
.../calcite/metadata/IgniteMdDistribution.java | 4 +-
...tinctRowCount.java => IgniteMdMinRowCount.java} | 43 +-
.../query/calcite/metadata/IgniteMetadata.java | 1 +
.../query/calcite/prepare/IgnitePlanner.java | 9 +
.../calcite/prepare/IgniteRelFieldTrimmer.java | 94 +
.../calcite/prepare/IgniteSqlToRelConvertor.java | 6 +
.../query/calcite/prepare/IgniteSqlValidator.java | 157 +-
.../query/calcite/prepare/PlannerPhase.java | 5 +-
.../query/calcite/prepare/PrepareServiceImpl.java | 327 +
.../query/calcite/prepare/QueryPlan.java | 2 +-
.../query/calcite/prepare/SelectForUpdatePlan.java | 142 +
.../prepare/ddl/SqlToNativeCommandConverter.java | 3 +-
.../query/calcite/rule/SortConverterRule.java | 60 +-
.../calcite/schema/CacheTableDescriptorImpl.java | 106 +-
.../calcite/sql/IgniteSqlSelectForUpdate.java | 131 +
.../calcite/sql/generated/IgniteSqlParserImpl.java | 15281 ++++++++++---------
.../generated/IgniteSqlParserImplConstants.java | 148 +-
.../generated/IgniteSqlParserImplTokenManager.java | 9626 ++++++------
.../query/calcite/util/IgniteResource.java | 16 +
.../calcite/exec/rel/ContinuousExecutionTest.java | 3 -
.../integration/AbstractBasicIntegrationTest.java | 36 +-
.../BulkOperationDeadlockIntegrationTest.java | 348 +
.../integration/CorrelatesIntegrationTest.java | 17 +
.../DynamicParametersIntegrationTest.java | 203 +
.../integration/KillCommandDdlIntegrationTest.java | 2 +-
.../integration/LimitOffsetIntegrationTest.java | 204 +-
.../integration/MemoryQuotasIntegrationTest.java | 29 +-
.../OperatorsExtensionIntegrationTest.java | 59 +
.../integration/RecursiveCteIntegrationTest.java | 60 +
.../SelectForUpdateIntegrationTest.java | 682 +
.../calcite/integration/SystemColumnsScanTest.java | 323 +
...lciteCommunicationMessageSerializationTest.java | 3 -
.../calcite/planner/LimitOffsetPlannerTest.java | 79 +
.../query/calcite/planner/PlanExecutionTest.java | 3 -
.../calcite/sql/SqlSelectForUpdateParserTest.java | 206 +
.../ignite/testsuites/IgniteCalciteTestSuite.java | 2 +
.../ignite/testsuites/IntegrationTestSuite.java | 8 +
modules/checkstyle/pom.xml | 7 -
.../{EmptyMessage.java => JdkMarshalled.java} | 10 +-
.../internal/MessageMarshallerGenerator.java | 191 +-
.../commandline/CommandHandlerParsingTest.java | 2 +
.../testsuites/IgniteControlUtilityTestSuite2.java | 2 +
.../org/apache/ignite/util/IoTestCommandTest.java | 126 +
.../ignite/internal/ClusterMetricsSnapshot.java | 1167 +-
.../ignite/internal/CoreMessagesProvider.java | 43 +-
.../ignite/internal/GridEventConsumeHandler.java | 76 +-
.../ignite/internal/GridJobExecuteRequest.java | 39 +-
.../ignite/internal/GridJobExecuteResponse.java | 1 -
.../apache/ignite/internal/GridJobSiblingImpl.java | 35 +-
.../ignite/internal/GridJobSiblingsResponse.java | 19 +-
.../ignite/internal/GridMessageListenHandler.java | 113 +-
.../ignite/internal/GridTaskSessionImpl.java | 6 +-
.../ignite/internal/GridTaskSessionRequest.java | 1 -
.../apache/ignite/internal/GridTopicMessage.java | 1 -
.../ignite/internal/IgniteDiagnosticRequest.java | 1 -
.../org/apache/ignite/internal/IgniteKernal.java | 38 +-
.../apache/ignite/internal/IgniteMXBeanImpl.java | 28 +-
.../org/apache/ignite/internal/TxEntriesInfo.java | 1 -
.../ignite/internal/UseBinaryMarshaller.java | 38 -
.../internal/cluster/ClusterGroupAdapter.java | 2 +-
.../internal/management/IgniteCommandRegistry.java | 4 +-
.../{cdc/CdcCommand.java => io/IoTestCommand.java} | 12 +-
.../management/io/IoTestCommunicationCommand.java | 152 +
.../io/IoTestCommunicationCommandArg.java | 120 +
.../management/io/IoTestCommunicationTask.java | 113 +
.../management/io/IoTestDiscoveryCommand.java | 136 +
.../management/io/IoTestDiscoveryCommandArg.java | 96 +
.../IoTestDiscoveryTask.java} | 38 +-
.../communication/CommunicationMarshalling.java | 61 +
.../communication/DiscoveryMarshalling.java | 52 +
.../managers/communication/GridIoManager.java | 717 +-
.../managers/communication/GridIoUserMessage.java | 2 -
.../communication/IgniteIoTestMessage.java | 299 +-
.../managers/communication/IoTestHandler.java | 753 +
.../managers/communication/IoTestResult.java | 234 +
.../managers/communication/MessageMarshalling.java | 44 +-
.../deployment/GridDeploymentInfoMessage.java | 2 +-
.../managers/discovery/GridDiscoveryManager.java | 10 +
.../managers/discovery/IgniteClusterNode.java | 8 +
.../discovery/IoTestDiscoveryAckMessage.java | 69 +
.../managers/discovery/IoTestDiscoveryHandler.java | 275 +
.../managers/discovery/IoTestDiscoveryMessage.java | 88 +
.../managers/discovery/IoTestDiscoveryResult.java | 181 +
.../managers/eventstorage/EventsDataBagItem.java | 2 -
.../eventstorage/GridEventStorageManager.java | 4 +-
.../eventstorage/GridEventStorageRequest.java | 2 -
.../eventstorage/GridEventStorageResponse.java | 2 -
.../plugin/AbstractMessageFactoryProvider.java | 51 +-
.../processors/affinity/GridAffinityUtils.java | 2 +-
.../cache/CacheEntryPredicateAdapter.java | 2 -
.../processors/cache/CacheEvictionEntry.java | 2 -
.../processors/cache/CacheInvokeDirectResult.java | 2 -
.../processors/cache/GridCacheAdapter.java | 64 +-
.../processors/cache/GridCacheEntryInfo.java | 128 +-
.../processors/cache/GridCacheIoManager.java | 4 +-
.../processors/cache/GridCacheMapEntry.java | 16 +-
.../internal/processors/cache/GridCacheReturn.java | 2 -
.../internal/processors/cache/StoredCacheData.java | 4 +
.../cache/binary/BinaryMetadataVersionInfo.java | 6 +-
.../distributed/GridCacheTtlUpdateRequest.java | 2 -
.../distributed/GridDistributedLockRequest.java | 2 -
.../distributed/GridDistributedLockResponse.java | 2 -
.../GridDistributedTxPrepareRequest.java | 2 -
.../cache/distributed/GridNearUnlockRequest.java | 2 -
.../cache/distributed/dht/GridDhtGetFuture.java | 20 +-
.../distributed/dht/GridDhtGetSingleFuture.java | 20 +-
.../cache/distributed/dht/GridDhtLockRequest.java | 2 -
.../cache/distributed/dht/GridDhtLockResponse.java | 2 -
.../dht/GridDhtTransactionalCacheAdapter.java | 9 +-
.../distributed/dht/GridDhtTxFinishResponse.java | 2 -
.../distributed/dht/GridDhtTxPrepareRequest.java | 2 -
.../distributed/dht/GridDhtTxPrepareResponse.java | 2 -
.../distributed/dht/GridDhtUnlockRequest.java | 2 -
.../dht/TransactionAttributesAwareRequest.java | 2 -
.../AtomicApplicationAttributesAwareRequest.java | 2 -
.../atomic/GridDhtAtomicSingleUpdateRequest.java | 2 -
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 2 -
.../atomic/GridNearAtomicFullUpdateRequest.java | 2 -
.../GridNearAtomicSingleUpdateFilterRequest.java | 2 -
.../GridNearAtomicSingleUpdateInvokeRequest.java | 2 -
.../atomic/GridNearAtomicSingleUpdateRequest.java | 2 -
.../dht/atomic/GridNearAtomicUpdateResponse.java | 2 -
.../distributed/dht/atomic/NearCacheUpdates.java | 2 -
.../cache/distributed/dht/atomic/UpdateErrors.java | 2 -
.../dht/preloader/GridDhtForceKeysRequest.java | 2 -
.../dht/preloader/GridDhtForceKeysResponse.java | 2 -
.../dht/preloader/GridDhtPartitionSupplier.java | 20 +-
.../preloader/GridDhtPartitionSupplyMessage.java | 2 -
.../preloader/GridDhtPartitionsExchangeFuture.java | 4 +-
.../cache/distributed/near/GridNearGetRequest.java | 2 -
.../distributed/near/GridNearGetResponse.java | 2 -
.../distributed/near/GridNearSingleGetRequest.java | 2 -
.../near/GridNearSingleGetResponse.java | 2 -
.../near/GridNearTxPrepareResponse.java | 2 -
.../wal/reader/StandaloneGridKernalContext.java | 8 +-
.../cache/query/GridCacheQueryRequest.java | 2 -
.../cache/query/GridCacheQueryResponse.java | 2 -
.../CacheContinuousQueryDeployableObject.java | 37 +-
.../continuous/CacheContinuousQueryEntry.java | 2 -
.../continuous/CacheContinuousQueryHandler.java | 337 +-
.../cache/transactions/IgniteTxEntry.java | 2 -
.../processors/cache/transactions/IgniteTxKey.java | 2 -
.../cache/transactions/IgniteTxManager.java | 4 +-
.../cache/transactions/TxEntryValueHolder.java | 2 -
.../cache/transactions/TxLocksRequest.java | 2 -
.../cache/transactions/TxLocksResponse.java | 2 -
.../cache/verify/PartitionHashRecord.java | 9 +-
.../cache/verify/TransactionsHashRecord.java | 9 +-
.../processors/cluster/NodeFullMetricsMessage.java | 9 +-
.../processors/cluster/NodeMetricsMessage.java | 1344 --
.../ContinousRoutineDiscoveryData.java} | 47 +-
.../ContinousRoutineDiscoveryDataItem.java | 96 +
.../continuous/ContinousRoutineLocalInfo.java | 131 +
.../continuous/ContinuousRoutineInfo.java | 44 +-
.../ContinuousRoutinesCommonDiscoveryData.java | 14 +-
...ContinuousRoutinesJoiningNodeDiscoveryData.java | 14 +-
.../continuous/GridContinuousHandler.java | 4 +-
.../continuous/GridContinuousProcessor.java | 387 +-
.../processors/continuous/StartRequestData.java | 5 +-
.../datastreamer/DataStreamProcessor.java | 4 +-
.../processors/datastreamer/DataStreamerEntry.java | 2 -
.../datastreamer/DataStreamerReceiverMessage.java | 2 -
.../internal/processors/job/GridJobProcessor.java | 43 +-
.../internal/processors/job/GridJobWorker.java | 8 +-
.../processors/query/QueryTypeDescriptorImpl.java | 12 +-
.../internal/processors/query/QueryUtils.java | 9 +
.../query/schema/management/SchemaManager.java | 3 +-
.../rest/handlers/task/GridTaskResultResponse.java | 2 -
.../rollingupgrade/RollingUpgradeClusterData.java | 13 +-
.../rollingupgrade/RollingUpgradeProcessor.java | 101 +-
.../feature/IgniteNodeFeatureSet.java | 87 +-
.../service/ServiceSingleNodeDeploymentResult.java | 2 -
.../session/GridTaskSessionProcessor.java | 2 +-
.../internal/processors/task/GridTaskWorker.java | 6 +-
.../apache/ignite/internal/util/ErrorMessage.java | 5 +
.../util/distributed/SingleNodeMessage.java | 5 +
.../org/apache/ignite/mxbean/IgniteMXBean.java | 10 +-
.../communication/MessageMarshaller.java | 17 +-
.../security/SecurityBasicPermissionSet.java | 2 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 4 +-
.../ignite/spi/discovery/DiscoveryDataBag.java | 8 -
.../discovery/isolated/IsolatedDiscoverySpi.java | 8 +-
.../spi/discovery/isolated/IsolatedNode.java | 13 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 8 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 19 +-
.../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 3 +-
.../spi/discovery/tcp/TcpDiscoveryIoSession.java | 11 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 30 +-
.../discovery/tcp/internal/TcpDiscoveryNode.java | 81 +-
.../tcp/internal/TcpDiscoveryNodesRing.java | 8 +-
.../TcpDiscoveryClientMetricsUpdateMessage.java | 8 +-
.../TcpDiscoveryClientNodesMetricsMessage.java | 8 +-
.../tcp/messages/TcpDiscoveryHandshakeRequest.java | 7 +-
.../messages/TcpDiscoveryHandshakeResponse.java | 7 +-
.../messages/TcpDiscoveryMetricsUpdateMessage.java | 6 +-
.../main/resources/META-INF/classnames.properties | 1 -
.../thin/ThinClientHandshakeTimeoutTest.java | 199 +
.../internal/codegen/MessageProcessorTest.java | 74 +
.../direct/DirectMarshallingMessagesTest.java | 3 +-
.../IgniteCoreMessagesSerializationTest.java | 3 +-
.../communication/CompressedMessageTest.java | 3 +-
.../GridIoManagerOrderedUnmarshalFailureTest.java | 7 +-
.../communication/IgniteIoTestMessagesTest.java | 308 +-
...MessageFactoryMarshallerInitializationTest.java | 138 -
.../affinity/GridAffinityAssignmentV2Test.java | 4 +-
.../processors/cache/GridCacheTestEntryEx.java | 11 +-
.../query/GridCacheQueryResponseUnmarshalTest.java | 6 +-
.../CacheContinuousQueryEntriesExpireTest.java | 4 +-
...ueryRemoteFilterMissingInClassPathSelfTest.java | 53 +-
...coveryDataDeserializationFailureHanderTest.java | 1 +
...GridCacheContinuousQueryNodesFilteringTest.java | 15 +-
...niteCacheContinuousQueryImmutableEntryTest.java | 3 +-
.../TxDeadlockDetectionMessageMarshallingTest.java | 8 +-
.../continuous/GridEventConsumeSelfTest.java | 9 +-
.../datastreamer/DataStreamerImplSelfTest.java | 4 +-
.../QueryEntityMessageSerializationTest.java | 14 +-
...rviceConfigurationMessageSerializationTest.java | 14 +-
.../OperationContextAttributePropagationTest.java | 4 +-
.../DistributedProcessResultMarshallingTest.java | 323 +
.../communication/MessageMarshalOnceTest.java | 13 +-
...ecurityBasicPermissionSetSerializationTest.java | 3 +-
.../apache/ignite/spi/MessagesPluginProvider.java | 20 +-
...dJobStealingCollisionSpiAttributesSelfTest.java | 3 +-
...StealingCollisionSpiCustomTopologySelfTest.java | 3 +-
.../GridJobStealingCollisionSpiSelfTest.java | 3 +-
.../GridAbstractCommunicationSelfTest.java | 3 +-
...unicationInverseConnectionEstablishingTest.java | 6 +-
...pCommunicationSpiConcurrentConnectSelfTest.java | 3 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 3 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 3 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 3 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 3 +-
.../tcp/GridTotallyUnreachableClientTest.java | 4 +-
.../IgniteTcpCommunicationHandshakeWaitTest.java | 2 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 3 +-
.../ClusterMetricsSnapshotSerializeSelfTest.java | 3 +-
.../tcp/DiscoveryUnmarshalVulnerabilityTest.java | 26 +-
.../spi/discovery/tcp/TestTcpDiscoverySpi.java | 3 +-
.../ignite/testframework/GridSpiTestContext.java | 6 +-
.../apache/ignite/testframework/GridTestUtils.java | 15 +-
.../ignite/testframework/junits/IgniteMock.java | 2 +-
.../ignite/testsuites/IgniteBasicTestSuite.java | 2 -
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 2 +
.../ignite/util/GridTopologyHeapSizeSelfTest.java | 3 +-
...sage.java => IncorrectMarshalledOnMessage.java} | 15 +-
...java => IncorrectMarshalledOnMessageArray.java} | 15 +-
...=> IncorrectMarshalledOnMessageCollection.java} | 17 +-
...> IncorrectMarshalledOnMessageCollection2.java} | 17 +-
...> IncorrectMarshalledOnMessageCollection3.java} | 17 +-
...> IncorrectMarshalledOnMessageCollection4.java} | 17 +-
...correctMarshalledOnMessageCollectionArray.java} | 17 +-
....java => IncorrectMarshalledOnMessageList.java} | 17 +-
...java => IncorrectMarshalledOnMessageList2.java} | 17 +-
...e.java => IncorrectMarshalledOnMessageMap.java} | 16 +-
....java => IncorrectMarshalledOnMessageMap2.java} | 18 +-
....java => IncorrectMarshalledOnMessageMap3.java} | 16 +-
....java => IncorrectMarshalledOnMessageMap4.java} | 16 +-
...e.java => IncorrectMarshalledOnMessageSet.java} | 16 +-
...age.java => IncorrectRawCollectionMessage.java} | 16 +-
...ge.java => IncorrectRawCollectionMessage2.java} | 16 +-
...peMessage.java => IncorrectRawListMessage.java} | 17 +-
...eMessage.java => IncorrectRawListMessage2.java} | 17 +-
...ageMessage.java => IncorrectRawMapMessage.java} | 16 +-
...geMessage.java => IncorrectRawMapMessage2.java} | 16 +-
.../codegen/TestCollectionsMessageMarshaller.java | 5 +-
...age.java => TestJdkMarshalledChildMessage.java} | 10 +-
.../TestJdkMarshalledChildMessageMarshaller.java | 83 +
...dMessage.java => TestJdkMarshalledMessage.java} | 10 +-
.../TestJdkMarshalledMessageMarshaller.java | 74 +
.../codegen/TestMapMessageMarshaller.java | 5 +-
.../codegen/TestMarshallableMessageMarshaller.java | 16 +-
.../TestMarshalledArrayMapMessageMarshaller.java | 21 +-
.../TestMarshalledCollectionMessageMarshaller.java | 5 +-
.../TestMarshalledMapMessageMarshaller.java | 5 +-
.../codegen/TestMarshalledMessageMarshaller.java | 16 +-
.../TestMarshalledObjectsMessageMarshaller.java | 16 +-
.../resources/codegen/TestMessageMarshaller.java | 11 +-
.../TestSelfMarshallingMessageMarshaller.java | 7 +-
...ridCommandHandlerClusterByClassTest_help.output | 19 +
...andHandlerClusterByClassWithSSLTest_help.output | 19 +
.../org/apache/ignite/client/ClientTestSuite.java | 2 +
.../processors/query/SqlSystemViewsSelfTest.java | 15 +-
.../ignite/internal/client/thin/ClientUtils.java | 23 +
.../internal/client/thin/TcpClientChannel.java | 22 +-
.../GridNioClientConnectionMultiplexer.java | 101 +-
.../cache/IgniteIoTestSendAllBenchmark.java | 2 +-
.../cache/IgniteIoTestSendRandomBenchmark.java | 2 +-
.../yardstick/io/IgniteIoTestSendAllBenchmark.java | 2 +-
.../io/IgniteIoTestSendRandomBenchmark.java | 2 +-
.../spi/discovery/zk/ZookeeperDiscoverySpi.java | 13 +-
.../zk/internal/DiscoveryMessageParser.java | 6 +-
.../zk/internal/ZookeeperClusterNode.java | 17 +
.../zk/internal/ZookeeperDiscoveryImpl.java | 2 +-
.../zk/internal/ZookeeperDiscoverySpiTestBase.java | 14 +-
parent/pom.xml | 11 +-
312 files changed, 23447 insertions(+), 16930 deletions(-)
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/{IgniteMdDistinctRowCount.java
=> IgniteMdMinRowCount.java} (51%)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteRelFieldTrimmer.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/SelectForUpdatePlan.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/sql/IgniteSqlSelectForUpdate.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/BulkOperationDeadlockIntegrationTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/RecursiveCteIntegrationTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/SelectForUpdateIntegrationTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/SystemColumnsScanTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/sql/SqlSelectForUpdateParserTest.java
copy
modules/codegen/src/main/java/org/apache/ignite/internal/{EmptyMessage.java =>
JdkMarshalled.java} (68%)
create mode 100644
modules/control-utility/src/test/java/org/apache/ignite/util/IoTestCommandTest.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/UseBinaryMarshaller.java
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{cdc/CdcCommand.java
=> io/IoTestCommand.java} (79%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestCommunicationCommand.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestCommunicationCommandArg.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestCommunicationTask.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestDiscoveryCommand.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestDiscoveryCommandArg.java
copy
modules/core/src/main/java/org/apache/ignite/internal/management/{kill/ScanQueryCancelTask.java
=> io/IoTestDiscoveryTask.java} (59%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/CommunicationMarshalling.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/DiscoveryMarshalling.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IoTestHandler.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IoTestResult.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryAckMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryHandler.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/IoTestDiscoveryResult.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/NodeMetricsMessage.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/{authentication/AuthentificationDataBagItem.java
=> continuous/ContinousRoutineDiscoveryData.java} (54%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/ContinousRoutineDiscoveryDataItem.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/ContinousRoutineLocalInfo.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/client/thin/ThinClientHandshakeTimeoutTest.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/managers/communication/MessageFactoryMarshallerInitializationTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/distributed/DistributedProcessResultMarshallingTest.java
copy modules/core/src/test/resources/codegen/{NioFieldOnNonMessageMessage.java
=> IncorrectMarshalledOnMessage.java} (85%)
copy modules/core/src/test/resources/codegen/{NioFieldOnNonMessageMessage.java
=> IncorrectMarshalledOnMessageArray.java} (84%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledObjectsMessage.java =>
IncorrectMarshalledOnMessageCollection.java} (81%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledObjectsMessage.java =>
IncorrectMarshalledOnMessageCollection2.java} (81%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledObjectsMessage.java =>
IncorrectMarshalledOnMessageCollection3.java} (81%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledObjectsMessage.java =>
IncorrectMarshalledOnMessageCollection4.java} (81%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledObjectsMessage.java =>
IncorrectMarshalledOnMessageCollectionArray.java} (81%)
copy
modules/core/src/test/resources/codegen/{TestCompressUnsupportedTypeMessage.java
=> IncorrectMarshalledOnMessageList.java} (84%)
copy
modules/core/src/test/resources/codegen/{TestCompressUnsupportedTypeMessage.java
=> IncorrectMarshalledOnMessageList2.java} (83%)
copy modules/core/src/test/resources/codegen/{TestMarshalledMessage.java =>
IncorrectMarshalledOnMessageMap.java} (82%)
copy
modules/core/src/test/resources/codegen/{TestCompressUnsupportedTypeMessage.java
=> IncorrectMarshalledOnMessageMap2.java} (82%)
copy modules/core/src/test/resources/codegen/{NioFieldOnNonMessageMessage.java
=> IncorrectMarshalledOnMessageMap3.java} (81%)
copy modules/core/src/test/resources/codegen/{WrongEnumSetMessage.java =>
IncorrectMarshalledOnMessageMap4.java} (81%)
copy modules/core/src/test/resources/codegen/{TestMarshalledMessage.java =>
IncorrectMarshalledOnMessageSet.java} (82%)
copy modules/core/src/test/resources/codegen/{TestMarshalledMessage.java =>
IncorrectRawCollectionMessage.java} (82%)
copy modules/core/src/test/resources/codegen/{TestMarshalledMessage.java =>
IncorrectRawCollectionMessage2.java} (82%)
copy
modules/core/src/test/resources/codegen/{TestCompressUnsupportedTypeMessage.java
=> IncorrectRawListMessage.java} (85%)
copy
modules/core/src/test/resources/codegen/{TestCompressUnsupportedTypeMessage.java
=> IncorrectRawListMessage2.java} (85%)
copy modules/core/src/test/resources/codegen/{NioFieldOnNonMessageMessage.java
=> IncorrectRawMapMessage.java} (84%)
copy modules/core/src/test/resources/codegen/{NioFieldOnNonMessageMessage.java
=> IncorrectRawMapMessage2.java} (83%)
copy modules/core/src/test/resources/codegen/{NioFieldOnNonMessageMessage.java
=> TestJdkMarshalledChildMessage.java} (83%)
create mode 100644
modules/core/src/test/resources/codegen/TestJdkMarshalledChildMessageMarshaller.java
copy modules/core/src/test/resources/codegen/{TestMarshalledMessage.java =>
TestJdkMarshalledMessage.java} (86%)
create mode 100644
modules/core/src/test/resources/codegen/TestJdkMarshalledMessageMarshaller.java
