This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-20503
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 87aeb32bfd Minor after review.
add c8685ff5b6 IGNITE-22269 Introduce new err code NULLABLE_VALUE_ERR
(#3983)
add 525c3ee2a4 IGNITE-22554 Rename nonStableNodeAssignments and simplify
code (#3969)
add 3095905ce4 IGNITE-22262 Sql. Fixed API usage example (SqlApiExample)
(#3961)
add da7a116d8c IGNITE-22582 Clarify KeyValueView#getAll javadoc about
non-existing keys (#3988)
add c8bd7550b6 IGNITE-22463 Improve CLI error message when executing
commands on uninitialized cluster (#3921)
add 9d7bc87c1b IGNITE-22561 Get rid of ByteString in messages (#3987)
add 1783a4a3de IGNITE-22541 Fix bool handling in C++ binary_tuple_builder
(#3984)
add de847a9fa2 IGNITE-22589 Rename
StopNodeOrHaltFailureHandlerConfigurationSchema.timeout to timeoutMillis (#3991)
add 9b42e3e815 IGNITE-22073 Sql. Add processing of the provided query
timeout (#3953)
add aab9667bda IGNITE-22589 Fix FailureProcessor initialization (#3994)
add 6e7f25d33c IGNITE-22569 Java thin: fix SqlBatchException propagation
(#3982)
add 055b61f97c IGNITE-22539 .NET: Add JobTarget (#3993)
add 8b6bf933dc Merge branch 'main' into ignite-20503
No new revisions were added by this update.
Summary of changes:
.../ignite/example/sql/ItSqlExamplesTest.java | 2 -
.../apache/ignite/example/sql/SqlApiExample.java | 108 +++++---
.../java/org/apache/ignite/lang/ErrorGroups.java | 29 +-
.../ignite/lang/UnexpectedNullValueException.java | 2 +-
.../org/apache/ignite/sql/SqlBatchException.java | 22 +-
.../java/org/apache/ignite/sql/SqlException.java | 9 +-
.../java/org/apache/ignite/table/KeyValueView.java | 1 +
...liCommandTestNotInitializedIntegrationBase.java | 7 +
.../cli/commands/ItNonInitializedClusterTest.java | 161 +++++++++++
.../commands/ItReplNonInitializedClusterTest.java} | 21 +-
.../ItRestartPartitionsReplCommandTest.java | 27 --
.../cluster/config/ClusterConfigShowCommand.java | 4 +-
.../config/ClusterConfigShowReplCommand.java | 2 +-
.../cluster/config/ClusterConfigUpdateCommand.java | 4 +-
.../config/ClusterConfigUpdateReplCommand.java | 2 +-
.../cluster/topology/LogicalTopologyCommand.java | 4 +-
.../topology/LogicalTopologyReplCommand.java | 2 +-
.../cluster/unit/ClusterUnitDeployCommand.java | 2 +-
.../cluster/unit/ClusterUnitDeployReplCommand.java | 2 +-
.../cluster/unit/ClusterUnitListCommand.java | 2 +-
.../cluster/unit/ClusterUnitListReplCommand.java | 2 +-
.../cluster/unit/ClusterUnitUndeployCommand.java | 2 +-
.../unit/ClusterUnitUndeployReplCommand.java | 2 +-
.../node/metric/NodeMetricSetListCommand.java | 2 +
.../node/metric/NodeMetricSetListReplCommand.java | 2 +
.../metric/NodeMetricSourceDisableCommand.java | 2 +-
.../metric/NodeMetricSourceDisableReplCommand.java | 2 +-
.../node/metric/NodeMetricSourceEnableCommand.java | 2 +-
.../metric/NodeMetricSourceEnableReplCommand.java | 2 +-
.../node/metric/NodeMetricSourceListCommand.java | 2 +-
.../metric/NodeMetricSourceListReplCommand.java | 2 +-
.../commands/node/unit/NodeUnitListCommand.java | 2 +-
.../node/unit/NodeUnitListReplCommand.java | 2 +-
.../partitions/reset/ResetPartitionsCommand.java | 2 +
.../reset/ResetPartitionsReplCommand.java | 2 +
.../restart/RestartPartitionsCommand.java | 2 +
.../restart/RestartPartitionsReplCommand.java | 2 +
.../partitions/states/PartitionStatesCommand.java | 2 +
.../states/PartitionStatesReplCommand.java | 2 +
.../ClusterNotInitializedExceptionHandler.java | 18 ++
.../internal/client/proto/ErrorExtensions.java | 2 +
.../jdbc/proto/event/JdbcBatchExecuteRequest.java | 25 +-
.../proto/event/JdbcBatchPreparedStmntRequest.java | 26 +-
.../jdbc/proto/event/JdbcQueryExecuteRequest.java | 29 +-
.../handler/ClientInboundMessageHandler.java | 27 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 43 ++-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 52 +---
.../handler/JdbcQueryEventHandlerImplTest.java | 14 +-
.../ignite/internal/client/TcpClientChannel.java | 32 ++-
.../ignite/internal/client/sql/ClientSql.java | 44 +--
.../apache/ignite/internal/util/ArrayUtils.java | 4 +
.../apache/ignite/internal/util/Cancellable.java | 4 +-
modules/failure-handler/build.gradle | 1 +
.../ignite/internal/failure/FailureProcessor.java | 11 +-
.../failure/handlers/NoOpFailureHandler.java | 2 +-
.../failure/handlers/StopNodeFailureHandler.java | 2 +-
.../handlers/StopNodeOrHaltFailureHandler.java | 4 +-
...odeOrHaltFailureHandlerConfigurationSchema.java | 4 +-
.../internal/failure/FailureProcessorTest.java | 35 ++-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 103 ++++++++
.../ignite/jdbc/ItJdbcMultiStatementSelfTest.java | 49 ++++
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 67 +++++
.../internal/jdbc/JdbcPreparedStatement.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 33 ++-
.../internal/network/annotations/Transferable.java | 2 +
.../network/direct/DirectMessageWriter.java | 6 +-
modules/platforms/cpp/cmake/ignite_test.cmake | 4 +
.../cpp/ignite/client/detail/table/table_impl.h | 13 +-
.../platforms/cpp/ignite/common/big_integer.cpp | 237 +++--------------
modules/platforms/cpp/ignite/common/big_integer.h | 27 +-
modules/platforms/cpp/ignite/common/detail/bits.h | 2 +-
modules/platforms/cpp/ignite/common/detail/bytes.h | 2 +-
modules/platforms/cpp/ignite/common/detail/mpi.cpp | 14 +
modules/platforms/cpp/ignite/common/detail/mpi.h | 43 ++-
.../cpp/ignite/common/detail/server_version.h | 2 +-
modules/platforms/cpp/ignite/common/error_codes.h | 22 +-
modules/platforms/cpp/ignite/common/ignite_error.h | 44 +--
modules/platforms/cpp/ignite/odbc/common_types.cpp | 3 +-
modules/platforms/cpp/ignite/odbc/odbc_error.h | 21 ++
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 69 ++---
.../platforms/cpp/ignite/odbc/query/data_query.h | 7 +
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 15 +-
modules/platforms/cpp/ignite/odbc/sql_connection.h | 36 +++
modules/platforms/cpp/ignite/protocol/utils.cpp | 18 +-
modules/platforms/cpp/ignite/protocol/utils.h | 9 +
.../cpp/ignite/tuple/binary_tuple_builder.cpp | 3 +-
modules/platforms/cpp/ignite/tuple/tuple_test.cpp | 137 +++++++++-
.../cpp/tests/client-test/compute_test.cpp | 3 +-
.../cpp/tests/odbc-test/odbc_connection.h | 6 +-
.../cpp/tests/test-common/ignite_runner.h | 3 +-
.../Apache.Ignite.Tests/BasicAuthenticatorTests.cs | 5 +-
.../Compute/ComputeClusterAwarenessTests.cs | 19 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 206 +++++++++------
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 2 +-
.../PartitionAwarenessRealClusterTests.cs | 8 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 16 +-
.../Proto/ColocationHashTests.cs | 17 +-
.../Table/SchemaSynchronizationTest.cs | 16 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 3 +
.../dotnet/Apache.Ignite.Tests/ToStringTests.cs | 5 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 2 +-
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 51 +---
.../IJobTarget.cs} | 17 +-
.../dotnet/Apache.Ignite/Compute/JobDescriptor.cs | 12 +-
.../dotnet/Apache.Ignite/Compute/JobTarget.cs | 87 ++++++
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 26 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 130 ++++-----
.../internal/raft/util/OptimizedMarshaller.java | 2 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 4 +-
.../raft/jraft/core/ReadOnlyServiceImpl.java | 8 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 12 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 19 +-
.../ignite/raft/jraft/storage/FileService.java | 6 +-
.../jraft/storage/snapshot/remote/CopySession.java | 5 +-
.../ignite/raft/jraft/util/AsciiStringUtil.java | 9 -
.../apache/ignite/raft/jraft/util/ByteString.java | 103 --------
.../apache/ignite/raft/jraft/util/BytesUtil.java | 30 +++
.../raft/jraft/util/RecyclableByteBufferList.java | 4 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 11 +-
.../raft/jraft/core/ReplicatorGroupTest.java | 4 +-
.../ignite/raft/jraft/core/ReplicatorTest.java | 28 +-
.../raft/jraft/rpc/AppendEntriesBenchmark.java | 7 +-
.../ignite/raft/jraft/storage/FileServiceTest.java | 5 +-
.../raft/jraft/storage/SnapshotExecutorTest.java | 10 +-
.../snapshot/local/LocalSnapshotCopierTest.java | 5 +-
.../storage/snapshot/remote/CopySessionTest.java | 6 +-
.../runner/app/ItIgniteNodeRestartTest.java | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +-
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 99 +++++++
.../sql/engine/ItDynamicParameterTest.java | 38 ++-
.../ignite/internal/sql/api/IgniteSqlImpl.java | 9 +-
.../ignite/internal/sql/engine/QueryCancel.java | 107 ++++++--
.../sql/engine/QueryCancelledException.java | 22 +-
.../internal/sql/engine/SqlOperationContext.java | 6 +-
.../internal/sql/engine/SqlQueryProcessor.java | 73 ++++-
.../internal/sql/engine/exec/ExecutionContext.java | 11 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 124 +++++++--
.../sql/engine/prepare/KeyValueGetPlan.java | 11 +
.../sql/engine/prepare/KeyValueModifyPlan.java | 11 +
.../sql/engine/prepare/PlanningContext.java | 2 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 70 +++--
.../internal/sql/engine/util/cache/Cache.java | 14 +
.../engine/util/cache/CaffeineCacheFactory.java | 10 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 294 ++++++++++++++++++++-
.../engine/exec/NoOpExecutableTableRegistry.java | 27 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 3 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 31 ++-
.../internal/sql/engine/framework/TestIndex.java | 15 +-
.../sql/engine/planner/AbstractPlannerTest.java | 2 +
.../sql/engine/planner/PlannerTimeoutTest.java | 4 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 101 ++++++-
.../sql/engine/util/EmptyCacheFactory.java | 10 +
.../internal/sql/engine/util/QueryCheckerImpl.java | 4 +-
.../internal/table/distributed/TableManager.java | 245 ++++++++---------
.../schema/CheckCatalogVersionOnAppendEntries.java | 2 +-
157 files changed, 2782 insertions(+), 1306 deletions(-)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItNonInitializedClusterTest.java
copy
modules/{file-io/src/test/java/org/apache/ignite/internal/fileio/RandomAccessFileIoTest.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItReplNonInitializedClusterTest.java}
(66%)
delete mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/partitions/restart/ItRestartPartitionsReplCommandTest.java
mode change 100644 => 100755 modules/platforms/cpp/ignite/common/error_codes.h
copy
modules/platforms/dotnet/Apache.Ignite/{Table/DataStreamerOperationType.cs =>
Compute/IJobTarget.cs} (79%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Compute/JobTarget.cs
mode change 100644 => 100755
modules/platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs
delete mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/util/ByteString.java
