Skip to content

Commit 910283b

Browse files
committed
revert WalStateAbstractMessage
1 parent 5c7f6ed commit 910283b

3 files changed

Lines changed: 13 additions & 3 deletions

File tree

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateAbstractMessage.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.ignite.internal.processors.cache;
1919

20+
import java.io.Serializable;
2021
import java.util.UUID;
2122
import org.apache.ignite.internal.Order;
2223
import org.apache.ignite.internal.managers.discovery.DiscoCache;
@@ -31,7 +32,10 @@
3132
/**
3233
* WAL state change abstract message.
3334
*/
34-
public abstract class WalStateAbstractMessage implements DiscoveryCustomMessage {
35+
public abstract class WalStateAbstractMessage implements DiscoveryCustomMessage, Serializable {
36+
/** */
37+
private static final long serialVersionUID = 0L;
38+
3539
/** Message ID */
3640
@Order(0)
3741
IgniteUuid id;
@@ -50,7 +54,7 @@ public abstract class WalStateAbstractMessage implements DiscoveryCustomMessage
5054

5155
/** Message that should be processed through exchange thread. */
5256
@GridToStringExclude
53-
private WalStateProposeMessage exchangeMsg;
57+
private transient WalStateProposeMessage exchangeMsg;
5458

5559
/** Constructor. */
5660
protected WalStateAbstractMessage() {

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateFinishMessage.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,9 @@
2727
* WAL state finish message.
2828
*/
2929
public class WalStateFinishMessage extends WalStateAbstractMessage {
30+
/** */
31+
private static final long serialVersionUID = 0L;
32+
3033
/** Whether WAL state was changed as a result of this call. */
3134
@Order(0)
3235
boolean changed;

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateProposeMessage.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,9 @@
2727
* WAL state propose message.
2828
*/
2929
public class WalStateProposeMessage extends WalStateAbstractMessage {
30+
/** */
31+
private static final long serialVersionUID = 0L;
32+
3033
/** Cache names which are expected to be in the group along with their deployment IDs. */
3134
@Order(0)
3235
Map<String, IgniteUuid> caches;
@@ -36,7 +39,7 @@ public class WalStateProposeMessage extends WalStateAbstractMessage {
3639
boolean enable;
3740

3841
/** Whether message is being handled on cache affinity node. */
39-
private boolean affNode;
42+
private transient boolean affNode;
4043

4144
/** Constructor. */
4245
public WalStateProposeMessage() {

0 commit comments

Comments
 (0)