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

Topics (27218)

Replies

Last Post

Views

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

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21993) Remove LocalCollectionOutputFormat from code base by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

About metric name truncation by Lu Niu

by Chesnay Schepler-3

[jira] [Created] (FLINK-21992) Investigate potential buffer leak in unaligned checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21991) flink varchar which exposes to users it not unified by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21990) Double check Task status when perform checkpoint. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21989) Add a SupportsSourceWatermark ability interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21988) testRequestKvStateWithIrrelevantRegistration fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21987) testRequestKvStateOfWrongJob failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21985) Support Explain Query/Modifcation syntax in Calcite Parser by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21983) Test failed because "mvn-${sys/mvn.forkNumber}" is not updated on time. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Out of Memory Error-Heap when storing parquet files using Flink Table API (Flink version-1.12.0) in Google Cloud Storage by Sivaraman Venkataram...

by Xintong Song

[jira] [Created] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21981) Increase the priority of the parameter in flink-conf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21980) ZooKeeperRunningJobsRegistry creates an empty znode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21977) Allow bigger offset in SlidingProcessingTimeWindows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21976) Move Flink ML pipeline API and library code to a separate repository named flink-ml by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21975) Remove hamcrest dependency from SchedulerBenchmarkBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21974) Don't match pattern `SET key= ' '` in SetOperationParseStrategy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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

1 ... 41424344454647 ... 778