(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 ... 38394041424344 ... 782

Topics (27369)

Replies

Last Post

Views

[jira] [Created] (FLINK-22225) Improve time formatting in LeaderRetrievalUtils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22224) Nettys NativeLibraryLoader is quite noisy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22223) Explicitly configure rest.address in distribution config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22221) Unclear purpose of spill directories by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22222) Global config is logged twice by the client for batch jobs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22220) Log task registration at network on debug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22219) Deduplicate enabling of external resources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22218) Skip logging of final null input split by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22217) Add quotes around job names by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22216) Log start of RM on info, instead of DeclarativeSlotManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22214) Add quotes around checkpoint storage types by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22215) Rename RECOVERING state to RESTORING by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22213) Do not log hashcode of filesystem factory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22212) Clean up RM resource requirement logging by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22211) DataStream.collect() logs warnings if job is not initialized yet by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22210) Log conversion of input channels on debug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22208) Bump snappy-java to 1.1.5+ by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22207) Hive Catalog retrieve Flink Properties error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22206) Add support server-mode submit for flink SQL. eg : FlinkServer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22205) Does it support gpu coding in flink? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22204) Does it support rate-limiting in flink 1.12? by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22203) KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to ConcurrentModificationException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22202) Thread safety in ParquetColumnarRowInputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22201) Incorrect output for simple sql query by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22199) The JDBC connector does not support TIMESTAMP(6) WITH LOCAL TIME ZONE NOT NULL. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22193) HiveTableSinkITCase.testNonPartStreamingMrWrite fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22192) HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 38394041424344 ... 782