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

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17922) Refactor generic and hive table rules for HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17921) RpcGlobalAggregateManager#updateGlobalAggregate would cause akka.timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Please update the Requirements of PyPI by Ray Chen

by jincheng sun

[ANNOUNCE] Apache Flink 1.11.0, release candidate #1 by Zhijiang(wangzhijian...

by Yang Wang

[jira] [Created] (FLINK-17920) Add the Python example of Time-windowed join in Table API doc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17919) KafkaConsumerThread should add ratelimiter functionality as well by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: java.lang.NoSuchMethodError while writing to Kafka from Flink by Guowei Ma

by Chesnay Schepler-3

[jira] [Created] (FLINK-17918) Jobs with two input operators are loosing data in unaligned checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly Community Update 2020/21 by Konstantin Knauf-4

by Konstantin Knauf-4

[DISCUSS] FLIP-84 Feedback Summary by godfreyhe

by Timo Walther-2

[jira] [Created] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17916) Separate KafkaShuffle read/write to different environments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17915) TransitiveClosureITCase>JavaProgramTestBase.testJobWithObjectReuse:113 Error while calling the test program: Could not retrieve JobResult by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0> by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17913) Streaming File Sink end-to-end test times out "Still waiting for restarts" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17911) K8s e2e: error: timed out waiting for the condition on deployments/flink-native-k8s-session-1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17910) Kerberized YARN on Docker e2e test: "Final Application State: FAILED" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17909) Make the GenericInMemoryCatalog to hold the serialized meta data to uncover more potential bugs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17908) Vague document about Kafka config in SQL-CLI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17907) flink-table-api-java: Compilation failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17906) Fix performance issues in WatermarkOutputMultiplexer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17905) Docs for JDBC connector show licence and markup by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17904) Add "scheduleWithFixedDelay" to ProcessingTimeService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17903) Evolve WatermarkOutputMultiplexer to make it reusable in FLIP-27 Sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17902) Support the new interfaces about temporary functions in PyFlink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17901) Add module interface in PyFlink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17900) Listener for when Files are committed in StreamingFileSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17899) Integrate FLIP-126 Timestamps and Watermarking with FLIP-27 sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17898) Remove Exceptions from signatures of SourceOutput methods by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17897) Resolve stability annotations discussion for FLIP-27 in 1.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17896) HiveCatalog can work with new table factory because of is_generic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17895) Default value of rows-per-second in datagen should be limited by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17894) RowGenerator in datagen connector should be serializable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 172173174175176177178 ... 778