(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 ... 373374375376377378379 ... 873

Topics (30525)

Replies

Last Post

Views

[jira] [Created] (FLINK-14741) Document pluggable sources and sinks in the production code for testing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14739) add failOnCastException Configuration to Json FormatDescriptor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14738) Job which status is finished, get operator metric by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14737) HiveTypeUtil.toFlinkPrimitiveType returns wrong Timestamp(6) instead of Timestamp(9) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14736) Fail to connect Hive metastore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14735) Improve batch schedule performance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14734) Add a ResourceSpec in SlotSharingGroup to describe its overall resources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14733) Introduce ResourceProfile builder to enable flexible building by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14732) flink-release-1.9.x can NOT compile with CDH 5.16 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14731) LogicalWatermarkAssigner should use specified trait set when doing copy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14730) Add pending slots for job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14729) Multi-topics consuming from KafkaTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14728) add reminder for users of potential thread safety issues of hive built-in function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14727) update doc of supported Hive versions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14726) avoid creating new HiveShim instance every time when calling HiveShimLoader.loadHiveShim() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Read thousands of files with batch by Dominik Wosiński

by Dominik Wosiński

[jira] [Created] (FLINK-14725) Remove unused (anymore) TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14724) Join condition could be simplified in logical phase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14723) Improve some code about computed column in planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14722) Optimize mapred.HadoopInputSplit to not serialize conf when split is not configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14721) HiveTableSource should implement LimitableTableSource interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14720) Bring down ExecutionVertex#deployToSlot access modifier and mark it with @VisibleForTesting annotation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14718) Refactor ComputedColumnToRelTest to resue TableTestBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14716) Cooperate computed column with project push down by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14715) HiveModuleTest fails with Hive-3.1.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14714) BytesHashMap should not warn invoking stack when it want to spill by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14713) Show Attempt History in Vertex SubTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14712) Add NetWork metric for IOMetricsInfo by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14711) Create Alter Function and Show Functions DDL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14710) Decide column nullability according to Hive constraints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14709) Allow outputting elements in close method of chained drivers. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14708) Introduce full restarts failover strategy for NG scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 373374375376377378379 ... 873