(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 ... 226227228229230231232 ... 786

Topics (27506)

Replies

Last Post

Views

[DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL by Wei Zhong-2

by Wei Zhong-2

[jira] [Created] (FLINK-16589) Flink Table SQL fails/crashes with big queries with lots of fields by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16588) Add Disk Space metrics to TaskManagers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16587) Add basic CheckpointBarrierHandler for unaligned checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16586) Build ResultSubpartitionInfo and InputChannelInfo in respective constructors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16583) SQLClientKafkaITCase.testKafka failed in SqlClientException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16581) Minibatch deduplication lack state TTL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16580) flink-connector-kafka desrializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink 1.10 StopWithSavepoint only suit for the sources that implement the StoppableFunction interface? by LakeShen

by LakeShen

[jira] [Created] (FLINK-16579) Upgrade Calcite version to 1.23 for Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16578) join lateral table function with condition fails with exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16576) State inconsistency on restore with memory state backends by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16575) develop HBaseCatalog to integrate HBase metadata into Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16574) StreamingFileSink should rename files or fail if destination file already exists by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] [FLIP-85] Flink Application Mode by Kostas Kloudas-5

by Aljoscha Krettek-2

[jira] [Created] (FLINK-16573) Kinesis consumer does not properly shutdown RecordFetcher threads by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Update on Flink Stateful Functions & what are the next steps? by Tzu-Li (Gordon) Tai

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-16571) Throw exception when current key are out of range by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16570) Difficulties to select correct metric with long name in dropdown of Flink UI task menu by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16569) Allow empty keys in Kafka egress messages for Statefun Python SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16568) Cannot call Hive UDAF that requires constant arguments by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16567) Get the API error of the StreamQueryConfig on Page "Query Configuration" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16566) Change the log level of the launching command and dynamic properties from DEBUG to INFO in Mesos integration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16565) Make Pipeline Json compitable between Java and Python if all Pipelinestage are Java ones by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16564) HadoopS3RecoverableWriterITCase fails with NullPointerException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16563) CommandLineParser should fail with explicit error message when parsing recognized arguments. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16562) Handle JobManager termination future in place by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Features of Apache Flink 1.11 by Zhijiang(wangzhijian...

by Zhijiang(wangzhijian...

[jira] [Created] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 226227228229230231232 ... 786