(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 ... 494495496497498499500 ... 783

Topics (27399)

Replies

Last Post

Views

[jira] [Created] (FLINK-8608) Add MiniDispatcher for job mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8607) Add a basic embedded SQL CLI client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8606) Clean up Table API for Java users by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8605) Enable job cancellation from the web UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8604) Move JobTerminationHandler to WebMonitorEndpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8603) Split RestClusterClient#submitJob into submitJob and requestJobResult by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Confused about method naming in heartbeatFromJobManager or heartbeatFromResourceManager by mingleizhang

by Till Rohrmann

Terminating streaming test by Thomas Weise

by Aljoscha Krettek-2

build/devops by cw7k

by Fabian Hueske-2

[jira] [Created] (FLINK-8602) Accelerate recover from failover when use incremental checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8601) Introduce LinkedBloomFilterState for Approximate calculation and other situations of performance optimization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8600) BucketingSink errors out when used with Presto filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8599) Improve the failure behavior of the ContinuousFileReaderOperator for bad files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Releasing Flink 1.4.1 by Tzu-Li (Gordon) Tai

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-8598) Intermittent test failure of BackPressureStatsTrackerITCase.testBackPressuredProducer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8597) Add examples for Connected Streams with Broadcast State. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8596) Custom command line code does not correctly catch errors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8595) Include table source factory services in flink-table jar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8594) Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8593) Latency metric docs are outdated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8592) LatencyMetric scope should include operator names by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8591) Handle unfinished BufferConsumers in subpartitions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8590) Drop ResultPartitionWriter#writeBufferToAllSubpartitions method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8589) Add data polling method to InputGate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8588) Handle sliced buffers in RecordDeserializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8587) Drop unused AdaptiveSpanningRecordDeserializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8586) Drop SpilledSubpartitionViewTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8585) Efficiently handle read-only buffers in DataInputDeserializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8584) Handle read-only buffers in DataInputDeserializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8583) Pass BufferConsumer to subpartitions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8582) Introduce BufferConsumer concept by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8581) Improve performance for low latency network by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8579) Support deletion flag for DataStream to Table upsert conversion. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8578) Implement rowtime DataStream to Table upsert conversion. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 494495496497498499500 ... 783