Github user skidder closed the pull request at:
https://github.com/apache/flink/pull/5810
---
GitHub user skidder opened a pull request:
https://github.com/apache/flink/pull/5810
[FLINK-9127] [Core] Filesystem State Backend logged incorrectly
## What is the purpose of the change
This pull-request fixes a message logged when during startup of the Flink
Task-Manager
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/4214
Sorry for not responding sooner! Thank you @StephanEwen and @tillrohrmann
for applying this fix!
---
GitHub user skidder opened a pull request:
https://github.com/apache/flink/pull/4214
[FLINK-7021]
Fixes issue FLINK-7021 by adding an `UnhandledErrorListener` implementation
to the Task Manager that will shutdown the Task Manager if an unretryable
exception is raised while
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/3458
@tzulitai I was able to scale up the number of shards on a Kinesis stream
without any interruption in processing. Looks good!
# Configuration
## Flink Cluster
Single Job Manager
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/3078
Thank you @tzulitai for the feedback on the styling! I've pushed a commit
that addresses your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/3078
Thanks @tzulitai , great feedback!
The `ProvisionedThroughputExceededException` exception will be reported
with an HTTP 400 response status code:
http://docs.aws.amazon.com/kinesis
GitHub user skidder opened a pull request:
https://github.com/apache/flink/pull/3078
[FLINK-5355] Handle AmazonKinesisException gracefully in Kinesis Streaming
Connector
My Flink job that consumes from a Kinesis stream must be restarted at least
once daily due to an uncaught
GitHub user skidder opened a pull request:
https://github.com/apache/flink/pull/2501
[FLINK-4622] CLI help message should include 'savepoint' action
The Flink CLI help message should include the 'savepoint' action in the
list of available actions. It currently looks like
Github user skidder commented on a diff in the pull request:
https://github.com/apache/flink/pull/2227#discussion_r70458869
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -299,3 +299,41 @@ Otherwise, the returned stream name is used.
Other optional configuration
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/2227
@tzulitai definitely, I'll add an explanation of the config setting in the
docs shortly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/2227
Thanks for the comment, @tzulitai !
I have not had any problems with testing Flink against a local Kinesalite
instance where the Region (required by Flink) is set to `us-east-1
GitHub user skidder opened a pull request:
https://github.com/apache/flink/pull/2227
[FLINK-4197] Allow Kinesis endpoint to be overridden via config
I perform local testing of my application stack with Flink configured as a
consumer on a Kinesis stream provided by Kinesalite
13 matches
Mail list logo
