This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch dependabot/maven/hamcrest.version-3.0
in repository https://gitbox.apache.org/repos/asf/ignite.git
omit 7d779c609b9 Bump hamcrest.version from 2.2 to 3.0
add e330af5355a IGNITE-28929 Move marshaller info into Messages classes
(#13410)
add a668494620f IGNITE-27833 [ducktests] Add Multi-DC Integration Test for
Cross-DC Network Partition Resilience (#12740)
add f9ebf2aa13b IGNITE-28934 Create message with direct constructor call
(#13416)
add 4927eec73bf IGNITE-28356 Get rid of redundant wire companion fields
and hand-written marshalling in messages (#13408)
add e59277bfcf2 IGNITE-28925 SQL Calcite: Fix unexpected
downstream().end() call for execution nodes - Fixes #13407.
add a20d1c0f302 IGNITE-28928 Use MessageSerializer for
SecurityPermissionSet (#13414)
add 5c899284ac5 IGNITE-28855 Client node permanently loses discovery
events delivered right after the reconnect response (#13327)
add 32bbb11c1e5 IGNITE-28936 Remove dead marshalling code from
GridDhtAtomicUpdateRequest (#13419)
add 2cb678f080d IGNITE-28924 SQL Calcite: Add the ability to implement a
custom DistinctAccumulator (#13405)
add 5e1e3ee4480 IGNITE-28943 Fix incorrect test file name in
MessageProcessorTest (#13423)
add 5394a9fa23a IGNITE-28736 Fixed order of fields in
BinaryType#fieldNames (#13411)
add a4b46a1f88b IGNITE-28937 Register core messages uniformly: drop
withSchema/withNoSchema (#13421)
add 152157d0040 IGNITE-27606 Replace GridUnsafe with byte-array VarHandle
views in PartitionUpdateCountersMessage (#13422)
add bc4c25c5ef3 IGNITE-28792 Use MessageSerializer to transfer
CacheGroupData and CacheData (#13386)
add f9273aef880 IGNITE-28946 Statically configured
IgniteMarshallerClassFilter (#13425)
add 4b92f71c2bb IGNITE-28901 Split GridEventStorageMessage into a request
and a response (#13428)
add 54f054c4fd7 IGNITE-28953 Init CalciteMessageFactory with marshallers
in Calcite tests (#13434)
add 19c424181c0 IGNITE-28793 Use MessageSerializer to transfer
BaselineStateAndHistoryData (#13412)
add 746cbb37d7f IGNITE-28791 Use MessageSerializer to transfer metastorage
DTO's in DataBag (#13409)
add 5cbb7fc2c1c IGNITE-28271 Use the generated marshalling for
GridJobExecuteResponse (#13435)
add 88d7dfb824f IGNITE-28930 Default field values are lost on remote nodes
when a query entity is added dynamically (#13430)
add 3209af44754 IGNITE-28938 Split MarshallableMessage: a message with a
custom wire form needs no marshaller (#13427)
add 601c69f6a7b IGNITE-28844 Calcite. Improve type checking in LIMIT /
OFFSET clauses (#13311)
add 9d17faa242f IGNITE-28719 Revise GridTopicMessage usage in messages
(#13438)
add e58ce26400d IGNITE-28946 Apply class name filter always (#13436)
add 5a9692d3eaf IGNITE-28944 Refactor SecurityPermissionSet (#13424)
add 08a835b1d9f IGNITE-26630 Separate the stripe key from the cache
partition (#13437)
add 109627e8173 IGNITE-28912 Move ErrorMessage to a common internal
package (#13443)
add 10a198c22a3 IGNITE-28956 Document Jetty 12 configuration changes
(#13448)
add c3da0f8d13c IGNITE-28960 Add annotation for empty messages (#13446)
add 2a37fcb3a1b IGNITE-28896 SQL Calcite: Adjust fractional value handling
in FETCH, OFFSET, and LIMIT (#13375)
add f86423746a0 IGNITE-28963 Added support for EnumSet collection type
during message serialization (#13451)
add c9e8b90ac03 Bump org.mock-server:mockserver-netty from 5.15.0 to 7.4.0
(#13442)
add 862cb4e37b4 IGNITE-28669 Removed usages of legacy security
compatibility properties (#13444)
add 00ce56d90bd IGNITE-28951 Fixed NPE in
TcpDiscoverySharedFsIpFinder#getRegisteredAddresses() for File.list() == null
(#13452)
add 9d67e0d1349 IGNITE-24401 Document nested SQL in Calcite UDFs (#13248)
add 32d3cad3f56 IGNITE-28528 Revise marshalling of the node filter in
StartRequestData (#13440)
add e18edd87deb IGNITE-28969 Added remote node features validation during
the TCP Discovery handshake (#13456)
add 119fc236342 IGNITE-28970 Remove stale methods from OptimizedMarshaller
(#13457)
add afcd7414baa IGNITE-19599 Document defragmentation status command
(#13460)
add 9bfb0553471 IGNITE-28970 Remove OptimizedMarshallerIdMapper (#13458)
add 54159731e86 IGNITE-27977 Refactor bytes serialization for
DataStreamerRequest (#13454)
add c21741a0c78 IGNITE-28959 Calcite. Merge Join occasionally return wrong
results (#13455)
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 28d9ed8408f IGNITE-28995 Fix publication of apache ignite snapshot
(#13492)
add 8a7dfc81dac IGNITE-28980
BinaryMemoryAllocator$ThreadLocalAllocator$Chunk resets maxMsgSize on shrink
check (#13487)
add 77ae40479b8 IGNITE-28991 GridDhtPartitionsSingleMessage might not
implement undesirable SelfMarshallingMessage (#13489)
add fd959e7c36c IGNITE-28981 Document Calcite SELECT FOR UPDATE (#13475)
add b8a009ececa IGNITE-28994 GridDhtPartitionsFullMessage might not
implement undesirable SelfMarshallingMessage (#13493)
add 174bde616a1 IGNITE-28900 Control-utility: Add mass query cancellation
command (#13420)
add e99390aaf75 IGNITE-28992 Fixed SSL handshake timeout deadlock in the
client connector (#13501)
add 798eb3e064b IGNITE-28971 SQL Calcite: Introduce value resolver for
FETCH, OFFSET, and LIMIT (#13467)
add e810b692686 IGNITE-28999 SQL Calcite: Plugable SQL grama (#13496)
add 1038d67cfd1 IGNITE-28998 Fix java doc build phase issues (#13498)
add 4cac38bd7e8 IGNITE-28996 Idle Verify utility shouldn't use Java's
ForkJoinPool (#13494)
add 9b091178c9a Bump at.yawk.lz4:lz4-java from 1.11.1 to 1.11.2 (#13500)
add f94c115ea6c IGNITE-28895 Document Calcite window functions (#13374)
add ecc045c6173 IGNITE-28826 Ducktests development guide. (#13285)
add 10c75392f67 IGNITE-29003 SQL Calcite: Support scalar subqueries in
table function arguments (#13506)
add f18cae5ff04 IGNITE-28341 Fix incorrect WHERE condition pushdown for
LEFT OUTER JOIN in GridSqlQuerySplitter- #13502
add 25ab91529c9 Bump sqlline:sqlline from 1.9.0 to 1.12.0 (#13499)
add e6828258c2e IGNITE-29008 SQL Calcite: Support custom aggregate
functions with SqlKind.OTHER_FUNCTION (#13511)
add 36bb502ea38 IGNITE-29000 NPE can be raised from
GridCachePartitionExchangeManager#lastAffinityChangedTopologyVersion (#13504)
add ff25813b2ae IGNITE-29007 Clean partsSizes in the
GridDhtPartitionsFullMessage.cleanUp method
add 28d7909c097 IGNITE-28612 Stale near-cache value may be returned after
rollback to savepoint (#13515)
add 464e82f28cc IGNITE-29002 VerifyBackupPartitionsTask should not use
test-only executor (#13508)
add dad9b9f8798 Bump hamcrest.version from 2.2 to 3.0
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 (7d779c609b9)
\
N -- N -- N refs/heads/dependabot/maven/hamcrest.version-3.0
(dad9b9f8798)
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/commit-check.yml | 2 +-
assembly/release-apache-ignite-base.xml | 2 +-
docs/_data/toc.yaml | 2 +
docs/_docs/SQL/custom-sql-func.adoc | 4 +
docs/_docs/SQL/sql-calcite.adoc | 27 +-
docs/_docs/code-snippets/xml/jetty.xml | 13 +-
.../native-persistence-defragmentation.adoc | 47 +-
docs/_docs/restapi.adoc | 4 +
docs/_docs/sql-reference/window-functions.adoc | 163 +
docs/_docs/tools/control-script.adoc | 125 +
modules/benchmarks/pom.xml | 2 +-
.../direct/JmhDirectMessageReaderBenchmark.java | 3 +-
.../benchmarks/jmh/sql/JmhSqlJoinBenchmark.java | 35 +
.../jol/GridAffinityAssignmentJolBenchmark.java | 5 +-
.../java/org/apache/ignite/binary/BinaryType.java | 6 +-
.../ignite/internal/binary/BinaryContext.java | 13 +-
.../ignite/internal/binary/BinaryMetadata.java | 7 +-
.../internal/binary/BinaryMetadataCollector.java | 6 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 15 +-
.../internal/marshaller/ClassLoaderUtils.java | 209 +
.../marshaller/optimized/OptimizedMarshaller.java | 34 -
.../optimized/OptimizedMarshallerIdMapper.java | 33 -
.../ignite/marshaller/MarshallerContext.java | 8 -
.../apache/ignite/marshaller/MarshallerUtils.java | 87 +-
.../org/apache/ignite/marshaller/Marshallers.java | 24 +-
.../ignite/marshaller/MarshallersFactory.java | 19 +-
.../ignite/internal/binary/BinaryReaderExImpl.java | 6 +-
.../internal/binary/builder/BinaryBuilderEnum.java | 5 +-
.../binary/builder/BinaryEnumArrayLazyValue.java | 5 +-
.../binary/builder/BinaryObjectArrayLazyValue.java | 5 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 4 +-
.../binary/streams/BinaryMemoryAllocator.java | 1 +
.../optimized/OptimizedClassDescriptor.java | 26 +-
.../optimized/OptimizedMarshallerImpl.java | 82 +-
.../optimized/OptimizedMarshallerUtils.java | 60 +-
.../optimized/OptimizedObjectInputStream.java | 30 +-
.../optimized/OptimizedObjectOutputStream.java | 18 +-
.../OptimizedObjectPooledStreamRegistry.java | 89 -
.../OptimizedObjectSharedStreamRegistry.java | 70 +-
.../optimized/OptimizedObjectStreamRegistry.java | 87 -
.../ignite/marshaller/MarshallersFactoryImpl.java | 20 +-
.../marshaller/jdk}/IgniteObjectInputFilter.java | 16 +-
.../ignite/marshaller/jdk/JdkMarshallerImpl.java | 41 +-
.../jdk/JdkMarshallerObjectInputStream.java | 14 +-
modules/calcite/pom.xml | 19 +
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 | 64 +-
.../query/calcite/exec/exp/agg/Accumulator.java | 5 +
.../query/calcite/exec/exp/agg/Accumulators.java | 18 +-
.../query/calcite/exec/rel/AbstractNode.java | 5 +-
.../rel/AbstractRightMaterializedJoinNode.java | 3 -
.../query/calcite/exec/rel/CollectNode.java | 11 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 12 +-
.../query/calcite/exec/rel/LimitNode.java | 94 +-
.../query/calcite/exec/rel/MergeJoinNode.java | 81 +-
.../query/calcite/exec/rel/SortAggregateNode.java | 10 +-
.../query/calcite/exec/rel/SortNode.java | 44 +-
.../query/calcite/externalize/RelJson.java | 4 +-
.../query/calcite/message/CalciteErrorMessage.java | 2 +-
.../calcite/message/CalciteMessageFactory.java | 28 +-
.../query/calcite/message/GenericValueMessage.java | 24 +-
.../query/calcite/message/MessageServiceImpl.java | 4 +-
.../query/calcite/message/QueryStartRequest.java | 27 +-
.../query/calcite/message/QueryStartResponse.java | 2 +-
.../query/calcite/metadata/ColocationGroup.java | 37 +-
.../calcite/metadata/FragmentDescription.java | 35 +-
.../query/calcite/metadata/IgniteMdCollation.java | 4 +-
.../calcite/metadata/IgniteMdDistribution.java | 4 +-
.../calcite/metadata/IgniteMdMinRowCount.java | 56 +
.../query/calcite/metadata/IgniteMetadata.java | 1 +
.../calcite/prepare/AbstractQueryContext.java | 3 +-
.../query/calcite/prepare/IgnitePlanner.java | 30 +-
.../calcite/prepare/IgniteRelFieldTrimmer.java | 94 +
...Context.java => IgniteSqlPaginationPolicy.java} | 30 +-
.../calcite/prepare/IgniteSqlToRelConvertor.java | 6 +
.../query/calcite/prepare/IgniteSqlValidator.java | 271 +-
.../query/calcite/prepare/PlannerPhase.java | 9 +-
.../query/calcite/prepare/PlanningContext.java | 2 +-
.../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 | 72 +-
.../rule/TableFunctionScanScalarSubQueryRule.java | 178 +
.../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/type/IgniteTypeSystem.java | 6 +
.../processors/query/calcite/util/IgniteMath.java | 19 +-
.../query/calcite/util/IgniteResource.java | 29 +-
.../calcite/exec/LogicalRelImplementorTest.java | 2 +-
.../calcite/exec/rel/ContinuousExecutionTest.java | 4 +-
.../calcite/exec/rel/JoinBuffersExecutionTest.java | 3 -
.../query/calcite/exec/rel/LimitExecutionTest.java | 9 +-
.../integration/AbstractBasicIntegrationTest.java | 36 +-
.../BulkOperationDeadlockIntegrationTest.java | 348 +
.../integration/CollectIntegrationTest.java | 52 +
.../integration/CorrelatesIntegrationTest.java | 41 +
.../DynamicParametersIntegrationTest.java | 258 +
.../integration/KillCommandDdlIntegrationTest.java | 2 +-
.../integration/LimitOffsetIntegrationTest.java | 231 +-
.../integration/MemoryQuotasIntegrationTest.java | 29 +-
.../OperatorsExtensionIntegrationTest.java | 181 +-
.../integration/QueryMetadataIntegrationTest.java | 58 +-
.../integration/RecursiveCteIntegrationTest.java | 60 +
.../SelectForUpdateIntegrationTest.java | 682 +
.../integration/SortAggregateIntegrationTest.java | 26 +
.../calcite/integration/SystemColumnsScanTest.java | 323 +
.../UserDefinedFunctionsIntegrationTest.java | 52 +
...lciteCommunicationMessageSerializationTest.java | 4 +-
.../query/calcite/planner/AbstractPlannerTest.java | 152 +-
.../planner/DynamicParametersPlannerTest.java | 85 +
.../query/calcite/planner/HashJoinPlannerTest.java | 4 +-
.../calcite/planner/LimitOffsetPlannerTest.java | 93 +
.../query/calcite/planner/PlanExecutionTest.java | 4 +-
.../calcite/sql/ParserCodegenResourcesTest.java | 38 +
.../calcite/sql/SqlSelectForUpdateParserTest.java | 206 +
.../ignite/testsuites/IgniteCalciteTestSuite.java | 4 +
.../ignite/testsuites/IntegrationTestSuite.java | 10 +
.../apache/ignite/testsuites/PlannerTestSuite.java | 2 +
modules/calcite/src/test/sql/order/test_limit.test | 76 +-
.../src/test/sql/types/decimal/test_decimal.test | 4 +-
.../test/sql/types/decimal/test_decimal_ops.test | 4 +-
modules/checkstyle/pom.xml | 28 +-
modules/clients/pom.xml | 7 +
.../client/suite/IgniteClientTestSuite.java | 9 +-
.../rest/JettyRestProcessorAbstractSelfTest.java | 64 +-
.../rest/JettyRestProcessorClassFilterTest.java | 121 +
.../rest/TcpRestUnmarshalVulnerabilityTest.java | 196 +-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 5 -
.../client/ClientMarshallerBenchmarkTest.java | 16 +-
.../org/apache/ignite/internal}/EmptyMessage.java | 21 +-
.../org/apache/ignite/internal/JdkMarshalled.java} | 25 +-
.../ignite/internal/MessageCompanionGenerator.java | 2 +-
.../internal/MessageMarshallerGenerator.java | 206 +-
.../apache/ignite/internal/MessageProcessor.java | 153 +-
.../internal/MessageSerializerGenerator.java | 102 +-
.../apache/ignite/internal/util/CommonUtils.java | 188 +-
.../MoveBinaryMetadataCompatibility.java | 23 +-
.../commandline/CommandHandlerParsingTest.java | 21 +
.../testsuites/IgniteControlUtilityTestSuite.java | 2 +
.../testsuites/IgniteControlUtilityTestSuite2.java | 2 +
.../apache/ignite/util/GridCommandHandlerTest.java | 152 +-
.../org/apache/ignite/util/IoTestCommandTest.java | 126 +
.../ignite/util/KillAllCommandsControlShTest.java | 333 +
.../org/apache/ignite/IgniteSystemProperties.java | 3 +
.../ignite/internal/ClusterMetricsSnapshot.java | 1167 +-
.../ignite/internal/CoreMessagesProvider.java | 689 +-
.../ignite/internal/GridEventConsumeHandler.java | 86 +-
.../ignite/internal/GridJobExecuteRequest.java | 178 +-
.../ignite/internal/GridJobExecuteResponse.java | 140 +-
.../apache/ignite/internal/GridJobSiblingImpl.java | 35 +-
.../ignite/internal/GridJobSiblingsResponse.java | 18 +-
.../apache/ignite/internal/GridKernalContext.java | 4 +
.../ignite/internal/GridKernalContextImpl.java | 10 +-
.../ignite/internal/GridMessageListenHandler.java | 121 +-
.../ignite/internal/GridTaskSessionImpl.java | 6 +-
.../ignite/internal/IgniteComponentType.java | 3 +-
.../org/apache/ignite/internal/IgniteKernal.java | 48 +-
.../apache/ignite/internal/IgniteMXBeanImpl.java | 28 +-
.../ignite/internal/MarshallerContextImpl.java | 35 +-
.../ignite/internal/SelfMarshallingMessage.java | 38 +
.../apache/ignite/internal/StripedMessage.java} | 23 +-
.../marshaller/jdk/GridClientJdkMarshaller.java | 35 +-
.../optimized/GridClientOptimizedMarshaller.java | 8 +-
.../internal/cluster/ClusterGroupAdapter.java | 2 +-
.../direct/stream/DirectByteBufferStream.java | 26 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 16 +-
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 2 +-
.../internal/management/IgniteCommandRegistry.java | 4 +-
.../cache/VerifyBackupPartitionsTask.java | 19 +-
.../consistency/ConsistencyRepairTask.java | 10 +-
.../internal/management/io/IoTestCommand.java} | 13 +-
.../management/io/IoTestCommunicationCommand.java | 152 +
.../io/IoTestCommunicationCommandArg.java | 120 +
.../management/io/IoTestCommunicationTask.java | 113 +
.../management/io/IoTestDiscoveryCommand.java | 136 +
.../management/io/IoTestDiscoveryCommandArg.java | 96 +
.../management/io/IoTestDiscoveryTask.java | 64 +
.../internal/management/kill/KillAllCommand.java | 96 +
.../management/kill/KillAllCommandArg.java | 129 +
.../internal/management/kill/KillAllTask.java | 287 +
.../management/kill/KillAllTaskResult.java} | 54 +-
.../internal/management/kill/KillCommand.java | 1 +
.../communication/CommunicationMarshalling.java | 61 +
.../communication/CompressedMessageSerializer.java | 5 +
.../communication/DiscoveryMarshalling.java | 52 +
.../managers/communication/GridIoManager.java | 747 +-
.../managers/communication/GridIoMessage.java | 23 +-
.../managers/communication/GridIoUserMessage.java | 79 +-
.../communication/IgniteIoTestMessage.java | 299 +-
.../communication/IgniteMessageFactory.java | 13 +-
.../communication/IgniteMessageFactoryImpl.java | 25 +-
.../managers/communication/IoTestHandler.java | 753 +
.../managers/communication/IoTestResult.java | 234 +
.../managers/communication/MessageMarshalling.java | 44 +-
.../communication/MessageUnmarshalOnceCheck.java | 7 +-
.../communication/SessionChannelMessage.java | 2 -
.../managers/deployment/GridDeployment.java | 5 +-
.../deployment/GridDeploymentCommunication.java | 6 +-
...nfoBean.java => GridDeploymentInfoMessage.java} | 16 +-
.../deployment/GridDeploymentLocalStore.java | 3 +-
.../managers/deployment/GridDeploymentManager.java | 73 +-
.../deployment/GridDeploymentMetadata.java | 20 -
.../deployment/GridDeploymentPerVersionStore.java | 5 +-
.../managers/deployment/GridDeploymentRequest.java | 31 +-
.../managers/discovery/GridDiscoveryManager.java | 34 +-
.../managers/discovery/IgniteClusterNode.java | 8 +
.../discovery/IoTestDiscoveryAckMessage.java | 69 +
.../managers/discovery/IoTestDiscoveryHandler.java | 275 +
.../managers/discovery/IoTestDiscoveryMessage.java | 88 +
.../managers/discovery/IoTestDiscoveryResult.java | 181 +
.../eventstorage/GridEventStorageManager.java | 50 +-
.../eventstorage/GridEventStorageMessage.java | 229 -
.../eventstorage/GridEventStorageRequest.java | 95 +
.../eventstorage/GridEventStorageResponse.java} | 61 +-
...er.java => AbstractMessageFactoryProvider.java} | 113 +-
.../processors/affinity/GridAffinityUtils.java | 5 +-
.../authentication/UserAcceptedMessage.java | 2 +-
.../internal/processors/cache/CacheData.java | 134 +-
.../internal/processors/cache/CacheGroupData.java | 103 +-
.../processors/cache/CacheInvokeDirectResult.java | 2 +-
.../cache/CacheNodeCommonDiscoveryData.java | 61 +-
.../processors/cache/ClusterCachesInfo.java | 16 +-
.../processors/cache/ExchangeFailureMessage.java | 2 +-
.../processors/cache/GridCacheAdapter.java | 64 +-
.../cache/GridCacheDeploymentManager.java | 21 +-
.../processors/cache/GridCacheEntryInfo.java | 129 +-
.../processors/cache/GridCacheIoManager.java | 28 +-
.../processors/cache/GridCacheMapEntry.java | 16 +-
.../processors/cache/GridCacheMessage.java | 21 +-
.../cache/GridCachePartitionExchangeManager.java | 35 +-
.../GridChangeGlobalStateMessageResponse.java | 2 +-
.../internal/processors/cache/StoredCacheData.java | 4 +
.../cache/binary/BinaryMetadataVersionInfo.java | 4 +
.../binary/MetadataUpdateProposedMessage.java | 2 +-
.../distributed/GridDistributedLockRequest.java | 4 +-
.../distributed/GridDistributedLockResponse.java | 2 +-
.../GridDistributedTxFinishResponse.java | 2 +-
.../GridDistributedTxPrepareRequest.java | 44 +-
.../GridDistributedTxPrepareResponse.java | 4 +-
.../cache/distributed/GridNearUnlockRequest.java | 4 +-
.../dht/GridDhtAffinityAssignmentResponse.java | 2 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 20 +-
.../distributed/dht/GridDhtGetSingleFuture.java | 20 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 9 +-
.../distributed/dht/GridDhtTxFinishRequest.java | 2 +-
.../distributed/dht/GridDhtTxFinishResponse.java | 2 +-
.../cache/distributed/dht/GridDhtTxLocal.java | 2 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 33 +-
.../distributed/dht/GridDhtTxPrepareRequest.java | 2 +-
.../dht/PartitionUpdateCountersMessage.java | 37 +-
.../atomic/GridDhtAtomicAbstractUpdateFuture.java | 7 -
.../atomic/GridDhtAtomicAbstractUpdateRequest.java | 27 -
.../distributed/dht/atomic/GridDhtAtomicCache.java | 53 +-
.../dht/atomic/GridDhtAtomicNearResponse.java | 2 +-
.../atomic/GridDhtAtomicSingleUpdateFuture.java | 2 -
.../atomic/GridDhtAtomicSingleUpdateRequest.java | 31 +-
.../dht/atomic/GridDhtAtomicUpdateFuture.java | 2 -
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 149 +-
.../dht/atomic/GridDhtAtomicUpdateResponse.java | 2 +-
.../atomic/GridNearAtomicAbstractUpdateFuture.java | 6 +-
.../atomic/GridNearAtomicCheckUpdateRequest.java | 10 +-
.../atomic/GridNearAtomicFullUpdateRequest.java | 29 +-
.../atomic/GridNearAtomicSingleUpdateRequest.java | 2 +-
.../dht/atomic/GridNearAtomicUpdateResponse.java | 9 +-
.../cache/distributed/dht/atomic/UpdateErrors.java | 2 +-
.../dht/preloader/GridDhtForceKeysResponse.java | 2 +-
.../dht/preloader/GridDhtPartitionSupplier.java | 20 +-
.../preloader/GridDhtPartitionSupplyMessage.java | 2 +-
.../GridDhtPartitionsAbstractMessage.java | 5 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 19 +-
.../preloader/GridDhtPartitionsFullMessage.java | 22 +-
.../preloader/GridDhtPartitionsSingleMessage.java | 22 +-
.../distributed/near/GridNearAtomicCache.java | 14 +-
.../cache/distributed/near/GridNearGetRequest.java | 48 +-
.../distributed/near/GridNearGetResponse.java | 2 +-
...dNearOptimisticSerializableTxPrepareFuture.java | 2 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 2 +-
.../near/GridNearPessimisticTxPrepareFuture.java | 2 +-
.../distributed/near/GridNearSingleGetRequest.java | 2 +-
.../near/GridNearSingleGetResponse.java | 2 +-
.../near/GridNearTransactionalCache.java | 5 +
.../distributed/near/GridNearTxFinishRequest.java | 2 +-
.../distributed/near/GridNearTxFinishResponse.java | 2 +-
.../cache/distributed/near/GridNearTxLocal.java | 2 +-
.../near/GridNearTxPrepareFutureAdapter.java | 8 +-
.../distributed/near/GridNearTxPrepareRequest.java | 11 +-
.../near/GridNearTxPrepareResponse.java | 47 +-
.../cache/distributed/near/GridNearTxRemote.java | 8 +-
.../distributed/near/KeyedVersionedValue.java} | 59 +-
.../snapshot/IncrementalSnapshotVerifyResult.java | 2 +-
.../snapshot/SnapshotCheckResponse.java | 2 +-
.../snapshot/SnapshotHandlerResult.java | 2 +-
.../snapshot/SnapshotOperationEndRequest.java | 2 +-
.../wal/reader/StandaloneGridKernalContext.java | 11 +-
.../query/GridCacheDistributedQueryManager.java | 5 +
.../cache/query/GridCacheQueryFutureAdapter.java | 20 +-
.../cache/query/GridCacheQueryRequest.java | 9 +-
.../cache/query/GridCacheQueryResponse.java | 2 +-
.../CacheContinuousQueryDeployableObject.java | 47 +-
.../continuous/CacheContinuousQueryEntry.java | 58 +-
.../CacheContinuousQueryEventBuffer.java | 6 +-
.../continuous/CacheContinuousQueryHandler.java | 352 +-
.../cache/transactions/IgniteTxHandler.java | 14 +-
.../cache/transactions/IgniteTxManager.java | 4 +-
.../cache/transactions/TxDeadlockDetection.java | 5 +-
.../cache/transactions/TxLocksRequest.java | 19 +-
.../cache/transactions/TxLocksResponse.java | 19 +-
.../processors/cache/verify/IdleVerifyUtility.java | 4 +-
.../cache/verify/PartitionHashRecord.java | 9 +-
.../cache/verify/TransactionsHashRecord.java | 9 +-
.../cluster/BaselineStateAndHistoryData.java | 53 +
.../cluster/BaselineTopologyHistory.java | 18 +-
.../cluster/BaselineTopologyHistoryItem.java | 41 +-
.../cluster/DiscoveryDataClusterState.java | 180 +-
.../cluster/GridClusterStateProcessor.java | 34 +-
.../processors/cluster/NodeFullMetricsMessage.java | 9 +-
.../processors/cluster/NodeMetricsMessage.java | 1344 --
.../continuous/ContinousRoutineDiscoveryData.java | 72 +
.../ContinousRoutineDiscoveryDataItem.java | 96 +
.../continuous/ContinousRoutineLocalInfo.java | 131 +
.../continuous/ContinuousRoutineInfo.java | 44 +-
.../ContinuousRoutineStartResultMessage.java | 2 +-
.../ContinuousRoutinesCommonDiscoveryData.java | 14 +-
...ContinuousRoutinesJoiningNodeDiscoveryData.java | 14 +-
.../continuous/GridContinuousHandler.java | 4 +-
.../continuous/GridContinuousProcessor.java | 416 +-
.../processors/continuous/StartRequestData.java | 78 +-
.../StartRoutineAckDiscoveryMessage.java | 2 +-
.../continuous/StartRoutineDiscoveryMessage.java | 2 +-
.../datastreamer/DataStreamProcessor.java | 52 +-
.../datastreamer/DataStreamerBuiltInUpdater.java | 72 +
.../processors/datastreamer/DataStreamerImpl.java | 70 +-
.../datastreamer/DataStreamerReceiverMessage.java | 66 +
.../datastreamer/DataStreamerRequest.java | 168 +-
.../datastreamer/DataStreamerResponse.java | 3 +-
.../internal/processors/job/GridJobProcessor.java | 80 +-
.../internal/processors/job/GridJobWorker.java | 39 +-
.../DistributedMetaStorageClusterNodeData.java | 104 +-
.../DistributedMetaStorageHistoryItem.java | 21 +-
.../DistributedMetaStorageHistoryItemMessage.java | 67 +
.../persistence/DistributedMetaStorageImpl.java | 155 +-
.../DistributedMetaStorageJoiningNodeData.java | 61 +-
.../DistributedMetaStorageKeyValuePair.java | 70 -
.../persistence/DistributedMetaStorageVersion.java | 2 +-
.../metastorage/persistence/DmsDataWriter.java | 26 +-
...InMemoryCachedDistributedMetaStorageBridge.java | 16 +-
.../processors/odbc/ClientListenerNioListener.java | 18 +-
.../client/compute/ClientExecuteTaskRequest.java | 3 +-
.../processors/platform/utils/PlatformUtils.java | 5 +-
.../internal/processors/pool/PoolProcessor.java | 43 +
.../processors/query/GridQueryProcessor.java | 3 +-
.../processors/query/QueryTypeDescriptorImpl.java | 15 +-
.../internal/processors/query/QueryUtils.java | 20 +-
.../query/schema/management/SchemaManager.java | 3 +-
.../query/schema/message/QueryEntityMessage.java | 30 +-
.../operation/SchemaAddQueryEntityOperation.java | 2 +-
.../rest/protocols/tcp/GridTcpRestNioListener.java | 3 +-
.../rest/protocols/tcp/GridTcpRestParser.java | 11 +-
.../rest/protocols/tcp/GridTcpRestProtocol.java | 15 +-
.../rollingupgrade/RollingUpgradeClusterData.java | 13 +-
.../rollingupgrade/RollingUpgradeProcessor.java | 101 +-
.../feature/IgniteNodeFeatureSet.java | 87 +-
.../feature/IgnitePluginFeatureSet.java | 4 +-
.../processors/security/IgniteSecurityAdapter.java | 4 +-
.../processors/security/SecurityUtils.java | 67 +-
.../service/LazyServiceConfigurationMessage.java | 27 +-
.../service/ServiceSingleNodeDeploymentResult.java | 2 +-
.../session/GridTaskSessionProcessor.java | 2 +-
.../processors/task/GridTaskProcessor.java | 3 +-
.../internal/processors/task/GridTaskWorker.java | 18 +-
.../processors/timeout/GridTimeoutProcessor.java | 16 +-
.../communication => util}/ErrorMessage.java | 7 +-
.../apache/ignite/internal/util/IgniteUtils.java | 28 -
.../internal/util/distributed/FullMessage.java | 2 +-
.../util/distributed/SingleNodeMessage.java | 7 +-
.../org/apache/ignite/mxbean/IgniteMXBean.java | 10 +-
.../communication/MessageMarshaller.java | 17 +-
.../security/SecurityBasicPermissionSet.java | 140 +-
.../plugin/security/SecurityPermissionSet.java | 13 +-
.../security/SecurityPermissionSetBuilder.java | 24 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 6 +-
.../tcp/internal/GridNioServerWrapper.java | 3 +-
.../TcpInverseConnectionResponseMessage.java | 1 -
.../tcp/messages/HandshakeWaitMessage.java | 2 +
.../spi/deployment/local/LocalDeploymentSpi.java | 3 +-
.../ignite/spi/discovery/DiscoveryDataBag.java | 8 -
.../discovery/isolated/IsolatedDiscoverySpi.java | 8 +-
.../spi/discovery/isolated/IsolatedNode.java | 13 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 46 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 79 +-
.../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 3 +-
.../spi/discovery/tcp/TcpDiscoveryIoSession.java | 11 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 49 +-
.../discovery/tcp/internal/TcpDiscoveryNode.java | 83 +-
.../tcp/internal/TcpDiscoveryNodesRing.java | 8 +-
.../internal/UnsupportedNodeVersionException.java} | 13 +-
.../sharedfs/TcpDiscoverySharedFsIpFinder.java | 7 +-
.../TcpDiscoveryClientMetricsUpdateMessage.java | 8 +-
.../TcpDiscoveryClientNodesMetricsMessage.java | 8 +-
.../tcp/messages/TcpDiscoveryHandshakeRequest.java | 15 +-
.../messages/TcpDiscoveryHandshakeResponse.java | 15 +-
.../messages/TcpDiscoveryMetricsUpdateMessage.java | 6 +-
.../ignite/stream/socket/SocketStreamer.java | 3 +-
.../main/resources/META-INF/classnames.properties | 8 +-
... class_list_exploit_excluded_jobs_included.txt} | 4 +-
.../test/config/class_list_exploit_included.txt | 2 +-
...t => class_list_exploit_with_jobs_included.txt} | 4 +-
.../org/apache/ignite/client/IgniteBinaryTest.java | 23 +
.../internal/MarshallerContextLockingSelfTest.java | 2 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 51 +-
.../GridBinaryMarshallerCtxDisabledSelfTest.java | 6 -
.../binary/RawBinaryObjectExtractorTest.java | 9 +-
.../ThreadLocalAllocatorChunkShrinkTest.java | 142 +
.../thin/ThinClientHandshakeTimeoutTest.java | 199 +
.../internal/codegen/MessageProcessorTest.java | 220 +-
.../direct/DirectMarshallingMessagesTest.java | 55 +-
.../direct/TestNestedContainersMessage.java | 15 +-
...irectByteBufferStreamImplByteOrderSelfTest.java | 4 +-
.../managers/AbstractMessageSerializationTest.java | 5 +-
.../IgniteCoreMessagesSerializationTest.java | 3 +-
.../communication/CompressedMessageTest.java | 3 +-
.../GridCommunicationSendMessageSelfTest.java | 4 +-
.../GridIoManagerOrderedUnmarshalFailureTest.java | 14 +-
.../communication/IgniteIoTestMessagesTest.java | 308 +-
.../IgniteMessageFactoryImplTest.java | 11 +-
.../MessageDirectTypeIdConflictTest.java | 2 +-
...MessageFactoryMarshallerInitializationTest.java | 138 -
...loymentRequestOfUnknownClassProcessingTest.java | 6 +-
.../GridDiscoveryManagerAttributesSelfTest.java | 93 -
.../optimized/OptimizedMarshallerEnumSelfTest.java | 2 +-
.../OptimizedMarshallerPooledSelfTest.java | 44 -
.../optimized/OptimizedMarshallerSelfTest.java | 2 +-
...edMarshallerSerialPersistentFieldsSelfTest.java | 2 +-
.../optimized/OptimizedMarshallerTest.java | 42 +-
.../optimized/OptimizedObjectStreamSelfTest.java | 42 +-
.../affinity/GridAffinityAssignmentV2Test.java | 4 +-
.../cache/GridCacheEntryMemorySizeSelfTest.java | 5 -
.../processors/cache/GridCacheTestEntryEx.java | 11 +-
.../dht/PartitionUpdateCountersMessageTest.java | 118 +
...GridDhtPartitionsExchangeFutureCleanUpTest.java | 107 +
.../near/GridNearTxPrepareDestroyedCacheTest.java | 20 +-
.../snapshot/IncrementalSnapshotTest.java | 2 +-
.../query/GridCacheQueryResponseUnmarshalTest.java | 6 +-
.../CacheContinuousQueryEntriesExpireTest.java | 4 +-
...ueryRemoteFilterMissingInClassPathSelfTest.java | 53 +-
...coveryDataDeserializationFailureHanderTest.java | 1 +
...GridCacheContinuousQueryNodesFilteringTest.java | 15 +-
...niteCacheContinuousQueryImmutableEntryTest.java | 88 +-
.../TxDeadlockDetectionMessageMarshallingTest.java | 8 +-
.../TxSavepointNearCacheVisibilityTest.java | 130 +
.../transactions/TxSavepointParameterizedTest.java | 8 +-
.../continuous/GridEventConsumeSelfTest.java | 9 +-
.../datastreamer/DataStreamerImplSelfTest.java | 105 +-
.../DistributedMetaStorageClassloadingTest.java | 96 +-
.../metastorage/DistributedMetaStorageTest.java | 20 +-
.../metastorage/persistence/DmsDataWriterTest.java | 14 +-
...moryCachedDistributedMetaStorageBridgeTest.java | 27 +-
.../QueryEntityMessageSerializationTest.java | 69 +-
.../rollingupgrade/AbstractRollingUpgradeTest.java | 12 +-
.../CoreVersionRollingUpgradeTest.java | 24 +-
.../PluginVersionRollingUpgradeTest.java | 4 +-
...0.java => TestPluginReleaseFeatures_2_1_0.java} | 7 +-
.../feature/TestPluginReleaseFeatures_3_0_0.java | 3 +
.../security/impl/TestSecurityProcessor.java | 11 +-
...rviceConfigurationMessageSerializationTest.java | 14 +-
.../timeout/GridTimeoutProcessorSelfTest.java | 56 +
.../OperationContextAttributePropagationTest.java | 4 +-
.../ErrorMessageSelfTest.java | 2 +-
.../ignite/internal/util/GridTestClockTimer.java | 2 +
.../DistributedProcessResultMarshallingTest.java | 323 +
.../nio/IgniteExceptionInNioWorkerSelfTest.java | 7 +-
.../TcpCommunicationSpiSslVolatilePayloadTest.java | 5 +-
.../marshaller/MarshallerContextSelfTest.java | 2 +-
.../marshaller/MarshallerContextTestImpl.java | 2 +-
.../marshaller/ObjectInputStreamFilteringTest.java | 27 -
.../p2p/ClassLoadingProblemExceptionTest.java | 4 +-
.../ignite/p2p/P2PScanQueryUndeployTest.java | 4 +-
.../communication/MessageMarshalOnceTest.java | 27 +-
...ecurityBasicPermissionSetSerializationTest.java | 133 +
.../security/SecurityPermissionSetBuilderTest.java | 36 +-
.../apache/ignite/spi/MessagesPluginProvider.java | 31 +-
...dJobStealingCollisionSpiAttributesSelfTest.java | 3 +-
...StealingCollisionSpiCustomTopologySelfTest.java | 3 +-
.../GridJobStealingCollisionSpiSelfTest.java | 3 +-
.../GridAbstractCommunicationSelfTest.java | 3 +-
.../communication/GridCacheMessageSelfTest.java | 10 +-
.../ignite/spi/communication/GridTestMessage.java | 2 +-
...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 +-
.../tcp/TestDelayMessageSerializer.java | 5 +
...rMetricsSnapshotSerializeCompatibilityTest.java | 5 +-
.../ClusterMetricsSnapshotSerializeSelfTest.java | 3 +-
.../tcp/DiscoveryDeserializationExceptionTest.java | 2 +-
.../tcp/DiscoveryUnmarshalVulnerabilityTest.java | 278 +-
.../tcp/TcpDiscoveryClientTopologyGapTest.java | 135 +
.../spi/discovery/tcp/TestTcpDiscoverySpi.java | 3 +-
.../SocketStreamerUnmarshalVulnerabilityTest.java | 257 +-
.../ignite/testframework/GridSpiTestContext.java | 6 +-
.../apache/ignite/testframework/GridTestUtils.java | 15 +-
.../testframework/junits/GridAbstractTest.java | 3 +-
.../junits/GridTestKernalContext.java | 1 -
.../ignite/testframework/junits/IgniteMock.java | 2 +-
.../junits/common/GridCommonAbstractTest.java | 10 +-
.../junits/spi/GridSpiAbstractTest.java | 10 +-
.../ignite/testsuites/IgniteBasicTestSuite.java | 4 +-
.../testsuites/IgniteBinaryObjectsTestSuite.java | 3 +
.../ignite/testsuites/IgniteCacheTestSuite10.java | 2 +
.../ignite/testsuites/IgniteCacheTestSuite12.java | 2 +
.../ignite/testsuites/IgniteCacheTestSuite19.java | 2 +
.../testsuites/IgniteMarshallerSelfTestSuite.java | 2 -
.../IgniteSpiDiscoverySelfTestSuite2.java | 10 +-
.../testsuites/IgniteStreamSelfTestSuite.java | 7 +-
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 2 +
.../ignite/testsuites/SecurityTestSuite.java | 2 +
.../ignite/util/GridTopologyHeapSizeSelfTest.java | 3 +-
.../resources/codegen/ChildMessageSerializer.java | 11 +-
...{EmptyMessage.java => CorrectEmptyMessage.java} | 6 +-
...zer.java => CorrectEmptyMessageSerializer.java} | 27 +-
...ustomEnumMapperOnNonEnumCollectionMessage.java} | 11 +-
...va => CustomEnumMapperOnNonEnumMapMessage.java} | 11 +-
.../codegen/CustomMapperEnumFieldsMessage.java | 7 +-
.../CustomMapperEnumFieldsMessageSerializer.java | 33 +-
.../codegen/DefaultMapperEnumFieldsMessage.java | 9 +
.../DefaultMapperEnumFieldsMessageSerializer.java | 58 +-
... => DefaultMapperEnumMapCollectionMessage.java} | 9 +-
.../codegen/IncorrectEmptyMessage.java} | 9 +-
...sage.java => IncorrectMarshalledOnMessage.java} | 16 +-
...java => IncorrectMarshalledOnMessageArray.java} | 16 +-
...=> 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} | 17 +-
....java => IncorrectMarshalledOnMessageMap2.java} | 18 +-
....java => IncorrectMarshalledOnMessageMap3.java} | 17 +-
....java => IncorrectMarshalledOnMessageMap4.java} | 17 +-
...e.java => IncorrectMarshalledOnMessageSet.java} | 17 +-
...age.java => IncorrectRawCollectionMessage.java} | 17 +-
...ge.java => IncorrectRawCollectionMessage2.java} | 17 +-
...tyMessage.java => IncorrectRawListMessage.java} | 17 +-
...yMessage.java => IncorrectRawListMessage2.java} | 17 +-
...ptyMessage.java => IncorrectRawMapMessage.java} | 17 +-
...tyMessage.java => IncorrectRawMapMessage2.java} | 17 +-
.../codegen/TestCacheIdMessageDeployer.java | 2 +-
.../codegen/TestCollectionsMessageMarshaller.java | 7 +-
.../codegen/TestCollectionsMessageSerializer.java | 64 +-
.../codegen/TestDeployableMessageDeployer.java | 2 +-
...mFieldsMessage.java => TestEnumSetMessage.java} | 13 +-
...izer.java => TestEnumSetMessageSerializer.java} | 57 +-
.../codegen/TestJdkMarshalledChildMessage.java} | 16 +-
.../TestJdkMarshalledChildMessageMarshaller.java | 83 +
...sMessage.java => TestJdkMarshalledMessage.java} | 19 +-
.../TestJdkMarshalledMessageMarshaller.java | 74 +
.../codegen/TestMapMessageMarshaller.java | 7 +-
.../codegen/TestMapMessageSerializer.java | 16 +-
.../codegen/TestMarshallableMessageMarshaller.java | 18 +-
.../codegen/TestMarshallableMessageSerializer.java | 11 +-
.../TestMarshalledArrayMapMessageMarshaller.java | 23 +-
.../TestMarshalledArrayMapMessageSerializer.java | 16 +-
.../TestMarshalledCollectionMessageMarshaller.java | 7 +-
.../TestMarshalledCollectionMessageSerializer.java | 11 +-
.../TestMarshalledMapMessageMarshaller.java | 7 +-
.../TestMarshalledMapMessageSerializer.java | 16 +-
.../codegen/TestMarshalledMessageMarshaller.java | 18 +-
.../codegen/TestMarshalledMessageSerializer.java | 11 +-
.../TestMarshalledObjectsMessageMarshaller.java | 18 +-
.../TestMarshalledObjectsMessageSerializer.java | 14 +-
.../resources/codegen/TestMessageMarshaller.java | 13 +-
.../resources/codegen/TestMessageSerializer.java | 11 +-
.../codegen/TestNestedDeployMessageDeployer.java | 2 +-
...essage.java => TestSelfMarshallingMessage.java} | 18 +-
...a => TestSelfMarshallingMessageMarshaller.java} | 20 +-
...a => TestSelfMarshallingMessageSerializer.java} | 19 +-
...a => TwoDifferentEnumsInCollectionMessage.java} | 10 +-
...{EmptyMessage.java => WrongEnumSetMessage.java} | 9 +-
...ssage.java => WrongSelfMarshallingMessage.java} | 18 +-
...ridCommandHandlerClusterByClassTest_help.output | 30 +
...andHandlerClusterByClassWithSSLTest_help.output | 30 +
modules/ducktests/DEV_GUIDE.md | 516 +
modules/ducktests/README.md | 3 +
.../ducktest/tests/dto/IndexedDataRecord.java | 96 +
.../internal/ducktest/tests/mdc/LoadMode.java} | 51 +-
.../tests/mdc/MdcCacheAwareApplication.java | 177 +
.../tests/mdc/MdcContinuousLoadApplication.java | 304 +
.../tests/mdc/MdcDataCheckerApplication.java | 72 +
.../tests/mdc/MdcDataGeneratorApplication.java | 76 +
.../tests/mdc/MdcThinClientLoadApplication.java | 145 +
.../DataLoaderAndCheckerApplication.java | 68 +-
.../ignite/internal/ducktest/utils/OpStats.java | 66 +
.../ignite/internal/ducktest/utils/Utils.java | 84 +
.../checks/services/network_group/check_manager.py | 141 +
.../tests/checks/utils/check_cache_distribution.py | 128 +
modules/ducktests/tests/docker/Dockerfile | 1 +
modules/ducktests/tests/docker/requirements.txt | 1 +
modules/ducktests/tests/docker/run_tests.sh | 5 +
.../tests/ignitetest/services/ignite_app.py | 16 +-
.../tests/ignitetest/services/mdc/__init__.py} | 9 +-
.../tests/ignitetest/services/mdc/mdc_cluster.py | 559 +
.../services/network_group/__init__.py} | 9 +-
.../services/network_group/configuration.py | 64 +
.../ignitetest/services/network_group/manager.py | 476 +
.../services/network_group/tc_rule_args.py | 135 +
.../services/utils/cdc/kafka_to_ignite.py | 2 +-
.../ignitetest/services/utils/control_utility.py | 142 +-
.../ignitetest/services/utils/ignite_aware.py | 22 +
.../utils/ignite_configuration/__init__.py | 1 +
.../utils/ignite_configuration/communication.py | 4 +-
.../tests/ignitetest/services/utils/ignite_spec.py | 2 +
.../tests/ignitetest/services/utils/log_utils.py | 14 +-
.../utils/templates/ignite_configuration_macro.j2 | 1 +
.../tests/control_utility/baseline_test.py | 12 +-
.../tests/ignitetest/tests/index_rebuild_test.py | 4 +-
.../tests/mdc/__init__.py} | 6 +-
.../tests/mdc/partition_resilience_test.py | 215 +
.../tests/ignitetest/tests/mdc/thin_client_test.py | 156 +
.../tests/mdc/transactional_partition_test.py | 154 +
.../processors/query/h2/dml/UpdatePlanBuilder.java | 3 +-
.../query/h2/sql/GridSqlQuerySplitter.java | 52 +-
.../query/h2/twostep/msg/GridH2Null.java | 4 +-
.../h2/twostep/msg/GridH2ValueMessageFactory.java | 57 +-
.../org/apache/ignite/client/ClientTestSuite.java | 2 +
.../query/IgniteSqlSplitterSelfTest.java | 60 +
.../processors/query/SqlSystemViewsSelfTest.java | 15 +-
.../internal/jackson/IgniteObjectMapper.java | 7 +-
modules/kubernetes/pom.xml | 2 +-
.../CollectionImplementationType.java} | 20 +-
.../communication/MessageCollectionItemType.java | 5 +-
.../communication/MessageCollectionType.java | 16 +-
.../extensions/communication/MessageEnumType.java | 70 +
.../extensions/communication/MessageFactory.java | 14 +-
.../communication/MessageSerializer.java | 5 +
.../cpp/core-test/config/compute-security.xml | 28 +-
.../Config/Compute/compute-security.xml | 40 +-
.../protocols/http/jetty/GridJettyRestHandler.java | 3 +-
modules/sqlline/pom.xml | 2 +-
.../ignite/internal/client/thin/ClientUtils.java | 28 +-
.../internal/client/thin/TcpClientChannel.java | 22 +-
.../internal/client/thin/TcpIgniteClient.java | 18 +-
.../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 +-
.../discovery/zk/internal/ZkMessageFactory.java | 19 +-
.../discovery/zk/internal/ZkNoServersMessage.java | 2 +
.../zk/internal/ZookeeperClusterNode.java | 17 +
.../zk/internal/ZookeeperDiscoveryImpl.java | 2 +-
.../zk/internal/ZookeeperDiscoverySpiTestBase.java | 14 +-
parent/pom.xml | 33 +-
pom.xml | 10 +-
669 files changed, 36063 insertions(+), 22454 deletions(-)
create mode 100644 docs/_docs/sql-reference/window-functions.adoc
create mode 100644
modules/binary/api/src/main/java/org/apache/ignite/internal/marshaller/ClassLoaderUtils.java
delete mode 100644
modules/binary/api/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshallerIdMapper.java
delete mode 100644
modules/binary/impl/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectPooledStreamRegistry.java
delete mode 100644
modules/binary/impl/src/main/java/org/apache/ignite/internal/marshaller/optimized/OptimizedObjectStreamRegistry.java
rename modules/binary/{api/src/main/java/org/apache/ignite/marshaller =>
impl/src/main/java/org/apache/ignite/marshaller/jdk}/IgniteObjectInputFilter.java
(72%)
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/IgniteMdMinRowCount.java
create mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteRelFieldTrimmer.java
copy
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{AbstractQueryContext.java
=> IgniteSqlPaginationPolicy.java} (51%)
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/rule/TableFunctionScanScalarSubQueryRule.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/CollectIntegrationTest.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/planner/DynamicParametersPlannerTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/sql/ParserCodegenResourcesTest.java
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/sql/SqlSelectForUpdateParserTest.java
create mode 100644
modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorClassFilterTest.java
copy modules/{core/src/test/resources/codegen =>
codegen/src/main/java/org/apache/ignite/internal}/EmptyMessage.java (66%)
copy
modules/{core/src/test/resources/codegen/TestNestedDeployMessageDeployer.java
=> codegen/src/main/java/org/apache/ignite/internal/JdkMarshalled.java} (54%)
create mode 100644
modules/control-utility/src/test/java/org/apache/ignite/util/IoTestCommandTest.java
create mode 100644
modules/control-utility/src/test/java/org/apache/ignite/util/KillAllCommandsControlShTest.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/SelfMarshallingMessage.java
copy
modules/core/src/{test/resources/codegen/DefaultMapperEnumFieldsMessage.java =>
main/java/org/apache/ignite/internal/StripedMessage.java} (62%)
copy
modules/core/src/{test/java/org/apache/ignite/internal/processors/rollingupgrade/feature/TestPluginReleaseFeatures_3_0_0.java
=> main/java/org/apache/ignite/internal/management/io/IoTestCommand.java} (71%)
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
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/io/IoTestDiscoveryTask.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/kill/KillAllCommand.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/kill/KillAllCommandArg.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/management/kill/KillAllTask.java
copy
modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteErrorMessage.java
=>
core/src/main/java/org/apache/ignite/internal/management/kill/KillAllTaskResult.java}
(53%)
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
rename
modules/core/src/main/java/org/apache/ignite/internal/managers/deployment/{GridDeploymentInfoBean.java
=> GridDeploymentInfoMessage.java} (85%)
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/managers/eventstorage/GridEventStorageMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/eventstorage/GridEventStorageRequest.java
copy
modules/core/src/main/java/org/apache/ignite/internal/{processors/datastreamer/DataStreamerResponse.java
=> managers/eventstorage/GridEventStorageResponse.java} (52%)
rename
modules/core/src/main/java/org/apache/ignite/internal/plugin/{AbstractMarshallableMessageFactoryProvider.java
=> AbstractMessageFactoryProvider.java} (53%)
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/{datastreamer/DataStreamerResponse.java
=> cache/distributed/near/KeyedVersionedValue.java} (50%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/BaselineStateAndHistoryData.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cluster/NodeMetricsMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/ContinousRoutineDiscoveryData.java
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/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerBuiltInUpdater.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerReceiverMessage.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageHistoryItemMessage.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DistributedMetaStorageKeyValuePair.java
rename
modules/core/src/main/java/org/apache/ignite/internal/{managers/communication
=> util}/ErrorMessage.java (93%)
copy
modules/core/src/{test/java/org/apache/ignite/internal/processors/rollingupgrade/feature/TestPluginReleaseFeatures_3_0_0.java
=>
main/java/org/apache/ignite/spi/discovery/tcp/internal/UnsupportedNodeVersionException.java}
(70%)
copy modules/core/src/test/config/{class_list_test_excluded.txt =>
class_list_exploit_excluded_jobs_included.txt} (82%)
copy modules/core/src/test/config/{class_list_exploit_included.txt =>
class_list_exploit_with_jobs_included.txt} (80%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/binary/streams/ThreadLocalAllocatorChunkShrinkTest.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
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/marshaller/optimized/OptimizedMarshallerPooledSelfTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/PartitionUpdateCountersMessageTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFutureCleanUpTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxSavepointNearCacheVisibilityTest.java
copy
modules/core/src/test/java/org/apache/ignite/internal/processors/rollingupgrade/feature/{TestPluginReleaseFeatures_3_0_0.java
=> TestPluginReleaseFeatures_2_1_0.java} (81%)
rename
modules/core/src/test/java/org/apache/ignite/internal/{managers/communication
=> util}/ErrorMessageSelfTest.java (97%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/distributed/DistributedProcessResultMarshallingTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/plugin/security/SecurityBasicPermissionSetSerializationTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryClientTopologyGapTest.java
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
CorrectEmptyMessage.java} (81%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledMessageSerializer.java
=> CorrectEmptyMessageSerializer.java} (68%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
CustomEnumMapperOnNonEnumCollectionMessage.java} (80%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
CustomEnumMapperOnNonEnumMapMessage.java} (81%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
DefaultMapperEnumMapCollectionMessage.java} (84%)
copy
modules/core/src/test/{java/org/apache/ignite/internal/processors/rollingupgrade/feature/TestPluginReleaseFeatures_3_0_0.java
=> resources/codegen/IncorrectEmptyMessage.java} (78%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessage.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageArray.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageCollection.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageCollection2.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageCollection3.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageCollection4.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageCollectionArray.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageList.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageList2.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageMap.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageMap2.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageMap3.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageMap4.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectMarshalledOnMessageSet.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectRawCollectionMessage.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectRawCollectionMessage2.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectRawListMessage.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectRawListMessage2.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectRawMapMessage.java} (76%)
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
IncorrectRawMapMessage2.java} (76%)
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessage.java =>
TestEnumSetMessage.java} (77%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledArrayMapMessageSerializer.java
=> TestEnumSetMessageSerializer.java} (51%)
copy
modules/core/src/test/{java/org/apache/ignite/internal/processors/rollingupgrade/feature/TestPluginReleaseFeatures_3_0_0.java
=> resources/codegen/TestJdkMarshalledChildMessage.java} (76%)
create mode 100644
modules/core/src/test/resources/codegen/TestJdkMarshalledChildMessageMarshaller.java
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
TestJdkMarshalledMessage.java} (80%)
create mode 100644
modules/core/src/test/resources/codegen/TestJdkMarshalledMessageMarshaller.java
copy modules/core/src/test/resources/codegen/{EmptyMessage.java =>
TestSelfMarshallingMessage.java} (75%)
copy
modules/core/src/test/resources/codegen/{TestMarshallableMessageMarshaller.java
=> TestSelfMarshallingMessageMarshaller.java} (63%)
copy
modules/core/src/test/resources/codegen/{TestMarshalledMessageSerializer.java
=> TestSelfMarshallingMessageSerializer.java} (73%)
copy
modules/core/src/test/resources/codegen/{DefaultMapperEnumFieldsMessage.java =>
TwoDifferentEnumsInCollectionMessage.java} (84%)
rename modules/core/src/test/resources/codegen/{EmptyMessage.java =>
WrongEnumSetMessage.java} (81%)
copy
modules/core/src/test/resources/codegen/{CustomMapperEnumFieldsMessage.java =>
WrongSelfMarshallingMessage.java} (73%)
create mode 100644 modules/ducktests/DEV_GUIDE.md
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/dto/IndexedDataRecord.java
copy
modules/{nio/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageCollectionType.java
=>
ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/LoadMode.java}
(51%)
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcCacheAwareApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcContinuousLoadApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcDataCheckerApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcDataGeneratorApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/tests/mdc/MdcThinClientLoadApplication.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/utils/OpStats.java
create mode 100644
modules/ducktests/src/main/java/org/apache/ignite/internal/ducktest/utils/Utils.java
create mode 100644
modules/ducktests/tests/checks/services/network_group/check_manager.py
create mode 100644
modules/ducktests/tests/checks/utils/check_cache_distribution.py
rename modules/{core/src/test/config/class_list_test_excluded.txt =>
ducktests/tests/ignitetest/services/mdc/__init__.py} (82%)
create mode 100644
modules/ducktests/tests/ignitetest/services/mdc/mdc_cluster.py
copy modules/ducktests/tests/{docker/requirements.txt =>
ignitetest/services/network_group/__init__.py} (82%)
create mode 100644
modules/ducktests/tests/ignitetest/services/network_group/configuration.py
create mode 100644
modules/ducktests/tests/ignitetest/services/network_group/manager.py
create mode 100644
modules/ducktests/tests/ignitetest/services/network_group/tc_rule_args.py
copy modules/ducktests/tests/{docker/requirements.txt =>
ignitetest/tests/mdc/__init__.py} (93%)
create mode 100644
modules/ducktests/tests/ignitetest/tests/mdc/partition_resilience_test.py
create mode 100644
modules/ducktests/tests/ignitetest/tests/mdc/thin_client_test.py
create mode 100644
modules/ducktests/tests/ignitetest/tests/mdc/transactional_partition_test.py
copy
modules/{yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteIoTestSendAllBenchmark.java
=>
nio/src/main/java/org/apache/ignite/plugin/extensions/communication/CollectionImplementationType.java}
(68%)
create mode 100644
modules/nio/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageEnumType.java
