[FLINK-4813] [test-utils] Make the hadoop-minikdc dependency optional
With this change, any project using flink-test-utils which also requires
SecureTestEnvironment must add a dependency to hadoop-minikdc itself, e.g. in
pom.xml:
...
org.apache.hadoop
hadoop-minikdc
[FLINK-5723] [web frontend] Use 'Used' instead of 'Initial' in TaskManager
memory consumption view
This closes #3275
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/03e6c249
Tree:
Repository: flink
Updated Branches:
refs/heads/master f113d7945 -> 03e6c2491
[FLINK-5749] [build] Unset HADOOP_HOME and HADOOP_CONF_DIR variables for tests
This unsets the HADOOP_HOME and HADOOP_CONF_DIR envirobment variables for
tests, to avoid
that the tests pick those variable up from
[FLINK-5723] [web frontend] Use 'Used' instead of 'Initial' in TaskManager
memory consumption view
This closes #3275
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e3e3c2a7
Tree:
Repository: flink
Updated Branches:
refs/heads/release-1.2 048a21c09 -> e3e3c2a7f
[FLINK-5749] [build] Unset HADOOP_HOME and HADOOP_CONF_DIR variables for tests
This unsets the HADOOP_HOME and HADOOP_CONF_DIR envirobment variables for
tests, to avoid
that the tests pick those variable up
[hotfix] [tests] Remove sysout logging in KvStateLocationTest
This helps keeping test log output free from clutter.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31f3d65c
Tree:
[FLINK-5895] [runtime] Decrease logging aggressiveness of FileSystemSafetyNet
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6e6e7ec
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f6e6e7ec
Diff:
Repository: flink
Updated Branches:
refs/heads/master 15ae922ad -> 6f3723e83
[FLINK-5885] [docs] Fix Cassandra Scala snippet
This closes #3400
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f3723e8
Tree:
[FLINK-5854] [core] Add base Flink Exception classes
This closes #3368
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/813c2585
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/813c2585
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.2 db3c5f388 -> b5ec14641
[FLINK-5895] [runtime] Decrease logging aggressiveness of FileSystemSafetyNet
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/74b29f5a
[FLINK-5877] [docs] Fix Async I/O Scala snippet
This closes #3383
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5ec1464
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5ec1464
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.2 b5ec14641 -> d8c2447bd
[FLINK-5885] [docs] Fix Cassandra Scala snippet
This closes #3400
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8c2447b
Tree:
[FLINK-5887] [checkpointing] Make CheckpointBarrier type immutable.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ffe75a5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ffe75a5
Diff:
Repository: flink
Updated Branches:
refs/heads/master 30c9e2b68 -> 417597fbf
[hotfix] [docs] Fix JavaDoc errors in 'flink-streaming-java'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1f9f38bf
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/6e7a9174/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/BarrierBufferAlignmentLimitTest.java
--
diff --git
[FLINK-5763] [checkpoints] Add CheckpointOptions
Adds `CheckpointOptions` to the triggered checkpoint messages (coordinator
to barrier injecting tasks) and barriers (flowing inline with the data:
```java
public class CheckpointOptions {
// Type of checkpoint
// => FULL_CHECKPOINT
// =>
http://git-wip-us.apache.org/repos/asf/flink/blob/6e7a9174/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
--
diff --git
[hotfix] [checkpoints] Remove equals()/hashCode() from CompletedCheckpoint as
semantic equality is not well defined.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/417597fb
Tree:
[FLINK-4813] [test-utils] Make the hadoop-minikdc dependency optional
With this change, any project using flink-test-utils which also requires
SecureTestEnvironment must add a dependency to hadoop-minikdc itself, e.g. in
pom.xml:
...
org.apache.hadoop
hadoop-minikdc
[FLINK-5497] [tests] Remove duplicated tests for hash tables
This closes #3089
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/53134594
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/53134594
Diff:
[hotfix] [core] Add missing @Internal annotations to classes in flink-core.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/082d40fd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/082d40fd
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/f113d794/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/LeaderChangeJobRecoveryTest.java
--
diff --git
[FLINK-5129] [distributed runtime] BlobCache to directly accesses Blobs from
distrinbuted file system if possible
This closes #3084
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f544d83
Tree:
[hotfix] [docs] Updated DC/OS setup instructions.
This closes #3349
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e68ee5cb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e68ee5cb
Diff:
[FLINK-5747] [distributed coordination] Eager scheduling allocates slots and
deploys tasks in bulk
That way, strictly topological deployment can be guaranteed.
Also, many quick deploy/not-enough-resources/fail/recover cycles can be
avoided in the cases where resources need some time to appear.
[FLINK-5640] [build] Configure the explicit Unit Test file suffix
This closes #3211
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ce2557d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4ce2557d
Diff:
[hotfix] [core] Add missing @PublicEvolving annotations to classes in
flink-core.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0aa9918c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0aa9918c
Diff:
[FLINK-5277] [tests] Add unit tests for ResultPartition#add() in case of
failures
This verifies that the given network buffer is recycled as expected and that
no notifiers are called upon failures to add a buffer.
This closes #3309
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
[FLINK-5522] [storm compatibility] Move Storm LocalCluster based test to a
separate class
This fixes the problem that the Storm LocalCluster can't run with powermock
This closes #3138
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5739] [client] Fix NullPointerException in CliFrontend
This closes #3292
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e32eb54
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e32eb54
Diff:
Repository: flink
Updated Branches:
refs/heads/master 70475b367 -> f113d7945
[FLINK-5817] [tests] Use TemporaryFold to create temp files and folds for test
This closes #3341
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5828] [distributed runtime] Fix initialization of Blob storage
directories
Flip the logic (check existence and create directory) to resolve currency
problem
This closes #3342
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5812] [core] Cleanups in FileSystem (round 1)
- This makes the FileSystem use the 'WriteMode' (otherwise it was an unused
enumeration)
- Extends comments
- Deprecate the method that controls the replication factor and block size
Project:
[FLINK-5812] [core] Cleanups in FileSystem (round 2)
Move the FileSystem safety net to a separate class.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5902ea0e
Tree:
[FLINK-5817] [test] (followup) Fix temporary folder and temp file path
generation
This makes sure the TemporaryFolder rule is already evaluated by the time
the temp files are generated.
This also injects a random parent directory to ensure that even for fix
directory/file
names, the absolute
[FLINK-5669] [contrib] Change DataStreamUtils to use the loopback address
(127.0.0.1) with local environments.
Using loopback rather than the "local address" allows tests to run in
situations where the local machine's hostname may not be resolvable in DNS
(because DNS is unreacable or the
[hotfix] [tests] Use random actor names in JobManagerHARecoveryTest to avoid
name collisions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31c26e3f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31c26e3f
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.2 b21f9d11d -> fee020c42
[hotfix] [docs] Updated DC/OS setup instructions.
This closes #3349
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fee020c4
Tree:
[FLINK-5828] [distributed runtime] Fix initialization of Blob storage
directories
Flip the logic (check existence and create directory) to resolve currency
problem
This closes #3342
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 6bc6b225e -> 186b12309
[FLINK-5631] [yarn] Support downloading additional jars from non-HDFS paths.
This closes #3202
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5729] [examples] Add hostname option to SocketWindowWordCount examples
This closes #3283
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30c5b771
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30c5b771
Diff:
[hotfix] [core] Add tests for Futures applying multiple functions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/61d7f15d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/61d7f15d
Diff:
Repository: flink
Updated Branches:
refs/heads/master f6709b4a4 -> ff3786663
[hotfix] [core] Improve FlinkFuture synchronous actions by avoiding creation of
ExecutionContext
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5790] [core] Followups and tests for the StateDescriptor changes
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2045cc5f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2045cc5f
Diff:
Repository: flink
Updated Branches:
refs/heads/master ded7faeab -> 2045cc5f8
[FLINK-5790] [core] Use list types when ListStateDescriptor extends
StateDescriptor
This closes #3305
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 663c1e3f7 -> f7af3b016
[FLINK-5788] [docs] Improve documentation of FileSystem and specify the data
persistence contract.
This closes #3301
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5762] [runtime] Protect initializeState() and open() by the same lock
This closes #3291
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a91b6ff0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a91b6ff0
Diff:
[FLINK-5553] [network] keep the original throwable in
PartitionRequestClientHandler
This way, when checking for a previous error in any input channel, we can throw
a meaningful exception instead of the inspecific
IllegalStateException("There has been an error in the channel.") before.
Note that
[FLINK-5132] [core] Introduce the ResourceSpec to define required resource
factors in API
This closes #3114
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd872a14
Tree:
[FLINK-5748] [jobmanager] Make the 'future executor' a ScheduledExecutorService
This closes #3289
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/665c7e39
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/665c7e39
Repository: flink
Updated Branches:
refs/heads/master 95765b6d8 -> 665c7e399
http://git-wip-us.apache.org/repos/asf/flink/blob/665c7e39/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingUtils.scala
--
Repository: flink
Updated Branches:
refs/heads/master 665c7e399 -> fd872a149
[FLINK-4912] Introduce RECONCILIATING state in ExecutionGraph and Execution for
JobManager failure recovery
This closes #3113
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master f250d95b7 -> 2ec2abfae
[FLINK-5814] [build] Fix packaging flink-dist in unclean source directory
If "/build-target" already existed, running 'mvn package' for
flink-dist would create a symbolic link inside "/build-target"
instead of
Repository: flink
Updated Branches:
refs/heads/master 67e3d9d44 -> f250d95b7
[hotfix] [tests] Stabilize FastFailuresITCase
The test triggers 200 immediate failures and recoveries. The restart strategy
allowed 200 restarts.
It may happen that another failure occurs as during the execution,
[FLINK-5805] [docs] Improvements to docs for ProcessFunction
This closes #3317
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8fd374c9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8fd374c9
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.2 e9ada34f2 -> d3f2fe262
[FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per
operator
Previously, the factory was created once per checkpoint, and its repeated
initialization logic
(like ensuring existence of base
[FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly
This closes #3257
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3f2fe26
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d3f2fe26
Diff:
[hotfix] [streaming] Properly mark non-transported fields as transient in
AbstractStreamOperator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8837c0c5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8837c0c5
Diff:
[hotfix] [tests] Stabilize FastFailuresITCase
The test triggers 200 immediate failures and recoveries. The restart strategy
allowed 200 restarts.
It may happen that another failure occurs as during the execution, in which
case the restart attempts are not
sufficient.
Project:
[FLINK-5814] [build] Fix packaging flink-dist in unclean source directory
If "/build-target" already existed, running 'mvn package' for
flink-dist would create a symbolic link inside "/build-target"
instead of replacing that symlink. This commit fixes this behaviour of 'ln -sf'
by adding the
Repository: flink
Updated Branches:
refs/heads/master 494edb041 -> f24514339
[FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly
This closes #3257
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 7477c5b57 -> 5fb267de6
[FLINK-5805] [docs] Improvements to docs for ProcessFunction
This closes #3317
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fb267de
Tree:
[FLINK-5793] [runtime] fix running slot may not be add to AllocatedMap in
SlotPool bug
This closes #3306
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/33ea78ea
Tree:
Repository: flink
Updated Branches:
refs/heads/master b06522681 -> 04e6758ab
[hotfix] [streaming] Properly mark non-transported fields as transient in
AbstractStreamOperator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per
operator
Previously, the factory was created once per checkpoint, and its repeated
initialization logic
(like ensuring existence of base paths) caused heavy load on some filesystems
at very large scale.
This closes #3312
Repository: flink
Updated Branches:
refs/heads/release-1.2 28dd4a57a -> 1dfb3e0e2
[FLINK-5247] [streaming api] Fix checks for allowed lateness in windowed streams
Also, fix outdated documentation.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[hotfix] [streaming api] Improve JavaDocs of the user-facing checkpointing and
state interfaces
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1dfb3e0e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1dfb3e0e
Diff:
[FLINK-4917] [streaming api] Deprecate "CheckpointedAsynchronously" interface
This closes #3087
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/083152c6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/083152c6
Diff:
[hotfix] [streaming api] Minor cleanup in WindowedStream and AllWindowedStream
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/159f51b2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/159f51b2
Diff:
[FLINK-5718] [core] TaskManagers exit the JVM on fatal exceptions.
This closes #3276
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dfc6fba5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dfc6fba5
Diff:
[hotfix] [dist] Add notice about memory pre-allocation to default
'flink-conf.yaml'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e29dfb84
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e29dfb84
Diff:
[FLINK-5759] [jobmanager] Set UncaughtExceptionHandlers for JobManager's Future
and I/O thread pools
This closes #3290
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef77c254
Tree:
Repository: flink
Updated Branches:
refs/heads/master 66305135b -> e29dfb840
[FLINK-5766] [distributed coordination] Unify the handling of
NoResourceAvailableException
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/release-1.2 33c5df6dd -> f4869a66d
[hotfix] [docs] Move 'dev/state_backends' to 'ops/state_backends'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/daad28ab
Tree:
[FLINK-5456] [docs] Add stub for types of state and state interfaces
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/58509531
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/58509531
Diff:
[FLINK-5459] [docs] Add templates for debugging classloading and debugging
event time issues
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef185d77
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef185d77
Diff:
[FLINK-5457] [docs] Add stub for Async I/O docs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2730e895
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2730e895
Diff:
[FLINK-5458] [docs] Add a template for migration guide
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b0c4d96
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4b0c4d96
Diff:
[FLINK-5457] [docs] Add documentation for asynchronous I/O
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f4869a66
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f4869a66
Diff:
[FLINK-5460] [docs] Add placeholder for Docker setup guide
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b41d0ff8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b41d0ff8
Diff:
[hotfix] [docs] Move section about internal snapshot implementation from
'state_backends.md' to 'stream_checkpointing.md'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac193d6a
Tree:
[FLINK-5454] [docs] Add stub for docs on "Tuning for large state"
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7aad7514
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7aad7514
Diff:
[FLINK-5455] [docs] Add stub for Upgrading Jobs and Framework
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a562e3d9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a562e3d9
Diff:
Repository: flink
Updated Branches:
refs/heads/master e2ba042c1 -> fb3761b57
[FLINK-5457] [docs] Add documentation for asynchronous I/O
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fb3761b5
Tree:
[FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception
This closes #3097
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa67ef40
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa67ef40
Diff:
[FLINK-3617] [scala apis] Added null value check.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fdce1f31
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fdce1f31
Diff:
[FLINK-5345] [core] Migrate various cleanup calls to concurrency-safe directory
deletion
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c4626cba
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c4626cba
Diff:
[FLINK-4450] [storm compat] Update storm version to 1.0
This closes #3037
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/475c0b1a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/475c0b1a
Diff:
[FLINK-5345] [core] Add a utility to delete directories without failing in the
presence of concurrent deletes
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8742ff1b
Tree:
[FLINK-4959] [docs] Add documentation for ProcessFunction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a339a65
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a339a65
Diff:
Repository: flink
Updated Branches:
refs/heads/master ef8cdfe59 -> 7a339a65f
[FLINK-5438] [streaming api] Typo in JobGraph generator Exception
This closes #3098
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c2f28c01
http://git-wip-us.apache.org/repos/asf/flink/blob/475c0b1a/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/util/FiniteSpout.java
--
diff --git
[FLINK-4959] [docs] Add documentation for ProcessFunction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2eb926f2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2eb926f2
Diff:
[FLINK-5485] [webfrontend] Mark compiled web frontend files as binary when
processed by git diff
Particularly beneficial now that javascript is minified, we can mark
compiled web frontend files as binary when processed by git diff.
https://linux.die.net/man/5/gitattributes
This does not
Repository: flink
Updated Branches:
refs/heads/release-1.2 f4869a66d -> 2eb926f2b
[FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception
This closes #3097
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-5438] [streaming api] Typo in JobGraph generator Exception
This closes #3098
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30b467f2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30b467f2
Diff:
[FLINK-3617] [scala apis] Added null value check.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27c11e1b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27c11e1b
Diff:
[FLINK-5345] [core] Add a utility to delete directories without failing in the
presence of concurrent deletes
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b1be3f5c
Tree:
[FLINK-5345] [core] Migrate various cleanup calls to concurrency-safe directory
deletion
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1b86aab
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d1b86aab
Diff:
Repository: flink
Updated Branches:
refs/heads/release-1.1 931929bf8 -> f6f1c244c
[FLINK-5585] [jobmanager] Fix NullPointerException in
JobManager.updateAccumulators
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
1001 - 1100 of 2984 matches
Mail list logo
