- 25 9月, 2017 2 次提交
-
-
由 Aljoscha Krettek 提交于
Recently, the aligned window operators were removes, these classes where leftover after that removal.
-
由 Bowen Li 提交于
-
- 24 9月, 2017 1 次提交
-
-
由 Aljoscha Krettek 提交于
-
- 23 9月, 2017 1 次提交
-
-
由 Fabian Hueske 提交于
[FLINK-7656] [runtime] Switch to user classloader before calling initializeOnMaster and finalizeOnMaster. This closes #4690.
-
- 22 9月, 2017 5 次提交
-
-
由 desktop 提交于
This closes #4685.
-
由 Bowen Li 提交于
The updateCredentials delay is an ignorable warning that occurs due to the fact that the default credential update delay is longer than the await termination timeout when shutting down KPL. See https://github.com/awslabs/amazon-kinesis-producer/issues/10 for details. This closes #4657.
-
由 Bowen Li 提交于
KinesisProducerLibrary (KPL) 0.10.x had been using a One-New-Thread-Per-Request model for all requests sent to AWS Kinesis, which is very expensive. 0.12.4 introduced a new ThreadingMode - Pooled, which will use a thread pool. This hugely improves KPL's performance and reduces consumed resources. By default, KPL still uses per-request mode. We should explicitly switch FlinkKinesisProducer's KPL threading mode to 'Pooled'. This closes #4656.
-
由 Mikhail Lipkovich 提交于
-
由 Till Rohrmann 提交于
This commit changes the fencing behaviour such that a component which is not the leader will set its fencing token to null. This distinction allows to throw different exceptions depending on whether it is a token mismatch or whether the receiver has no fencing token set (== not being the leader). This closes #4689.
-
- 21 9月, 2017 7 次提交
-
-
由 Aljoscha Krettek 提交于
This also adds an end-to-end test that verifies correct order for both classes and resources.
-
由 Fabian Hueske 提交于
This closes #4635.
-
由 yew1eb 提交于
This closes #4692.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Till Rohrmann 提交于
Similar to a registration error we should also delay the retrying registration in case of connection error which could happen if the remote endpoint has not been started yet. This closes #4686.
-
由 Till Rohrmann 提交于
Lets DashboardConfigHandler implement the LegacyRestHandler. Moreover, this commit defines the appropriate DashboardConfigurationHeaders. The DispatcherRestEndpoint registers the DashboardConfigHandler. This closes #4604.
-
- 20 9月, 2017 10 次提交
-
-
由 Till Rohrmann 提交于
Introduce LegacyRestHandler interface which the old REST handler have to implement in order to make them usable for the RestServerEndpoint in combination with the LegacyRestHandlerAdapter. The LegacyRestHandlerAdapter extends the AbstractRestHandler and runs the LegacyRestHandler implementation. As an example, this commit ports the ClusterOverviewHandler to the new interface. The Dispatcher side still has to be properly implemented. This closes #4603.
-
由 Till Rohrmann 提交于
Adds the StaticFileContentHandler to the DispatcherRestEndpoint if the flink-runtime-web dependency is in the classpath. In order to setup the respective channel handler, this commit introduces the setupChannelHandlers method to the RestServerEndpoint. Refactor RestServerEndpoint#initializeHandler to support StaticFileServerHandler registration This closes #4601.
-
由 lincoln-lil 提交于
This closes #3829.
-
由 Rong Rong 提交于
This closes #4521.
-
由 Mikhail Lipkovich 提交于
This closes #4630.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Move metrics handlers under o.a.f.runtime.webmonitor.handlers Move StaticFileServerHandler under o.a.f.runtime.webmonitor.files This closes #4600.
-
由 Till Rohrmann 提交于
With this change, the complete REST address (protocol://hostname:port) is retrieved from the RestfulGateway. That way we decouple the RestHandlers from the underlying RestServerEndpoint/WebRuntimeMonitor because they no longer have to know whether HTTPs is enabled or not. This closes #4599.
-
由 Till Rohrmann 提交于
This commit creates the DispatcherRestEndpoint and integrates it with the Dispatcher. The DispatcherRestEndpoint is created in the SessionClusterEntrypoint and its address is passed to the Dispatcher such that it can answer the requestRestAddress RPC. This closes #4598.
-
由 Till Rohrmann 提交于
By letting the AbstractRestHandler extend the RedirectHandler, we add redirection capabilities to the AbstractRestHandler. This closes #4597.
-
- 19 9月, 2017 10 次提交
-
-
由 Tony Wei 提交于
-
由 Bowen Li 提交于
This closes #4662.
-
由 yew1eb 提交于
This closes #4677.
-
由 Bowen Li 提交于
This closes #4663.
-
由 Nico Kruber 提交于
This fixes the netty check and makes all of them more robust against failures of the executed commands counting the number of dependencies. This closes #4653.
-
由 zentol 提交于
This closes #4646.
-
由 zentol 提交于
This closes #4644.
-
由 Till Rohrmann 提交于
The TaskExecutorITCase does not wait for the leader election to have finished before sending remote messages to the ResourceManager. Waiting on the completion fixed the test instability.
-
由 Till Rohrmann 提交于
The LeaderGatewayRetriever implementations, AkkaJobManagerRetriever and the RpcGatewayRetriever, now automatically retry the gateway retrieval operation for a fixed number of times with a retry delay before completing the gateway future with an exception. Retry AkkaJobManagerRetriever Retry RpcGatewayRetriever Add support for fenced components This closes #4643.
-
由 Till Rohrmann 提交于
Add test case Only log LeaderGatewayRetriever exception on Debug log level Properly fail outdated gateway retrieval operations This closes #4602.
-
- 18 9月, 2017 4 次提交
-
-
由 Till Rohrmann 提交于
Introduce RedirectHandler which can be extended to add redirection functionality to all SimpleInboundChannelHandlers. This allows to share the same functionality across the StaticFileServerHandler and the RuntimeMonitorHandlerBase which could now be removed. In the future, the AbstractRestHandler will also extend the RedirectHandler. This closes #4551.
-
由 Till Rohrmann 提交于
Introduce a generalized GatewayRetriever replacing the JobManagerRetriever. The GatewayRetriever fulfills the same purpose as the JobManagerRetriever with the ability to retrieve the gateway for an arbitrary endpoint type. This closes #4549.
-
由 Yestin 提交于
This closes #4673
-
由 Yestin 提交于
This closes #4632
-