(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 ... 398399400401402403404 ... 784

Topics (27408)

Replies

Last Post

Views

[jira] [Created] (FLINK-11489) Add an initial Blink streaming runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11488) Merge a basic Blink planner framework by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11487) Support for writing data to Apache Flume by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11486) Remove RecoveryITCase for jobmanager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11485) Migrate PojoSerializer to use new serialization compatibility abstractions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11484) Blink java.util.concurrent.TimeoutException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11483) Improve StreamOperatorSnapshotRestoreTest with Parameterized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11482) Implement GenericHiveMetastoreCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11481) Integrate HiveTableFactory with existing table factory discovery mechanism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11480) Create HiveTableFactory that creates TableSource/Sink from a Hive table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11479) Implement HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11478) Handle existing table registration via YAML file in the context of catalog support by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11477) Define catalog entries in SQL client YAML file and handle the creation and registration of those entries by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11476) Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11475) Adapt existing InMemoryExternalCatalog to GenericInMemoryCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11474) Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11473) Clarify Documenation on Latency Markers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11472) KafkaITCase.testCancelingEmptyTopic failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11471) Job is reported RUNNING prematurely for queued scheduling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11470) LocalEnvironment doesn't call FileSystem.initialize() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11469) fix Tuning Checkpoints and Large State doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11468) Setup jUnit categories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11466) Implement LocalStandaloneKafkaResource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11467) Port Kafka Streaming end-to-end test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11465) Implement LocalStandaloneFlinkResource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11464) Implement DownloadCache by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11463) Rework end-to-end tests in Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11462) "Powered by Flink" page does not display correctly on Firefox by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11461) Remove useless MockRecordWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11460) Remove useless AcknowledgeStreamMockEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Proposal of external shuffle service by Zhijiang(wangzhijian...

by qi luo

[jira] [Created] (FLINK-11459) Presto S3 does not show errors due to missing credentials with minio by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Side Outputs for late arriving records by Ramya Ramamurthy

by Fabian Hueske-2

[jira] [Created] (FLINK-11458) Ensure sink commit side-effects when cancelling with savepoint. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11457) PrometheusPushGatewayReporter either overwrites its own metrics or creates too may labels by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 398399400401402403404 ... 784