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

Topics (27218)

Replies

Last Post

Views

[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...

[jira] [Created] (FLINK-20976) Unify Binary format for Keyed State savepoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20974) docker容器pyflink中stream任务取消之后会留下几个僵尸进程 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20973) failed to submit flink-on-yarn job on Windows due to error of classPath by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20971) Allow SQL expressions in Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

转发：flink-sql字段类型问题 by 郝文强

by 郝文强

[jira] [Created] (FLINK-20970) DECIMAL(10, 0) can not be GROUP BY key. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20969) Update Scala 2.12 version to 2.12.13 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20968) Remove legacy exec nodes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20967) Add Documentation for hbase connector new Function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20966) Rename StreamExecIntermediateTableScan to StreamPhysicalIntermediateTableScan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20965) BigDecimalTypeInfo can not be converted. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Backport broadcast operations in BATCH mode to Flink by Aljoscha Krettek-2

by Kurt Young

[jira] [Created] (FLINK-20964) Introduce PythonStreamGroupWindowAggregateOperator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20963) Rewrite the example under 'flink-python/pyflink/table/examples' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20962) Rewrite the example in 'flink-python/pyflink/shell.py' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer by Tzu-Li (Gordon) Tai

by Yu Li

[jira] [Created] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20960) Add warning in 1.12 release notes about potential corrupt data stream with unaligned checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20959) How to close Apache Flink REST API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20958) Starting flink doc build script in preview mode occur version error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20957) StreamTaskTest.testProcessWithUnAvailableOutput unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20956) SQLClientSchemaRegistryITCase.testWriting unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 73747576777879 ... 778