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

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-17676) Is there some way to rollback the .out file of TaskManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

changing the output files names in Streamfilesink from part-00 to something else by dhurandar S

by Danny Chan

[jira] [Created] (FLINK-17675) Resolve CVE-2019-11358 from jquery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[CVE-2020-1960] Apache Flink JMX information disclosure vulnerability by Chesnay Schepler-3

by Chesnay Schepler-3

[jira] [Created] (FLINK-17674) OperatorCoordinator state in checkpoints should always be a ByteStreamStateHandle by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17673) Add failure reason to OperatorCoordinator.failTask(...) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17672) OperatorCoordinators receive failure notifications on task failurenstead of restarts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17671) Simplify the ManuallyTriggeredScheduledExecutortriggering logic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17670) Savepoint handling of "non-restored" state should also take OperatorCoordinator state into account by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17669) Use new WatermarkStrategy/WatermarkGenerator in Kafka connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17668) Fix shortcomings in new data structures by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17667) Implement INSERT for Hive dialect by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17666) Insert into partitioned table can fail with select * by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17665) Serialize buffer data type of Buffer into BufferResponse by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17664) Introduce print, blackhole connector in table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17663) CheckpointBarrierUnaligner.getFlattenedChannelIndex can throw ArrayIndexOutOfBoundsException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17662) testDetachedModeSecureWithPreInstallKeytab: "The JobManager and the TaskManager should both run with Kerberos." by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Reading parquet from S3 by Kirill Polunin

by Jingsong Li

GenericType<java.sql.Timestamp>; Actual: LocalDateTime by 邵志鹏

by 邵志鹏

GenericType<org.apache.commons.net.ntp.TimeStamp>; Actual: LocalDateTime by 邵志鹏

by 邵志鹏

[jira] [Created] (FLINK-17661) Add APIs for using new WatermarkStrategy/WatermarkGenerator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17660) DataTypeExtractor does not check for default constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17659) Add common watermark strategies and WatermarkStrategies helper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17658) Add new TimestampAssigner and WatermarkGenerator interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17656) Migrate e2e tests to flink-docker by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17655) Remove old and long deprecated TimestampExtractor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17654) Move Clock classes to flink-core to make them usable outside runtime by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17653) FLIP-126: Unify (and separate) Watermark Assigners by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17652) Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17651) DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17650) Impossible to set Security related configs as dynamic properties by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17649) Generated hash aggregate code may produce NPE when there exists an aggregate call with Filter. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-17647) Improve new connector options exception in old planner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 180181182183184185186 ... 778