Apache Flink Mailing List archive.

This forum is an archive for the mailing list dev@flink.apache.org (more options) Messages posted here will be sent to this mailing list.

This is a public archive of the Flink mailing mailing list.

More about the different Flink mailing lists: http://flink.apache.org/community.html#community

New Topic

People

1234 ... 653

Topics (22825)

Replies

Last Post

Views

[DISCUSS] FLIP-143: Unified Sink API by Guowei Ma

by Aljoscha Krettek-2

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

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19360) Flink fails if JAVA_HOME contains spaces by Xuannan Su (Jira)

by Xuannan Su (Jira)

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

by Xuannan Su (Jira)

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

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19357) Introduce createBucketWriter to BucketsBuilder by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19356) Introduce FileLifeCycleListener to Buckets by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19354) Add invalidateCache() method in CachedTable by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19355) Add close() method to TableEnvironment by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19352) Add cache() method to Table by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19353) BlinkPlanner translate and optimize CacheOperation by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19350) StreamingJobGraphGenerator generate job graph with cached node by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19351) StreamingJobGraphGenerator set the caching node to BoundedBlockingType by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19349) StreamGraph handle CacheSource and CacheSink by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19348) Introduce CacheSource and CacheSink by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19347) Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor by Xuannan Su (Jira)

by Xuannan Su (Jira)

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

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19345) Introduce File streaming sink compaction by Xuannan Su (Jira)

by Xuannan Su (Jira)

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

by Robert Metzger

[jira] [Created] (FLINK-19344) DispatcherResourceCleanupTest#testJobSubmissionUnderSameJobId is unstable on Azure Pipeline by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19343) FLIP-36: Support Interactive Programming in Flink by Xuannan Su (Jira)

by Xuannan Su (Jira)

Does Flink support such a feature currently? by Roc Marshal

by Marta Paes Moreira

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

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19341) Update API module for FLIP-107 by Xuannan Su (Jira)

by Xuannan Su (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 Xuannan Su (Jira)

by Xuannan Su (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

Kafka connection issues by Ramya Ramamurthy

by Ramya Ramamurthy

[jira] [Created] (FLINK-19339) Support Avro's unions with logical types by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19338) New source interface cannot unregister unregistered source by Xuannan Su (Jira)

by Xuannan Su (Jira)

Automatically get udf's resource files from hdfs when running a job that uses hive-udf by Husky Zeng

by Jark Wu-2

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

by Yu Li

[jira] [Created] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name. by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19336) EncodingUtils#encodeObjectToString should propagate inner exception by Xuannan Su (Jira)

by Xuannan Su (Jira)

[jira] [Created] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf by Xuannan Su (Jira)

by Xuannan Su (Jira)

1234 ... 653