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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-14821) Enable 'Queryable state (rocksdb) with TM restart' E2E test to pass with new DefaultScheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14820) Replace Time with Duration in FutureUtils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14819) Replace Time with Duration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14818) StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[NOTICE] Travis cron job settings UI bug by Chesnay Schepler-3

by Chesnay Schepler-3

[jira] [Created] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14816) Add thread dump feature for taskmanager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14815) Expose network pool usage in IOMetricsInfo by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14814) Show the vertex that produces the backpressure source in the job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14813) expose the new mechanism implemented in FLINK-14472 as a "is back-pressured" metric. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14812) Add metric libs to Flink classpath with an environment variable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14811) Replace Java Streams with for-loops in vertex input checking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14810) It's weird that copy julianDateFloor from DateTimeUtils and change the implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14809) DataStreamAllroundTestProgram does not run because return types cannot be determined by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14807) Add Table#collect api for fetching data to client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14806) Introduce setTimestamp/getTimestamp interface to TypeGetterSetters/VectorizedColumnBatch and writeTimestamp interface to BinaryWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14805) Remove unixDateCeil related code by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14804) The flink that starts stand-alone mode appears abnormal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14803) Support Consistency Level for InfluxDB metrics reporter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14802) Multi vectorized read version support for hive orc read by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14801) flink sql parser unparser func partition frame local variable name mistake by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14800) Introduce parallelism inference for HiveSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14799) Improve batch sql and hive integrate performance milestone-2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14798) how to setup a ha flink cluster on k8s? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

flink checkpoint state data corruption by Jeffrey Martin

by Yun Tang

[jira] [Created] (FLINK-14797) Remove power mockito from RemoteStreamExecutionEnvironmentTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14796) Add document about limitations of different Hive versions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14795) Rework TaskExecutorPartitionLifecycleTest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14794) KeyedStream#transform not working with factories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14793) Add SPI interface to discovery state backend and establish well-known names by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14792) Extend TaskExecutor interface to support release of cluster partitions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-14791) Process ClusterPartitionReport on ResourceManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Flink Avro Cloudera Registry (FLINK-14577) by Őrhidi Mátyás

by Őrhidi Mátyás

[jira] [Created] (FLINK-14790) Custom state backend in job graph composition without depending on concrete state backend implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 276277278279280281282 ... 778