(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 (27203)

Replies

Last Post

Views

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

[jira] [Created] (FLINK-17568) Task may consume data after checkpoint barrier before performing checkpoint for unaligned checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17567) Create a dedicated Python directory in release directory to place Python-related source and binary packages by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17566) Fix potential K8s resources leak after JobManager finishes in Applicaion mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.10.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17564) Inflight data of incoming channel may be disordered for unaligned checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17563) YARN Setup page has a broken link by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17562) Monitoring REST API page has duplicate items by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17561) Table program cannot be compiled by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17559) Backpressure seems to be broken when not going through network by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17558) Partitions are released in TaskExecutor Main Thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17557) Add configuration to disallow ambiguous file schemes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17556) FATAL: Thread 'flink-metrics-akka.remote.default-remote-dispatcher-3' produced an uncaught exception. Stopping the process... java.lang.OutOfMemoryError: Direct buffer memory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17555) docstring of pyflink.table.descriptors.FileSystem:1:duplicate object description of pyflink.table.descriptors.FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17554) Add release hooks for user code class loader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 183184185186187188189 ... 778