(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 ... 979899100101102103 ... 785

Topics (27475)

Replies

Last Post

Views

[jira] [Created] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20460) Support async lookup for HBase connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20459) Handle null message correctly in JSON RowData deserializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20458) Translate page 'SQL-gettingStarted' into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20456) Make streaming SQL concepts more approachable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20455) Add check to LicenseChecker for top level /LICENSE files in shaded jars by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20453) Move checkpointing classes to a the appropriate package by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20450) Missing usage information on "run-application" in Flink CLI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

State Processor API SQL State by Dominik Wosiński

by Dominik Wosiński

[jira] [Created] (FLINK-20449) UnalignedCheckpointITCase times out by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20448) Obsolete generated avro classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20447) Querying grouy by PK does not work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS]Select Chinese words from table union all get java.lang.OutOfMemoryError: Java heap space on Flink 1.9.x with Blink planner by Smile

by Smile

[jira] [Created] (FLINK-20446) NoMatchingTableFactoryException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20445) NoMatchingTableFactoryException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20444) Chain AsyncWaitOperator to new sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20443) ContinuousProcessingTimeTrigger lost data in last interval in per window by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20442) Fix license documentation mistakes in flink-python.jar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.12.0, release candidate #2 by Robert Metzger

by Robert Metzger

[jira] [Created] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in Hop window by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20439) Consider simplifying or removing mechanism to scheduleOrUpdateConsumers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20438) org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20437) Port ExecNode to Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20436) Simplify type parameter of ExecNod by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20435) Refactor ExecNode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

flink 1.9 Restore from a checkpoint taken in 1.11 by Lu Niu

by Yun Tang

[jira] [Created] (FLINK-20434) Getting The desired archetype does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20432) SQLClientSchemaRegistryITCase hangs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1> by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 979899100101102103 ... 785