This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-20167
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from caa600e59d Minors after review.
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)
add 23d886ad2a IGNITE-20058 Flaky distribution zone tests were fixed by
fixing order of the meta storage watches deploying and a distribution zone
manager start (#2400)
add 014668fc64 Merge branch 'main' into ignite-20167
No new revisions were added by this update.
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 | 54 ++--
.../distributionzones/DistributionZonesUtil.java | 13 +-
.../BaseDistributionZoneManagerTest.java | 7 +-
.../DistributionZoneManagerAlterFilterTest.java | 5 -
...ibutionZoneManagerConfigurationChangesTest.java | 7 +-
.../DistributionZoneManagerScaleUpTest.java | 11 +-
.../DistributionZonesSchedulersTest.java | 237 +++++++++++------
.../DistributionZoneCausalityDataNodesTest.java | 24 +-
.../DistributionZonesTestUtil.java | 29 ---
.../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 ++++++
73 files changed, 1118 insertions(+), 1739 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
