date:20210716

[ignite-3] branch ignite-14743 updated (6354d4e -> 95fecab)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from 6354d4e  Revert unrelated changes.
 add 95fecab  Minor.

No new revisions were added by this update.

Summary of changes:
 .../ignite/internal/schema/row/RowAssembler.java   | 77 --
 1 file changed, 44 insertions(+), 33 deletions(-)

[ignite] branch master updated: IGNITE-14728 Changed IGNITE_PDS_WAL_REBALANCE_THRESHOLD from System property to Distributed property. Fixes #9248

2021-07-16 Thread sk0x50

This is an automated email from the ASF dual-hosted git repository.

sk0x50 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
 new c767558  IGNITE-14728 Changed IGNITE_PDS_WAL_REBALANCE_THRESHOLD from 
System property to Distributed property. Fixes #9248
c767558 is described below

commit c7675588f2fb6f91fa27e0b4d91f711fb5f49c93
Author: Eduard Rakhmankulov 
AuthorDate: Fri Jul 16 16:29:09 2021 +0300

IGNITE-14728 Changed IGNITE_PDS_WAL_REBALANCE_THRESHOLD from System 
property to Distributed property. Fixes #9248

Signed-off-by: Slava Koptilin 
---
 .../util/GridCommandHandlerPropertiesTest.java | 47 ++
 .../org/apache/ignite/IgniteSystemProperties.java  |  2 +
 .../GridCacheDatabaseSharedManager.java| 55 +++---
 3 files changed, 98 insertions(+), 6 deletions(-)

diff --git 
a/modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerPropertiesTest.java
 
b/modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerPropertiesTest.java
index e535b24..b114aba 100644
--- 
a/modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerPropertiesTest.java
+++ 
b/modules/control-utility/src/test/java/org/apache/ignite/util/GridCommandHandlerPropertiesTest.java
@@ -32,6 +32,8 @@ import org.junit.Test;
 
 import static 
org.apache.ignite.internal.commandline.CommandHandler.EXIT_CODE_INVALID_ARGUMENTS;
 import static 
org.apache.ignite.internal.commandline.CommandHandler.EXIT_CODE_OK;
+import static 
org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager.DFLT_PDS_WAL_REBALANCE_THRESHOLD;
+import static 
org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager.HISTORICAL_REBALANCE_THRESHOLD_DMS_KEY;
 import static org.apache.ignite.testframework.GridTestUtils.assertContains;
 
 /**
@@ -197,4 +199,49 @@ public class GridCommandHandlerPropertiesTest extends 
GridCommandHandlerClusterB
 )
 );
 }
+
+/**
+ * Check the set command for property 'history.rebalance.threshold'.
+ */
+@Test
+public void testPropertyWalRebalanceThreshold() {
+
assertDistributedPropertyEquals(HISTORICAL_REBALANCE_THRESHOLD_DMS_KEY, 
DFLT_PDS_WAL_REBALANCE_THRESHOLD);
+
+int newVal = DFLT_PDS_WAL_REBALANCE_THRESHOLD * 2;
+
+assertEquals(
+EXIT_CODE_OK,
+execute(
+"--property", "set",
+"--name", HISTORICAL_REBALANCE_THRESHOLD_DMS_KEY,
+"--val", Integer.toString(newVal)
+)
+);
+
+
assertDistributedPropertyEquals(HISTORICAL_REBALANCE_THRESHOLD_DMS_KEY, newVal);
+}
+
+/**
+ * Validates that distributed property has specified value across all 
nodes.
+ *
+ * @param propName Distributed property name.
+ * @param expected Expected property value.
+ * @param  Property type.
+ */
+private  void 
assertDistributedPropertyEquals(String propName, T expected) {
+for (Ignite ign : G.allGrids()) {
+IgniteEx ignEx = (IgniteEx) ign;
+
+if (ign.configuration().isClientMode())
+continue;
+
+DistributedChangeableProperty prop =
+
ignEx.context().distributedConfiguration().property(propName);
+
+assertEquals(
+"Validation has failed on the cluster node [name=" + 
ign.configuration().getIgniteInstanceName(),
+prop.get(),
+expected);
+}
+}
 }
diff --git 
a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java 
b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
index e149dbe..7007013 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
@@ -1113,7 +1113,9 @@ public final class IgniteSystemProperties {
 
 /**
  * WAL rebalance threshold.
+ * @deprecated use Distributed MetaStorage property {@code 
historical.rebalance.threshold}.
  */
+@Deprecated
 @SystemProperty(value = "WAL rebalance threshold", type = Integer.class,
 defaults = "" + DFLT_PDS_WAL_REBALANCE_THRESHOLD)
 public static final String IGNITE_PDS_WAL_REBALANCE_THRESHOLD = 
"IGNITE_PDS_WAL_REBALANCE_THRESHOLD";
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
index 4cd7cc8..da71924 100755
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java
+++ 
b/modules/core/src/main/

[ignite-3] branch ignite-14743 updated (824cc7d -> 6354d4e)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


 discard 824cc7d  Revert unrelated changes.
 add 6354d4e  Revert unrelated changes.

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   (824cc7d)
\
 N -- N -- N   refs/heads/ignite-14743 (6354d4e)

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.

No new revisions were added by this update.

Summary of changes:
 .../internal/schema/registry/SchemaRegistryImplTest.java   | 10 +-
 .../benchmarks/TupleMarshallerFixlenOnlyBenchmark.java |  2 +-
 .../benchmarks/TupleMarshallerVarlenOnlyBenchmark.java |  2 +-
 3 files changed, 7 insertions(+), 7 deletions(-)

[ignite-3] branch ignite-14743 updated (f915189 -> 824cc7d)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from f915189  Fix compilation after merge with main.
 add 824cc7d  Revert unrelated changes.

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/ignite/internal/schema/SchemaManager.java  |  2 +-
 .../ignite/internal/schema/registry/SchemaRegistryImpl.java|  6 --
 .../internal/schema/registry/SchemaRegistryImplTest.java   | 10 +-
 .../benchmarks/TupleMarshallerFixlenOnlyBenchmark.java |  2 +-
 .../benchmarks/TupleMarshallerVarlenOnlyBenchmark.java |  2 +-
 5 files changed, 12 insertions(+), 10 deletions(-)

[ignite-3] branch ignite-14743 updated (dfcb3d6 -> f915189)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from dfcb3d6  Merge branch 'main' into ignite-14743
 add f915189  Fix compilation after merge with main.

No new revisions were added by this update.

Summary of changes:
 .../apache/ignite/internal/schema/registry/SchemaRegistryImplTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

[ignite-3] branch ignite-14743 updated (520cfb1 -> dfcb3d6)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from 520cfb1  Styles.
 add d7b295e  IGNITE-15055 Fixed an issue with creation a table that 
already exists. Fixes #200
 add b96acd6  IGNITE-14833 Bring back checksum support. Fixes #206
 add 7ada2bb  IGNITE-14861 Live-schema. Upgrade schema when new column 
detected. (#212)
 add fc7b39d  IGNITE-15057 Implemented LockManager to handle concurrency 
control in transactions - Fixes #211.
 add b67df02  IGNITE-15086 Public transactions API - Fixes #214.
 add c9a1ab9  IGNITE-14864: Schema update. Merge multiple converters 
stages. (#194)
 add 79edfa4  IGNITE-15019 Fixed flaky testFollowerStartStopFollowing test. 
Fixes #215
 add dfcb3d6  Merge branch 'main' into ignite-14743

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/ignite/app/Ignite.java|   8 +
 .../schema/{PrimaryIndex.java => SchemaMode.java}  |  18 +-
 .../apache/ignite/table/KeyValueBinaryView.java|   5 +
 .../java/org/apache/ignite/table/KeyValueView.java |  15 +
 .../java/org/apache/ignite/table/RecordView.java   |   4 +
 .../main/java/org/apache/ignite/table/Table.java   |  12 +
 .../java/org/apache/ignite/table/TableView.java|  15 +
 .../apache/ignite/table/manager/IgniteTables.java  |  15 +-
 .../org/apache/ignite/tx/IgniteTransactions.java}  |  28 +-
 .../java/org/apache/ignite/tx/Transaction.java}|  37 +-
 .../ignite/internal/manager/EventListener.java |   1 -
 .../internal/manager/ListenerRemovedException.java |  12 +
 .../apache/ignite/internal/manager/Producer.java   |  15 +-
 .../apache/ignite/raft/jraft/core/ITNodeTest.java  |  21 +-
 .../java/org/apache/ignite/internal/raft/Loza.java |   4 +-
 .../internal/raft/server/impl/JRaftServerImpl.java |   2 +-
 .../apache/ignite/raft/jraft/RaftGroupService.java |  37 --
 .../apache/ignite/raft/jraft/core/NodeImpl.java|   4 +-
 .../apache/ignite/raft/jraft/core/Replicator.java  |   5 +-
 .../ignite/raft/jraft/entity/RaftOutter.java   |   5 +
 .../ignite/raft/jraft/option/RaftOptions.java  |   2 +-
 .../raft/jraft/rpc/message/EntryMetaImpl.java  |  13 +
 .../org/apache/ignite/raft/jraft/util/Utils.java   |   2 +-
 .../jraft/util/concurrent/AdjustableSemaphore.java |   1 -
 .../raft/jraft/conf/ConfigurationManagerTest.java  |   1 -
 .../ignite/raft/jraft/conf/ConfigurationTest.java  |   1 -
 .../apache/ignite/raft/jraft/core/TestCluster.java |   2 +
 .../ignite/raft/jraft/rpc/TestIgniteRpcServer.java |  17 +
 .../ignite/raft/jraft/test/MockAsyncContext.java   |   2 +-
 .../runner/app/AbstractSchemaChangeTest.java   | 123 +-
 .../runner/app/DynamicTableCreationTest.java   |  67 ++-
 .../runner/app/LiveSchemaChangeKVViewTest.java | 220 +
 .../runner/app/LiveSchemaChangeTableTest.java  | 325 ++
 .../runner/app/SchemaChangeKVViewTest.java | 137 ++
 .../runner/app/SchemaChangeTableViewTest.java  | 174 
 .../internal/runner/app/TableCreationTest.java | 212 -
 .../org/apache/ignite/internal/app/IgniteImpl.java |   6 +
 .../ignite/internal/schema/SchemaManager.java  |  38 --
 .../schema/builder/SchemaTableBuilderImpl.java |   4 +-
 .../SchemaConfigurationConverter.java  |  48 ++
 .../internal/schema/mapping/ColumnMapping.java |  32 ++
 .../schema/registry/SchemaRegistryImpl.java|  54 ++-
 .../schema/registry/UpgradingRowAdapter.java   |   6 +-
 .../{ => registry}/SchemaRegistryImplTest.java |  66 ++-
 .../ignite/distributed/ITDistributedTableTest.java |   2 +-
 .../ignite/internal/table/AbstractTableView.java   |  22 +-
 .../ignite/internal/table/InternalTable.java   |  61 ++-
 .../ignite/internal/table/KVBinaryViewImpl.java|  65 ++-
 .../apache/ignite/internal/table/KVViewImpl.java   |  15 +-
 .../internal/table/LiveSchemaTupleBuilderImpl.java | 145 ++
 .../ignite/internal/table/RecordViewImpl.java  |  19 +-
 .../apache/ignite/internal/table/TableImpl.java|  71 ++-
 .../ignite/internal/table/TupleBuilderImpl.java|  19 +-
 .../internal/table/distributed/TableManager.java   | 108 +++--
 .../distributed/storage/InternalTableImpl.java |  51 ++-
 .../org/apache/ignite/internal/table/Example.java  |   2 +-
 .../internal/table/KVViewOperationsTest.java   |  21 +-
 .../internal/table/StrictSchemaOperationsTest.java |   8 +-
 .../table/TableBinaryViewOperationsTest.java   |  18 +-
 .../ignite/internal/table/TableManagerTest.java|  51 ++-
 .../org/apache/ignite/internal/table/TxTest.java   | 208 +
 .../table/impl/DummyInternalTableImpl.java |  44 +-
 modules/transactions/pom.xml   |   7 +
 .../apache/ignite/internal/tx/LockException.java}  |  23 +-
 .../org/apache/ignite/internal/tx/LockManager.java |  32 +-
 .../org/apache/ignite/in

[ignite-3] branch ignite-14896 updated (5bb6b2d -> 9615c23)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14896
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from 5bb6b2d  Merge branch 'main' into ignite-14896
 add 9615c23  Styles.

No new revisions were added by this update.

Summary of changes:
 .../org/apache/ignite/internal/schema/mapping/ColumnMapperImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

[ignite-3] branch ignite-14896 updated (2b53853 -> 5bb6b2d)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14896
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from 2b53853  Fix compilation.
 add d7b295e  IGNITE-15055 Fixed an issue with creation a table that 
already exists. Fixes #200
 add b96acd6  IGNITE-14833 Bring back checksum support. Fixes #206
 add 7ada2bb  IGNITE-14861 Live-schema. Upgrade schema when new column 
detected. (#212)
 add fc7b39d  IGNITE-15057 Implemented LockManager to handle concurrency 
control in transactions - Fixes #211.
 add b67df02  IGNITE-15086 Public transactions API - Fixes #214.
 add c9a1ab9  IGNITE-14864: Schema update. Merge multiple converters 
stages. (#194)
 add 5bb6b2d  Merge branch 'main' into ignite-14896

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/ignite/app/Ignite.java|   8 +
 .../schema/{PrimaryIndex.java => SchemaMode.java}  |  18 +-
 .../apache/ignite/table/KeyValueBinaryView.java|   5 +
 .../java/org/apache/ignite/table/KeyValueView.java |  15 +
 .../java/org/apache/ignite/table/RecordView.java   |   4 +
 .../main/java/org/apache/ignite/table/Table.java   |  12 +
 .../java/org/apache/ignite/table/TableView.java|  15 +
 .../apache/ignite/table/manager/IgniteTables.java  |  15 +-
 .../org/apache/ignite/tx/IgniteTransactions.java}  |  28 +-
 .../java/org/apache/ignite/tx/Transaction.java}|  37 +-
 .../ignite/internal/manager/EventListener.java |   1 -
 .../internal/manager/ListenerRemovedException.java |  12 +
 .../apache/ignite/internal/manager/Producer.java   |  15 +-
 .../apache/ignite/raft/jraft/core/ITNodeTest.java  |   1 -
 .../java/org/apache/ignite/internal/raft/Loza.java |   4 +-
 .../apache/ignite/raft/jraft/core/NodeImpl.java|   4 +-
 .../apache/ignite/raft/jraft/core/Replicator.java  |   5 +-
 .../ignite/raft/jraft/entity/RaftOutter.java   |   5 +
 .../ignite/raft/jraft/option/RaftOptions.java  |   2 +-
 .../raft/jraft/rpc/message/EntryMetaImpl.java  |  13 +
 .../org/apache/ignite/raft/jraft/util/Utils.java   |   2 +-
 .../jraft/util/concurrent/AdjustableSemaphore.java |   1 -
 .../raft/jraft/conf/ConfigurationManagerTest.java  |   1 -
 .../ignite/raft/jraft/conf/ConfigurationTest.java  |   1 -
 .../ignite/raft/jraft/test/MockAsyncContext.java   |   2 +-
 .../runner/app/AbstractSchemaChangeTest.java   |   6 -
 .../runner/app/LiveSchemaChangeKVViewTest.java | 220 +
 .../runner/app/LiveSchemaChangeTableTest.java  | 325 ++
 .../org/apache/ignite/internal/app/IgniteImpl.java |   6 +
 .../ignite/internal/schema/SchemaManager.java  |   2 +-
 .../SchemaConfigurationConverter.java  |  48 ++
 .../schema/mapping/ColumnMapperBuilder.java|  14 +-
 .../internal/schema/mapping/ColumnMapperImpl.java  |  19 +-
 .../internal/schema/mapping/ColumnMapping.java |   2 +-
 .../schema/registry/SchemaRegistryImpl.java|  24 +-
 .../{ => registry}/SchemaRegistryImplTest.java | 177 +---
 .../ignite/distributed/ITDistributedTableTest.java |   2 +-
 .../ignite/internal/table/AbstractTableView.java   |  22 +-
 .../ignite/internal/table/InternalTable.java   |  61 ++-
 .../ignite/internal/table/KVBinaryViewImpl.java|  65 ++-
 .../apache/ignite/internal/table/KVViewImpl.java   |  15 +-
 .../internal/table/LiveSchemaTupleBuilderImpl.java | 145 ++
 .../ignite/internal/table/RecordViewImpl.java  |  19 +-
 .../apache/ignite/internal/table/TableImpl.java|  71 ++-
 .../ignite/internal/table/TupleBuilderImpl.java|  19 +-
 .../internal/table/distributed/TableManager.java   | 106 +++--
 .../distributed/storage/InternalTableImpl.java |  51 ++-
 .../org/apache/ignite/internal/table/Example.java  |   2 +-
 .../internal/table/KVViewOperationsTest.java   |  21 +-
 .../internal/table/StrictSchemaOperationsTest.java |   8 +-
 .../table/TableBinaryViewOperationsTest.java   |  18 +-
 .../ignite/internal/table/TableManagerTest.java|  51 ++-
 .../org/apache/ignite/internal/table/TxTest.java   | 208 +
 .../table/impl/DummyInternalTableImpl.java |  44 +-
 modules/transactions/pom.xml   |   7 +
 .../apache/ignite/internal/tx/LockException.java}  |  23 +-
 .../org/apache/ignite/internal/tx/LockManager.java |  32 +-
 .../org/apache/ignite/internal/tx/Timestamp.java   |  85 
 .../tx/{LockOrderException.java => Waiter.java}|  15 +-
 .../ignite/internal/tx/impl/HeapLockManager.java   | 335 ++
 .../internal/tx/AbstractLockManagerTest.java   | 489 +
 ...ckManagerTest.java => HeapLockManagerTest.java} |  11 +-
 62 files changed, 2672 insertions(+), 322 deletions(-)
 copy modules/api/src/main/java/org/apache/ignite/schema/{PrimaryIndex.java => 
SchemaMode.java} (59%)
 copy 
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.j

[ignite-3] branch main updated: IGNITE-15019 Fixed flaky testFollowerStartStopFollowing test. Fixes #215

2021-07-16 Thread sk0x50

This is an automated email from the ASF dual-hosted git repository.

sk0x50 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
 new 79edfa4  IGNITE-15019 Fixed flaky testFollowerStartStopFollowing test. 
Fixes #215
79edfa4 is described below

commit 79edfa4b56c788e6161a2a0ee35109d8ac1a71b2
Author: Mirza Aliev 
AuthorDate: Fri Jul 16 15:08:10 2021 +0300

IGNITE-15019 Fixed flaky testFollowerStartStopFollowing test. Fixes #215

Signed-off-by: Slava Koptilin 
---
 .../apache/ignite/raft/jraft/core/ITNodeTest.java  | 20 +++-
 .../internal/raft/server/impl/JRaftServerImpl.java |  2 +-
 .../apache/ignite/raft/jraft/RaftGroupService.java | 37 --
 .../apache/ignite/raft/jraft/core/TestCluster.java |  2 ++
 .../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 17 ++
 5 files changed, 32 insertions(+), 46 deletions(-)

diff --git 
a/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/ITNodeTest.java
 
b/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/ITNodeTest.java
index 268c07a..dc5a525 100644
--- 
a/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/ITNodeTest.java
+++ 
b/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/ITNodeTest.java
@@ -2665,7 +2665,8 @@ public class ITNodeTest {
 List firstFollowers = cluster.getFollowers();
 assertEquals(4, firstFollowers.size());
 for (Node node : firstFollowers) {
-assertTrue(waitForCondition(() -> ((MockStateMachine) 
node.getOptions().getFsm()).getOnStartFollowingTimes() == 1, 5_000));
+assertTrue(
+waitForCondition(() -> ((MockStateMachine) 
node.getOptions().getFsm()).getOnStartFollowingTimes() == 1, 5_000));
 assertEquals(0, ((MockStateMachine) 
node.getOptions().getFsm()).getOnStopFollowingTimes());
 }
 
@@ -2681,7 +2682,8 @@ public class ITNodeTest {
 List secondFollowers = cluster.getFollowers();
 assertEquals(3, secondFollowers.size());
 for (Node node : secondFollowers) {
-assertEquals(2, ((MockStateMachine) 
node.getOptions().getFsm()).getOnStartFollowingTimes());
+assertTrue(
+waitForCondition(() -> ((MockStateMachine) 
node.getOptions().getFsm()).getOnStartFollowingTimes() == 2, 5_000));
 assertEquals(1, ((MockStateMachine) 
node.getOptions().getFsm()).getOnStopFollowingTimes());
 }
 
@@ -2697,15 +2699,17 @@ public class ITNodeTest {
 List thirdFollowers = cluster.getFollowers();
 assertEquals(3, thirdFollowers.size());
 for (int i = 0; i < 3; i++) {
-if 
(thirdFollowers.get(i).getNodeId().getPeerId().equals(secondLeader.getNodeId().getPeerId()))
 {
-assertEquals(2,
-((MockStateMachine) 
thirdFollowers.get(i).getOptions().getFsm()).getOnStartFollowingTimes());
+Node follower = thirdFollowers.get(i);
+if 
(follower.getNodeId().getPeerId().equals(secondLeader.getNodeId().getPeerId())) 
{
+assertTrue(
+waitForCondition(() -> ((MockStateMachine) 
follower.getOptions().getFsm()).getOnStartFollowingTimes() == 2, 5_000));
 assertEquals(1,
-((MockStateMachine) 
thirdFollowers.get(i).getOptions().getFsm()).getOnStopFollowingTimes());
+((MockStateMachine) 
follower.getOptions().getFsm()).getOnStopFollowingTimes());
 continue;
 }
-assertEquals(3, ((MockStateMachine) 
thirdFollowers.get(i).getOptions().getFsm()).getOnStartFollowingTimes());
-assertEquals(2, ((MockStateMachine) 
thirdFollowers.get(i).getOptions().getFsm()).getOnStopFollowingTimes());
+
+assertTrue(waitForCondition(() -> ((MockStateMachine) 
follower.getOptions().getFsm()).getOnStartFollowingTimes() == 3, 5_000));
+assertEquals(2, ((MockStateMachine) 
follower.getOptions().getFsm()).getOnStopFollowingTimes());
 }
 
 cluster.ensureSame();
diff --git 
a/modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/JRaftServerImpl.java
 
b/modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/JRaftServerImpl.java
index 8b77e79..042f727 100644
--- 
a/modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/JRaftServerImpl.java
+++ 
b/modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/JRaftServerImpl.java
@@ -170,7 +170,7 @@ public class JRaftServerImpl implements RaftServer {
 
 var peerId = new PeerId(addr.host(), addr.port(), 0, 
ElectionPriority.DISABLED);
 
-var server = new RaftGroupService(groupId, peerId, nodeOptions, 
rpcServer, nodeManager, true);
+var server = new RaftGroupService(groupId, peerId, nodeOptions, 
rpcServer, nodeManage

[ignite-3] branch main updated: IGNITE-14864: Schema update. Merge multiple converters stages. (#194)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
 new c9a1ab9  IGNITE-14864: Schema update. Merge multiple converters 
stages. (#194)
c9a1ab9 is described below

commit c9a1ab902045fda232c0caac89f4f682a62e5e24
Author: Andrew V. Mashenkov 
AuthorDate: Fri Jul 16 14:16:27 2021 +0300

IGNITE-14864: Schema update. Merge multiple converters stages. (#194)
---
 .../runner/app/AbstractSchemaChangeTest.java   | 123 +++-
 .../runner/app/DynamicTableCreationTest.java   |  67 +++
 .../runner/app/SchemaChangeKVViewTest.java | 137 +
 .../runner/app/SchemaChangeTableViewTest.java  | 174 +
 .../internal/runner/app/TableCreationTest.java | 212 ++---
 .../apache/ignite/internal/schema/NativeTypes.java |   1 +
 .../ignite/internal/schema/SchemaManager.java  |  38 
 .../schema/builder/SchemaTableBuilderImpl.java |   3 +
 .../internal/schema/mapping/ColumnMapping.java |  33 
 .../schema/registry/SchemaRegistryImpl.java|  54 +-
 .../schema/registry/UpgradingRowAdapter.java   |   6 +-
 .../{ => registry}/SchemaRegistryImplTest.java |  66 ++-
 .../internal/table/distributed/TableManager.java   |   2 +-
 13 files changed, 720 insertions(+), 196 deletions(-)

diff --git 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/AbstractSchemaChangeTest.java
 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/AbstractSchemaChangeTest.java
index 3788b5a..8070888 100644
--- 
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/AbstractSchemaChangeTest.java
+++ 
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/AbstractSchemaChangeTest.java
@@ -22,8 +22,10 @@ import java.util.ArrayList;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.function.Supplier;
 import org.apache.ignite.app.Ignite;
 import org.apache.ignite.app.IgnitionManager;
+import org.apache.ignite.internal.schema.InvalidTypeException;
 import org.apache.ignite.internal.testframework.WorkDirectory;
 import org.apache.ignite.internal.testframework.WorkDirectoryExtension;
 import org.apache.ignite.internal.util.IgniteUtils;
@@ -33,6 +35,9 @@ import org.apache.ignite.schema.SchemaBuilders;
 import org.apache.ignite.schema.SchemaTable;
 import org.jetbrains.annotations.NotNull;
 import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 
 import static 
org.apache.ignite.internal.schema.configuration.SchemaConfigurationConverter.convert;
@@ -94,6 +99,90 @@ abstract class AbstractSchemaChangeTest {
 }
 
 /**
+ * Check unsupported column type change.
+ */
+@Disabled("https://issues.apache.org/jira/browse/IGNITE-15056";)
+@Test
+public void testChangeColumnType() {
+List grid = startGrid();
+
+createTable(grid);
+
+Assertions.assertThrows(InvalidTypeException.class, () -> {
+grid.get(0).tables().alterTable(TABLE,
+tblChanger -> tblChanger.changeColumns(cols -> {
+final String colKey = 
tblChanger.columns().namedListKeys().stream()
+.filter(c -> 
"valInt".equals(tblChanger.columns().get(c).name()))
+.findFirst()
+.orElseThrow(() -> {
+throw new IllegalStateException("Column not 
found.");
+});
+
+tblChanger.changeColumns(listChanger ->
+listChanger.update(colKey, colChanger -> 
colChanger.changeType(c -> c.changeType("STRING")))
+);
+})
+);
+});
+}
+
+/**
+ * Check unsupported column nullability change.
+ */
+@Disabled("https://issues.apache.org/jira/browse/IGNITE-15056";)
+@Test
+public void testMakeColumnNonNullable() {
+List grid = startGrid();
+
+createTable(grid);
+
+Assertions.assertThrows(InvalidTypeException.class, () -> {
+grid.get(0).tables().alterTable(TABLE,
+tblChanger -> tblChanger.changeColumns(cols -> {
+final String colKey = 
tblChanger.columns().namedListKeys().stream()
+.filter(c -> 
"valInt".equals(tblChanger.columns().get(c).name()))
+.findFirst()
+.orElseThrow(() -> {
+throw new IllegalStateException("Column not 
found.");
+});
+
+tblChanger.changeColumns(listChanger ->
+

[ignite-3] branch ignite-14864 updated (a7e8973 -> c360974)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14864
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from a7e8973  Fix wrong cache cleanup. Test added.
 add d7b295e  IGNITE-15055 Fixed an issue with creation a table that 
already exists. Fixes #200
 add b96acd6  IGNITE-14833 Bring back checksum support. Fixes #206
 add 7ada2bb  IGNITE-14861 Live-schema. Upgrade schema when new column 
detected. (#212)
 add fc7b39d  IGNITE-15057 Implemented LockManager to handle concurrency 
control in transactions - Fixes #211.
 add b67df02  IGNITE-15086 Public transactions API - Fixes #214.
 add c360974  Merge branch 'main' into ignite-14864

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/ignite/app/Ignite.java|   8 +
 .../schema/{PrimaryIndex.java => SchemaMode.java}  |  18 +-
 .../apache/ignite/table/KeyValueBinaryView.java|   5 +
 .../java/org/apache/ignite/table/KeyValueView.java |  15 +
 .../java/org/apache/ignite/table/RecordView.java   |   4 +
 .../main/java/org/apache/ignite/table/Table.java   |  12 +
 .../java/org/apache/ignite/table/TableView.java|  15 +
 .../apache/ignite/table/manager/IgniteTables.java  |  15 +-
 .../org/apache/ignite/tx/IgniteTransactions.java}  |  28 +-
 .../java/org/apache/ignite/tx/Transaction.java}|  37 +-
 .../ignite/internal/manager/EventListener.java |   1 -
 .../internal/manager/ListenerRemovedException.java |  12 +
 .../apache/ignite/internal/manager/Producer.java   |  15 +-
 .../apache/ignite/raft/jraft/core/ITNodeTest.java  |   1 -
 .../java/org/apache/ignite/internal/raft/Loza.java |   4 +-
 .../apache/ignite/raft/jraft/core/NodeImpl.java|   4 +-
 .../apache/ignite/raft/jraft/core/Replicator.java  |   5 +-
 .../ignite/raft/jraft/entity/RaftOutter.java   |   5 +
 .../ignite/raft/jraft/option/RaftOptions.java  |   2 +-
 .../raft/jraft/rpc/message/EntryMetaImpl.java  |  13 +
 .../org/apache/ignite/raft/jraft/util/Utils.java   |   2 +-
 .../jraft/util/concurrent/AdjustableSemaphore.java |   1 -
 .../raft/jraft/conf/ConfigurationManagerTest.java  |   1 -
 .../ignite/raft/jraft/conf/ConfigurationTest.java  |   1 -
 .../ignite/raft/jraft/test/MockAsyncContext.java   |   2 +-
 .../runner/app/LiveSchemaChangeKVViewTest.java | 220 +
 .../runner/app/LiveSchemaChangeTableTest.java  | 325 ++
 .../org/apache/ignite/internal/app/IgniteImpl.java |   6 +
 .../SchemaConfigurationConverter.java  |  48 ++
 .../ignite/distributed/ITDistributedTableTest.java |   2 +-
 .../ignite/internal/table/AbstractTableView.java   |  22 +-
 .../ignite/internal/table/InternalTable.java   |  61 ++-
 .../ignite/internal/table/KVBinaryViewImpl.java|  65 ++-
 .../apache/ignite/internal/table/KVViewImpl.java   |  15 +-
 .../internal/table/LiveSchemaTupleBuilderImpl.java | 145 ++
 .../ignite/internal/table/RecordViewImpl.java  |  19 +-
 .../apache/ignite/internal/table/TableImpl.java|  71 ++-
 .../ignite/internal/table/TupleBuilderImpl.java|  19 +-
 .../internal/table/distributed/TableManager.java   | 106 +++--
 .../distributed/storage/InternalTableImpl.java |  51 ++-
 .../org/apache/ignite/internal/table/Example.java  |   2 +-
 .../internal/table/KVViewOperationsTest.java   |  21 +-
 .../internal/table/StrictSchemaOperationsTest.java |   8 +-
 .../table/TableBinaryViewOperationsTest.java   |  18 +-
 .../ignite/internal/table/TableManagerTest.java|  51 ++-
 .../org/apache/ignite/internal/table/TxTest.java   | 208 +
 .../table/impl/DummyInternalTableImpl.java |  44 +-
 modules/transactions/pom.xml   |   7 +
 .../apache/ignite/internal/tx/LockException.java}  |  23 +-
 .../org/apache/ignite/internal/tx/LockManager.java |  32 +-
 .../org/apache/ignite/internal/tx/Timestamp.java   |  85 
 .../tx/{LockOrderException.java => Waiter.java}|  15 +-
 .../ignite/internal/tx/impl/HeapLockManager.java   | 335 ++
 .../internal/tx/AbstractLockManagerTest.java   | 489 +
 ...ckManagerTest.java => HeapLockManagerTest.java} |  11 +-
 55 files changed, 2505 insertions(+), 245 deletions(-)
 copy modules/api/src/main/java/org/apache/ignite/schema/{PrimaryIndex.java => 
SchemaMode.java} (59%)
 copy 
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java
 => api/src/main/java/org/apache/ignite/tx/IgniteTransactions.java} (62%)
 copy 
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationNamedListListener.java
 => api/src/main/java/org/apache/ignite/tx/Transaction.java} (53%)
 create mode 100644 
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/LiveSchemaChangeKVViewTest.java
 create mode 100644 
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/

[ignite] branch master updated: IGNITE-14392: Hide SQL Transactions page from TOC (#9262)

2021-07-16 Thread dmagda

This is an automated email from the ASF dual-hosted git repository.

dmagda pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
 new b51  IGNITE-14392: Hide SQL Transactions page from TOC (#9262)
b51 is described below

commit b511c082cc3529771b0c7ebc311bc8b0f24c
Author: IgGusev 
AuthorDate: Fri Jul 16 13:26:10 2021 +0300

IGNITE-14392: Hide SQL Transactions page from TOC (#9262)
---
 docs/_data/toc.yaml | 2 --
 1 file changed, 2 deletions(-)

diff --git a/docs/_data/toc.yaml b/docs/_data/toc.yaml
index 0edcf6e..a4881c7 100644
--- a/docs/_data/toc.yaml
+++ b/docs/_data/toc.yaml
@@ -195,8 +195,6 @@
   url: SQL/sql-api
 - title: Distributed Joins
   url: SQL/distributed-joins
-- title: SQL Transactions
-  url: SQL/sql-transactions
 - title: Custom SQL Functions
   url: SQL/custom-sql-func
 - title: JDBC Driver

[ignite-3] branch ignite-14864 updated (18eee04 -> a7e8973)

2021-07-16 Thread amashenkov

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14864
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


from 18eee04  Minor.
 add a7e8973  Fix wrong cache cleanup. Test added.

No new revisions were added by this update.

Summary of changes:
 .../schema/registry/SchemaRegistryImpl.java| 19 +--
 .../{ => registry}/SchemaRegistryImplTest.java | 66 --
 2 files changed, 76 insertions(+), 9 deletions(-)
 rename modules/schema/src/test/java/org/apache/ignite/internal/schema/{ => 
registry}/SchemaRegistryImplTest.java (90%)

[ignite-3] branch ignite-14743 updated (6354d4e -> 95fecab)

[ignite] branch master updated: IGNITE-14728 Changed IGNITE_PDS_WAL_REBALANCE_THRESHOLD from System property to Distributed property. Fixes #9248

[ignite-3] branch ignite-14743 updated (824cc7d -> 6354d4e)

[ignite-3] branch ignite-14743 updated (f915189 -> 824cc7d)

[ignite-3] branch ignite-14743 updated (dfcb3d6 -> f915189)

[ignite-3] branch ignite-14743 updated (520cfb1 -> dfcb3d6)

[ignite-3] branch ignite-14896 updated (5bb6b2d -> 9615c23)

[ignite-3] branch ignite-14896 updated (2b53853 -> 5bb6b2d)

[ignite-3] branch main updated: IGNITE-15019 Fixed flaky testFollowerStartStopFollowing test. Fixes #215

[ignite-3] branch main updated: IGNITE-14864: Schema update. Merge multiple converters stages. (#194)

[ignite-3] branch ignite-14864 updated (a7e8973 -> c360974)

[ignite] branch master updated: IGNITE-14392: Hide SQL Transactions page from TOC (#9262)

[ignite-3] branch ignite-14864 updated (18eee04 -> a7e8973)

13 matches

Site Navigation

Mail list logo

Footer information