(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 ... 382383384385386387388 ... 784

Topics (27408)

Replies

Last Post

Views

[jira] [Created] (FLINK-11933) Exception in thread "main" java.lang.RuntimeException: No data sinks have been created yet. A program needs at least one sink that consumes data. Examples are writing the data set or printing it. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11932) Add support for generating optimized logical plan for 'select * from mytable' by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11931) Avro Bulk Writer Factory for StreamingFileSink Bulk Format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11930) Split SegmentsUtil into some dedicated utilities by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11928) Create a Compression string writer for flink-connectors-filesystem by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply contributor permission by Jacky Yin 殷传旺

by Fabian Hueske-2

[jira] [Created] (FLINK-11927) Code clean up and refactor BinaryHashTable and LongHybridHashTable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11925) KryoSerializerSnapshot doesn't completely capture state / configuration of Kryo instance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11924) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "EXISTS" at line 1, column 40. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11923) Move reporter instantiation into MetricRegistryConfiguration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11922) Support MetricReporter factories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11921) Upgrade Calcite dependency to 1.19 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

I want to contribute to Apache Flink. by 徐小斌

by Chesnay Schepler-3

[jira] [Created] (FLINK-11920) EnumValueSerializerUpgradeTest fails on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11919) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.8.0, release candidate #1 by Aljoscha Krettek-2

by jincheng sun

[jira] [Created] (FLINK-11918) Deprecated Window and Rename it to GroupWindow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11917) Allow state schema migration from Kryo to POJO / Avro by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11916) Join with a Temporal Table should throw exception for left join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11915) DataInputViewStream skip returns wrong value by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11914) Expose a REST endpoint in JobManager to disconnect specific TaskManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11913) Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka consumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11911) KafkaTopicPartition is not a valid POJO by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Status of FLINK-2491 (Checkpointing of shutdown sources) by mxm

by mxm

[jira] [Created] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11908) Port window classes into flink-api-java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11907) GenericTypeInfoTest fails on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11906) Getting error while submitting job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-11905) BlockCompressionTest does not compile with Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Submitting a Flink Job via the Flink Dash Board by Durga Durga

by Chesnay Schepler-3

[jira] [Created] (FLINK-11904) Improve MemoryStateBackendTest by using JUnit's Parameterized by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 382383384385386387388 ... 784