This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch catalog-feature
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 420a07bbad after merge ai-main
add cdddfae611 IGNITE-19937 Remove BinaryRow#byteBuffer method (#2408)
add d5c265d933 IGNITE-19770 Add a mechanism to wait till a schema is
available via Schema Sync at a ts (#2402)
add 6546bc46f9 IGNITE-20128: Clean up ignored SQL tests (#2392)
add 5d9494fc7a IGNITE-19783 StripedScheduledExecutorService is created for
DistributionZoneManager#executor (#2380)
new f493d76f82 Merge branch 'ai-main' into catalog-feature
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/PULL_REQUEST_TEMPLATE.md | 12 +-
.idea/codeStyles/Project.xml | 3 +-
.../ignite/internal/catalog/CatalogService.java | 8 +-
.../ignite/internal/hlc/HybridTimestamp.java | 19 +-
...java => AbstractStripedThreadPoolExecutor.java} | 109 ++++----
.../thread/StripedScheduledThreadPoolExecutor.java | 105 ++++++++
.../internal/thread/StripedThreadPoolExecutor.java | 196 ++------------
.../ignite/internal/hlc/HybridTimestampTest.java | 80 ++++++
.../distributionzones/DistributionZoneManager.java | 42 +--
.../distributionzones/DistributionZonesUtil.java | 13 +-
.../DistributionZoneManagerScaleUpTest.java | 11 +-
.../DistributionZonesSchedulersTest.java | 237 +++++++++++------
.../DistributionZoneCausalityDataNodesTest.java | 24 +-
.../filter/test_constant_comparisons.test_ignore | 12 -
.../sql/filter/test_obsolete_filters.test_ignore | 281 ---------------------
...sert_type.test_ignore => test_insert_type.test} | 1 -
.../src/integrationTest/sql/sqlite/join/join1.test | 7 +-
.../sql/sqlite/join/join1.test_ignore | 159 ------------
...est_ignored => select2_erroneous_hash_res.test} | 0
...res.test_ignored => select2_erroneous_res.test} | 0
...test_ignore => select3_erroneous_hash_res.test} | 0
..._res.test_ignore => select3_erroneous_res.test} | 0
.../any_all/test_uncorrelated_all_subquery.test | 22 +-
.../test_uncorrelated_all_subquery.test_ignore | 217 ----------------
...ignored => test_uncorrelated_any_subquery.test} | 1 -
.../subquery/exists/test_correlated_exists.test | 16 ++
.../exists/test_correlated_exists.test_ignore | 17 --
.../scalar/test_count_star_subquery.test_ignore | 2 +-
.../scalar/test_uncorrelated_scalar_subquery.test | 7 +-
.../test_uncorrelated_scalar_subquery.test_ignore | 126 ---------
...est_aliasing.test_ignore => test_aliasing.test} | 2 -
.../sql/subquery/table/test_table_subquery.test | 6 +
.../subquery/table/test_table_subquery.test_ignore | 55 ----
.../apache/ignite/internal/schema/BinaryRow.java | 16 --
.../ignite/internal/schema/BinaryRowImpl.java | 11 +-
.../ignite/internal/schema/ByteBufferRow.java | 84 ------
.../org/apache/ignite/internal/schema/row/Row.java | 5 -
.../sql/engine/exec/UpdatableTableImpl.java | 53 ++--
.../exec/rel/TableScanNodeExecutionTest.java | 3 +-
.../AbstractMvPartitionStorageConcurrencyTest.java | 16 +-
.../internal/storage/BaseMvStoragesTest.java | 5 +-
.../storage/rocksdb/PartitionDataHelper.java | 6 +-
.../ignite/distributed/ItTablePersistenceTest.java | 21 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 27 +-
.../ignite/internal/table/ItColocationTest.java | 13 +-
.../table/distributed/StorageUpdateHandler.java | 16 +-
.../table/distributed/TableMessageGroup.java | 6 +
.../distributed/command/UpdateAllCommand.java | 4 +-
.../table/distributed/command/UpdateCommand.java | 13 +-
.../table/distributed/raft/PartitionListener.java | 2 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 7 +-
.../snapshot/message/SnapshotMvDataResponse.java | 4 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 24 +-
...owReplicaRequest.java => BinaryRowMessage.java} | 26 +-
.../request/MultipleRowReplicaRequest.java | 12 +-
.../request/SingleRowReplicaRequest.java | 6 +-
.../replication/request/SwapRowReplicaRequest.java | 10 +-
.../replicator/PartitionReplicaListener.java | 80 +++---
.../distributed/schema/SchemaSyncService.java | 44 ++++
.../distributed/schema/SchemaSyncServiceImpl.java | 54 ++++
.../distributed/storage/InternalTableImpl.java | 79 +++---
.../internal/table/distributed/IndexBaseTest.java | 32 ++-
.../PartitionRaftCommandsSerializationTest.java | 41 +--
.../raft/PartitionCommandListenerTest.java | 40 +--
.../incoming/IncomingSnapshotCopierTest.java | 11 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 79 +++---
.../PartitionReplicaListenerIndexLockingTest.java | 12 +-
.../replication/PartitionReplicaListenerTest.java | 61 +++--
.../schema/SchemaSyncServiceImplTest.java | 84 ++++++
69 files changed, 1108 insertions(+), 1689 deletions(-)
copy
modules/core/src/main/java/org/apache/ignite/internal/thread/{StripedThreadPoolExecutor.java
=> AbstractStripedThreadPoolExecutor.java} (64%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/thread/StripedScheduledThreadPoolExecutor.java
delete mode 100644
modules/runner/src/integrationTest/sql/filter/test_constant_comparisons.test_ignore
delete mode 100644
modules/runner/src/integrationTest/sql/filter/test_obsolete_filters.test_ignore
rename
modules/runner/src/integrationTest/sql/insert/{test_insert_type.test_ignore =>
test_insert_type.test} (88%)
delete mode 100644
modules/runner/src/integrationTest/sql/sqlite/join/join1.test_ignore
rename
modules/runner/src/integrationTest/sql/sqlite/select2/{select2_erroneous_hash_res.test_ignored
=> select2_erroneous_hash_res.test} (100%)
rename
modules/runner/src/integrationTest/sql/sqlite/select2/{select2_erroneous_res.test_ignored
=> select2_erroneous_res.test} (100%)
rename
modules/runner/src/integrationTest/sql/sqlite/select3/{select3_erroneous_hash_res.test_ignore
=> select3_erroneous_hash_res.test} (100%)
rename
modules/runner/src/integrationTest/sql/sqlite/select3/{select3_erroneous_res.test_ignore
=> select3_erroneous_res.test} (100%)
delete mode 100644
modules/runner/src/integrationTest/sql/subquery/any_all/test_uncorrelated_all_subquery.test_ignore
rename
modules/runner/src/integrationTest/sql/subquery/any_all/{test_uncorrelated_any_subquery.test_ignored
=> test_uncorrelated_any_subquery.test} (97%)
delete mode 100644
modules/runner/src/integrationTest/sql/subquery/scalar/test_uncorrelated_scalar_subquery.test_ignore
rename
modules/runner/src/integrationTest/sql/subquery/table/{test_aliasing.test_ignore
=> test_aliasing.test} (86%)
delete mode 100644
modules/runner/src/integrationTest/sql/subquery/table/test_table_subquery.test_ignore
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/ByteBufferRow.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/{ReadWriteMultiRowReplicaRequest.java
=> BinaryRowMessage.java} (66%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/SchemaSyncService.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/SchemaSyncServiceImpl.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/schema/SchemaSyncServiceImplTest.java
