[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-09 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/5645 ---

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-07 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172939401 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -163,8 +224,9 @@ public T copy(T

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172922843 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -163,8 +224,9 @@ public T copy(T from, T

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-07 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172911926 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -163,8 +224,19 @@ public T copy(T

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-07 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172907369 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -163,8 +224,19 @@ public T copy(T

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172893030 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -163,8 +224,19 @@ public T copy(T from,

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172510349 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java --- @@ -277,6 +349,26 @@ private void

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172509993 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java --- @@ -502,6 +572,22 @@ private void

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5645#discussion_r172508524 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java --- @@ -502,6 +572,22 @@ private void

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-06 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/5645 FLINK-8876 Improve concurrent access handling in stateful serializers ## What is the purpose of the change Help detecting accidental concurrent use of serializers. If the log