(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 ... 347348349350351352353 ... 778

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-12793) Add localKeyBy API to DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12792) Support states mergence for local aggregation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12791) Introduce LocalKeyedStateHandle interface and implement LocalKeyedKeyGroupsStateHandle / LocalKeyedIncrementalKeyedStateHandle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12790) Implement KeyScope enum to distinguish LocalKeyBy and general keyBy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12789) Fix java docs in UserDefinedAggregateFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12788) Add support to run a Python job-specific cluster on Kubernetes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12787) Allow to specify directory in option -pyfs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12786) Implement local aggregation in Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

I want to contribute to Apache Flink by ruiyin chen

by ruiyin chen

Join to Flink Community by Jasper Yue

by Jasper Yue

[jira] [Created] (FLINK-12784) Support retention policy for InfluxDB metrics reporter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

apply for contributer by 王杰

by 王杰

[jira] [Created] (FLINK-12783) A K8S CRD to manage job lifecycle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12782) Show formatted timestamp in Watermark Tab of JM Web UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12781) run job REST api doesn't return complete stack trace for start job failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12780) use LogicalTypeRoot for type comparison by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12779) Avoid field conflicts when generate field names for non-composite Typeinformation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12778) Fix deriveTableAggRowType bug for non-composite types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Clean up and reorganize the JIRA components by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-12777) Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12776) Ambiguous content in flink-dist NOTICE file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12775) Bump flink-shaded version to 7.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12774) Pin version of build-helper-maven plugin by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12773) Unstable kafka e2e test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12772) Support mapping ARRAY, MAP, ROW (STRUCT) between Flink and Hive in HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12770) Make number of bulk concurrentRequests configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12769) Simplify expression design for symbols by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12768) FlinkKinesisConsumerTest.testSourceSynchronization unstable on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Request for Permission by lyang

by lyang

[jira] [Created] (FLINK-12767) Support user defined connectors/format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12766) Dynamically allocate TaskExecutor’s managed memory to slots. This step is a temporal workaround for release 1.9 to meet the basic usability requirements of batch functions from Blink. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12765) JobMaster calculates resource needs and requests slot for the entire slot sharing group. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12764) Launch customized TaskExecutor for tasks whose resource needs cannot be satisfied by existing TaskExecutor-s in active container mode. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 347348349350351352353 ... 778