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

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17599) Update documents due to FLIP-84 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Hope to contribute code by i'mpossible

by Leonard Xu

[jira] [Created] (FLINK-17598) Implement FileSystemHAServices for native K8s setups by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17597) JavaSqlTests#test_java_sql_ddl is instable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17596) Unstable PyFlinkBlinkStreamUserDefinedFunctionTests testMethod#test_udf_in_join_condition_2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17595) JobExceptionsInfo. ExecutionExceptionInfo miss getter method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17594) Support path-based PartFileWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17593) Support arbitrary recovery mechanism for PartFileWriter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17592) flink-table-planner doesn't compile on Scala 2.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17590) Add Bucket lifecycle listener to support acquiring bucket state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17587) Filesystem streaming sink support partition commit (success file) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17586) Due to the new behavior of the table planner the Python dependency management command line options does not work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Would you please give me the permission as a contributor by 天地任我游

by Yangze Guo

[jira] [Created] (FLINK-17584) disableAutoTypeRegistration option does not work with Streaming API, only with Batch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17583) Allow option to store a savepoint's _metadata file separate from its data files by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17582) Update quickstarts to use universal Kafka connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17581) Update translation of S3 documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17580) NPE in unaligned checkpoint for EndOfPartition events by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17579) Set the resource id of taskexecutor from environment variable if possible in standalone mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

What is the RocksDB local directory in flink checkpointing? by LakeShen

by Yun Tang

[jira] [Created] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17577) SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17574) Deduplicate the process execution logic in Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17573) There is duplicate source data in ProcessWindowFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17572) Remove checkpoint alignment buffered metric from webui by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17571) A better way to show the files used in currently checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17570) BatchTableEnvironment#fromValues(Object... values) causes StackOverflowError by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17569) to support ViewFileSystem when wait lease revoke of hadoop filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 183184185186187188189 ... 778