- 18 3月, 2017 4 次提交
-
-
由 Aljoscha Krettek 提交于
Before, it was set on the ExecutionConfig for some stream execution environments and later for others. Now, we don't set the default parallelism on the ExecutionConfig but instead set it at the latest possible point, in the StreamingJobGraphGenerator. This also adds tests that verify that we don't set the default parallelism on the ExecutionConfig.
-
由 Stefan Richter 提交于
-
由 Till Rohrmann 提交于
The HeartbeatServices are used to create all services relevant for heartbeating. This includes at the moment the creation of HeartbeatManager implementations which actively send heartbeats and those which only respond to heartbeat requests. Add comments
-
由 淘江 提交于
This closes #3151.
-
- 17 3月, 2017 10 次提交
-
-
由 kl0u 提交于
-
由 kl0u 提交于
-
由 Till Rohrmann 提交于
Remove start method from HeartbeatManager This closes #3555.
-
由 Stefan Richter 提交于
-
由 WangTaoTheTonic 提交于
This closes #3486
-
由 Kurt Young 提交于
This closes #3520. fix compilation failure fix compilation failure again. 1. Deep copy TableSource when we copy TableSourceScan 2. unify push project into scan rule for both batch and stream address comments. expand project list before creating new RexProgram update tests
-
由 tonycox 提交于
fix filterable test rebase and trying fix rexnode parsing create wrapper and update rules
-
由 Stefan Richter 提交于
-
由 zentol 提交于
- added missing serialVersionUID - PythonPlan* classes no longer implement serializable - marked several fields as transient - replaced some fields by local variables - input/output files are now being deleted - remvoed some unnecessary casts - renamved several ignored exceptions - close socket in PythonPlanStreamer - simplified PyProcess health check - eliminated several uses of raw types - removed some unthrown exception declarations
-
由 zentol 提交于
-
- 16 3月, 2017 16 次提交
-
-
由 liuyuzhong7 提交于
This close #3532
-
由 Greg Hogan 提交于
This is likely only used by Gelly and we have a more featureful implementation allowing for multiple outputs and setting the job name. Deprecation will allow this to be removed in Flink 2.0. This closes #3516
-
由 淘江 提交于
This closes #3455
-
由 Stephan Ewen 提交于
-
由 Tony Wei 提交于
This closes #3374
-
由 Jin Mingjian 提交于
This closes #3384
-
由 Stephan Ewen 提交于
This closes #3548
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Jin Mingjian 提交于
This closes #3373
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
-
由 kl0u 提交于
The CEP operator now cleans the registered state for a key. This happens: 1) for the priority queue, when the queue is empty. 2) for the NFA, when its shared buffer is empty. 3) finally the key is removed from the watermark callback service if both the above are empty.
-
由 Nico Kruber 提交于
The hostname used for the BlobServer was set to the akka address which is invalid for this use. Instead, this adds the hostname to the RpcGateway / AkkaInvocationHandler so that this information is available to the TaskExecutor. This closes #3551.
-
由 金竹 提交于
-
由 Joshua Griffith 提交于
This closes #3538.
-
- 15 3月, 2017 10 次提交
-
-
由 kl0u 提交于
-
由 Stefan Richter 提交于
[FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...)
-
由 Stefan Richter 提交于
[FLINK-6061] [state backends] Throw IllegalStateException when using RocksDB keyed state with no key set
-
由 Aljoscha Krettek 提交于
-
由 Patrick Lucas 提交于
docker-entrypoint.sh should error on invalid args Improve docker build.sh cleanup Dockerfile improvements per review Remove unnecessary Dockerfile build steps Now that docker-entrypoint.sh uses 'start-foreground', munging flink-daemon.sh and overwriting the log4j config are not longer necessary. Improve Dockerfile and docker-entrypoint.sh Clean up Dockerfile and improve docker-entrypoint.sh to support '--help' and pass through non-(jobmanager|taskmanager) commands. This closes #3205. This closes #3494.
-
由 Jamie Grier 提交于
Modifying Dockerfile to build from local flink-dist as well as release URLs. Logging to stdout. Adding scripts to deploy seamlessly on Docker Swarm. Updating Docker Compose scripts to work correctly. Parameterizing things so these Docker scripts are more generally useful.
-
由 Till Rohrmann 提交于
-
由 Zhuoluo Yang 提交于
This closes #3530.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #3527.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #3528.
-