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

Topics (27218)

Replies

Last Post

Views

SDK vs Connectors by Prasanna kumar

by Prasanna kumar

[jira] [Created] (FLINK-19028) Translate the "application_parameters.zh.md" into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19026) Improve threading model of Unaligner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19025) table sql write orc file but hive2.1.1 can not read by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19024) Remove unused "releaseMemory" from ResultSubpartition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19023) Remove pruning of Record Serializer Buffer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19022) AkkaRpcActor failed to start but no exception information by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19021) Cleanups of the ResultPartition components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19020) Add more metrics around async operations and backpressure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19019) Add HDFS / S3 / GCS support to Flink-StateFun Docker image. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19018) Add connection timeout to remote functions. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19017) Increases the visibility of a remote function call retry by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19016) Checksum mismatch when restore from RocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Unclean S3 checkpointing using Presto plugin by vishalovercome

by vishalovercome

[jira] [Created] (FLINK-19015) java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19014) Investigate minimum e2e test duration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19013) Log start/end of state restoration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument." by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19011) Parallelize the restoreOperation in OperatorStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19010) Add a system metric to show the checkpoint restore time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19009) wrong way to calculate the "downtime" metric by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Decompose failure recovery time by Zhinan Cheng-2

by Zhinan Cheng-2

[jira] [Created] (FLINK-19006) project transformation does not support conversion to Tuple25 type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.10.2, release candidate #2 by Zhu Zhu

by Yun Tang

[jira] [Created] (FLINK-19005) used metaspace grow on every execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19003) Add micro-benchmark for unaligned checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19002) Support to only read changelogs of specific database and table for canal-json format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19001) Add data-stream integration for stateful functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19000) Forward JobStatus.INITIALIZING timestamp to ExecutionGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 136137138139140141142 ... 778