Repository: flink
Updated Branches:
refs/heads/master 63720634e - 4046819b3
http://git-wip-us.apache.org/repos/asf/flink/blob/4046819b/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamJoinOperator.scala
[FLINK-1481] Fixes flakey JobManagerITCase which relied on non-deterministic
behaviour.
This closes #365.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ccd1fd5
Tree:
Repository: flink
Updated Branches:
refs/heads/master 140faa945 - 0ccd1fd5b
[runtime] Enables remote communication for local standalone cluster mode which
is required by the JobClient.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 82cda12ef - 90834ca70
[FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to
log level WARNING.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 1e9b68164 - bec9c4dae
[runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bec9c4da
Tree:
[FLINK-1556] [runtime] Corrects faulty JobClient behaviour in case of a
submission failure
Fixes unhandled FailsIntermediateResultPartitions message. Changes
JobResultFailed and JobResultCanceled to send the cause as a throwable instead
of a string.
Fixes NullPointerException if an execution
Repository: flink
Updated Branches:
refs/heads/master c1e326707 - ac7bf4279
[FLINK-1549] [yarn] Adds proper exception handling to YarnJobManager
This closes #397.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/447ce0aa
[avro] Cleaning up project structure
Updates .gitignore to ignore generated files
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90ab2bb4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90ab2bb4
Diff:
Repository: flink
Updated Branches:
refs/heads/release-0.8 10f89c73b - 90ab2bb4b
[FLINK-1531] [runtime] Adds proper EOFException forwarding to KryoSerializer.
Conflicts:
flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoGenericTypeSerializerTest.java
Project:
[FLINK-1533] [runtime] Fixes NPE in the scheduler where the allocated shared
slots are not properly checked.
This closes #388.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc1432a2
Tree:
Repository: flink
Updated Branches:
refs/heads/master 5c8b0ba79 - 36b762e43
[gelly-tests] Fixes DegreesWithExceptionITCase to check expected exceptions
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36b762e4
Tree:
[FLINK-1695] [ml] Initial commit to establish module structure. Adds simple
Vector and Matrix types.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf492be9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf492be9
[FLINK-1697] [ml] Adds web documentation for alternating least squares. Adds
web documentation for polynomial base feature mapper.
[ml] Adds comments
[ml] Set degree of parallelism of test suites to 2
[ml] Replaces FlatSpec tests with JUnit integration test cases in order to
suppress the
[FLINK-1696] [ml] Adds batch gradient descent linear regression with l2 norm
[ml] Adds batch gradient descent linear regression with convergence criterion
as relative change in sum of squared residuals
[ml] Adds comments to MultipleLinearRegression
Project:
[ml] Introduces FlinkTools containing persist methods.
[ml] Changes comments into proper ScalaDoc in MultipleLinearRegression
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86485434
Tree:
Repository: flink
Updated Branches:
refs/heads/master 8b3cbb525 - de45c06f1
[docs] Adds akka configuration description
This closes #527.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de45c06f
Tree:
[FLINK-1718] [ml] Unifies existing test cases
This closes #539.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d2e2d79f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d2e2d79f
Diff:
Repository: flink
Updated Branches:
refs/heads/master c63580244 - d2e2d79fc
[ml] Adds convenience functions for Breeze matrix/vector conversion
[ml] Adds breeze to flink-dist LICENSE file
[ml] Optimizes sanity checks in vector/matrix accessors
[ml] Fixes scala check style error with missing
[FLINK-1718] [ml] Adds sparse matrix and sparse vector types
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9219af7b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9219af7b
Diff:
Author: trohrmann
Date: Fri Mar 27 09:40:39 2015
New Revision: 1669535
URL: http://svn.apache.org/r1669535
Log:
Adds machine learning slides to website
Modified:
flink/material.md
flink/site/blog/feed.xml
flink/site/material.html
Modified: flink/material.md
URL:
http
Repository: flink
Updated Branches:
refs/heads/master c0b297573 - b8aa49ce7
[FLINK-1794] [test-utils] Adds test base for scala tests and adapts existing
flink-ml tests
[FLINK-1794] [test-utils] Adds scala docs to FlinkTestBase
This closes #540.
Project:
Repository: flink
Updated Branches:
refs/heads/master cbc8423e2 - 015af177d
[FLINK-1717] [ml] Adds support to directly read libSVM and SVMLight files
This closes #543.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master a201b3011 - 84c11e690
[scala api] Moves TraversableType behind the CaseClassType in the TypeAnalyzer
priority
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/84c11e69
Repository: flink
Updated Branches:
refs/heads/master 7abed950d - 0ae0cba31
[scala-api] Corrects type cast in Scala API's DataSet.collect method and adds
test cases for that
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master c032725d3 - 9de47e7c4
[docs] Fixes jekyll's config to bind to localhost
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9de47e7c
Tree:
Repository: flink
Updated Branches:
refs/heads/master e83d1ec10 - 80dd85900
[docs] Fixes Java broadcast variable example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80dd8590
Tree:
Repository: flink
Updated Branches:
refs/heads/master 64607433d - b0df4f4d9
[docs] [ml] Fixes wrong ALS example code
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0df4f4d
Tree:
Repository: flink
Updated Branches:
refs/heads/master 844d5e2c4 - 9a18e5790
[yarn] [python] Adds -Xms start option for yarn, fixes python test case to
overwrite files, fixes python docs
Fixes failing yarn test cases
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/844d5e2c/docs/setup/config.md
--
diff --git a/docs/setup/config.md b/docs/setup/config.md
index 2fb3546..afc8631 100644
--- a/docs/setup/config.md
+++ b/docs/setup/config.md
@@
[docs] Moves slots_parallelism.svg to correct directory
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/844d5e2c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/844d5e2c
Diff:
Repository: flink
Updated Branches:
refs/heads/master 912edbca1 - bdd842961
[ml] Adds proper log properties file setting for scalatest plugin
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bdd84296
Tree:
[scala] Introduces trait type to TypeAnalyzer which avoids compiler warnings
due to misclassification as a pojo type
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0b45c45
Tree:
[FLINK-1933] [ml] Adds distance metrics and documentation to machine learning
library
[ml] [docs] Add a overview documentation for Distance Metrics
[FLINK-1933] [ml] Moves metrics.distances package to org.apache.flink.ml
This closes #629.
Project:
Repository: flink
Updated Branches:
refs/heads/master 689240315 - ddb2b3470
[FLINK-1937] [ml] Fixes sparse vector/matrix creation fromCOO with a single
element
This closes #636.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master ea710204e - 32a04e42d
[docs] Corrects combineGroup documentation example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/32a04e42
Tree:
Repository: flink
Updated Branches:
refs/heads/master 5dd42c1ab - 4343e448c
[dist] Excludes the empty *-tests.jar from being copied to the
flink-dist/../examples directory
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master e0d60ddbd - 97611c245
[FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package,
test for the for the corresponding functionality and documentation.
This closes #798.
Project:
[ml] Makes StandardScalers state package private and reduce redundant code.
Adjusts flink-ml readme.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/97611c24
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/97611c24
Repository: flink
Updated Branches:
refs/heads/release-0.9 ee7c41738 - 80cf2c544
[FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package,
test for the for the corresponding functionality and documentation.
This closes #798.
Project:
[ml] Makes StandardScalers state package private and reduce redundant code.
Adjusts flink-ml readme.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80cf2c54
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/80cf2c54
Repository: flink
Updated Branches:
refs/heads/master 1481647d5 - d81f4cf92
[FLINK-2194] [type extractor] Excludes Writable type from
WritableTypeInformation to be treated as an interface
This closes #814.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 7a7a29403 - bc3684e69
[FLINK-2278] [ml] Fixes wrong Breeze sparse vector to Flink sparse vector
conversion
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc3684e6
[FLINK-2214] [ml] Fixes prediction join operation and empirical risk join
operation of ALS by giving join hint
This closes #844.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38ee125e
Tree:
Repository: flink
Updated Branches:
refs/heads/master 7f3108d37 - 63b8c3647
[FLINK-2072] [ml] Adds quickstart guide
This closes #792.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/63b8c364
Tree:
Repository: flink
Updated Branches:
refs/heads/master d38154129 - 5374ba97c
[FLINK-2225] [scheduler] Excludes static code paths from co-location constraint
to avoid scheduling problems
This closes #843.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[legal] Updates LICENSE/NOTICE file of source and binary distribution
This closes #830.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a9782af
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6a9782af
Diff:
Repository: flink
Updated Branches:
refs/heads/release-0.9 0a8142a99 - 6a9782afe
[FLINK-2225] [scheduler] Excludes static code paths from co-location constraint
to avoid scheduling problems
This closes #843.
Conflicts:
Repository: flink
Updated Branches:
refs/heads/master 3e860e7fd - d1d2ccc63
[2104] [ml] Hotfix for wrong class name after renaming
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1d2ccc6
Tree:
Repository: flink
Updated Branches:
refs/heads/master 63edeca85 - c77947e94
[FLINK-2073] [ml] [docs] Adds contribution guide. Adds links to FlinkML main
site.
Adds html titles. Adds explicit operation section to all operators.
This closes #727.
Project:
Repository: flink
Updated Branches:
refs/heads/master 96bbdbd70 - c81256bd2
[ml] [docs] Fixes broken back links
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c81256bd
Tree:
Repository: flink
Updated Branches:
refs/heads/master 41181603d - 995f8f969
[FLINK-2047] [ml] Renaming CoCoA to SVM
This closes #733.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/995f8f96
Tree:
Repository: flink
Updated Branches:
refs/heads/master 995f8f969 - d951f1120
[ml] [docs] Replaces remaining CoCoA names by SVM
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d951f112
Tree:
Repository: flink
Updated Branches:
refs/heads/master d951f1120 - 3e860e7fd
[FLINK-2104] [ml] Fixes problem with type inference for fallback implicits
where Nothing is not correctly treated (see SI-1570)
This closes #741.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 7571959a1 - d163a817f
[FLINK-2102] [ml] Add predict function for labeled data for SVM and MLR.
These functions return for each example in the input DataSet[LabeledVector] a
pair (truth, prediction)
Added documentation for new predict
[ml] Replaces RichMapFunctions with mapWithBcVariable in FlinkML
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/950b79c5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/950b79c5
Diff:
Repository: flink
Updated Branches:
refs/heads/master d163a817f - 950b79c59
[ml] Adds syntactic sugar for map with single broadcast element. Rewrites the
optimization framework to to consolidate the loss function.
Adds closure cleaner to convenience functions on RichDataSet
Removing
Repository: flink
Updated Branches:
refs/heads/master 950b79c59 - 90c0142ef
[ml] Fixes implicit issue with BreezeVectorConverter
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90c0142e
Tree:
[FLINK-2297] [ml] Adds threshold setting for SVM binary predictions.
Added Threshold option for SVM, to determine which predictions are
positive/negative.
Added parameter to determine output of prediction function.
Determines whether we output raw distances to the boundary
or binary class
Repository: flink
Updated Branches:
refs/heads/master a137321ac - eb23f8074
[FLINK-2272] [ml] Removed roadmap and vision from docs, added link to them in
the wiki.
This closes #864.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/1e574750/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
--
diff --git
[FLINK-2034] [ml] [docs] Adds FlinkML web documentation (introduction, vision,
roadmap)
Also added attribution for some of the Latex in optimization framework.
This closes #688.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/1e574750/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/TPCHQuery3WithUnionITCase.java
--
diff --git
[FLINK-2050] [ml] Introduces new pipelining mechanism using implicit classes to
wrap the algorithm logic
This closes #704.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fde0341f
Tree:
Repository: flink
Updated Branches:
refs/heads/master 35ea6505c - 1e574750d
[FLINK-1992] [ml] Adds convergence criterion to Flink's SGD algorithm
Added test case for convergence
This closes #692.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/1e574750/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/experimental/Transformer.scala
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master 44c247bda - 48e2cb5e8
[FLINK-2056] [ml] [docs] Addes docs for ML pipelines
This closes #714.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/48e2cb5e
Tree:
Repository: flink
Updated Branches:
refs/heads/master a1d2df614 - ae446388b
[FLINK-2053] [ml] Adds automatic type registration of flink-ml types. Adds
de-duplication of registered types at ExecutionConfig. Fixes bug in Breeze
SparseVector to Flink SparseVector conversion.
This closes #723.
Repository: flink
Updated Branches:
refs/heads/master f78339faa - b015a32f6
[FLINK-2083] [ml] [docs] Improves FlinkML documentation
Added tables for parameter values
Adds links to optimization parameter values in the description
This closes #715.
Project:
Repository: flink
Updated Branches:
refs/heads/master 8602b7af0 - baaa3daca
[tests] Replaces Scala mixins for the Job/TaskManager with classes which extend
the respective classes. Adds proper logger registration for sub-classes of
FlinkUntypedActor.
Project:
Repository: flink
Updated Branches:
refs/heads/master 58421b848 - c9cfb17cb
[FLINK-1901] [core] Create sample operator for Dataset.
[FLINK-1901] [core] enable sample with fixed size on the whole dataset.
[FLINK-1901] [core] add more comments for RandomSamplerTest.
[FLINK-1901] [core]
Repository: flink
Updated Branches:
refs/heads/master bb5e61d24 - 77b747158
[docs] Fixes broken link in FlinkML docs
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77b74715
Tree:
Repository: flink
Updated Branches:
refs/heads/master 416ff589e - fab61a195
[FLINK-2409] [webserver] Replaces ActorRefs with ActorGateways in the web
server to automatically decorate messages with a leader session ID.
Refactored MiniCluster to also store a reference to the web server to stop
Repository: flink
Updated Branches:
refs/heads/master b19e5e3bb - 4ce9475cd
[travis tools] Adds $HOME/bin/artifacts to $PATH of watchdog script
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ce9475c
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/test/java/org/apache/flink/runtime/instance/InstanceManagerTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master fa78be6df - 45428
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterActor.scala
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master 0c538915b - 4473db64c
[docs] Fixes broken links on the setup_quickstart.html site
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4473db64
Tree:
Repository: flink
Updated Branches:
refs/heads/master f33f33206 -> 90b7a9eb9
[docs] Fix typos in streaming documentation
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90b7a9eb
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/src/main/resources/web/fonts/fontawesome-webfont.eot
--
diff --git
a/flink-runtime-web/src/main/resources/web/fonts/fontawesome-webfont.eot
[FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in
ZooKeeperStateHandleStore
The old StateHandleProvider used in ZooKeeperStateHandleStore had to be
replaced because the state backend implementation has changed. Since the new
state backend could not be used
[FLINK-2804] [runtime] Add blocking job submission support for HA
The JobClientActor is now repsonsible for receiving the JobStatus updates from
a newly elected leader. It uses the LeaderRetrievalService to be notified about
new leaders. The actor can only be used to submit a single job to the
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/util/TwoInputStreamOperatorTestHarness.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/src/main/resources/web/js/index.js.orig
--
diff --git a/flink-runtime-web/src/main/resources/web/js/index.js.orig
[FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode
Squashes:
5a88d5e [tests] Add HttpTestClient for testing HTTP responses
656d6d6 Split WebMonitor and LeaderRetrievalService start up
a7e8da8 Move generated /web files to src/main/resources
Add comment to webMonitorPort
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf
--
diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html
--
diff --git
a/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/src/main/resources/web/js/index.js
--
diff --git a/flink-runtime-web/src/main/resources/web/js/index.js
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html
--
diff --git
a/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/web-dashboard/web/js/vendor.js
--
diff --git a/flink-runtime-web/web-dashboard/web/js/vendor.js
b/flink-runtime-web/web-dashboard/web/js/vendor.js
http://git-wip-us.apache.org/repos/asf/flink/blob/73c73e92/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/web-dashboard/web/css/vendor.css
--
diff --git a/flink-runtime-web/web-dashboard/web/css/vendor.css
b/flink-runtime-web/web-dashboard/web/css/vendor.css
[FLINK-2354] [runtime] Remove state changing futures in JobManager
Internal actor states must only be modified within the actor thread.
This avoids all the well-known issues coming with concurrency.
Fix RemoveCachedJob by introducing RemoveJob
Fix JobManagerITCase
Add removeJob which maintains
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf
--
diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/73c73e92/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskCancelTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/web-dashboard/web/partials/jobmanager/config.html
--
diff --git
a/flink-runtime-web/web-dashboard/web/partials/jobmanager/config.html
[FLINK-2805] [blobmanager] Write JARs to file state backend for recovery
Move StateBackend enum to top level and org.apache.flink.runtime.state
Abstract blob store in blob server for recovery
This closes #1227.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/web-dashboard/web/js/vendor.js
--
diff --git a/flink-runtime-web/web-dashboard/web/js/vendor.js
b/flink-runtime-web/web-dashboard/web/js/vendor.js
new
1 - 100 of 4810 matches
Mail list logo