(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 ... 558559560561562563564 ... 781

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6534) SharedStateRegistry is disposing state handles from main thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6533) Duplicated registration of new shared state when checkpoint confirmations are still pending by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6532) Mesos version check by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6531) Deserialize checkpoint hooks with user classloader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6530) Unclosed Response in DatadogHttpClient#validateApiKey() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6529) Rework the shading model in Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6528) Refactor BlobLibraryCacheManager <=> BlobServer/Cache <=> BlobStore hierarchy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6527) OperatorSubtaskState has empty implementations of (un)/registerSharedStates by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6526) BlobStore files might become orphans in case of recovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6525) Transferred TM log/stdout files are never removed from BlobStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6524) Make server address of BlobCache configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6523) Improve lifecycle management of created BlobCaches in TaskManagerLogHandler and JobClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6521) Add per job cleanup methods to HighAvailabilityServices by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

assignment request: FLINK-1750 (CCA for MLLib) by Alex De Castro-3

by Chesnay Schepler-3

[jira] [Created] (FLINK-6520) FlinkKafkaConsumer09+ does not overwrite props to not auto commit offsets when commit mode is OffsetCommitMode.ON_CHECKPOINTS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6519) Integrate BlobStore in HighAvailabilityServices lifecycle management by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6518) Migrate BlobServer configuration options by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6517) Support multiple consecutive windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6516) using real row count instead of dummy row count when optimizing plan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6514) Cannot start Flink Cluster in standalone mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6513) various typos and grammatical flaws by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6512) some code examples are poorly formatted by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6511) JobClient does not properly clean up BlobCache resources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6510) Add CI integration for Windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6509) TestingListener might miss JobLeader notifications by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6508) Include license files of packaged dependencies by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6507) Potential bug in ContinuousFileProcessing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6506) Some tests in flink-tests exceed memory the resources in containerized Travis builds by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6502) Support writing data in DataSet to ElasticSearch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 558559560561562563564 ... 781