(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 ... 584585586587588589590 ... 780

Topics (27278)

Replies

Last Post

Views

[jira] [Created] (FLINK-5723) Use "Used" instead of "Initial" to make taskmanager tag more readable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5722) Implement DISTINCT as dedicated operator by Shang Yuanchun (Jira...

by Radu Tudoran

[jira] [Created] (FLINK-5721) Add FoldingState to State Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5720) Deprecate "Folding" in all of DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5719) Let LatencyMarkers completely bypass operators / chains by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5716) Make streaming SourceContexts aware of source idleness by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5715) Asynchronous snapshotting for HeapKeyedStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5714) Use a builder pattern for creating CsvTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5710) Add ProcTime() function to indicate StreamSQL by Shang Yuanchun (Jira...

by Ufuk Celebi-2

[jira] [Created] (FLINK-5713) Protect against NPE in WindowOperator window cleanup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5712) update several deprecated configuration options by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5711) Deserialization schema that gives has full kafka log information by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apache IoT by Trevor Grant

by Trevor Grant

Task assignment by Dmitrii Kniazev

by Till Rohrmann

[jira] [Created] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5708) we should remove duplicated configuration options by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5707) Find better keys for backend configuration parameters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5706) Implement Flink's own S3 filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5705) webmonitor's request/response use UTF-8 explicitly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

STREAM SQL inner queries by Radu Tudoran

by Radu Tudoran

[jira] [Created] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5702) Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5701) FlinkKafkaPrdocuer violates at-least-once by not handling failed records by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5700) Document akka.client.timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5698) Add NestedFieldsProjectableTableSource interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Support for Auto scaling by Meghashyam Sandeep V

by Meghashyam Sandeep V

[jira] [Created] (FLINK-5696) Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5695) Optimize table type systems based on database semantics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Conditional branching in Table API by Chen Qin

by Fabian Hueske-2

Call for abstracts open for Dataworks & Hadoop Summit San Jose by Alan Gates-2

by Alan Gates-2

1 ... 584585586587588589590 ... 780