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

Topics (27218)

Replies

Last Post

Views

Using Statefun with Confluent Kafka by hezekiah maina

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-19485) Consider runtime-mode when creating the StreamGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs/cache'" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Introduce MongoDB connector for Flink by Dominik Wosiński

by Dominik Wosiński

[jira] [Created] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19481) Add support for a flink native GCS FileSystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19480) Support RichFunction in Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19478) Translate page 'intro_to_table_api' into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19477) Translate page 'python_table_api_connectors' into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19476) Introduce CacheManager in CatalogManager to keep track of the ClusterPartitionDescriptor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Release flink-shaded 12.0 by Chesnay Schepler-3

by Till Rohrmann

[VOTE] FLIP-142: Disentangle StateBackends from Checkpointing by Seth Wiesman-4

by Till Rohrmann

[jira] [Created] (FLINK-19475) Implement a timer service that holds a single key at a time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19474) Implement a state backends that holds a single key at a time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19472) Implement a one input sorting DataInput by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19473) Implement multi inputs sorting DataInput by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19471) CVE-2020-7712 is reported for flink-streaming-java_2.11:jar:1.11.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19470) ParquetColumnarRowSplitReader::reachEnd returns false after it has reached end by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19468) Metrics not returned when data stream / operator name contains "+" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19467) Implement HashMapStateBackend and EmbeddedRocksDBStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19466) Implement JobManagerCheckpointStorage and FileSystemCheckpointStorage by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19464) Rename CheckpointStorage interface to CheckpointStorageAccess by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19465) Add CheckpointStorage interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19463) Disentangle StateBackends from Checkpointing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT][VOTE] FLIP-142: Disentangle StateBackends from Checkpointing by Seth Wiesman-4

by Seth Wiesman-4

[jira] [Created] (FLINK-19462) Checkpoint statistics for unfinished task snapshots by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19460) AWS Kinesis Producer EXACTLY_ONCE semantic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19459) flink-dist won't build locally with newer (3.3+) maven versions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19458) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange: ZooKeeper unexpectedly modified by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19457) Port NumberSequenceSource to FLIP-27 source interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-142: Disentangle StateBackends from Checkpointing by Seth Wiesman-4

by Yu Li

1 ... 120121122123124125126 ... 778