(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 ... 46474849505152 ... 783

Topics (27371)

Replies

Last Post

Views

[jira] [Created] (FLINK-21973) Flink 1.12 has a column bug in creating views by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21972) Check whether TemporalTableSourceSpec can be serialized or not by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21971) Support FLIP-27 based kafka source connector in PyFlink DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21970) DegreesWithExceptionITCase fails on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21969) PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21968) Calcite parser doesn't support to parse "-- test" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21967) Add document on the operation of blocking result partition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21966) Support Kinesis connector in Python DataStream API. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21965) Surefire plugin seems to have failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21964) HA e2e test failed due to not enough resources being available by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21963) ReactiveModelITCase.testScaleDownOnTaskManagerLoss failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21962) SQL Group Windows do not work on Flink 1.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Introducing Backpressure for connected streams by Robin KC

by Robin KC

[jira] [Created] (FLINK-21961) Add JSON StateFun type to the Python SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21960) Simplify module.yaml spec by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21959) Rename Kafka/Kinesis ingress/egress types. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21958) Rename statefun-sdk to statefun-sdk-embedded by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21957) Rename statefun-python-sdk => statefun-sdk-python by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21956) NPE in Kafka ingress when the key is missing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21955) Remove the old examples by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21954) JobMasterTest.testRestoringFromSavepoint fails with adaptive scheduler being enabled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21953) Add documentation on batch mode support of Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21951) Fix wrong if condition in BufferReaderWriterUtil#writeBuffers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21950) DemultiplexingRecordDeserializerTest fail due to multiple memory freeing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21949) Support collect to array aggregate function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21948) Show Watermarks in Human Friendly Format in the Web User Interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21947) Support TIMESTAMP_LTZ type in CSV format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21946) FlinkRelMdUtil.numDistinctVals produces exceptional Double.NaN result when domainSize is in range(0,1) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21945) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21944) AbstractArrowPythonAggregateFunctionOperator.dispose should consider whether arrowSerializer is null by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21943) Redundant checkNotNull by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21941) testSavepointRescalingOutPartitionedOperatorStateList fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21942) KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 46474849505152 ... 783