Repository: flink
Updated Branches:
refs/heads/master 131daa28b -> d85fe58d7
[FLINK-8517] Fix missing synchronization in TaskEventDispatcher
This closes #5621.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d85fe58d
Tree
Repository: flink
Updated Branches:
refs/heads/release-1.5 05f3fa45d -> 6b06292fb
[FLINK-8859][checkpointing] RocksDB backend should pass WriteOption to
Rocks.put() when restoring
(cherry picked from commit 131daa2)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://g
Repository: flink
Updated Branches:
refs/heads/master 3c8a673f9 -> 131daa28b
[FLINK-8859][checkpointing] RocksDB backend should pass WriteOption to
Rocks.put() when restoring
This closes #5635.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/r
Repository: flink
Updated Branches:
refs/heads/release-1.5 8f995e7a0 -> 05f3fa45d
[FLINK-8458][config][docs] Add config of credit-based network buffers
(cherry picked from commit 3c8a673)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/as
Repository: flink
Updated Branches:
refs/heads/master fc0001c85 -> 3c8a673f9
[FLINK-8458][config][docs] Add config of credit-based network buffers
This closes #5317.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c8a673
Repository: flink
Updated Branches:
refs/heads/release-1.5 824eb0262 -> 8f995e7a0
[FLINK-8769][flip6] do not print error causing exceptions without debugging
In DispatcherRestEndpoint and TaskExecutor, there were two places where without
errors (running a job inside an IDE) exceptions were log
Repository: flink
Updated Branches:
refs/heads/master c74d8cac2 -> fc0001c85
[FLINK-8769][flip6] do not print error causing exceptions without debugging
In DispatcherRestEndpoint and TaskExecutor, there were two places where without
errors (running a job inside an IDE) exceptions were logged.
Repository: flink
Updated Branches:
refs/heads/release-1.5 7c3be9149 -> 824eb0262
[FLINK-8818][yarn/s3][tests] harden YarnFileStageTest upload test for eventual
consistent read-after-write
In case the newly written object cannot be read (yet), we do 4 more retries to
retrieve the value and wa
Repository: flink
Updated Branches:
refs/heads/master 56fef58a3 -> c74d8cac2
[FLINK-8818][yarn/s3][tests] harden YarnFileStageTest upload test for eventual
consistent read-after-write
In case the newly written object cannot be read (yet), we do 4 more retries to
retrieve the value and wait 50
[FLINK-8737][network] disallow creating a union of UnionInputGate instances
Recently, the pollNextBufferOrEvent() was added but not implemented but this is
used in getNextBufferOrEvent() and thus any UnionInputGate containing a
UnionInputGate
would have failed already. There should be no use case
Repository: flink
Updated Branches:
refs/heads/release-1.5 f14532760 -> 926566651
[hotfix][network] minor improvements in UnionInputGate
(cherry picked from commit 4203557)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/
[FLINK-8737][network] disallow creating a union of UnionInputGate instances
Recently, the pollNextBufferOrEvent() was added but not implemented but this is
used in getNextBufferOrEvent() and thus any UnionInputGate containing a
UnionInputGate
would have failed already. There should be no use case
Repository: flink
Updated Branches:
refs/heads/master 6165b3db5 -> e8de53817
[hotfix][network] minor improvements in UnionInputGate
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42035571
Tree: http://git-wip-us.apache.or
Repository: flink
Updated Branches:
refs/heads/release-1.5 d5338c415 -> f14532760
[FLINK-8747][bugfix] The tag of waiting for floating buffers in
RemoteInputChannel should be updated properly
(cherry picked from commit 6e9e0dd)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Comm
[hotfix] Fix package private and comments
(cherry picked from commit 6165b3d)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f1453276
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f1453276
Diff: http://git-wip-us.a
[hotfix] Fix package private and comments
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6165b3db
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6165b3db
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6165b3
Repository: flink
Updated Branches:
refs/heads/master b9b7416f4 -> 6165b3db5
[FLINK-8747][bugfix] The tag of waiting for floating buffers in
RemoteInputChannel should be updated properly
This closes #5558.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.
[FLINK-8694][runtime] Fix notifyDataAvailable race condition
Before there was a race condition that might resulted in igonoring some
notifyDataAvailable calls.
This fixes the problem by moving buffersAvailable handling to Supartitions and
adds stress test
for flushAlways (without this fix this t
[FLINK-8750][runtime] Improve detection of no remaining data after
EndOfPartitionEvent
Because of race condition between:
1. releasing inputChannelsWithData lock in this method and reaching this place
2. empty data notification that re-enqueues a channel
we can end up with moreAvailable flag
Repository: flink
Updated Branches:
refs/heads/release-1.5 623e94459 -> d5338c415
[hotfix][tests] Deduplicate code in SingleInputGateTest
(cherry picked from commit 67a547a)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit
[FLINK-8760][runtime] Correctly propagate moreAvailable flag through
SingleInputGate
Previously if we SingleInputGate was re-eqnqueuing an input channel,
isMoreAvailable
might incorrectly return false. This might caused some dead locks.
(cherry picked from commit 6c9e267)
Project: http://git-
[FLINK-8805][runtime] Optimize EvenSerializer.isEvent method
For example, previously if the method was used to check for EndOfPartitionEvent
and the Buffer contained huge custom event, the even had to be deserialized
before
performing the actual check. Now we are quickly entering the correct if/e
[hotfix][tests] Do not hide original exception in
SuccessAfterNetworkBuffersFailureITCase
(cherry picked from commit 2c2e189)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e62f907
Tree: http://git-wip-us.apache.org/repos/
[hotfix][runtime] Remove duplicated check
(cherry picked from commit 42f71f6)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b7a4480
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b7a4480
Diff: http://git-wip-us.a
[FLINK-8750][runtime] Improve detection of no remaining data after
EndOfPartitionEvent
Because of race condition between:
1. releasing inputChannelsWithData lock in this method and reaching this place
2. empty data notification that re-enqueues a channel
we can end up with moreAvailable flag
[hotfix][runtime] Remove duplicated check
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42f71f61
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42f71f61
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/42f71f
[FLINK-8760][runtime] Correctly propagate moreAvailable flag through
SingleInputGate
Previously if we SingleInputGate was re-eqnqueuing an input channel,
isMoreAvailable
might incorrectly return false. This might caused some dead locks.
Project: http://git-wip-us.apache.org/repos/asf/flink/rep
[hotfix][tests] Deduplicate code in SingleInputGateTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/67a547ad
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/67a547ad
Diff: http://git-wip-us.apache.org/repos/asf/fli
[FLINK-8694][runtime] Fix notifyDataAvailable race condition
Before there was a race condition that might resulted in igonoring some
notifyDataAvailable calls.
This fixes the problem by moving buffersAvailable handling to Supartitions and
adds stress test
for flushAlways (without this fix this t
Repository: flink
Updated Branches:
refs/heads/master af8efe92c -> b9b7416f4
[FLINK-8805][runtime] Optimize EvenSerializer.isEvent method
For example, previously if the method was used to check for EndOfPartitionEvent
and the Buffer contained huge custom event, the even had to be deserialized
[hotfix][tests] Do not hide original exception in
SuccessAfterNetworkBuffersFailureITCase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c2e1896
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c2e1896
Diff: http://
Repository: flink
Updated Branches:
refs/heads/release-1.5 cf854ccbc -> 623e94459
[FLINK-8557][checkpointing] Remove illegal characters from operator description
text before using it to construct the instance directory in RocksDB
(cherry picked from commit 66474da)
Project: http://git-wip-u
Repository: flink
Updated Branches:
refs/heads/master f57793082 -> af8efe92c
[FLINK-8557][checkpointing] Remove illegal characters from operator description
text before using it to construct the instance directory in RocksDB
This closes #5598.
Project: http://git-wip-us.apache.org/repos/asf
Repository: flink
Updated Branches:
refs/heads/release-1.5 302aaeb02 -> 59b607b0c
[FLINK-8777][checkpointing] Cleanup local state more eagerly in recovery
(cherry picked from commit 296f9ff)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos
Repository: flink
Updated Branches:
refs/heads/master 6c837d738 -> 296f9ff74
[FLINK-8777][checkpointing] Cleanup local state more eagerly in recovery
This closes #5578.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/296f
Repository: flink
Updated Branches:
refs/heads/release-1.5 a13f7b234 -> 9f0295aa3
[hotfix] Improved logging for task local recovery
(cherry picked from commit 56c7560)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f029
Repository: flink
Updated Branches:
refs/heads/master 8d180d5fa -> 56c756040
[hotfix] Improved logging for task local recovery
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/56c75604
Tree: http://git-wip-us.apache.org/rep
[FLINK-8781][scheduler] Try to reschedule failed tasks to previous allocation
This closes #5403.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d63bc75f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d63bc75f
Diff:
Repository: flink
Updated Branches:
refs/heads/master 647c552a2 -> d63bc75ff
http://git-wip-us.apache.org/repos/asf/flink/blob/d63bc75f/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SchedulerSlotSharingTest.java
---
http://git-wip-us.apache.org/repos/asf/flink/blob/d63bc75f/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduleWithCoLocationHintTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/
[hotfix] Update RocksDB version to 5.7.5
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a8fc3b14
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a8fc3b14
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a8fc3b1
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-runtime/src/test/java/org/apache/flink/runtime/state/OperatorStateBackendTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/Operato
[hotfix] Introduce ShutdownHookUtil to avoid code duplication
(Un)registering shotdown hooks for cleanups is a very common concern in Flink.
Many places in the code essentially duplicate all the code for doing this.
This commit introduces a utils class and deduplicates the code.
Project: http://
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImplTest.java
--
diff --git
a/flink-streaming-java/src/test/java/org/
[FLINK-8360][checkpointing] Implement file-based local recovery for
FsStateBackend
This reverts commit 8925b7c
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e04321fa
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/chec
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/st
[hotfix] RocksDB improve resource cleanup (disposal order, dispose all
WriteOptions)
This commit ensures that all WriteOption objects are closed and that we do not
create unessesary
WriteOption objects for each state.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://gi
[FLINK-8360][checkpointing] Implement state storage for local recovery and
integrate with task lifecycle
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/df3e6bb7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/df3e6bb
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
--
diff --git
a/flink-state-backends/flink-
[hotfix] Do not track completed checkpoint ids without incremental checkpointing
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b5c53f5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b5c53f5
Diff: http://git-wip-us
[hotfix] Replace use of deprecated remove calls to RocksDB with delete
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff6662c9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ff6662c9
Diff: http://git-wip-us.apache.or
http://git-wip-us.apache.org/repos/asf/flink/blob/617e67c2/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
--
diff --git
a/flink-streaming-java/src/test/java/org/ap
http://git-wip-us.apache.org/repos/asf/flink/blob/1619fa8a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
--
diff --git
a/flink-state-backends/f
[hotfix] Remove outdated class OperatorStateHandles and replace it with
OperatorSubtaskState
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/617e67c2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/617e67c2
Diff: http
[FLINK-8699][checkpointing] Create deep copy of state meta data to avoid
concurrency problem with checkpoints
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f271161
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/Abstra
Repository: flink
Updated Branches:
refs/heads/master 4e7f03e41 -> f9a583b72
[hotfix] Rename OperatorSnapshotResult to OperatorSnapshotFutures.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ea0d16d4
Tree: http://git-wip-
http://git-wip-us.apache.org/repos/asf/flink/blob/1619fa8a/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/IncrementalRocksStreamOperatorSnapshotRestoreTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/df3e6bb7/flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskStateManager.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskSta
[hotfix] Suppress emitting non-causal exceptions from closed checkpointing
thread
This avoids that an exception that is caused by closing a running snapshot is
reported.
With this we avoid that users get confused by their logs or that this exception
could be
reported before its actual cause, th
[hotfix] RocksDB make default column family first
According to the documentation of RocksDB, the default column family should
always be created first.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca523fd5
Tree: http://git
[hotfix] Remove some unecessary null checks in RocksDBKeyedStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b55ffbe
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b55ffbe
Diff: http://git-wip-us.apache.o
[FLINK-8360][checkpointing] Documentation for local recovery
This closes #5239.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/32e25eb6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/32e25eb6
Diff: http://git-wip-us
[FLINK-8360][checkpointing] Implement file-based local recovery for
RocksDBStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1619fa8a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1619fa8a
Diff: http://gi
[hotfix] Clear interrupted flag in stream task cancellation
We clear the interrupted flag before the cleanup code block of task
cancellation.
Otherwise, code that would like to wait until services are properly shutdown
will
always immediately return from calls that are supposed to be blocking wa
Repository: flink
Updated Branches:
refs/heads/master 0651876ae -> eeac022f0
[FLINK-8679][State Backends] Ensure that RocksDBKeyedBackend.getKeys() filters
keys by namespace
This closes #5518.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/master e96f28bd3 -> 1e315f0dd
[FLINK-8639][State Backends] Fix always need to seek multiple times when
iterator RocksDBMapState
This closes #5465.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/r
Repository: flink
Updated Branches:
refs/heads/master 3126bf522 -> a144d0f77
[FLINK-8674][runtime] Improve performance of flushAlways in StreamRecordWriter
Reduce the number of data notifications in case of flushAlways = true. Instead
of notifying all of
the channels/subpartitions, notify onl
Repository: flink
Updated Branches:
refs/heads/master 831349a61 -> 3126bf522
http://git-wip-us.apache.org/repos/asf/flink/blob/3126bf52/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/SpillingBarrierBufferTest.java
---
http://git-wip-us.apache.org/repos/asf/flink/blob/3126bf52/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTestBase.java
--
diff --git
a/flink-streaming-java/src/test/java/org/apache/flink/str
http://git-wip-us.apache.org/repos/asf/flink/blob/3126bf52/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferTest.java
--
diff --git
a/flink-streaming-java/src/test/java/org/apache/flink/streami
[FLINK-8547][network] Implement CheckpointBarrierHandler not to spill data for
exactly-once
This closes #5400.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3126bf52
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/
Repository: flink
Updated Branches:
refs/heads/master fa024726b -> 5909b5bb7
[FLINK-8657][documentation] Fix incorrect description for configuration of
async snapshot for heap based backend
This closes #5490.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-
[hotfix][test] Simplify RecordWriterTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ec7934ef
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ec7934ef
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ec7934e
[hotfix][runtime] Refactor ResultPartition for cleaner recycle path
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5ad84509
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5ad84509
Diff: http://git-wip-us.apache.org/r
http://git-wip-us.apache.org/repos/asf/flink/blob/5b1e127f/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runti
[FLINK-8582][runtime] Optimize BufferBuilder writes
By introducing #commit() method on critical path we reduce number of volatile
writes from 2 down to 1.
This improves network throughput by 20% and restores the orignal performance
for high latency cases.
This closes #5423.
Project: http://gi
[hotfix][test] Deduplicate code in LargeRecordsTest and
SpanningRecordSerializationTest
Dedupilcated code was effectively identical, but implemented in a slightly
different way.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/comm
http://git-wip-us.apache.org/repos/asf/flink/blob/e9943c58/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runti
[FLINK-8590][runtime] Drop addBufferConsumerToAllSubpartitions method
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eb96d5d2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/eb96d5d2
Diff: http://git-wip-us.apache.org
[FLINK-8588][runtime] Handle sliced buffers in RecordDeserializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1310c725
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1310c725
Diff: http://git-wip-us.apache.org/rep
[hotfix][runtime] Deduplicate buffersInBacklog code in Pipelined and Spillable
subtartitions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/10d11d79
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/10d11d79
Diff: http
[hotfix][benchmarks] Add network stack benchmarks for LocalInputChannels
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/08f7284a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/08f7284a
Diff: http://git-wip-us.apache.
[hotfix][runtime] Simplify PipelinedSubpartition
notifyBuffersAvailable is a quick call that doesn't need to be executed outside
of the lock
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57228145
Tree: http://git-wip-us.ap
[hotfix][tests] Do not hide original exception in Serialization tests
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/058c0ed1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/058c0ed1
Diff: http://git-wip-us.apache.org
[hotfix][runtime] Simplify RecordWriter code
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91dc1c9a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91dc1c9a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/91d
Repository: flink
Updated Branches:
refs/heads/master 9d5a7857f -> fa024726b
[hotfix][network] Invert if check in SpanningRecordSerializer to improve
readability
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c520f6bb
Tr
[FLINK-8589][runtime] Add polling method to InputGate
This is a preparation for changes in data notifications, which will not be
that strict as they are now.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/98bd689a
Tree: http
[FLINK-8591][runtime] Pass unfinished bufferConsumers to subpartitions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b1e127f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5b1e127f
Diff: http://git-wip-us.apache.or
[hotfix][tests] Remove masking original exception in StreamTaskTimerTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4c38b38b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4c38b38b
Diff: http://git-wip-us.apache.
[hotfix][runtime-tests] Immediatelly fail test when one of the futures fails
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/433e05c7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/433e05c7
Diff: http://git-wip-us.apa
[hotfix][tests] Correctly set moreAvailable flag in StreamTestSingleInputGate
and handle redundant data notifications
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/78df079b
Tree: http://git-wip-us.apache.org/repos/asf/flink
[FLINK-8582][runtime] Introduce BufferConsumer
BufferConsumer will be used in the future for reading partially written
MemorySegments. On flushes instead of requesting new MemorySegment
BufferConsumer
code will allow to continue writting to partially filled up MemmorySegment.
Project: http://gi
[hotfix][tests] Reduce mockito usage in StreamTaskTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0af22bf2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0af22bf2
Diff: http://git-wip-us.apache.org/repos/asf/flin
[FLINK-8587][runtime] Drop unused AdaptiveSpanningRecordDeserializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c0f4d4a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c0f4d4a
Diff: http://git-wip-us.apache.org/
[hotfix][runtime] Rename setNextBufferBuilder to
continueWritingWithNextBufferBuilder
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa024726
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa024726
Diff: http://git-
[FLINK-8584] handle read-only buffers in deserializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/329f0961
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/329f0961
Diff: http://git-wip-us.apache.org/repos/asf/flink
[hotfix][tests] Properly clean up RescalingITCase and allow it to run in the
loop
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7d7ef12
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e7d7ef12
Diff: http://git-wip-
[hotfix][runtime] Drop unused throws IOException
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/635c29d8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/635c29d8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff
401 - 500 of 712 matches
Mail list logo
