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

Topics (27406)

Replies

Last Post

Views

[jira] [Created] (FLINK-12225) Simplify the interface of the PartFileWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12224) Kafka 0.10 e2e test fails on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12223) HeapMemorySegment.getArray should return null after being freed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12222) No way to ship custom jars to yarn cluster in scala-shell by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12221) Distinguish long tail task based on IOMetrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12220) Speculatively schedule execution for long tail task by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12219) Yarn application can't stop when flink job failed in per-job yarn cluste mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12218) Report more record information in IOMetrics for Speculative Schedule by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12217) OperationTreeBuilder.map() should perform ExpressionResolver.resolve() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] (FLINK-8297) A solution for FLINK-8297 Timebased RocksDBListState by faxianzhao

by SHI Xiaogang

Contributor permission Request by Kevin Tang

by Fabian Hueske-2

[jira] [Created] (FLINK-12214) Add JobListener to capture job submission process by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12213) Pass TaskManagerMetricGroup into constructor of NetworkEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12212) Clarify documentation about async checkpointing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12211) Add more it cases to blink batch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12210) Fix a bug in AbstractPagedInputView.readLine by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12209) Refactor failure handling with CheckpointFailureManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12208) Introduce Sort / TemporalSort / SortLimit/ Limit operators for blink streaming runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Backtracking for failover regions by Chesnay Schepler-3

by Zhu Zhu

[jira] [Created] (FLINK-12207) JsonRowDeserializationSchema and JsonRowSerializationSchema Types "==" bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

How can I use 1.9-SNAPSHOT Blink version for MapBundleFunction? by Felipe Gutierrez

by Kurt Young

[jira] [Created] (FLINK-12206) cannot query nested fields using Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12205) Internal server error., <Exception on server side: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher#-1774235985] by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12204) Improve JDBCOutputFormat ClassCastException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12203) Refactor ResultPartitionManager to break tie with Task by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12202) Consider introducing batch metric register in NetworkEnviroment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12201) Introduce InputGateWithMetrics in Task to increment in/out byte metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12200) [Table API] Support UNNEST for MAP types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12199) Refactor IOMetrics to not distinguish between local/remote by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12198) Flink JDBC Connector: Update existing JDBCInputFormat to support setting auto-commit mode of DB connection by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12197) Avro row deser for Confluent binary format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12196) FlinkKafkaProducerITCase#testRunOutOfProducersInThePool throws NPE by Shang Yuanchun (Jira...

by Alexander Chermenin

[jira] [Created] (FLINK-12195) Incorrect resource time setting causes flink to fail to submit by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 372373374375376377378 ... 784