(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 ... 74757677787980 ... 780

Topics (27277)

Replies

Last Post

Views

[Discussion] More Deep Learning usages on Apache Flink by Qing Lan

by Becket Qin

[DISCUSS] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo by Seth Wiesman-4

by Stephan Ewen

[jira] [Created] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21000) set MetricGroup in SourceCoordinatorContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20998) flink-raw-1.12.jar does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20997) YarnTestBaseTest fails due to NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20994) Add public method to create TableEnvironment in PyFlink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

outdated version of com.esotericsoftware.kryo by Teunissen, F.G.J. (F...

by Seth Wiesman-4

[jira] [Created] (FLINK-20993) Cleaning up checkpoint during shutdown may fail JM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20992) Checkpoint cleanup can kill JobMaster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20991) Create 1.12.1 official image by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20990) Service account property ignored for Kubernetes Standalone deployment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS][FLINK-20726] Introduce Pulsar connector by 赵建云

by Till Rohrmann

[DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn by jie.wang

by Rui Li

[DISCUSS] Releasing Apache Flink 1.10.3 by Matthias

by Xintong Song

[jira] [Created] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20988) Various resource allocation improvements for active resource managers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20987) Upgrade Stateful Functions to use Flink 1.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20986) GenericTypeInfo equality issue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20985) end the stream-job in docker container will remain some zombie processes in 1.11, these useless processes not be maked as zombie but still exist in 1.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20984) can not convert an array into Table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20983) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 60000milliseconds while awaiting InitProducerId by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT] [VOTE] Release 1.12.1, release candidate #2 by Xintong Song-2

by Xintong Song-2

[VOTE] Release 1.12.1, release candidate #2 by Xintong Song-2

by Xintong Song

InfluxDB Source Sink Connector by Leon Papke

by Leon Papke

[jira] [Created] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20981) ArchivedExecutionGraph#createFromInitializingJob should support SUSPENDED as final state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20980) ResourceCounter#withResources accepts negative count by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20978) Implement HeapSavepointRestoreOperation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20977) can not use `use` command to switch database by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 74757677787980 ... 780