(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 ... 525526527528529530531 ... 809

Topics (28304)

Replies

Last Post

Views

[jira] [Created] (FLINK-8434) The new yarn resource manager should take over the running task managers after failover by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8433) Update code example for "Managed Operator State" documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8432) Add openstack swift filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8430) Implement stream-stream non-window full outer join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8429) Implement stream-stream non-window right outer join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8428) Implement stream-stream non-window left outer join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8427) Checkstyle for org.apache.flink.optimizer.costs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8426) Error in Generating Timestamp/Watermakr doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8425) SpilledSubpartitionView not protected against concurrent release calls by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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...

1 ... 525526527528529530531 ... 809