clear query| facets| time Search criteria: .   Results from 1 to 10 from 707 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-4582] Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams - Flink - [issue]
...AWS DynamoDB is a NoSQL database service that has a CDC-like (change data capture) feature called DynamoDB Streams (http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.ht...
http://issues.apache.org/jira/browse/FLINK-4582    Author: Tzu-Li , 2018-09-18, 18:43
[FLINK-9377] Remove writing serializers as part of the checkpoint meta information - Flink - [issue]
...When writing meta information of a state in savepoints, we currently write both the state serializer as well as the state serializer's configuration snapshot.Writing both is actually redunda...
http://issues.apache.org/jira/browse/FLINK-9377    Author: Tzu-Li , 2018-09-18, 08:05
[FLINK-9376] Allow upgrading to incompatible state serializers (state schema evolution) - Flink - [issue]
...Currently, users have access to upgrade state serializers on the restore run of a stateful job, as long as the upgraded new serializer remains backwards compatible with all previous written ...
http://issues.apache.org/jira/browse/FLINK-9376    Author: Tzu-Li , 2018-09-18, 08:04
[FLINK-8418] Kafka08ITCase.testStartFromLatestOffsets() times out on Travis - Flink - [issue]
...Instance: https://travis-ci.org/kl0u/flink/builds/327733085...
http://issues.apache.org/jira/browse/FLINK-8418    Author: Tzu-Li , 2018-09-15, 21:29
[FLINK-8410] Kafka consumer's commitedOffsets gauge metric is prematurely set - Flink - [issue]
...The committedOffset metric gauge value is set too early. It is set here:https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/...
http://issues.apache.org/jira/browse/FLINK-8410    Author: Tzu-Li , 2018-09-15, 21:21
Could you please assign issue-10002 to me? - Flink - [mail # dev]
...Hi,You are now assigned to the JIRA. You can now also assign tickets to yourself in the future.Cheers,GordonOn 11 September 2018 at 10:02:06 AM, Xinyu Zhang ([EMAIL PROTECTED]) wrote:Hi I ha...
   Author: Tzu-Li , 2018-09-11, 04:23
Why FlinkKafkaConsumer doesn't subscribe to topics? - Flink - [mail # user]
...Hi Julio,As Renjie had already mentioned, to achieve exactly-once semantics with the Kafka consumer, Flink needs to have control over the Kafka partition to source subtask assignment.To add ...
   Author: Tzu-Li , 2018-09-04, 15:43
[FLINK-9885] End-to-end test: Elasticsearch 6.x connector - Flink - [issue]
...We have decided to try and merge the pending Elasticsearch 6.x PRs. This should also come with an end-to-end test that covers this....
http://issues.apache.org/jira/browse/FLINK-9885    Author: Tzu-Li , 2018-08-31, 08:00
[FLINK-6344] Migrate from Java serialization for BucketingSink's state - Flink - [issue]
...See umbrella JIRA FLINK-6343 for details. This subtask tracks the migration for `BucketingSink`....
http://issues.apache.org/jira/browse/FLINK-6344    Author: Tzu-Li , 2018-08-25, 05:18
[FLINK-6347] Migrate from Java serialization for MessageAcknowledgingSourceBase's state - Flink - [issue]
...See umbrella JIRA FLINK-6343 for details. This subtask tracks the migration for MessageAcknowledgingSourceBase....
http://issues.apache.org/jira/browse/FLINK-6347    Author: Tzu-Li , 2018-08-25, 05:17