(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 ... 104105106107108109110 ... 778

Topics (27218)

Replies

Last Post

Views

[jira] [Created] (FLINK-19989) Add collect operation in Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19987) HBaseDynamicTableFactoryTest.testTableSourceFactory failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19986) The automatic license check failed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19985) job went into zombie state after ZK session timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19982) AggregateReduceGroupingITCase.testSingleAggOnTable_SortAgg by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19981) Improve dealing with Row in DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19980) Add StreamTableEnvironment.to/fromChangelogStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19979) Sanity check after bash e2e tests for no leftover processes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19978) Add StreamStatementSet.attachToStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19977) Add new toDataStream and toDataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19976) FLIP-136: Improve interoperability between DataStream and Table API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-136: Improve interoperability between DataStream and Table API by Timo Walther-2

by Timo Walther-2

[jira] [Created] (FLINK-19975) Bump testconatiners version by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19974) SQLClientKafkaITCase.testKafka times out while creating topic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19972) Provide more details when type serializers are not compatible by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19971) flink-connector-hbase-base depends on hbase-server, instead of hbase-client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19969) CliFrontendParser does not provide any help for run-application by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Releasing StateFun hotfix version 2.2.1 by Tzu-Li (Gordon) Tai

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-19968) Exception in thread "main" java.lang.IllegalStateException: No ExecutorFactory found to execute the application. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19967) Clean legacy classes for Parquet and Orc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19966) Filter push down not work for filesystem connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19965) Refactor HiveMapredSplitReader to adapt to the new hive source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19964) Gelly ITCase stuck on Azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19963) Let the `SinkWriter` support using the `TimerService` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19962) fix doc: more examples for expanding arrays into a relation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19961) Bash e2e utility run_test_with_timeout is (sometimes?) not properly stopping it's watchdog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19960) Introduce PartitionFieldExtractor to extract partition field from split by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19959) Multiple input creation algorithm will deduce an incorrect input order if the inputs are related under PIPELINED shuffle mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-19958) Unified exception signature in Sink API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] New Apache Flink Committer - Congxian Qiu by Yu Li

by Guowei Ma

1 ... 104105106107108109110 ... 778