This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-21920
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from c96835649e Minors after review.
add 5075e7d48c IGNITE-21924 Improve user threads handling (#3547)
add e067aeae9d IGNITE-21494 Data Streamer: use one executor per node for
flushTimer (#3562)
add b03ea24f6e IGNITE-22002 Substitute assertion with explicit check for
PrimaryReplicaChangeCommand (#3573)
add 6fda2047ac IGNITE-22008 Fix double-checked locking in
ReadWriteTransactionImpl (#3576)
add 266fdc6fa6 IGNITE-20606 Sql. Add syntax to support setting the default
distribution zone (#3567)
add 6f29716426 IGNITE-21382 Fixed flaky
ItPrimaryReplicaChoiceTest.testPrimaryChangeLongHandling (#3495)
add 7b1463fba9 Merge branch 'main' into ignite-21920
No new revisions were added by this update.
Summary of changes:
...java => AlterZoneSetDefaultCatalogCommand.java} | 51 +++----
.../ignite/internal/client/ReliableChannel.java | 44 ++++--
.../internal/client/table/ClientDataStreamer.java | 7 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
.../internal/lang/IgniteSystemProperties.java | 3 +
.../internal/streamer/StreamerSubscriber.java | 43 +++---
.../ignite/internal/thread/PublicApiThreading.java | 116 +++++++++++++++
.../apache/ignite/internal/util/IgniteUtils.java | 6 +-
.../internal/streamer/StreamerSubscriberTest.java | 22 +++
.../internal/testframework/IgniteTestUtils.java | 36 ++++-
...IndexNodeFinishedRwTransactionsCheckerTest.java | 11 +-
.../ItPrimaryReplicaChoiceTest.java | 22 +--
.../MultiActorPlacementDriverTest.java | 10 +-
.../internal/placementdriver/LeaseUpdater.java | 46 +++---
.../internal/placementdriver/leases/Lease.java | 34 ++++-
.../negotiation/LeaseAgreement.java | 9 ++
.../placementdriver/PlacementDriverTest.java | 6 +
.../leases/LeaseSerializationTest.java | 24 +++-
.../ItPlacementDriverReplicaSideTest.java | 26 ++--
.../ignite/internal/replicator/ReplicaManager.java | 29 ++--
.../internal/runner/app/ItDataSchemaSyncTest.java | 2 -
.../app/ItIgniteInMemoryNodeRestartTest.java | 15 +-
.../runner/app/ItIgniteNodeRestartTest.java | 19 ++-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 3 +-
.../streamer/ItServerDataStreamerTest.java | 3 -
.../ignite/internal/table/ItDurableFinishTest.java | 45 +++---
.../ignite/internal/table/ItInternalTableTest.java | 14 ++
.../internal/table/ItPublicApiColocationTest.java | 23 ++-
.../internal/table/ItReadOnlyTransactionTest.java | 38 +++--
.../org/apache/ignite/internal/app/IgniteImpl.java | 12 +-
.../ignite/internal/PublicApiThreadingTests.java | 2 +-
.../apache/ignite/internal/table/NodeUtils.java | 157 +++++++--------------
.../internal/sql/api/ItSqlSynchronousApiTest.java | 1 -
.../ignite/internal/sql/engine/ItSetOpTest.java | 1 +
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 9 ++
.../sql/threading/ItSqlApiThreadingTest.java | 2 +-
modules/sql-engine/src/main/codegen/config.fmpp | 1 +
.../src/main/codegen/includes/parserImpls.ftl | 13 +-
.../internal/sql/api/AntiHijackAsyncResultSet.java | 2 +-
...teSql.java => PublicApiThreadingIgniteSql.java} | 55 +++++---
.../sql/engine/exec/ddl/DdlCommandHandler.java | 9 ++
.../exec/ddl/DdlToCatalogCommandConverter.java | 8 ++
...ommand.java => AlterZoneSetDefaultCommand.java} | 6 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 21 +++
...meTo.java => IgniteSqlAlterZoneSetDefault.java} | 27 +---
.../exec/rel/TableScanNodeExecutionTest.java | 3 +-
.../DistributionZoneSqlToCommandConverterTest.java | 24 ++++
.../internal/sql/engine/util/QueryCheckerImpl.java | 3 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 2 -
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 2 +-
.../rebalance/ItRebalanceRecoveryTest.java | 3 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 3 +-
.../ignite/internal/table/ItColocationTest.java | 3 +-
.../table/ItTransactionPrimaryChangeTest.java | 3 +-
.../internal/table/ItTransactionRecoveryTest.java | 11 +-
.../threading/ItKvRecordApiThreadingTest.java | 5 +-
.../threading/ItTablesApiThreadingTest.java | 2 +-
.../ignite/internal/table/AbstractTableView.java | 11 +-
.../apache/ignite/internal/table/DataStreamer.java | 11 +-
.../ignite/internal/table/InternalTable.java | 8 ++
.../internal/table/KeyValueBinaryViewImpl.java | 35 ++---
.../ignite/internal/table/KeyValueViewImpl.java | 45 +++---
...ew.java => PublicApiThreadingKeyValueView.java} | 88 ++++++------
...View.java => PublicApiThreadingRecordView.java} | 75 +++++-----
...ewBase.java => PublicApiThreadingViewBase.java} | 25 +++-
.../internal/table/RecordBinaryViewImpl.java | 39 ++---
.../ignite/internal/table/RecordViewImpl.java | 41 +++---
...es.java => PublicApiThreadingIgniteTables.java} | 10 +-
...jackTable.java => PublicApiThreadingTable.java} | 22 +--
.../internal/table/distributed/TableManager.java | 40 +++++-
.../distributed/storage/InternalTableImpl.java | 13 +-
.../distributed/storage/InternalTableImplTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 3 +-
.../table/impl/DummyInternalTableImpl.java | 3 +-
.../tx/ItTransactionsApiThreadingTest.java | 28 ++--
...a => PublicApiThreadingIgniteTransactions.java} | 22 +--
...ion.java => PublicApiThreadingTransaction.java} | 25 ++--
.../internal/tx/impl/ReadWriteTransactionImpl.java | 2 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 5 +-
.../storage/state/AbstractTxStateStorageTest.java | 13 +-
.../tx/storage/state/test/TestTxStateStorage.java | 12 +-
modules/workers/build.gradle | 1 +
.../ignite/internal/worker/ThreadAssertions.java | 37 ++---
.../internal/worker/ThreadAssertionsTest.java | 95 +++++++++++++
84 files changed, 1184 insertions(+), 634 deletions(-)
copy
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{DropZoneCommand.java
=> AlterZoneSetDefaultCatalogCommand.java} (50%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/{AntiHijackIgniteSql.java
=> PublicApiThreadingIgniteSql.java} (63%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/{DropZoneCommand.java
=> AlterZoneSetDefaultCommand.java} (85%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/{IgniteSqlAlterZoneRenameTo.java
=> IgniteSqlAlterZoneSetDefault.java} (70%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/{AntiHijackKeyValueView.java
=> PublicApiThreadingKeyValueView.java} (66%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/{AntiHijackRecordView.java
=> PublicApiThreadingRecordView.java} (66%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/{AntiHijackViewBase.java
=> PublicApiThreadingViewBase.java} (74%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{AntiHijackIgniteTables.java
=> PublicApiThreadingIgniteTables.java} (84%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{AntiHijackTable.java
=> PublicApiThreadingTable.java} (68%)
rename
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/{AntiHijackIgniteTransactions.java
=> PublicApiThreadingIgniteTransactions.java} (61%)
rename
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/{AntiHijackTransaction.java
=> PublicApiThreadingTransaction.java} (75%)
create mode 100644
modules/workers/src/test/java/org/apache/ignite/internal/worker/ThreadAssertionsTest.java
