Repository: flink
Updated Branches:
refs/heads/master 40c978b04 -> cd43dd59e
[FLINK-4485] close and remove user class loader after job completion
Keeping the user class loader around after job completion may lead to
excessive temp space usage because all user jars are kept until the
class load
[FLINK-4555] wait for ResourceManager to cleanly unregister application
This ensures that the ResourceManager has enough time to unregister the
application before shutting down.
This closes #2514
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/rep
Repository: flink
Updated Branches:
refs/heads/release-1.1 8fd08bf29 -> 06496439a
[FLINK-4485] close and remove user class loader after job completion
Keeping the user class loader around after job completion may lead to
excessive temp space usage because all user jars are kept until the
class
Repository: flink
Updated Branches:
refs/heads/master cd43dd59e -> 4a8e94403
[FLINK-4485] close classloader in absence of reference holders
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a8e9440
Tree: http://git-wip-us.a
Repository: flink
Updated Branches:
refs/heads/release-1.1 06496439a -> 62c666f57 (forced update)
[FLINK-4485] close and remove user class loader after job completion
Keeping the user class loader around after job completion may lead to
excessive temp space usage because all user jars are kept
[FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses
This closes #2561
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87767ab4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/87767ab4
Diff:
[FLINK-4606] integrate features of old ResourceManager
This closes #2540
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38766309
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/38766309
Diff: http://git-wip-us.apache
Repository: flink
Updated Branches:
refs/heads/flip-6 5513fe61d -> 387663094
[FLINK-4606] Integrate the new ResourceManager with the existed
FlinkResourceManager
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/69d08ca4
T
Repository: flink
Updated Branches:
refs/heads/master eece0dd05 -> 5a573c6bc
[FLINK-4732] remove maven junction plugin
On Windows, the plugin downloads and executes code from the author's
web site. The downloaded file is not signed in the same way as Maven
artifacts from Maven central which ha
Repository: flink
Updated Branches:
refs/heads/release-1.1 98b399d4b -> a31a22ec7
[FLINK-4732] remove maven junction plugin
On Windows, the plugin downloads and executes code from the author's
web site. The downloaded file is not signed in the same way as Maven
artifacts from Maven central whi
Repository: flink
Updated Branches:
refs/heads/master 825ef3be3 -> 8c7c42f0e
[FLINK-4677] fail if user jar contains no executions
This closes #2548.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c7c42f0
Tree: http://gi
Repository: flink
Updated Branches:
refs/heads/release-1.1 a83dbaeb0 -> fddd89bcd
[FLINK-4677] fail if user jar contains no executions
This closes #2548.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fddd89bc
Tree: http
Repository: flink
Updated Branches:
refs/heads/release-1.1 fddd89bcd -> bab59dfa7
[FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling
This closes #2593.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba
[FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with
ResourceManager
Instead of relying on a full synchronization of all slots information on
every heartbeat, the SlotManager is now responsible for updating its
state. It initially syncs all slots upon registration of the
TaskExecut
Repository: flink
Updated Branches:
refs/heads/flip-6 85424c135 -> 0518af03a
http://git-wip-us.apache.org/repos/asf/flink/blob/0518af03/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
Repository: flink
Updated Branches:
refs/heads/master 8d953bf26 -> 706dc131c
[FLINK-4318][docs] change default version in config
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/706dc131
Tree: http://git-wip-us.apache.org/r
Repository: flink-web
Updated Branches:
refs/heads/asf-site 799a6cdcf -> aaf1263c9
[FLINK-4318][docs] change default version in config
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/d758d51a
Tree: http://git-wip-u
update website
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/aaf1263c
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/aaf1263c
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/aaf1263c
Branch:
http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/news/2016/08/08/release-1.1.0.html
--
diff --git a/content/news/2016/08/08/release-1.1.0.html
b/content/news/2016/08/08/release-1.1.0.html
index 4f5b30b..3eefa
Repository: flink
Updated Branches:
refs/heads/release-1.1 bab59dfa7 -> 7267562bb
[FLINK-4777] catch IOException in ContinuousFileMonitoringFunction
FileSystem.listStatus(path) may throw an IOException when it lists files
and then retrieves their file status. This is quite common, e.g. editors
Repository: flink
Updated Branches:
refs/heads/master 706dc131c -> b949d42d9
[FLINK-4777] catch IOException in ContinuousFileMonitoringFunction
FileSystem.listStatus(path) may throw an IOException when it lists files
and then retrieves their file status. This is quite common, e.g. editors
whic
Repository: flink
Updated Branches:
refs/heads/master 7b79c8b52 -> 15df71ba9
[FLINK-4799] re-add 'build-target' symlink on Unix systems
This adds back the link 'build-target' which points to the final build
assembly in 'flink-dist/target/'.
This closes #2620
Project: http://git-wip-us.apach
Repository: flink
Updated Branches:
refs/heads/flip-6 64ee13862 -> 35a44daa6
[FLINK-4516] update leadership information in ResourceManager
The leadership information remained static for connected
JobMasters. This updates it to remove stale JobMasters when they lose
leadership status.
This clo
[FLINK-3932] Added ZK ACL configuration for secure cluster setup
This closes #2589.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5bd47012
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5bd47012
Diff: http://git-wi
Repository: flink
Updated Branches:
refs/heads/master 85b53444a -> 6d4dd7585
[FLINK-4667] Fix for using correct ZK namespace in Yarn deployment
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d4dd758
Tree: http://git-wip-
Repository: flink
Updated Branches:
refs/heads/master 6d4dd7585 -> a2e999b96
[FLINK-4667] add import for config entry
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a2e999b9
Tree: http://git-wip-us.apache.org/repos/asf/fl
[FLINK-3931] Implement Transport Encryption (SSL/TLS)
Enabled SSL support for the different network transport within flink.
This feature is documented as task T3 in the "Secure Data Access in Flink"
design doc -
https://docs.google.com/document/d/1-GQB6uVOyoaXGwtqwqLV8BHDxWiMO2WnVzBoJ8oPaAs
Thi
Repository: flink
Updated Branches:
refs/heads/master dffde7efb -> 069de27df
http://git-wip-us.apache.org/repos/asf/flink/blob/069de27d/flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java
--
diff --git
a/fli
[FLINK-4829] protect user accumulators against concurrent updates
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/783dca56
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/783dca56
Diff: http://git-wip-us.apache.org/rep
Repository: flink
Updated Branches:
refs/heads/master f46ca3918 -> d95929e01
[FLINK-4829] snapshot accumulators on a best-effort basis
Heartbeats should not fail when accumulators could not be snapshotted. Instead,
we should simply skip the reporting of the failed accumulator. Eventually, the
[FLINK-4829] snapshot accumulators on a best-effort basis
Heartbeats should not fail when accumulators could not be snapshotted. Instead,
we should simply skip the reporting of the failed accumulator. Eventually, the
accumulator will be reported; at the latest, when the job finishes.
This closes
Repository: flink
Updated Branches:
refs/heads/release-1.1 fe464b424 -> 210230c4a
[FLINK-4829] protect user accumulators against concurrent updates
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1d6b246
Tree: http://git-
Repository: flink
Updated Branches:
refs/heads/master 0d2903541 -> a27451d8e
[FLINK-4833] properly log exceptions in CountMinHeavyHitter
This closes #2660
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a27451d8
Tree: htt
Repository: flink
Updated Branches:
refs/heads/master a27451d8e -> 58a16c100
[FLINK-4881][docker] remove shared volume for configuration
README.md -Description of the bluemix specific steps
build.sh -modify permissions to make script executable by
de
Repository: flink
Updated Branches:
refs/heads/release-1.1 5731672e5 -> 05a5f460b
[FLINK-4862] fix Timer register in ContinuousEventTimeTrigger
Backported to release-1.1.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/05
Repository: flink
Updated Branches:
refs/heads/master e33243729 -> 45762162f
[FLINK-4862] fix Timer register in ContinuousEventTimeTrigger
This closes #2671
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/45762162
Tree: h
[FLINK-4800] Introduce the TimestampedFileInputSplit for Continuous File
Processing
This commit mainly introduces the TimestampedFileInputSplit,
which extends the class FileInputSplit and also contains:
i) the modification time of the file it belongs to and also, and
ii) when checkpointing, the p
http://git-wip-us.apache.org/repos/asf/flink/blob/b410c393/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
--
diff --git
a/flink-streaming-java/src/main/java/org
Repository: flink
Updated Branches:
refs/heads/master fc730bb07 -> b410c393c
[FLINK-4913][yarn] include user jars in system class loader
When deploying a Yarn cluster for a single job, this change
pre-configures the cluster to include the user jar(s) on all nodes.
This eliminates the need to u
Repository: flink
Updated Branches:
refs/heads/release-1.1 17bb96dd6 -> ea41b9c56
[FLINK-4913][yarn] include user jars in system class loader
When deploying a Yarn cluster for a single job, this change
pre-configures the cluster to include the user jar(s) on all nodes.
This eliminates the need
Repository: flink
Updated Branches:
refs/heads/master ba2d007e5 -> 59a5551ef
[hotfix] Fixes the TimestampedInputSplit.EOS comparison.
This closes #2718
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59a5551e
Tree: http:/
Repository: flink
Updated Branches:
refs/heads/master 7d61e1f2f -> bb26c9e1b
[yarn] fix debug string displayed for failed applications
This closes #2745.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb26c9e1
Tree: http
Repository: flink
Updated Branches:
refs/heads/release-1.1 6e57e7f46 -> d3d6907b5
[yarn] fix debug string displayed for failed applications
This closes #2745.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3d6907b
Tree:
Repository: flink
Updated Branches:
refs/heads/master ac3997927 -> e4807621b
[FLINK-4998][yarn] fail if too many task slots are configured
This fails the deployment of the Yarn application if the number of task
slots are configured to be larger than the maximum virtual cores of the
Yarn cluste
[FLINK-3813][yarn] wait for CLI to complete before checking output
This closes #2749.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e4807621
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e4807621
Diff: http://git-
Repository: flink
Updated Branches:
refs/heads/release-1.1 5133bf9ea -> 42334de84
[FLINK-3813][yarn] wait for CLI to complete before checking output
This closes #2749.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42334
Repository: flink
Updated Branches:
refs/heads/release-1.1 42334de84 -> fe2c4ba6a
[FLINK-4998][yarn] fail if too many task slots are configured
This fails the deployment of the Yarn application if the number of task
slots are configured to be larger than the maximum virtual cores of the
Yarn c
Repository: flink
Updated Branches:
refs/heads/master 59b3be0ec -> 8b1b4a1cc
[docker] improve Dockerfile
- Make build.sh executable
- Fix Dockerfile using ARG instead of ENV
- Prevent exit only for job-/taskmanger shortcuts
This closes #3086.
Project: http://git-wip-us.apache.org/repos/asf/
Repository: flink
Updated Branches:
refs/heads/master e85f787b2 -> 082d87e51
[FLINK-4199] fix misleading CLI messages during job submission
- change CLI message upon cluster retrieval
- save JobExecutionResult for interactive executions
- only print Collection size in accumulator results
- rem
Repository: flink
Updated Branches:
refs/heads/master e3fec1f9a -> c6715b7f7
[travis] remove outdated comment regarding snapshots
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c6715b7f
Tree: http://git-wip-us.apache.org/
Repository: flink
Updated Branches:
refs/heads/master c6715b7f7 -> 2648bc1a5
http://git-wip-us.apache.org/repos/asf/flink/blob/2648bc1a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnFlinkResourceManagerTest.java
--
diff --
[FLINK-4152] Allow re-registration of TMs at resource manager
- Add YarnFlinkResourceManager test to reaccept task manager registrations from
a re-elected job manager
- Remove unnecessary sync logic between JobManager and ResourceManager
- Avoid duplicate reigstration attempts in case of a refu
Repository: flink
Updated Branches:
refs/heads/master 2648bc1a5 -> cd232e683
[FLINK-4261][tools] retry in case of failed snapshot deployment
Unfortunately, we can't deploy snapshots atomically using the Nexus
repository. The staged process which leads to an atomic deployment is
only designed t
Repository: flink
Updated Branches:
refs/heads/master 9bcbcf4a5 -> 884d3e2a4
[FLINK-4258] fix potential NPE in SavepointCoordinator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/884d3e2a
Tree: http://git-wip-us.apache.or
Repository: flink
Updated Branches:
refs/heads/master 12bf7c1a0 -> 5eb0e38fb
http://git-wip-us.apache.org/repos/asf/flink/blob/5eb0e38f/flink-runtime/src/test/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManagerTest.java
--
[FLINK-3904] enhancements to GlobalConfiguration
- fail if config couldn't be loaded
- remove duplicate api methods
- remove undocumented XML loading feature
- generate yaml conf in tests instead of xml conf
- only load one config file instead of all xml or yaml files (flink-conf.yaml)
- make glob
Repository: flink
Updated Branches:
refs/heads/master d618b13e8 -> a30ec83da
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org/repo
Repository: flink
Updated Branches:
refs/heads/release-1.1 12bf7c1a0 -> 8a1fe66e8
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/release-1.0 3150c7e20 -> 5794350cc
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/master 873d6cd18 -> 4b8f28825
[cleanup] remove unused code
- remove unused utility testing function
- remove leftover FLINK_CONF_DIR jvm property
This closes #2325
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wi
Repository: flink
Updated Branches:
refs/heads/master 8ccee48c5 -> f0992aa13
[maven] fix snapshot deployment of hadoop1 version
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0992aa1
Tree: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/master f170e04ab -> 726d7c7ff
[FLINK-4236] fix error handling for jar files with no main method
This change shows only entry classes with a valid main method. It
ignores classes which contain no main method.
This closes #2347
Project: http://gi
Repository: flink
Updated Branches:
refs/heads/release-1.1 58c810aea -> f67cb89d4
[FLINK-4236] fix error handling for jar files with no main method
This change shows only entry classes with a valid main method. It
ignores classes which contain no main method.
This closes #2347
Project: http
Repository: flink
Updated Branches:
refs/heads/master c894896a4 -> 889c63e56
[FLINK-3155] Update docker flink container to the latest release
[FLINK-3155] Make docker image execute as non-root user (l:flink)
[FLINK-3155] Change default FLINK_HOME from /usr/local/flink to /opt/flink
[FLINK-31
Repository: flink
Updated Branches:
refs/heads/master 889c63e56 -> 9f928d1ec
[FLINK-4287] Ensure the yarn-session.sh classpath contains all Hadoop related
paths
This closes #2317
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/
Repository: flink
Updated Branches:
refs/heads/release-0.9 1a1c134ac -> 19fec0fc9
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/release-0.8 96849b5e3 -> bc40b1b8e
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/release-0.7 2a228e206 -> 6b52efed5
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/release-0.6 e48285d50 -> eeef2cd32
[docs] require at least Ruby 1.9.0 for building
The json module is bundled with Ruby from 1.9.0 and upwards. This
cures dependency problems with different versions of Ruby.
Project: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/master 844c874b5 -> 720645587
[FLINK-4454] always display JobManager address using LeaderRetrievalService
This closes #2406
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/72
Repository: flink
Updated Branches:
refs/heads/release-1.1 e352ce4be -> 70b818b1b
[FLINK-4454] always display JobManager address using LeaderRetrievalService
This closes #2406
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/comm
Repository: flink
Updated Branches:
refs/heads/release-1.1 70b818b1b -> b87165deb
[docs] adapt baseURL of documentation
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b87165de
Tree: http://git-wip-us.apache.org/repos/asf/
Repository: flink
Updated Branches:
refs/heads/master 444315a12 -> 259a3a556
http://git-wip-us.apache.org/repos/asf/flink/blob/259a3a55/flink-runtime/src/main/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala
[FLINK-4273] Modify JobClient to attach to running jobs
These changes are required for FLINK-4272 (introduce a JobClient class
for job control). Essentially, we want to be able to re-attach to a
running job and monitor it. It shouldn't make any difference whether we
just submitted the job or we re
Repository: flink
Updated Branches:
refs/heads/master 259a3a556 -> 481091043
[FLINK-3677] FileInputFormat: Allow to specify include/exclude file name
patterns
This closes #2109
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/co
Repository: flink
Updated Branches:
refs/heads/master abb449678 -> b05ea6939
[FLINK-4273] adapt JobRetrievalITCase to lazy classloader reconstruction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b05ea693
Tree: http://gi
Repository: flink
Updated Branches:
refs/heads/master 3505316c6 -> 7a539c05a
[FLINK-3677] Remove Guava dependency from flink-core
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a539c05
Tree: http://git-wip-us.apache.org/
[FLINK-1984] Mesos ResourceManager - T1 milestone (2)
Add license information
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/67be9e07
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/67be9e07
Diff: http://git-wip-us.a
[FLINK-1984] port Mesos code to latest master
- move Scala code to /scala dir
- remove merge commits
- update version
This closes #2315
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/842e3e7d
Tree: http://git-wip-us.apache.
Repository: flink
Updated Branches:
refs/heads/master 578e80e3c -> 842e3e7d1
http://git-wip-us.apache.org/repos/asf/flink/blob/d9b2be05/flink-mesos/src/test/scala/org/apache/flink/runtime/akka/FSMSpec.scala
--
diff --git
a/fli
http://git-wip-us.apache.org/repos/asf/flink/blob/59eeea4c/flink-mesos/src/main/scala/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala
--
diff --git
a/flink-mesos/src/main/scala/org/apache/flink/runtime/cluste
[FLINK-1984] Mesos ResourceManager - T1 milestone
Implemented Mesos AppMaster including:
- runners for AppMaster and TaskManager
- MesosFlinkResourceManager as a Mesos framework
- ZK persistent storage for Mesos tasks
- reusable scheduler actors for:
- offer handling using Netflix Fenzo (LaunchC
[FLINK-1984] Mesos ResourceManager - T1 milestone (4)
- adjust pom.xml per feedback
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38a9534c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/38a9534c
Diff: http://git-wi
http://git-wip-us.apache.org/repos/asf/flink/blob/d9b2be05/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/RegisteredMesosWorkerNode.scala
--
diff --git
a/flink-mesos/src/main/java/org/apache/flink/mesos/
http://git-wip-us.apache.org/repos/asf/flink/blob/d9b2be05/flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/TaskMonitor.scala
--
diff --git
a/flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/TaskMonitor.scala
[FLINK-1984] Mesos ResourceManager - T1 milstone (3)
- Fenzo usage fix - always call scheduleOnce after expireAllLeases.
- increased aggressiveness of task scheduler
- factored YarnJobManager and MesosJobManager to share base class
`ContaineredJobManager`
- improved supervision for task actors, un
[FLINK-4488][yarn] only automatically shutdown clusters for detached jobs
- add check to yarn tests to verify cluster hasn't been shutdown prematurely
This closes #2419
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87114cd
[hotfix] fix Checkstyle error
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6226108e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6226108e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6226108e
Branch:
Repository: flink
Updated Branches:
refs/heads/master 842e3e7d1 -> 6226108e8
[FLINK-4486] detached YarnSession: wait until cluster startup is complete
This closes #2423
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ab1d
[FLINK-4526][yarn] remove redundant proxy messages
This closes #2437
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31c88a56
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31c88a56
Diff: http://git-wip-us.apache.org
[FLINK-4486] detached YarnSession: wait until cluster startup is complete
This closes #2423
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4cdeb118
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4cdeb118
Diff: http:
Repository: flink
Updated Branches:
refs/heads/release-1.1 3cf494a3e -> f7ec1efb3
[FLINK-4488][yarn] only automatically shutdown clusters for detached jobs
- add check to yarn tests to verify cluster hasn't been shutdown prematurely
This closes #2419
Project: http://git-wip-us.apache.org/re
[FLINK-4526][yarn] remove redundant proxy messages
This closes #2437
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7ec1efb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7ec1efb
Diff: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/master e99949a5c -> b13db273c
[hotfix] remove Guava dependency from flink-mesos
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b13db273
Tree: http://git-wip-us.apache.org/rep
Repository: flink
Updated Branches:
refs/heads/master b13db273c -> 96b6359fc
[maven] update checkstyle plugins
- update checkstyle plugin to 2.17
- update scalastyle plugin to 0.8.0
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flin
set baseline for build system
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/5ca5915b
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/5ca5915b
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/5c
Repository: flink-web
Updated Branches:
refs/heads/asf-site 8d02e41db -> 5ca5915be
update build system for docs
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/c718e0de
Tree: http://git-wip-us.apache.org/repos/asf/
[FLINK-4516] leader election of resourcemanager
- add serial rpc service
- add a special rpcService implementation which directly executes the
asynchronous calls serially one by one, it is just for testcase
- Change ResourceManagerLeaderContender code and TestingSerialRpcService code
- override s
Repository: flink
Updated Branches:
refs/heads/flip-6 5d71a552a -> 454bf51b0
[FLINK-4347][cluster management] Implement SlotManager core
This closes #2388
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c4abfd9b
Tree: htt
[FLINK-4363] Implement TaskManager basic startup of all components in java
This closes #2400
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/806f2f14
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/806f2f14
Diff: http
1 - 100 of 868 matches
Mail list logo
