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

Topics (27469)

Replies

Last Post

Views

[jira] [Created] (FLINK-21901) Update StateFun version to 3.0-SNAPSHOT by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21900) flink-statebackend-rocksdb test core dump by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21899) Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21898) JobRetrievalITCase crash by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21897) CalcITCase.testPrimitiveMapType[StateBackend=HEAP] fail because of "Not enough resources available for scheduling" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21895) IncrementalAggregateJsonPlanTest.testIncrementalAggregate fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21894) Update type of HiveTablePartition#partitionSpec from Map<String, Object> to Map<String, String> by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21893) A ValidationException will be thrown out when deriveRowType of Rank if partition key is an expression result of Input Node. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21892) Add documentation for the DESC statement syntax by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21891) The .staging_xxx directory isn't deleted after writing data to hive table in batch mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21890) Rename DAGProcessor to ExecNodeGraphProcessor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21889) source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21888) Maintain our own ASTNode class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21887) Add show views test in CliClientITCase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21886) Loosen argument of TableEnvironmentInternal#executeInternal from QueryOperation to Operation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21885) Minor Typo Fix in JDBC Connector Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21884) Reduce TaskManager failure detection time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21883) Introduce cooldown period into adaptive scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21882) Create a Python based greeter example by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21881) Support local global optimization for window aggregation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21880) UnalignedCheckpointRescaleITCase fails on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21878) JoinJsonPlanITCase#testIsNullInnerJoinWithNullCond fails on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21877) Add E2E test for upsert-kafka connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21876) Provide a way to handle when the returned value of Python UDF doesn't match the defined result type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21875) GSRKinesisPubsubClient is not compiling in IntelliJ by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21874) Check for out-dated slot allocation confirmations is insufficient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21872) Create a utility to create DataStream API's DataType and Schema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21871) Support watermark for Hive and Filesystem streaming source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21870) RelDataType of TableFunction different in local and CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21869) Support StreamExecTemporalSort json serialization/deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21868) Support StreamExecLookupJoin json serialization/deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21867) Extend UI to expose also concurrent task failures besides the root cause by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 51525354555657 ... 785