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

Topics (27215)

Replies

Last Post

Views

[jira] [Created] (FLINK-11074) Improve the harness test to make it possible test with state backend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11072) KafkaITCase.testKeyValueSupport failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Embracing Table API in Flink ML by Weihua Jiang

by Weihua Jiang

[jira] [Created] (FLINK-11071) Dynamic proxy classes cannot be resolved when deserializing job graph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Flink 1.7.0 released by Till Rohrmann

by bowen.li

Proposal regarding Queryable State by Galen Warren

by Galen Warren

withPartitioner() vs calling partitionCustom() beforehand by Giannis Evagorou

by Giannis Evagorou

[jira] [Created] (FLINK-11070) Add stream-stream non-window cross join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11069) Remove FutureUtil by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11068) Port Table class to Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11067) Port TableEnvironments to Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11066) Migrate main Table API classes to flink-table-api-base by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11065) Migrate flink-table runtime classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11064) Setup a new flink-table module structure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11063) Make flink-table Scala-free by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11062) web ui log error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11061) Add travis profile that would run on each commit with scala 2.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11060) Unable to set number of task manager and slot per task number in scala shell local mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11059) JobMaster may continue using an invalid slot if releasing idle slot meet a timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11058) FlinkKafkaProducer011 fails when kafka broker crash by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11057) where in grammar will cause stream inner join loigcal by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11056) Remove MesosApplicationMasterRunner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11055) Allow Queryable State to be transformed on the TaskManager before being returned to the client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

support/docs for compression in StreamingFileSink by Addison Higham

by Kostas Kloudas

[jira] [Created] (FLINK-11054) Ingest Long value as TIMESTAMP attribute by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11053) Examples in documentation not compiling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11052) Add Bounded(Group Window) FlatAggregate operator to batch Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11051) Add Bounded(Group Window) FlatAggregate operator to streaming Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11049) Unable to execute partial DAG by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11047) CoGroupGroupSortTranslationTest does not compile with scala 2.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 407408409410411412413 ... 778