- 20 6月, 2016 3 次提交
-
-
由 Maximilian Michels 提交于
-
由 Stefan Richter 提交于
This closes #2116.
-
由 Stefan Richter 提交于
This closes #2117.
-
- 19 6月, 2016 3 次提交
-
-
由 Fabian Hueske 提交于
This closes #2122
-
由 zentol 提交于
This closes #2119
-
由 Fabian Hueske 提交于
- setOutputType calls are forwarded to wrapped functions. - test added for InternalWindowFucntions. This closes #2118
-
- 17 6月, 2016 13 次提交
-
-
由 Trevor Grant 提交于
This closes #1898.
-
由 Till Rohrmann 提交于
Hardens ZooKeeperElectionTest by allowing the testing listener to return out-dated leader information. This can happen if the ZooKeeper connection was suspended and the new leader information has not been sent to the testing listener. In this case, the testing listener will be queried again to return the actual leader information. Add debug statements to ZooKeeperLeaderElectionTest.testZooKeeperReelection This closes #2103.
-
由 Maximilian Michels 提交于
-
由 Ufuk Celebi 提交于
Trying to prevent failures like [1] from happening again. I could not explain who deleted the savepoint file concurrently with the exists check. The savepoint is triggered and retrieved successfully. Shutting down the cluster does not remove any savepoints. [1] https://s3.amazonaws.com/archive.travis-ci.org/jobs/136396433/log.txt
-
由 kl0u 提交于
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
- integrates with and extends the refactoring of FLINK-3667 - enables to resume from Yarn properties or Yarn application id - introduces additional StandaloneClusterDescriptor - introduces DefaultCLI to get rid of standalone mode switches in CliFrontend - various fixes and improvements - remove legacy code from CliFrontend - change activation code of CustomCommandLine interface - use checked exceptions to signal supported operations - remove all checked exceptions of type Exception - fix logging and reduce verbosity of per-job clusters - print 'id' argument in YarnSessionCli - minor renaming of methods names - improve documentation - deprecate streaming option - extend CliFrontendYarnAddressConfigurationTest - move loading of custom CLIs to CliFrontend This closes #2085
-
由 Sebastian Klemke 提交于
- enables to use list, savepoint, cancel and stop subcommands - adapt FlinkYarnSessionCli to also accept YARN application Id to attach to - update documentation This closes #2034
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
- ClusterDescriptor: base interface for cluster deployment descriptors - ClusterDescriptor: YarnClusterDescriptor - ClusterClient: base class for ClusterClients, handles lifecycle of cluster - ClusterClient: shares configuration with the implementations - ClusterClient: StandaloneClusterClient, YarnClusterClient - ClusterClient: remove run methods and enable detached mode via flag - CliFrontend: remove all Yarn specific logic - CliFrontend: remove all cluster setup logic - CustomCommandLine: interface for other cluster implementations - Customcommandline: enables creation of new cluster or resuming from existing - Yarn: move Yarn classes and functionality to the yarn module (yarn properties, yarn interfaces) - Yarn: improve reliability of cluster startup - Yarn Tests: only disable parallel execution of ITCases This closes #1978
-
由 Fabian Hueske 提交于
This closes #2107
-
由 Fabian Hueske 提交于
This closes #2104
-
由 Vasudevan 提交于
This closes #1856
-
- 16 6月, 2016 8 次提交
-
-
由 zentol 提交于
This closes #1771
-
由 Andrea Sella 提交于
-
由 zentol 提交于
-
由 Till Rohrmann 提交于
Introduce timeout handling flag for the NFACompiler Expose timeout handling via Java API Update documentation of PatternStream and CEP Introduce timeout select function to CEP Scala API Add select and flatSelect with timeout support to CEP Scala API Add test cases for timeout handling Update documentation Fix CEP Scala API completeness test This closes #2041.
-
由 zentol 提交于
currentLowWatermark lastCheckpointSize numBytes(In/Out)(Local/Remote) numRecords(In/Out) numSplitsProcessed (Batch only) This closes #2090
-
由 Aljoscha Krettek 提交于
-
由 kl0u 提交于
This closes #2100
-
由 Flavio Pompermaier 提交于
This closes #2007
-
- 15 6月, 2016 7 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 zentol 提交于
This closes #2084
-
由 zentol 提交于
This closes #2091
-
由 Maximilian Michels 提交于
The ScalaShellITCase sometimes gets stuck before test execution with no output in the logs. We ran about a hundred builds against Surefire 2.18.1 which confirmed that the failures don't occur with this version. Waiting for an upstream fix until this can be reverted. This closes #2101
-
由 smarthi 提交于
This closes #2099
-
由 kl0u 提交于
This commit is a combination of several commits/changes. It combines changes to the file input formats and the streaming file read operator and integrates them into the API. These are the messages of the other two commits: [FLINK-3717] Make FileInputFormat checkpointable This adds a new interface called CheckpointableInputFormat which describes input formats whose state is queryable, i.e. getCurrentState() returns where the reader is in the underlying source, and they can resume reading from a user-specified position. This functionality is not yet leveraged by current readers. [FLINK-3889] Refactor File Monitoring Source This is meant to replace the different file reading sources in Flink streaming. Now there is one monitoring source with DOP 1 monitoring a directory and assigning input split to downstream readers. In addition, it makes the new features added by FLINK-3717 work together with the aforementioned entities (the monitor and the readers) in order to have fault tolerant file sources and exactly once guarantees. This does not replace the old API calls. This will be done in a future commit.
-
由 kl0u 提交于
It adds a method failExternally() to the StreamTask, so that custom Operators can make their containing task fail when needed.
-
- 14 6月, 2016 2 次提交
-
-
由 gallenvara 提交于
This closes #2049
-
由 Fabian Hueske 提交于
[revert] [FLINK-3944] [tableAPI] Reverts "Add rewrite rules to reorder Cartesian products and joins." This reverts commit 85793a25. Added rewrite rules blow up search space which cannot be effectively pruned without cardinality estimates. This closes #2098
-
- 11 6月, 2016 1 次提交
-
-
由 Fabian Hueske 提交于
These rules are necessary to resolve join orders that initially contain Cartesian products due to the order in which base relations are added in the FROM clause (SQL) or joined (Table API). This closes #2044
-
- 10 6月, 2016 3 次提交
-
-
由 Stephan Ewen 提交于
[hotfix] [core] Make sure Dropwizard reporters do not block operator creation/teardown while reporting The "report()" method used to hold the same lock that was needed to create and shutdown metrics. Holding that lock too long could delay operator creation and teardown. This also removes the no longer needed dependency on dropwizard in flink-core.
-
由 zentol 提交于
-
由 omaralvarez 提交于
This closes #2063
-