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