(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 ... 209210211212213214215 ... 786

Topics (27506)

Replies

Last Post

Views

[jira] [Created] (FLINK-17103) Supports dynamic table options for Blink planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17101) Supports dynamic table options for Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17100) Document Native Kubernetes Improvements by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17099) Refactoring State TTL solution in Group Agg、TopN operator, etc replace Timer with StateTtlConfig by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17098) CatalogManager#dropTemporaryTable and dropTemporaryView should use ObjectIdentifier as its argument by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-71: E2E View support in Flink SQL by Zhenghua Gao

by Zhenghua Gao

[jira] [Created] (FLINK-17097) Flink HBase Connector String field size at least equal 8 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17096) Minibatch Group Agg support state ttl by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17095) KafkaProducerExactlyOnceITCase fails with "address already in use" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17094) OverWindowITCase#testRowTimeBoundedPartitionedRowsOver failed by FileNotFoundException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17093) Python UDF doesn't work when the input column is of composite type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-113: Supports Dynamic Table Options for Flink SQL by Danny Chan-2

by Benchao Li

[jira] [Created] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17091) AvroRowSerializationSchema doesn't support new Timestamp conversion classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17090) Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-71 - E2E View support in Flink SQL by Zhenghua Gao

by Zhenghua Gao

[jira] [Created] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17088) Search TaskManager log content based on keywords function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17085) Remove FlinkKubeClient#handleException since it does not do anything by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17084) Implement type inference for ROW/ARRAY/MAP constructors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17082) Remove mocking from SQL client tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL by Jark Wu-2

by Jark Wu-2

[jira] [Created] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17080) Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17076) Revamp Kafka Connector Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17075) Add task status reconciliation between TM and JM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Configuring autolinks to Flink JIRA ticket in github repos by Yun Tang

by Till Rohrmann

[DISCUSS] FLIP-111: Docker image unification by Andrey Zagrebin-4

by Ismaël Mejía

[jira] [Created] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 209210211212213214215 ... 786