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

Topics (27393)

Replies

Last Post

Views

[DISCUSS] GitBox by Greg Hogan

by Chesnay Schepler-3

[jira] [Created] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7218) ExecutionVertex.getPreferredLocationsBasedOnInputs() will always return empty by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Facebook BSD+patents license and Apache products by Andrew Palumbo

by Torok, David

[jira] [Created] (FLINK-7217) Give hints about unsupported SQL / Table API features. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7216) ExecutionGraph can perform concurrent global restarts to scheduling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7215) Typo in FAQ page by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7214) Add a sink that writes to ORCFile on HDFS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7213) Introduce state management by OperatorID in TaskManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7212) JobManagerLeaderSessionIDITSuite not executed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Greetings and question by Tzu-Li (Gordon) Tai

by Fabian Hueske-2

[jira] [Created] (FLINK-7211) Exclude Gelly javadoc jar from release by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7207) Support getAccumulatorType when use DataView by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7206) Implementation of DataView to support state access for UDAGG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [DISCUSS] Managing announcements of breaking API / state compatibility changes in major releases by Ted Yu

by Tzu-Li (Gordon) Tai

Clarification of TypesSerializers by Dawid Wysakowicz

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-7205) Add UUID supported in TableAPI/SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7204) CombineHint.NONE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7203) Remove useless "flink-avro" module by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7200) Make metrics more Datadog friendly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7199) Graph simplification does not set parallelism by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7198) Datadog Metric Reporter reports incorrect host for JobManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7197) Missing call to GraphAlgorithmWrappingBase#canMergeConfigurationWith() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7196) add a TTL to transient BLOB files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7195) FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7193) Update all OVER window ProcessFunction implementations to use SortedQueueState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7192) Activate checkstyle flink-java/test/operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7191) Activate checkstyle flink-java/operators/translation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-7190) Activate checkstyle flink-java/* by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 538539540541542543544 ... 783