(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 496497498499500501502 ... 780

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8421) HeapInternalTimerService should reconfigure compatible key / namespace serializers on restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8420) Timeout exceptions are not properly recognized by RetryingRegistration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Dynamic SessionWindow gaps by Dyana Rose

by Dyana Rose

[jira] [Created] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8418) Kafka08ITCase.testStartFromLatest() times out on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8415) Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Issues to work on for newbie to the Flink project by Ashutosh Dubey

by Mingmin Xu

[jira] [Created] (FLINK-8414) Gelly performance seriously decreases when using the suggested parallelism configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8413) Checkpointing in flink doesnt maintain the snapshot state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8412) Show outdated warning for 1.3 docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8411) inconsistent behavior between HeapListState#add() and RocksDBListState#add() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Using SQL with dynamic tables where rows are updated by Ghassan Yammine

by Ghassan Yammine

[jira] [Created] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8407) Setting the parallelism after a partitioning operation should be forbidden by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8406) BucketingSink does not detect hadoop file systems by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8405) Keyed State in broadcasted data steam. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8404) Mark Flip-6 tests with Flip6 annotation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8403) Flink Gelly examples hanging without returning result by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8401) Allow subclass to override write-failure behavior in CassandraOutputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8400) Use the lexicographic smallest attribute as the common group id when extract unique key by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8399) Use independent configurations for the different timeouts in slot manager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric by Shang Yuanchun (Jira...

by Marvin777

[jira] [Created] (FLINK-8397) Support ROW type in CassandraOutputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8396) Create (derived) duplicate Buffer class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8395) Create (derived) sliced Buffer class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 496497498499500501502 ... 780