This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-21580
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 3614527085 Remove unwanted project
discard 9854ead1a7 fixup! Fix aggregate row count estimation.
discard 35bed7de59 Fix tests.
discard dd4e70c8df Fix aggregate row count estimation.
discard aec5db3b6f Fix tests
discard f49027b304 Fix distinct row count calculation.
discard f2df075a0e Fix Collation pass-through for sorted map aggregate
discard 99cf852c80 Fix typo
discard 637ecf197f fix tests
discard 913f0e5046 Fix wrong memory estimation for IgniteAggregate.
add 0d4dbce79c IGNITE-21896 Close RocksDB flush listener on stop (#3533)
add e896751ac6 IGNITE-21890 Fix BinaryTupleComparator for decimal values
(#3527)
add 167f8dce56 IGNITE-21808 CREATE ZONE syntax must work with any the case
of zone name (#3508)
add dd75ada680 IGNITE-21765 Fix streamer partition awareness (#3538)
add c41a26f2d8 IGNITE-21761 Within commitPartition mark txnState with
cleanup finished timestamp (#3496)
add e394902598 IGNITE-21572 Fix one phase transaction protocol
inconsistency in case of primary replica expirations (#3467)
add bac613c518 IGNITE-17591 Refactor toString generation for network
messages (#3519)
add d9480d7e38 IGNITE-21567 Sql. Fixed precision when converting from
TIME/TIMESTAMP to VARCHAR (#3513)
add 87ee3037d4 IGNITE-21794: Sql. Rename ItKeyValuePutTest and
ItKeyValueGetTest (#3515)
add d28153dce8 IGNITE-21879 Sql. Jdbc
IdbcStatementSelfTest.testOpenCursorsPureQuery is flaky (#3543)
add 10d97f81d1 IGNITE-21887 Sql. Reuse caller thread if query already
prepared (#3525)
add 4de0999022 IGNITE-21094 Sql. Combine single/script query execution
methods into a single one (#3536)
add d3ff291c4c IGNITE-21931 .NET: Refactor DataStreamer to use
StreamerBatchSend (#3546)
add 7c8ebb82bb IGNITE-21897 Sql. Invalid collation passthrough for sorted
aggregates (#3537)
new 9970fd7652 Fix wrong memory for IgniteAggregate and distinct count
estimation.
new 04540a545e Fix tests.
new 9f9af65ff6 Add TPC-H planner test
new 3d79a7b36d Optimize test logs a bit.
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 (3614527085)
\
N -- N -- N refs/heads/ignite-21580 (3d79a7b36d)
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.
The 4 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:
.../internal/binarytuple/BinaryTupleReader.java | 7 +-
.../handler/ClientPrimaryReplicaTracker.java | 30 ++-
.../client/handler/JdbcQueryEventHandlerImpl.java | 36 +--
.../requests/sql/ClientSqlExecuteRequest.java | 2 +-
...entTablePartitionPrimaryReplicasGetRequest.java | 19 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 4 +-
.../ignite/internal/client/table/ClientTable.java | 53 +++--
.../client/fakes/FakeIgniteQueryProcessor.java | 34 ++-
.../apache/ignite/internal/lang/InternalTuple.java | 3 +-
.../internal/tostring/IgniteToStringExclude.java | 6 +-
.../internal/tostring/IgniteToStringInclude.java | 6 +-
.../apache/ignite/jdbc/ItJdbcErrorsSelfTest.java | 2 -
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 10 +-
.../processor/messages/MessageImplGenerator.java | 15 +-
.../internal/network/AllTypesMessageTest.java | 17 ++
.../internal/network/messages/AllTypesMessage.java | 10 +
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 15 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 10 +-
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 8 +-
.../Table/SchemaSynchronizationTest.cs | 2 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 7 +-
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 5 +-
.../Internal/Proto/ClientOpExtensions.cs | 1 +
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 139 +++++++-----
.../Apache.Ignite/Internal/Table/RecordView.cs | 18 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 41 ++--
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 1 +
.../apache/ignite/internal/replicator/Replica.java | 31 ++-
.../ignite/internal/replicator/ReplicaManager.java | 2 -
.../exception/PrimaryReplicaMissException.java | 14 ++
.../message/PrimaryReplicaChangeCommand.java} | 22 +-
.../replicator/message/ReplicaMessageGroup.java | 3 +
.../replicator/PlacementDriverReplicaSideTest.java | 2 +
.../internal/rocksdb/flush/RocksDbFlusher.java | 7 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 4 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 2 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 15 +-
.../benchmark/SqlMultiStatementBenchmark.java | 15 +-
.../ignite/internal/table/ItDurableFinishTest.java | 53 +++++
.../internal/ClusterPerClassIntegrationTest.java | 15 ++
.../org/apache/ignite/internal/TestWrappers.java | 10 +
.../apache/ignite/internal/table/NodeUtils.java | 28 ++-
.../sql/api/ItKvKeyColumnPositionTest.java | 31 +--
.../sql/engine/BaseSqlMultiStatementTest.java | 9 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 33 +++
.../internal/sql/engine/ItDataTypesTest.java | 4 +-
...eGetTest.java => ItSqlUsesKeyValueGetTest.java} | 2 +-
...ePutTest.java => ItSqlUsesKeyValuePutTest.java} | 2 +-
.../sql/types/date/date_parsing.test | 56 +++++
.../sql/types/date/date_parsing.test_ignore | 1 +
.../integrationTest/sql/types/date/test_date.test | 38 ++++
.../sql/types/date/test_date.test_ignore | 2 +
.../time/{test_time.test_ignore => test_time.test} | 23 +-
.../sql/types/time/time_parsing.test | 29 +++
.../sql/types/time/time_parsing.test_ignore | 2 +-
.../sql/types/timestamp/bc_timestamp.test_ignore | 3 +-
.../sql/types/timestamp/test_timestamp.test | 25 +++
.../src/main/codegen/includes/parserImpls.ftl | 6 +-
.../ignite/internal/sql/api/IgniteSqlImpl.java | 17 +-
.../ignite/internal/sql/engine/QueryProcessor.java | 32 +--
.../internal/sql/engine/SqlQueryProcessor.java | 104 ++++-----
.../sql/engine/exec/exp/RexToLixTranslator.java | 16 +-
.../engine/metadata/IgniteMdDistinctRowCount.java | 17 +-
.../engine/metadata/cost/IgniteCostFactory.java | 4 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 80 +++++--
.../internal/sql/engine/rel/IgniteAggregate.java | 27 +--
.../engine/rel/agg/IgniteSortAggregateBase.java | 61 +++---
.../sql/engine/rel/agg/MapReduceAggregates.java | 2 +-
.../internal/sql/engine/sql/ParserServiceImpl.java | 27 ---
.../ignite/internal/sql/engine/util/Commons.java | 10 +
.../internal/sql/engine/util/IgniteMethod.java | 11 +
.../ignite/internal/sql/api/IgniteSqlImplTest.java | 20 +-
.../engine/benchmarks/TpchPrepareBenchmark.java | 3 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 2 +-
.../sql/engine/exec/TransactionEnlistTest.java | 13 +-
.../sql/engine/framework/TestBuilders.java | 2 +-
.../planner/AbstractAggregatePlannerTest.java | 58 +++--
.../sql/engine/planner/AbstractPlannerTest.java | 49 ++++-
.../sql/engine/planner/AggregatePlannerTest.java | 136 +++++++++---
.../planner/ColocatedHashAggregatePlannerTest.java | 73 +++++++
.../planner/ColocatedSortAggregatePlannerTest.java | 80 +++++++
.../planner/MapReduceHashAggregatePlannerTest.java | 114 +++++++++-
.../planner/MapReduceSortAggregatePlannerTest.java | 148 +++++++++++--
.../internal/sql/engine/planner/PlannerTest.java | 82 -------
.../sql/engine/planner/PlannerTimeoutTest.java | 3 +-
.../sql/engine/planner/TpchQueryPlannerTest.java | 110 ++++++++++
.../sql/engine/prepare/PrepareServiceImplTest.java | 3 +-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 32 +++
.../sql/engine/sql/ParserServiceImplTest.java | 141 +-----------
.../internal/sql/engine/sql/SqlDdlParserTest.java | 37 +++-
.../internal/sql/engine/util/QueryCheckerTest.java | 13 +-
.../sql/metrics/PlanningCacheMetricsTest.java | 3 +-
.../internal/sql/engine/util/QueryCheckerImpl.java | 4 +-
.../storage/index/BinaryTupleComparator.java | 6 +-
.../storage/index/BinaryTupleComparatorTest.java | 4 +-
.../index/AbstractSortedIndexStorageTest.java | 27 ++-
.../internal/storage/index/impl/TestIndexRow.java | 55 ++++-
.../table/ItTransactionPrimaryChangeTest.java | 219 +++++++++++++++++++
.../internal/table/ItTransactionRecoveryTest.java | 4 +-
.../distributed/command/UpdateAllCommand.java | 5 +
.../table/distributed/command/UpdateCommand.java | 3 +
.../table/distributed/raft/PartitionListener.java | 52 ++++-
.../request/SingleRowReplicaRequest.java | 2 +
.../replicator/PartitionReplicaListener.java | 241 +++++++++++++--------
.../distributed/storage/InternalTableImpl.java | 24 +-
.../raft/PartitionCommandListenerTest.java | 35 ++-
.../replication/PartitionReplicaListenerTest.java | 10 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 49 ++++-
.../ignite/internal/tx/UpdateCommandResult.java | 100 +++++++++
.../internal/tx/impl/PlacementDriverHelper.java | 45 +++-
.../internal/tx/impl/TxCleanupRequestHandler.java | 106 ++++++++-
.../internal/tx/impl/TxCleanupRequestSender.java | 103 +++++++--
.../ignite/internal/tx/impl/TxManagerImpl.java | 10 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 7 +-
.../tx/impl/WriteIntentSwitchProcessor.java | 9 +-
...atchMessage.java => CleanupReplicatedInfo.java} | 32 ++-
.../tx/message/TxCleanupMessageResponse.java | 6 +
.../WriteIntentSwitchReplicatedInfo.java} | 60 ++---
.../state/ThreadAssertingTxStateStorage.java | 14 ++
.../internal/tx/storage/state/TxStateStorage.java | 16 ++
.../state/rocksdb/TxStateRocksDbSharedStorage.java | 1 +
.../state/rocksdb/TxStateRocksDbStorage.java | 110 ++++++++--
.../apache/ignite/internal/tx/TxCleanupTest.java | 18 +-
.../storage/state/AbstractTxStateStorageTest.java | 24 ++
.../tx/storage/state/test/TestTxStateStorage.java | 24 ++
.../ignite/internal/worker/ThreadAssertions.java | 14 +-
126 files changed, 2838 insertions(+), 1121 deletions(-)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxStateCoordinatorRequest.java
=>
replicator/src/main/java/org/apache/ignite/internal/replicator/message/PrimaryReplicaChangeCommand.java}
(63%)
rename
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/{ItKeyValueGetTest.java
=> ItSqlUsesKeyValueGetTest.java} (98%)
rename
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/{ItKeyValuePutTest.java
=> ItSqlUsesKeyValuePutTest.java} (98%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/date/date_parsing.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/date/test_date.test
rename
modules/sql-engine/src/integrationTest/sql/types/time/{test_time.test_ignore =>
test_time.test} (58%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/time/time_parsing.test
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/TpchQueryPlannerTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItTransactionPrimaryChangeTest.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/UpdateCommandResult.java
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{FinishedTransactionsBatchMessage.java
=> CleanupReplicatedInfo.java} (58%)
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/{Lock.java =>
message/WriteIntentSwitchReplicatedInfo.java} (54%)
