You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ti...@apache.org on 2024/12/10 14:50:42 UTC
(ignite) branch application_context updated (3dfd135acc5 -> 1bcd39bcb12)
This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a change to branch application_context
in repository https://gitbox.apache.org/repos/asf/ignite.git
from 3dfd135acc5 IGNITE-23392 Add SessionContext API (#11618)
add 734dc16f564 IGNITE-23657 Added logging of the IdleVerify command (#11665)
add c1e0332085e IGNITE-23684 SQL Calcite: Add date formatting/parsing functions with custom format - Fixes #11674.
add bb4dc197c98 IGNITE-23676 SQL Calcite: Fix sensitive information removal failure for JOINs and other SQL nodes - Fixes #11663.
add 5a9dab62bf3 IGNITE-23472 Fix JavaLogger doesn't log configuration file path (#11615)
add 84a2d58f577 IGNITE-23794 Fixed send a stack trace to a thin client if task fails on map phase. (#11687)
add 964dc48a454 IGNITE-23820 Run against approved commit in privileged workflow (#11691)
add 9dfc3ad116f IGNITE-12678 Fix zero size GridLongList#add (#11693)
add 275bc22d854 IGNITE-18572 Add query thread pool metrics in the log file (#10489)
add 9b55a744f6a IGNITE-23807 Remove all DirectByteBufferStreamImpl except last (#11688)
add 3a9be379bd2 IGNITE-23839 Remove IgniteFeatures#CACHE_METRICS_V2 and related code (#11697)
add b1907143894 MINOR: Cleanup dead IgniteFeatures entries (#11709)
add 21f6b889989 IGNITE-23745 SQL Calcite: Add ability to extend SQL engine with new system functions/operators - Fixes #11684.
add ffb07dbb3c7 IGNITE-23804 SQL Calcite: Fix numeric to interval cast - Fixes #11707.
add c4b72191b35 IGNITE-23562 SQL Calcite: Fix partition reservation for index-count-scan - Fixes #11651.
add ef8fe979af3 IGNITE-23875 Remove setForceServerMode from indexing tests (#11710)
add 8bf906fd083 IGNITE-23200 Fix attempts limit in java thin client for Ignite cluster request (#11660)
add 39e7958db6c IGNITE-23110 Disallow cache clear operations within transaction (#11559)
add 49321cd7081 IGNITE-23887 Remove setForceServerMode from IgniteCacheAbstractQuerySelfTest (#11711)
add 84dd0279535 IGNITE-23840 Remove IgniteFeatures#DIFFERENT_REBALANCE_POOL_SIZE and related code (#11698)
add 114fc57b146 IGNITE-23897 Remove setForceServerMode from GridAffinityProcessorAbstractSelfTest and other tests (#11712)
add b3821327115 IGNITE-23841 Remove IgniteFeatures#CLUSTER_READ_ONLY_MODE and related code (#11699)
add db3e9468552 IGNITE-23842 Remove IgniteFeatures#TRANSACTION_OWNER_THREAD_DUMP_PROVIDING and related code (#11700)
add a3d93a9be10 IGNITE-23843 Remove IgniteFeatures#SUSPEND_RESUME_PESSIMISTIC_TX and related code (#11701)
add 2bbfc98d929 IGNITE-23903 Remove setForceServerMode from IgniteClientDataStructuresTest (#11715)
add 543ac72cc37 IGNITE-23632 Support force deactivation flag in thin client (#11647)
add 783b4934509 IGNITE-23913 Remove setForceServerMode from IgniteCacheManyClientsTest (#11717)
add 5d3f9efc200 IGNITE-18520 Support stopWarmup command in thin client (#11646)
add 700f921a43a IGNITE-23808 Remove MessageFactory (#11692)
add fe029464b70 IGNITE-23815 Fix assertion during RotatedIdPartRecord read from WAL - Fixes #11695.
add 7472af68961 IGNITE-23844 Remove IgniteFeatures#MASTER_KEY_CHANGE and related code (#11702)
add 7cde4f477c3 IGNITE-23922 Remove setForceServerMode from simple core tests (#11720)
add cbd8973151b IGNITE-23932 Remove setForceServerMode from GridTaskFailoverAffinityRunTest (#11722)
new 1bcd39bcb12 Merge branch 'master' into application_context
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/sonar-pr-from-fork-build.yml | 5 -
.github/workflows/sonar-pr-from-fork-scan.yml | 12 +-
docs/_docs/SQL/sql-calcite.adoc | 2 +-
.../jmh/io/JmhDirectByteBufferStreamBenchmark.java | 156 --
.../query/calcite/CalciteQueryProcessor.java | 31 +-
.../query/calcite/exec/AbstractCacheScan.java | 4 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 6 +
.../query/calcite/exec/IndexCountScan.java | 197 +++
.../query/calcite/exec/LogicalRelImplementor.java | 4 +-
.../query/calcite/exec/exp/IgniteRexBuilder.java | 11 +-
.../query/calcite/exec/exp/RexImpTable.java | 17 +-
.../query/calcite/exec/exp/RexToLixTranslator.java | 39 +-
.../calcite/message/CalciteMessageFactory.java | 4 +-
.../calcite/prepare/IgniteConvertletTable.java | 2 +-
.../calcite/prepare/IgniteSqlCallRewriteTable.java | 21 +-
.../query/calcite/schema/CacheIndexImpl.java | 147 +-
.../query/calcite/schema/IgniteIndex.java | 4 +-
.../query/calcite/schema/SystemViewIndexImpl.java | 5 +-
.../calcite/sql/fun/IgniteStdSqlOperatorTable.java | 3 +
.../query/calcite/util/IgniteMethod.java | 4 +
.../integration/AbstractBasicIntegrationTest.java | 4 +-
.../AbstractBasicIntegrationTransactionalTest.java | 4 +-
.../query/calcite/integration/IntervalTest.java | 16 +-
.../OperatorsExtensionIntegrationTest.java | 208 +++
.../PartitionsReservationIntegrationTest.java | 142 ++
.../integration/SqlDiagnosticIntegrationTest.java | 8 +-
.../calcite/integration/StdSqlOperatorsTest.java | 3 +
.../UnstableTopologyIntegrationTest.java} | 41 +-
...lciteCommunicationMessageSerializationTest.java | 4 +-
.../ignite/testsuites/IntegrationTestSuite.java | 8 +-
.../GridCommandHandlerInterruptCommandTest.java | 15 +
.../main/java/org/apache/ignite/IgniteCache.java | 16 +-
.../ignite/internal/IgniteComponentType.java | 8 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 57 -
.../internal/client/thin/ClientClusterImpl.java | 24 +-
.../internal/client/thin/ClientOperation.java | 5 +-
.../client/thin/ProtocolBitmaskFeature.java | 6 +-
.../internal/client/thin/ReliableChannel.java | 9 +-
.../internal/client/thin/TcpClientCache.java | 89 +-
.../internal/client/thin/TcpClientChannel.java | 39 +-
.../internal/client/thin/TcpIgniteClient.java | 5 +
.../internal/direct/DirectMessageReader.java | 55 +-
.../internal/direct/DirectMessageWriter.java | 63 +-
.../direct/stream/DirectByteBufferStream.java | 1792 ++++++++++++++++++-
.../stream/v1/DirectByteBufferStreamImplV1.java | 1356 ---------------
.../stream/v2/DirectByteBufferStreamImplV2.java | 1820 --------------------
.../stream/v3/DirectByteBufferStreamImplV3.java | 304 ----
.../stream/v4/DirectByteBufferStreamImplV4.java | 204 ---
.../cache/VerifyBackupPartitionsTaskV2.java | 8 +
.../managers/communication/GridIoManager.java | 30 +-
.../communication/GridIoMessageFactory.java | 10 +-
.../communication/IgniteMessageFactoryImpl.java | 37 +-
.../managers/encryption/GridEncryptionManager.java | 14 -
.../managers/encryption/GroupKeyChangeProcess.java | 5 -
.../internal/plugin/IgniteLogInfoProviderImpl.java | 2 +
.../processors/cache/CacheMetricsSnapshot.java | 181 +-
.../processors/cache/CacheMetricsSnapshotV2.java | 1250 --------------
.../processors/cache/GridCacheAdapter.java | 27 +-
.../cache/GridCachePartitionExchangeManager.java | 95 +-
.../cache/ValidationOnNodeJoinUtils.java | 31 -
.../wal/serializer/RecordDataV1Serializer.java | 2 +-
.../cache/transactions/IgniteTxManager.java | 22 -
.../cluster/GridClusterStateProcessor.java | 8 -
.../ClientConnectionNodeRecoveryException.java} | 15 +-
.../processors/odbc/ClientListenerNioListener.java | 29 +-
.../processors/odbc/ClientListenerProcessor.java | 10 +-
.../processors/odbc/ClientListenerRequest.java | 5 +
.../platform/client/ClientBitmaskFeature.java | 6 +-
.../platform/client/ClientMessageParser.java | 17 +-
.../processors/platform/client/ClientStatus.java | 3 +
.../platform/client/IgniteClientException.java | 2 +-
.../ClientCacheStopWarmupRequest.java} | 38 +-
.../cluster/ClientClusterChangeStateRequest.java | 25 +-
.../platform/client/compute/ClientComputeTask.java | 8 +-
.../apache/ignite/internal/util/GridLongList.java | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 33 +-
.../internal/util/nio/GridNioMessageReader.java | 42 -
.../internal/util/nio/GridNioMessageWriter.java | 49 -
.../org/apache/ignite/logger/java/JavaLogger.java | 27 +-
.../communication/IgniteMessageFactory.java | 39 -
.../extensions/communication/MessageFactory.java | 30 +-
.../communication/MessageFactoryProvider.java | 21 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 5 +
.../tcp/TcpCommunicationMetricsListener.java | 6 +-
.../tcp/internal/GridNioServerWrapper.java | 16 +-
.../main/resources/META-INF/classnames.properties | 1 -
modules/core/src/test/config/jul-debug.properties | 50 +
.../org/apache/ignite/client/ReliabilityTest.java | 29 +-
.../internal/GridNodeMetricsLogSelfTest.java | 1 +
.../internal/GridTaskFailoverAffinityRunTest.java | 30 +-
.../internal/client/thin/BlockingTxOpsTest.java | 14 -
.../internal/client/thin/ClusterApiTest.java | 32 +-
.../internal/client/thin/ComputeTaskTest.java | 40 +-
.../internal/client/thin/RecoveryModeTest.java | 195 +++
...inClientNonTransactionalOperationsInTxTest.java | 98 ++
.../direct/DirectMarshallingMessagesTest.java | 13 +-
...rectByteBufferStreamImplByteOrderSelfTest.java} | 34 +-
.../GridManagerLocalMessageListenerSelfTest.java | 5 +-
...tractCommunicationMessageSerializationTest.java | 8 +-
.../GridCommunicationSendMessageSelfTest.java | 5 +-
...iteIoCommunicationMessageSerializationTest.java | 4 +-
.../IgniteMessageFactoryImplTest.java | 34 +-
.../MessageDirectTypeIdConflictTest.java | 5 +-
.../IgniteTopologyPrintFormatSelfTest.java | 8 +-
.../GridAffinityProcessorAbstractSelfTest.java | 3 -
.../CacheAtomicSingleMessageCountSelfTest.java | 9 +-
.../cache/CacheMetricsCacheSizeTest.java | 2 +-
.../cache/CacheStopAndDestroySelfTest.java | 3 -
.../GridCacheConditionalDeploymentSelfTest.java | 5 +-
.../GridCacheMixedPartitionExchangeSelfTest.java | 3 -
.../cache/GridCachePutAllFailoverSelfTest.java | 9 +-
.../IgniteCacheConfigurationTemplateTest.java | 28 -
.../cache/IgniteCacheNearLockValueSelfTest.java | 3 -
.../cache/IgniteDynamicCacheStartSelfTest.java | 4 -
...lientNodeBinaryObjectMetadataMultinodeTest.java | 13 +-
...ridCacheClientNodeBinaryObjectMetadataTest.java | 3 -
.../IgniteClientDataStructuresAbstractTest.java | 600 -------
.../IgniteClientDataStructuresTest.java | 556 +++++-
.../distributed/GridCacheMixedModeSelfTest.java | 3 -
...gniteCacheClientNodePartitionsExchangeTest.java | 23 +-
.../IgniteCacheClientReconnectTest.java | 41 +-
.../distributed/IgniteCacheManyClientsTest.java | 18 -
.../IgniteCacheNearRestartRollbackSelfTest.java | 4 -
.../GridCacheRendezvousAffinityClientSelfTest.java | 7 +-
.../lru/LruNearOnlyNearEvictionPolicySelfTest.java | 5 +-
.../wal/WalRotatedIdPartRecordTest.java | 182 ++
.../cache/query/IndexingSpiQueryTxSelfTest.java | 2 -
...niteCacheContinuousQueryImmutableEntryTest.java | 8 +-
.../NonTransactionalOperationsInTxTest.java | 125 ++
.../processors/cache/warmup/WarmUpSelfTest.java | 35 +
.../apache/ignite/logger/java/JavaLoggerTest.java | 112 +-
.../messaging/IgniteMessagingWithClientTest.java | 4 -
.../GridAbstractCommunicationSelfTest.java | 5 +-
.../communication/GridCacheMessageSelfTest.java | 5 +-
...pCommunicationSpiConcurrentConnectSelfTest.java | 5 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 3 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 3 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 5 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 3 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 5 +-
.../tcp/TcpCommunicationStatisticsTest.java | 5 +-
.../tcp/TcpClientDiscoverySpiMulticastTest.java | 33 +-
.../discovery/tcp/TcpDiscoveryFailedJoinTest.java | 7 -
.../vm/TcpDiscoveryVmIpFinderSelfTest.java | 19 +-
.../ignite/testframework/GridSpiTestContext.java | 8 +-
.../ignite/testframework/ListeningTestLogger.java | 8 +
.../junits/logger/GridTestLog4jLogger.java | 20 +-
.../junits/logger/GridTestLog4jLoggerSelfTest.java | 95 +-
.../ignite/testsuites/IgniteBasicTestSuite2.java | 2 +
.../IgniteCacheDataStructuresSelfTestSuite.java | 2 -
.../testsuites/IgniteMarshallerSelfTestSuite.java | 4 +-
.../ignite/testsuites/IgnitePdsTestSuite7.java | 3 +
.../apache/ignite/util/GridLongListSelfTest.java | 13 +-
.../ignite/util/GridMessageCollectionTest.java | 27 +-
.../h2/twostep/msg/GridH2ValueMessageFactory.java | 10 +-
.../org/apache/ignite/client/ClientTestSuite.java | 4 +
.../CacheScanPartitionQueryFallbackSelfTest.java | 3 -
.../cache/IgniteCacheAbstractQuerySelfTest.java | 3 -
.../cache/IgniteCacheNoClassQuerySelfTest.java | 3 -
.../query/IgniteSqlDefaultValueTest.java | 11 -
.../H2CommunicationMessageSerializationTest.java | 4 +-
.../opencensus/OpenCensusTracingSpiTest.java | 8 -
162 files changed, 4713 insertions(+), 7158 deletions(-)
delete mode 100644 modules/benchmarks/src/main/java/org/apache/ignite/internal/benchmarks/jmh/io/JmhDirectByteBufferStreamBenchmark.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexCountScan.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/OperatorsExtensionIntegrationTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/PartitionsReservationIntegrationTest.java
rename modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/{UnstableTopologyTest.java => integration/UnstableTopologyIntegrationTest.java} (86%)
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/direct/stream/v1/DirectByteBufferStreamImplV1.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/direct/stream/v3/DirectByteBufferStreamImplV3.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/direct/stream/v4/DirectByteBufferStreamImplV4.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshotV2.java
rename modules/core/src/{test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDiscoveryDataStructuresTest.java => main/java/org/apache/ignite/internal/processors/odbc/ClientConnectionNodeRecoveryException.java} (68%)
copy modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/{cluster/ClientClusterChangeStateRequest.java => beforestart/ClientCacheStopWarmupRequest.java} (65%)
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageReader.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMessageWriter.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/IgniteMessageFactory.java
create mode 100644 modules/core/src/test/config/jul-debug.properties
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/client/thin/RecoveryModeTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/client/thin/ThinClientNonTransactionalOperationsInTxTest.java
rename modules/core/src/test/java/org/apache/ignite/internal/direct/stream/{v2/DirectByteBufferStreamImplV2ByteOrderSelfTest.java => DirectByteBufferStreamImplByteOrderSelfTest.java} (93%)
delete mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/IgniteClientDataStructuresAbstractTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/wal/WalRotatedIdPartRecordTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/NonTransactionalOperationsInTxTest.java
(ignite) 01/01: Merge branch 'master' into application_context
Posted by ti...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a commit to branch application_context
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 1bcd39bcb12299c8fece36e029c89d9c5f18b42e
Merge: 3dfd135acc5 cbd8973151b
Author: Maksim Timonin <ti...@gmail.com>
AuthorDate: Tue Dec 10 17:50:25 2024 +0300
Merge branch 'master' into application_context
.github/workflows/sonar-pr-from-fork-build.yml | 5 -
.github/workflows/sonar-pr-from-fork-scan.yml | 12 +-
docs/_docs/SQL/sql-calcite.adoc | 2 +-
.../jmh/io/JmhDirectByteBufferStreamBenchmark.java | 156 --
.../query/calcite/CalciteQueryProcessor.java | 31 +-
.../query/calcite/exec/AbstractCacheScan.java | 4 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 6 +
.../query/calcite/exec/IndexCountScan.java | 197 +++
.../query/calcite/exec/LogicalRelImplementor.java | 4 +-
.../query/calcite/exec/exp/IgniteRexBuilder.java | 11 +-
.../query/calcite/exec/exp/RexImpTable.java | 17 +-
.../query/calcite/exec/exp/RexToLixTranslator.java | 39 +-
.../calcite/message/CalciteMessageFactory.java | 4 +-
.../calcite/prepare/IgniteConvertletTable.java | 2 +-
.../calcite/prepare/IgniteSqlCallRewriteTable.java | 21 +-
.../query/calcite/schema/CacheIndexImpl.java | 147 +-
.../query/calcite/schema/IgniteIndex.java | 4 +-
.../query/calcite/schema/SystemViewIndexImpl.java | 5 +-
.../calcite/sql/fun/IgniteStdSqlOperatorTable.java | 3 +
.../query/calcite/util/IgniteMethod.java | 4 +
.../integration/AbstractBasicIntegrationTest.java | 4 +-
.../AbstractBasicIntegrationTransactionalTest.java | 4 +-
.../query/calcite/integration/IntervalTest.java | 16 +-
.../OperatorsExtensionIntegrationTest.java | 208 +++
.../PartitionsReservationIntegrationTest.java | 142 ++
.../integration/SqlDiagnosticIntegrationTest.java | 8 +-
.../calcite/integration/StdSqlOperatorsTest.java | 3 +
.../UnstableTopologyIntegrationTest.java} | 41 +-
...lciteCommunicationMessageSerializationTest.java | 4 +-
.../ignite/testsuites/IntegrationTestSuite.java | 8 +-
.../GridCommandHandlerInterruptCommandTest.java | 15 +
.../main/java/org/apache/ignite/IgniteCache.java | 16 +-
.../ignite/internal/IgniteComponentType.java | 8 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 57 -
.../internal/client/thin/ClientClusterImpl.java | 24 +-
.../internal/client/thin/ClientOperation.java | 5 +-
.../client/thin/ProtocolBitmaskFeature.java | 6 +-
.../internal/client/thin/ReliableChannel.java | 9 +-
.../internal/client/thin/TcpClientCache.java | 89 +-
.../internal/client/thin/TcpClientChannel.java | 39 +-
.../internal/client/thin/TcpIgniteClient.java | 5 +
.../internal/direct/DirectMessageReader.java | 55 +-
.../internal/direct/DirectMessageWriter.java | 63 +-
.../direct/stream/DirectByteBufferStream.java | 1792 ++++++++++++++++++-
.../stream/v1/DirectByteBufferStreamImplV1.java | 1356 ---------------
.../stream/v2/DirectByteBufferStreamImplV2.java | 1820 --------------------
.../stream/v3/DirectByteBufferStreamImplV3.java | 304 ----
.../stream/v4/DirectByteBufferStreamImplV4.java | 204 ---
.../cache/VerifyBackupPartitionsTaskV2.java | 8 +
.../managers/communication/GridIoManager.java | 30 +-
.../communication/GridIoMessageFactory.java | 10 +-
.../communication/IgniteMessageFactoryImpl.java | 37 +-
.../managers/encryption/GridEncryptionManager.java | 14 -
.../managers/encryption/GroupKeyChangeProcess.java | 5 -
.../internal/plugin/IgniteLogInfoProviderImpl.java | 2 +
.../processors/cache/CacheMetricsSnapshot.java | 181 +-
.../processors/cache/CacheMetricsSnapshotV2.java | 1250 --------------
.../processors/cache/GridCacheAdapter.java | 27 +-
.../cache/GridCachePartitionExchangeManager.java | 95 +-
.../cache/ValidationOnNodeJoinUtils.java | 31 -
.../wal/serializer/RecordDataV1Serializer.java | 2 +-
.../cache/transactions/IgniteTxManager.java | 22 -
.../cluster/GridClusterStateProcessor.java | 8 -
.../ClientConnectionNodeRecoveryException.java} | 15 +-
.../processors/odbc/ClientListenerNioListener.java | 29 +-
.../processors/odbc/ClientListenerProcessor.java | 10 +-
.../processors/odbc/ClientListenerRequest.java | 5 +
.../platform/client/ClientBitmaskFeature.java | 6 +-
.../platform/client/ClientMessageParser.java | 17 +-
.../processors/platform/client/ClientStatus.java | 3 +
.../platform/client/IgniteClientException.java | 2 +-
.../ClientCacheStopWarmupRequest.java} | 38 +-
.../cluster/ClientClusterChangeStateRequest.java | 25 +-
.../platform/client/compute/ClientComputeTask.java | 8 +-
.../apache/ignite/internal/util/GridLongList.java | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 33 +-
.../internal/util/nio/GridNioMessageReader.java | 42 -
.../internal/util/nio/GridNioMessageWriter.java | 49 -
.../org/apache/ignite/logger/java/JavaLogger.java | 27 +-
.../communication/IgniteMessageFactory.java | 39 -
.../extensions/communication/MessageFactory.java | 30 +-
.../communication/MessageFactoryProvider.java | 21 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 5 +
.../tcp/TcpCommunicationMetricsListener.java | 6 +-
.../tcp/internal/GridNioServerWrapper.java | 16 +-
.../main/resources/META-INF/classnames.properties | 1 -
modules/core/src/test/config/jul-debug.properties | 50 +
.../org/apache/ignite/client/ReliabilityTest.java | 29 +-
.../internal/GridNodeMetricsLogSelfTest.java | 1 +
.../internal/GridTaskFailoverAffinityRunTest.java | 30 +-
.../internal/client/thin/BlockingTxOpsTest.java | 14 -
.../internal/client/thin/ClusterApiTest.java | 32 +-
.../internal/client/thin/ComputeTaskTest.java | 40 +-
.../internal/client/thin/RecoveryModeTest.java | 195 +++
...inClientNonTransactionalOperationsInTxTest.java | 98 ++
.../direct/DirectMarshallingMessagesTest.java | 13 +-
...rectByteBufferStreamImplByteOrderSelfTest.java} | 34 +-
.../GridManagerLocalMessageListenerSelfTest.java | 5 +-
...tractCommunicationMessageSerializationTest.java | 8 +-
.../GridCommunicationSendMessageSelfTest.java | 5 +-
...iteIoCommunicationMessageSerializationTest.java | 4 +-
.../IgniteMessageFactoryImplTest.java | 34 +-
.../MessageDirectTypeIdConflictTest.java | 5 +-
.../IgniteTopologyPrintFormatSelfTest.java | 8 +-
.../GridAffinityProcessorAbstractSelfTest.java | 3 -
.../CacheAtomicSingleMessageCountSelfTest.java | 9 +-
.../cache/CacheMetricsCacheSizeTest.java | 2 +-
.../cache/CacheStopAndDestroySelfTest.java | 3 -
.../GridCacheConditionalDeploymentSelfTest.java | 5 +-
.../GridCacheMixedPartitionExchangeSelfTest.java | 3 -
.../cache/GridCachePutAllFailoverSelfTest.java | 9 +-
.../IgniteCacheConfigurationTemplateTest.java | 28 -
.../cache/IgniteCacheNearLockValueSelfTest.java | 3 -
.../cache/IgniteDynamicCacheStartSelfTest.java | 4 -
...lientNodeBinaryObjectMetadataMultinodeTest.java | 13 +-
...ridCacheClientNodeBinaryObjectMetadataTest.java | 3 -
.../IgniteClientDataStructuresAbstractTest.java | 600 -------
.../IgniteClientDataStructuresTest.java | 556 +++++-
.../distributed/GridCacheMixedModeSelfTest.java | 3 -
...gniteCacheClientNodePartitionsExchangeTest.java | 23 +-
.../IgniteCacheClientReconnectTest.java | 41 +-
.../distributed/IgniteCacheManyClientsTest.java | 18 -
.../IgniteCacheNearRestartRollbackSelfTest.java | 4 -
.../GridCacheRendezvousAffinityClientSelfTest.java | 7 +-
.../lru/LruNearOnlyNearEvictionPolicySelfTest.java | 5 +-
.../wal/WalRotatedIdPartRecordTest.java | 182 ++
.../cache/query/IndexingSpiQueryTxSelfTest.java | 2 -
...niteCacheContinuousQueryImmutableEntryTest.java | 8 +-
.../NonTransactionalOperationsInTxTest.java | 125 ++
.../processors/cache/warmup/WarmUpSelfTest.java | 35 +
.../apache/ignite/logger/java/JavaLoggerTest.java | 112 +-
.../messaging/IgniteMessagingWithClientTest.java | 4 -
.../GridAbstractCommunicationSelfTest.java | 5 +-
.../communication/GridCacheMessageSelfTest.java | 5 +-
...pCommunicationSpiConcurrentConnectSelfTest.java | 5 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 3 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 3 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 5 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 3 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 5 +-
.../tcp/TcpCommunicationStatisticsTest.java | 5 +-
.../tcp/TcpClientDiscoverySpiMulticastTest.java | 33 +-
.../discovery/tcp/TcpDiscoveryFailedJoinTest.java | 7 -
.../vm/TcpDiscoveryVmIpFinderSelfTest.java | 19 +-
.../ignite/testframework/GridSpiTestContext.java | 8 +-
.../ignite/testframework/ListeningTestLogger.java | 8 +
.../junits/logger/GridTestLog4jLogger.java | 20 +-
.../junits/logger/GridTestLog4jLoggerSelfTest.java | 95 +-
.../ignite/testsuites/IgniteBasicTestSuite2.java | 2 +
.../IgniteCacheDataStructuresSelfTestSuite.java | 2 -
.../testsuites/IgniteMarshallerSelfTestSuite.java | 4 +-
.../ignite/testsuites/IgnitePdsTestSuite7.java | 3 +
.../apache/ignite/util/GridLongListSelfTest.java | 13 +-
.../ignite/util/GridMessageCollectionTest.java | 27 +-
.../h2/twostep/msg/GridH2ValueMessageFactory.java | 10 +-
.../org/apache/ignite/client/ClientTestSuite.java | 4 +
.../CacheScanPartitionQueryFallbackSelfTest.java | 3 -
.../cache/IgniteCacheAbstractQuerySelfTest.java | 3 -
.../cache/IgniteCacheNoClassQuerySelfTest.java | 3 -
.../query/IgniteSqlDefaultValueTest.java | 11 -
.../H2CommunicationMessageSerializationTest.java | 4 +-
.../opencensus/OpenCensusTracingSpiTest.java | 8 -
162 files changed, 4713 insertions(+), 7158 deletions(-)
diff --cc modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java
index b6de7c29e22,7a8a68945b7..7e9763e161f
--- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java
+++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java
@@@ -259,8 -259,10 +263,11 @@@ public class CalciteQueryProcessor exte
prepareSvc = new PrepareServiceImpl(ctx);
timeoutSvc = new TimeoutServiceImpl(ctx);
qryReg = new QueryRegistryImpl(ctx);
+ injectSvc = new InjectResourcesService(ctx);
+ FrameworkConfig customFrameworkCfg = ctx.plugins().createComponent(FrameworkConfig.class);
+ frameworkCfg = customFrameworkCfg != null ? customFrameworkCfg : FRAMEWORK_CONFIG;
+
QueryEngineConfiguration[] qryEnginesCfg = ctx.config().getSqlConfiguration().getQueryEnginesConfiguration();
if (F.isEmpty(qryEnginesCfg))
@@@ -763,8 -776,8 +781,13 @@@
return distrCfg;
}
+ /** */
+ public FrameworkConfig frameworkConfig() {
+ return frameworkCfg;
+ }
++
+ /** */
+ public InjectResourcesService injectService() {
+ return injectSvc;
+ }
}
diff --cc modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java
index a1b304b2269,4fe07c2149b..f4773275fe6
--- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java
+++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java
@@@ -100,8 -101,8 +101,11 @@@ public enum IgniteMethod
/** See {@link IgniteSqlFunctions#skipFirstArgument(Object, Object)}. **/
SKIP_FIRST_ARGUMENT(IgniteSqlFunctions.class, "skipFirstArgument", Object.class, Object.class),
+ /** See {@link BigDecimal#multiply(BigDecimal)}. */
- BIG_DECIMAL_MULTIPLY(BigDecimal.class, "multiply", BigDecimal.class);
++ BIG_DECIMAL_MULTIPLY(BigDecimal.class, "multiply", BigDecimal.class),
++
+ /** See {@link ExecutionContext#udfInstance(String)}. */
+ UDF_INSTANCE(ExecutionContext.class, "udfInstance", String.class);
/** */
private final Method method;
diff --cc modules/calcite/src/test/java/org/apache/ignite/testsuites/IntegrationTestSuite.java
index 0f8278ac2e5,9117c21a6ec..7fe1315084e
--- a/modules/calcite/src/test/java/org/apache/ignite/testsuites/IntegrationTestSuite.java
+++ b/modules/calcite/src/test/java/org/apache/ignite/testsuites/IntegrationTestSuite.java
@@@ -144,7 -146,7 +147,8 @@@ import org.junit.runners.Suite
DdlTransactionCalciteSelfTest.class,
MultiLineQueryTest.class,
ViewsIntegrationTest.class,
+ OperatorsExtensionIntegrationTest.class,
+ SessionContextSqlFunctionTest.class,
})
public class IntegrationTestSuite {
}