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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-11328) Migrate all parameterless serializers / TypeSerializerSingleton's to use new serializer snapshot abstractions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11327) Migrate all remaining Flink serializers' snapshot classes to the new TypeSerializerSnapshot / TypeSerializerSchemaCompatibility abstractions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[NOTICE] Mandatory migration of git repos to gitbox.apache.org - three weeks left! by Apache Infrastructur...

by Apache Infrastructur...

[jira] [Created] (FLINK-11325) Flink Consumer Kafka Topic Not Found ConsumerID by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11324) Custom Log4j properties for each flink job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11323) Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11322) Use try-with-resource for FlinkKafkaConsumer010 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11320) Support user callback in Kafka sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11319) Allow usage of custom implementation of Kafka Producer and Consumer in source and sink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply for flink contributor permission by Benchao Li

by Fabian Hueske-2

[jira] [Created] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11317) test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11316) JarFileCreatorTest fails when run with Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Multiple select single result by dhanuka ranasinghe

by dhanuka ranasinghe

[jira] [Created] (FLINK-11315) Make magic number in KvStateSerializer as a constant to make more readable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11314) Reuse RocksDBWriteBatchWrapper in the flush method of RocksDBMapState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Disable local data transportation by Chris Miller

by Biao Liu

[jira] [Created] (FLINK-11313) [checkpoint] Introduce LZ4 compression for keyed state in full checkpoints and savepoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Identify the task within PartitionRequestQueue by Chris Miller

by Zhijiang(wangzhijian...

[jira] [Created] (FLINK-11312) The link to Zookeeper is broken in "jobmanager_high_availability" document by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

An exception about checkpoint by Leor Li

by Congxian Qiu

[jira] [Created] (FLINK-11310) Convert predicates to IN or NOT_IN for Project by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11309) Batch Job Failover Using RestartPipelinedRegionStrategy Fails in Some Scenes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

SQL codegen bytecode beyond 64KB. by 563280193@qq.com

by Timo Walther-2

[jira] [Created] (FLINK-11308) flink sql In the case when statement has a large in statement error： class DataStreamCalcRule$1933 grows beyond 64 KB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11307) Set up nightly to run Tests with Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply for dev authority by Jary Zhen

by Fabian Hueske-2

[jira] [Created] (FLINK-11305) Allow developer to test flink without building the whole flink project by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11304) Typo in time attributes doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11303) Utilizing Kafka headers for serialization and deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Recovery problem in Flink 1.6.3 by John Stone

by John Stone

ElasticSearch Connector by Ramya Ramamurthy

by dwysakowicz

1 ... 398399400401402403404 ... 778