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

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] New Apache Flink Committer - Godfrey He by Jark Wu-2

by bin zhou

[jira] [Created] (FLINK-19368) TableEnvHiveConnectorITCase fails with Hive-3.x by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19367) Migrate Filesystem source to FLIP-27 source interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19366) [umbrella] Migrate Filesystem and Hive to new Table connector interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19365) Migrate Hive table source to new source interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19364) Add Batch Physical Pandas Group Window Aggregate Rule and RelNode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19363) Code of split method grows beyond 64 KB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19362) Remove confusing comment for `DOT` operator codegen by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19361) Create a synchronized metastore client to talk to a remote HMS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19360) Flink fails if JAVA_HOME contains spaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19359) Restore from Checkpoint fails if checkpoint folders is corrupt/partial by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19357) Introduce createBucketWriter to BucketsBuilder by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19356) Introduce FileLifeCycleListener to Buckets by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19354) Add invalidateCache() method in CachedTable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19355) Add close() method to TableEnvironment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19352) Add cache() method to Table by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19353) BlinkPlanner translate and optimize CacheOperation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19350) StreamingJobGraphGenerator generate job graph with cached node by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19351) StreamingJobGraphGenerator set the caching node to BoundedBlockingType by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19349) StreamGraph handle CacheSource and CacheSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19348) Introduce CacheSource and CacheSink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19347) Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19346) Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19345) Introduce File streaming sink compaction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19344) DispatcherResourceCleanupTest#testJobSubmissionUnderSameJobId is unstable on Azure Pipeline by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Does Flink support such a feature currently? by RocMarshal

by Marta Paes Moreira

[jira] [Created] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19341) Update API module for FLIP-107 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19340) AggregateITCase.testListAggWithDistinct failed with "expected:<List(1,A, 2,B, 3,C#A, 4,EF)> but was:<List(1,A, 2,B, 3,C#A, 4,EF#EF)>" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly Community Update 2020/38 by Konstantin Knauf-4

by Konstantin Knauf-4

[DISCUSS] FLIP-33: Standardize connector metrics by Becket Qin

by Konstantin Knauf-4

[jira] [Created] (FLINK-19339) Support Avro's unions with logical types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 124125126127128129130 ... 778