- 14 7月, 2018 6 次提交
-
-
由 Till Rohrmann 提交于
With this commit we can use dynamic properties to overwrite configuration values in the TaskManagerRunner. This closes #6318.
-
由 Till Rohrmann 提交于
With this commit we can use dynamic properties to overwrite configuration values in the ClusterEntrypoint. This closes #6317.
-
由 Till Rohrmann 提交于
This closes #6316.
-
由 Till Rohrmann 提交于
The StandaloneJobClusterEntryPoint is the basic entry point for containers. It is started with the user code jar in its classpath and the classname of the user program. The entrypoint will then load this user program via the classname and execute its main method. This will generate a JobGraph which is then used to start the MiniDispatcher. This closes #6315.
-
由 Till Rohrmann 提交于
The cluster component command line parser is responsible for parsing the common command line arguments with which the cluster components are started. These include the configDir, webui-port and dynamic properties. This closes #6314.
-
由 Till Rohrmann 提交于
-
- 13 7月, 2018 13 次提交
-
-
由 Rune Skou Larsen 提交于
Maintain a deterministic port ordering, so we can have expectations on which endpoint is behind which port index. This closes #6288.
-
由 gyao 提交于
Use the Jepsen framework (https://github.com/jepsen-io/jepsen) to implement tests that verify Flink's HA capabilities under real-world faults, such as sudden TaskManager/JobManager termination, HDFS NameNode unavailability, network partitions, etc. The Flink cluster under test is automatically deployed on YARN (session & job mode) and Mesos. Provide Dockerfiles for local test development. This closes #6240.
-
由 yanghua 提交于
This closes #6129.
-
由 klion26 提交于
This closes #6305.
-
由 Stephan Ewen 提交于
The upgraded ciphers are not yet supported on all platforms and JDK versions, making the getting-started process rough. Instead, we document our recommendation to set these values in the configuration. This reverts "[FLINK-9310] [security] Update standard cipher suites for secure mode"
-
由 zentol 提交于
This closes #6102.
-
由 zentol 提交于
This closes #6274.
-
由 zentol 提交于
This closes #6310.
-
由 zentol 提交于
This closes #6304.
-
由 Deepak Sharnma 提交于
This closes #6170.
-
由 kkloudas 提交于
-
由 Florian Schmidt 提交于
This adds the Java and Scala API for performing an IntervalJoin. In jave this will look like: Example: ```java keyedStream.intervalJoin(otherKeyedStream) .between(Time.milliseconds(-2), Time.milliseconds(2)) // lower and upper bound .upperBoundExclusive(true) // optional .lowerBoundExclusive(true) // optional .process(new IntervalJoinFunction() {...}); ``` This closes #5482.
-
由 Andrey Zagrebin 提交于
This closes #6313.
-
- 12 7月, 2018 10 次提交
-
-
由 Till Rohrmann 提交于
-
由 sihuazhou 提交于
This closes #6306.
-
由 Stefan Richter 提交于
This closes #6308.
-
由 an4828 提交于
This closes #6298.
-
由 Nico Kruber 提交于
If an assertion in the test fails and as a result the cleanup fails, in most tests the original assertion was swallowed making it hard to debug. Furthermore, #testConcurrentRecycleAndRelease2() does even not clean up at all if successful. This closes #6271
-
由 Nico Kruber 提交于
-
由 Nico Kruber 提交于
This closes #6291
-
由 Stephan Ewen 提交于
This feature is currently only exposed on StreamTransformations (internal API) rather than in the public API, because it is a hidden expert feature. This closes #6309
-
由 Till Rohrmann 提交于
In order to avoid race conditions between resource clean up, we now wait for the proper termination of a previously running JobMaster responsible for the same job (e.g. originating from a job recovery or a re-submission). This closes #6279.
-
由 yanghua 提交于
This closes #6277.
-
- 11 7月, 2018 11 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 minwenjun 提交于
Before, a window Trigger would not be invoked if the window is empty at the time of the timer firing. Now the Trigger is always invoked. As a side effect, this resolves FLINK-9687.
-
由 zentol 提交于
This closes #6286.
-
由 zentol 提交于
This closes #6285.
-
由 an4828 提交于
This closes #6295.
-
由 sihuazhou 提交于
This closes #6164.
-
由 lamber-ken 提交于
This closes #6230.
-
由 lamber-ken 提交于
This closes #6247.
-
由 lamber-ken 提交于
This closes #6184.
-
由 zentol 提交于
This closes #6292.
-
由 snuyanzin 提交于
This closes #6263.
-