- 14 7月, 2015 4 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
This closes #633
-
由 Stephan Ewen 提交于
This closes #901
-
由 Fabian Hueske 提交于
This closes #908
-
- 13 7月, 2015 13 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-2235] Fix tests to allow exception in 'EnvironmentInformationTest.getSizeOfFreeHeapMemory()' if Xmx is not set.
-
由 Maximilian Michels 提交于
The Java runtime may return Long.MAX_VALUE for a call to the maxMemory() method of the Runtime class. In these cases, we can get hold of the physical memory size of the operating system by using a proprietary Oracle JDK method. Otherwise, we fail with an explanatory exception. The Oracle JVM defines the max memory to be 1/4 of the physical memory if the user has more than 192 Megabytes which is assumed here. This closes #859
-
由 Till Rohrmann 提交于
[FLINK-2329] [runtime] Introduces InstanceGateway as an abstraction to communicate with the TaskManager. Replaces AkkaUtils.globalExecutionContext with instance dependent ExecutionContext. This closes #893
-
由 Robert Metzger 提交于
This closes #895
-
由 mjsax 提交于
This closes #903
-
由 Stephan Ewen 提交于
-
由 dabaitu 提交于
This closes #854
-
由 Aljoscha Krettek 提交于
Before, it said to call /etc/init.d/ssh restart. This does not work on some systems. There you might need /etc/init.d/sshd restart.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Maximilian Michels 提交于
-
- 12 7月, 2015 2 次提交
-
-
由 Stephan Ewen 提交于
-
由 Shivani 提交于
[FLINK-2141][gelly] Added Test cases for GSAConfiguration setDirection. Made changes in coding style [FLINK-2141][gelly]Removed Example [FLINK-2141][gelly] Corrected Annotation and Gelly guide Minor Changes in Gelly Guide This closes #877
-
- 11 7月, 2015 5 次提交
-
-
由 Gyula Fora 提交于
Closes #900
-
由 mjsax 提交于
additional improvements - added RawOutputFormatter - bug fix in SimpleOutputFormatter - enable default output formatter for StormBoltFileSink Closes #884
-
由 Gábor Hermann 提交于
Closes #872
-
由 Gábor Hermann 提交于
-
由 Gábor Hermann 提交于
-
- 10 7月, 2015 1 次提交
-
-
由 jkirsch 提交于
Fix wrong wget call This closes #897
-
- 09 7月, 2015 15 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[hotfix] [tests] Increase registration timeout for TaskManagers in ProcessFailureCancelingITCase to compensate for sloggy CI environments
-
由 Stephan Ewen 提交于
-
由 Fabian Hueske 提交于
This closes #894
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-2124] [streaming] Handle 'fromElements()' for non-serializable elements. Cleanup code, and add proper tests.
-
由 Johannes Reifferscheid 提交于
This change rewrites the FromElementsFunction to work with arbitrary types. The elements are serialized to a byte array (using a TypeSerializer) when the FromElementsFunction is constructed and deserialized when run is called. This closes #848
-
由 Stephan Ewen 提交于
[FLINK-2331] Whitelist the 'akka.remote.RemoteTransportExceptionNoStackTrace' to be acceptable in YARN logs
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
This closes #886
-
由 Ufuk Celebi 提交于
- FLINK-2288: Setup ZooKeeper for distributed coordination * Add FlinkZooKeeperQuorumPeer to wrap ZooKeeper's quorum peers with utilities to write required config values (default datadir, myid) * Add default conf/zoo.cfg config for ZooKeeper * Add startup scripts for ZooKeeper quorum * Add conf/masters file for HA masters - FLINK-2302: Allow multiple instances to run on single host * Multiple TaskManager and JobManager instances can run on a single host.
-
由 Stephan Ewen 提交于
-