You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ar...@apache.org on 2016/12/30 08:44:50 UTC
[10/12] storm git commit: STORM-1886 Make patch compatible with Java
1.7
STORM-1886 Make patch compatible with Java 1.7
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f115162f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f115162f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f115162f
Branch: refs/heads/1.x-branch
Commit: f115162f7ae65257d574a729426c845486a057ed
Parents: 6906870
Author: Balazs Kossovics <ba...@s4m.io>
Authored: Fri Dec 2 13:39:06 2016 +0100
Committer: Balazs Kossovics <ba...@s4m.io>
Committed: Fri Dec 2 13:39:06 2016 +0100
----------------------------------------------------------------------
.../main/java/org/apache/storm/redis/state/RedisKeyValueState.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/f115162f/external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java
----------------------------------------------------------------------
diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java b/external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java
index c2ca4df..4de9fda 100644
--- a/external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java
+++ b/external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java
@@ -44,7 +44,7 @@ public class RedisKeyValueState<K, V> implements KeyValueState<K, V> {
private static final String COMMIT_TXID_KEY = "commit";
private static final String PREPARE_TXID_KEY = "prepare";
private static final Serializer<Optional<byte[]>> internalValueSerializer = new DefaultStateSerializer<>();
- private static final String TOMBSTONE = encode(internalValueSerializer.serialize(Optional.absent()));
+ private static final String TOMBSTONE = encode(internalValueSerializer.serialize(Optional.<byte[]>absent()));
private final String namespace;
private final String prepareNamespace;