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

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-20517) Disallow operators with mixed key/non-keyed inputs with BATCH state backend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20516) Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20515) Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20513) Separate the implementation of BatchExecExchange and StreamExecExchange by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20514) Introduce StreamExecPythonGroupTableAggregateRule and StreamExecGroupTableAggregate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20512) Introduce getDescription, getOutputType, replaceInputEdge methods for ExecNode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20511) Deprecate the classes in scala `nodes.exec` package by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20510) Enable log4j2 monitor interval by default by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20509) Refactor verifyPlan method in TableTestBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20508) Introduce PythonStreamGroupTableAggregateOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20507) Support Aggregate Operation in Python Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20506) Support FlatMap Operation in Python Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20505) Yarn provided lib does not work with http paths. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20504) NPE when writing to hive and fail over happened by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20503) Internal cpu configuration option is leaked in logs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20501) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed with "Delete test topic : flink-kafka-producer-fail-and-recover-same-checkpoint-twice" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20499) ES7 ElasticsearchSinkITCase hangs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20498) SQLClientSchemaRegistryITCase testReading test timed out after 120000 milliseconds by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20497) FlinkKafkaProducerITCase testRestoreToCheckpointAfterExceedingProducersPool Timeout expired after 60000milliseconds while awaiting InitProducerId by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20496) RocksDB partitioned index filter option by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20494) SQLClientHBaseITCase Task Timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20493) SQLClientSchemaRegistryITCase test failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20491) Support Broadcast State in BATCH execution mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20490) Don't share inputs between FlinkPhysicalRel and ExecNode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20489) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.10.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20488) Supporting changes (UI, conf) for timing out aligned checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20487) FLINK SQL GROUP BY TUMBLE AND OVER FUNCTION by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20485) Map views are deserialized multiple times by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20484) Improve hive temporal table exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink 1.9Version State TTL parameter configuration it does not work by YangPeng007

by YangPeng007

1 ... 88899091929394 ... 778