You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation - posted by Hequn Cheng <he...@apache.org> on 2020/08/01 00:40:51 UTC, 11 replies.
- [jira] [Created] (FLINK-18794) Custom metric doesn't work in flink1.11.1 - posted by "JasonLee (Jira)" <ji...@apache.org> on 2020/08/01 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18795) Support for HBase 2 - posted by "Felipe Lolas (Jira)" <ji...@apache.org> on 2020/08/01 18:04:00 UTC, 0 replies.
- Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4) - posted by Roman Khachatryan <ro...@data-artisans.com> on 2020/08/01 21:31:51 UTC, 8 replies.
- [jira] [Created] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/08/01 21:51:00 UTC, 0 replies.
- to be a contributor - posted by 朱丹 <ws...@163.com> on 2020/08/02 03:40:09 UTC, 1 replies.
- Error with Flink-Gelly, lastJobExecutionResult is null - posted by Xia Rui <xi...@smail.nju.edu.cn> on 2020/08/02 09:27:43 UTC, 3 replies.
- [jira] [Created] (FLINK-18797) docs and examples use deprecated forms of keyBy - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/08/02 18:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18798) Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/03 04:02:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-132: Temporal Table DDL - posted by Jark Wu <im...@gmail.com> on 2020/08/03 04:03:47 UTC, 21 replies.
- [jira] [Created] (FLINK-18799) improve slot allocation to make resource balance among machines. - posted by "nobleyd (Jira)" <ji...@apache.org> on 2020/08/03 04:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization - posted by "Mohammad Hossein Gerami (Jira)" <ji...@apache.org> on 2020/08/03 05:49:00 UTC, 0 replies.
- Re: [DISCUSS] StreamingFileSink: parallelizing active buckets checkpointing? - posted by Till Rohrmann <tr...@apache.org> on 2020/08/03 07:45:57 UTC, 0 replies.
- [VOTE] FLIP-133: Rework PyFlink Documentation - posted by jincheng sun <su...@gmail.com> on 2020/08/03 07:56:57 UTC, 10 replies.
- [jira] [Created] (FLINK-18801) Add the new document "10 minutes to PyFlink" - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/03 08:39:00 UTC, 0 replies.
- [VOTE] FLIP-36: Support Interactive Programming in Flink - posted by Xuannan Su <su...@gmail.com> on 2020/08/03 09:00:42 UTC, 0 replies.
- [jira] [Created] (FLINK-18802) Creating an uber jar when packaging flink-avro - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/08/03 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18803) JobGraph cannot be GC when submit via RemoteStreamEnvironment in attach mode - posted by "Libin Qin (Jira)" <ji...@apache.org> on 2020/08/03 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18804) ConfigDocsGenerator should not create files if they contain no options - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/03 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18805) ConfigDocsGenerator does not handle multiple upper characters properly - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/03 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18806) Taskmanager doesn't start up with error in config - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/08/03 13:09:00 UTC, 0 replies.
- [Announce] Flink Forward Global Lineup Released - posted by Seth Wiesman <sj...@gmail.com> on 2020/08/03 16:25:37 UTC, 1 replies.
- dev - posted by 牛奶咖啡 <zh...@163.com> on 2020/08/04 00:34:42 UTC, 0 replies.
- [jira] [Created] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/04 01:57:00 UTC, 0 replies.
- [VOTE] FLIP-132: Temporal Table DDL - posted by Leonard Xu <xb...@gmail.com> on 2020/08/04 03:07:47 UTC, 2 replies.
- [jira] [Created] (FLINK-18808) Task-level numRecordsOut metric may be underestimated - posted by "ming li (Jira)" <ji...@apache.org> on 2020/08/04 03:59:00 UTC, 0 replies.
- Re: [DISCUSS] Planning Flink 1.12 - posted by Kurt Young <yk...@gmail.com> on 2020/08/04 05:51:17 UTC, 19 replies.
- [jira] [Created] (FLINK-18809) Update internal aggregate functions to new type system - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/08/04 07:53:00 UTC, 0 replies.
- Re: [DISCUSS] Introduce SupportsParallelismReport and SupportsStatisticsReport for Hive and Filesystem - posted by Jingsong Li <ji...@gmail.com> on 2020/08/04 08:21:10 UTC, 0 replies.
- Status of FLIPs - posted by Dian Fu <di...@gmail.com> on 2020/08/04 09:40:48 UTC, 2 replies.
- [jira] [Created] (FLINK-18810) Golang remote functions SDK - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2020/08/04 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again - posted by "Kai Chen (Jira)" <ji...@apache.org> on 2020/08/04 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18812) Upgrade StateFun to Flink 1.11.1 - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/08/04 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18813) Translate 'Local Installation' page of 'Try Flink' into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/04 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18814) Translate 'Side Outputs' page of 'DataStream API' into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/04 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/04 18:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18816) Correct API usage in Pyflink Dependency Management page - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/08/05 00:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/05 01:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/05 01:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18819) All the PubSub tests are failing - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/05 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18820) SourceOperator should send MAX_WATERMARK to downstream operator when closed - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2020/08/05 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/08/05 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18822) [umbrella] Improve and complete Change Data Capture formats - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/05 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18823) Support serialization for debezium-json format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/05 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18824) Support serialization for canal-json format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/05 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18825) Support to process CDC message in batch mode - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/05 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18826) Support to emit and encode upsert messages to Kafka - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/05 07:56:00 UTC, 0 replies.
- A question when use flink sql 1.11.0 - posted by 魏烽 <we...@nequal.com> on 2020/08/05 09:14:58 UTC, 1 replies.
- [jira] [Created] (FLINK-18827) The time attribute is lost when constructing a Table via TableEnvironment.from - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/05 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/08/05 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18829) Remove logback-related codepaths and configuration file - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/05 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2020/08/05 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18831) Improve the Python documentation about the operations in Table - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/05 13:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/08/05 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18833) Improve the Python documentation about sql - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/08/06 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18834) Could not locate the included file 'generated/rocks_db_native_metric_configuration.html' - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/08/06 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18835) sql using group by, duplicated group fileld appears - posted by "YHF (Jira)" <ji...@apache.org> on 2020/08/06 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/06 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18837) Allow retract message for StreamSelectTableSink - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/08/06 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18838) Support JdbcCatalog in Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/06 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18839) Add documentation about how to use catalog in Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/06 09:24:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.10.2 - posted by Zhu Zhu <re...@gmail.com> on 2020/08/06 11:25:33 UTC, 9 replies.
- Dependency vulnerabilities with Apache Flink 1.10.1 version - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2020/08/06 12:06:21 UTC, 1 replies.
- [jira] [Created] (FLINK-18840) Support StatementSet with DataStream API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/08/06 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18841) CVE-2018-10237 and CWE-400 occurred in flink dependency - posted by "Jeff Hu (Jira)" <ji...@apache.org> on 2020/08/06 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/07 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18843) Flink WEB-UI ISSUE - posted by "Zhang Jianguo (Jira)" <ji...@apache.org> on 2020/08/07 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18844) support maxwell-json for Maxwell binlog collector - posted by "jinxin (Jira)" <ji...@apache.org> on 2020/08/07 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource. - posted by "HuiyuZhou (Jira)" <ji...@apache.org> on 2020/08/07 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18846) Set a meaningful operator name for the filesystem sink - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/07 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18847) Add documentation about data types in Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/07 07:29:00 UTC, 0 replies.
- Re: [DISCUSS] Upgrade HBase connector to 2.2.x - posted by Robert Metzger <rm...@apache.org> on 2020/08/07 07:30:25 UTC, 7 replies.
- [jira] [Created] (FLINK-18848) table.to_pandas should thrown exceptions if table is not append only - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/07 08:43:00 UTC, 0 replies.
- Re: Adding a new "Docker Images" component to Jira - posted by Robert Metzger <rm...@apache.org> on 2020/08/07 10:18:09 UTC, 5 replies.
- [jira] [Created] (FLINK-18849) Improve the code tabs of the Flink documents - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/07 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18850) Add late records dropped metric for row time over windows - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/08/07 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/08/07 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18852) StreamScan should keep the same parallelism as the input - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2020/08/07 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18853) Supports properties from flink-conf.yaml for SET command in sql client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/08/07 13:43:00 UTC, 0 replies.
- [DISCUSS] Retrieve savepoint location after suspension of jobclusters - posted by Fabian Paul <fa...@data-artisans.com> on 2020/08/07 13:57:53 UTC, 6 replies.
- [jira] [Created] (FLINK-18854) Translate the 'API Migration Guides' page of 'Application Development' into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/08 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18855) Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/08 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/08/08 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18857) Invalid lambda deserialization when use ElasticsearchSink#Builder to build ElasticserachSink - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/08/08 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18858) Kinesis SQL Connector - posted by "Waldemar Hummer (Jira)" <ji...@apache.org> on 2020/08/08 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18859) ExecutionGraphNotEnoughResourceTest.testRestartWithSlotSharingAndNotEnoughResources failed with "Condition was not met in given timeout." - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/09 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18860) Translate "Execution Plans" page of "Managing Execution" into Chinese - posted by "Huang Xiao (Jira)" <ji...@apache.org> on 2020/08/09 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18861) Support add_source() to get a DataStream for Python StreamExecutionEnvironment - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/09 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18862) sql 中agg算子的 count(1) 的结果不能强转成String类型 - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2020/08/09 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18863) Support print() and write_as_text() interface for Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/09 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18864) Support key_by() operation for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/09 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18865) Missing documentation of FlinkKafkaConsumer.setStartFromEarliest behavior when a partition offset becomes out of range - posted by "Vladimirs Kotovs (Jira)" <ji...@apache.org> on 2020/08/09 22:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18866) Support filter() interface for Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/10 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18867) Generic table stored in Hive catalog is incompatible between 1.10 and 1.11 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/10 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18868) Converting data into JSON format with flinksql - posted by "mzz (Jira)" <ji...@apache.org> on 2020/08/10 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18869) Batch SQL end-to-end test unstable due to terminated process - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/10 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18870) [Kinesis][EFO] Update Kinesis Consumer website to reflect EFO - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/08/10 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18871) Non-deterministic function could break retract mechanism - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/08/10 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18872) Aggregate with mini-batch does not respect state retention - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/08/10 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18873) Make the WatermarkStrategy API more scala friendly - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/10 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18874) Support conversion between Table and DataStream - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/10 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18875) DESCRIBE table can return the table properties - posted by "Kaibo Zhou (Jira)" <ji...@apache.org> on 2020/08/10 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18876) BlobServer moves file with an open FileInputStream - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/10 13:05:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Timo Walther <tw...@apache.org> on 2020/08/10 13:32:06 UTC, 1 replies.
- [jira] [Created] (FLINK-18877) Faulty BinarySection.equals() - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/08/10 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/10 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/11 01:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18880) Allow to configure the heap memory used by the gateway server - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/11 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18881) Modify the Access Broken Link - posted by "weizheng (Jira)" <ji...@apache.org> on 2020/08/11 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18882) Investigate supporting Hive interval type - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/11 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18883) Support reduce() operation for Python KeyedStream. - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/11 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for DataStream - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/11 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18885) Add partitioning interfaces for Python DataStream. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/11 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18887) Add ElasticSearch connector for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/11 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18886) Support Kafka connectors for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/11 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18888) Add ElasticSearch connector for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/11 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18889) New Async Table Function type inference fails - posted by "Mulan (Jira)" <ji...@apache.org> on 2020/08/11 06:00:00 UTC, 0 replies.
- Re: [DISCUSS][Release 1.12] Stale blockers and build instabilities - posted by Robert Metzger <rm...@apache.org> on 2020/08/11 06:08:47 UTC, 4 replies.
- Flink cluster deployment strategy - posted by sidhant gupta <si...@gmail.com> on 2020/08/11 07:15:43 UTC, 1 replies.
- [jira] [Created] (FLINK-18890) Update AsyncTableFunctions to the new type system - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/08/11 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18891) flink job failed but yarn application still running via yarn-per-job mode - posted by "Peng (Jira)" <ji...@apache.org> on 2020/08/11 08:18:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records - posted by Dongwon Kim <ea...@gmail.com> on 2020/08/11 11:12:16 UTC, 2 replies.
- [VOTE] Release 1.10.2, release candidate #1 - posted by Zhu Zhu <re...@gmail.com> on 2020/08/11 12:47:38 UTC, 7 replies.
- [jira] [Created] (FLINK-18892) Upgrade Guava to version 28.2-jre - posted by "Igor Dvorzhak (Jira)" <ji...@apache.org> on 2020/08/11 16:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes." - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/11 18:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18894) StateFun job stalls on stop-with-savepoint - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/08/11 20:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster - posted by "Pasha Shaik (Jira)" <ji...@apache.org> on 2020/08/11 22:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18896) Translate "stateful-functions" page into Chinese - posted by "Feng Jie (Jira)" <ji...@apache.org> on 2020/08/12 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18897) Add documentation for the maxwell-json format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/12 03:11:00 UTC, 0 replies.
- 退订 - posted by 智子 <76...@qq.com> on 2020/08/12 03:15:36 UTC, 2 replies.
- [jira] [Created] (FLINK-18898) .flink-runtime.version.properties file does not exist in flink-dist.jar - posted by "Aki Tanaka (Jira)" <ji...@apache.org> on 2020/08/12 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18899) The property yarn.application-attempts default value is not none - posted by "Peng (Jira)" <ji...@apache.org> on 2020/08/12 07:10:00 UTC, 0 replies.
- 来自kris18的邮件 - posted by kris18 <kr...@126.com> on 2020/08/12 07:36:35 UTC, 1 replies.
- [ANNOUNCE] New Flink Committer: David Anderson - posted by Robert Metzger <rm...@apache.org> on 2020/08/12 07:50:47 UTC, 29 replies.
- [jira] [Created] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/12 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18901) Use new type inference for SQL DDL of aggregate functions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/08/12 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18902) Cannot serve results of asynchronous REST operations in per-job mode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/08/12 13:00:12 UTC, 0 replies.
- [jira] [Created] (FLINK-18903) Flink集成Hive内置时间函数使用报错 - posted by "龚旭伦 (Jira)" <ji...@apache.org> on 2020/08/12 14:41:00 UTC, 0 replies.
- [DISCUSS] FLIP-134: DataStream Semantics for Bounded Input - posted by Kostas Kloudas <kk...@apache.org> on 2020/08/12 15:21:24 UTC, 11 replies.
- [jira] [Created] (FLINK-18904) Support multiple source operators chaining in StreamConfig - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/08/12 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18905) Add runtime support for multiple input operator chained with sources - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/08/12 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18906) Support checkpointing with multiple input operator chained with sources - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/08/12 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18907) Add watermarks and metrics tests for MultipleSourceOperatorStreamTask - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/08/12 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18908) Ensure max parallelism is at least 128 - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/08/12 16:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18909) SequenceGenerator doesn't work as expected - posted by "Alan (Jira)" <ji...@apache.org> on 2020/08/12 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18910) Create the new document structure for Python documentation according to FLIP-133 - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18911) Move the "Installation" document from the old Python Table API documentation to the new Python API documentation - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18912) Add a Table API tutorial link under the "Python API" -> "GettingStart" -> "Tutorial" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18913) Add a "TableEnvironment" document under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section with a new name "DataTypes" - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl cause ORC - posted by "wei (Jira)" <ji...@apache.org> on 2020/08/13 04:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18916) Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18917) Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18920) Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18922) Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18923) Add a "CEP" document under the "Python API" -> "User Guide" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18924) Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18925) Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18927) Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18928) Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ" - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18929) Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18930) Translate "Hive Dialect" page of "Hive Integration" into Chinese - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/13 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/13 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18933) Delete the old Python Table API document section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18932) Add a "Overview" document under the "Python API" section - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18934) Idle stream does not advance watermark in connected stream - posted by "Truong Duc Kien (Jira)" <ji...@apache.org> on 2020/08/13 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18935) CompletedOperationCache accepts new operations after closeAsync has been called - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/08/13 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18936) Update documentation about user-defined aggregate functions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/08/13 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18937) Add a "Environment Setup" section to the "Installation" document - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/08/13 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18938) Throw better exception message for quering sink-only connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/13 08:11:00 UTC, 0 replies.
- [DISCUSS] flink authorization supports - posted by Jacky Lau <li...@gmail.com> on 2020/08/13 09:08:21 UTC, 0 replies.
- [jira] [Created] (FLINK-18939) Sort-partition result is incorrect when use Bigdecimal as Key - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2020/08/13 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData" - posted by "jack sun (Jira)" <ji...@apache.org> on 2020/08/13 12:12:00 UTC, 0 replies.
- [Announce] Flink Forward Global Program is now Live - posted by Seth Wiesman <sj...@gmail.com> on 2020/08/13 16:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-18941) There are some typos in "Set up JobManager Memory" - posted by "Peng (Jira)" <ji...@apache.org> on 2020/08/14 01:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18942) HiveTableSink shouldn't try to create BulkWriter factory when using MR writer - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/14 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18943) Support connect() operation for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18944) Support JDBC connector for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/14 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18945) Support key_by() on ConnectedStreams for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18946) Support Cassandra connector for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/14 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18947) Support partitionCustom() operation for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18948) Add end to end test for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18949) Support Streaming File Sink for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18951) Add documentation for Configurations in Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/14 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18950) Add documentation for Operations in Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/14 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18953) Add documentation for DataTypes in Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18954) Add documentation for Metrics in Python DataStream API. - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18952) Add 10 minutes to DataStream API documentation - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/14 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18955) Add snapshot path to job startup message - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/08/14 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18956) StreamTask.invoke should catch Throwable instead of Exception - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/14 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18957) Implement bulk fulfil-ability timeout tracking for shared slots - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/08/14 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18958) Lose column comment when create table - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/08/14 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close - posted by "Liu (Jira)" <ji...@apache.org> on 2020/08/14 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18960) flink sideoutput union - posted by "xiaohang.li (Jira)" <ji...@apache.org> on 2020/08/14 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18961) In the case of FlatMap linking map, if map returns null, an exception will be thrown in FlatMap - posted by "Ryan (Jira)" <ji...@apache.org> on 2020/08/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18962) Improve error message if checkpoint directory is not writable - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/08/14 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18963) Added Copyright information to coding style guide - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/08/14 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18964) package org.apache.flink.sql.parser.impl does not exist - posted by "weizihan (Jira)" <ji...@apache.org> on 2020/08/14 15:37:00 UTC, 0 replies.
- Flink S3 Hadoop dependencies - posted by Satish Saley <sa...@apache.org> on 2020/08/14 18:25:42 UTC, 1 replies.
- [jira] [Created] (FLINK-18965) ExecutionContextTest.testCatalogs failed with "ClassNotFoundException: org.apache.hadoop.fs.BlockStoragePolicySpi" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/15 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/15 04:28:00 UTC, 0 replies.
- flink1.10.0 set execution.attached - posted by 魏烽 <we...@nequal.com> on 2020/08/15 14:50:46 UTC, 2 replies.
- [jira] [Created] (FLINK-18967) Upgrade ORC to 1.5.10 version - posted by "Igor Dvorzhak (Jira)" <ji...@apache.org> on 2020/08/16 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18968) Translate StateFun homepage to Chinese - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2020/08/16 08:50:00 UTC, 0 replies.
- [DISCUSS] FLIP-135: Approximate Task-Local Recovery - posted by Yuan Mei <yu...@gmail.com> on 2020/08/16 14:48:31 UTC, 0 replies.
- [jira] [Created] (FLINK-18969) Source code build error: Could not resolve dependencies for project org.apache.flink:flink-oss-fs-hadoop:jar:1.12-SNAPSHOT - posted by "Xin Wang (Jira)" <ji...@apache.org> on 2020/08/17 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18970) Adding Junit TestMarkers - posted by "goutham (Jira)" <ji...@apache.org> on 2020/08/17 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18971) Support to mount kerberos conf as ConfigMap and Keytab as Secrete - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/08/17 07:13:00 UTC, 0 replies.
- [DISCUSS] Removing deprecated methods from DataStream API - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/08/17 08:53:01 UTC, 13 replies.
- [jira] [Created] (FLINK-18972) Unfulfillable slot requests of Blink planner batch jobs never timeout - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/08/17 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18973) Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/17 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/17 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18975) Translate the 'Execution Plans' page of "Application Development's Managing Execution" into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/17 10:25:00 UTC, 0 replies.
- [VOTE] Release 1.10.2, release candidate #2 - posted by Zhu Zhu <re...@gmail.com> on 2020/08/17 11:55:29 UTC, 8 replies.
- [jira] [Created] (FLINK-18976) Support user defined query in JDBC Source - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/17 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18977) Extract WindowOperator construction into a builder class - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/08/17 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18978) Support full table scan of key and namespace from statebackend - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/08/17 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18979) Update statefun docs to better emphasize remote modules - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/08/17 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18980) "Avro Confluent Schema Registry nightly end-to-end test" hangs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/18 01:54:00 UTC, 0 replies.
- Decompose failure recovery time - posted by Zhinan Cheng <zn...@cse.cuhk.edu.hk> on 2020/08/18 02:06:58 UTC, 4 replies.
- [jira] [Created] (FLINK-18981) Support column comment for Hive tables - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/18 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18982) InputFormat should remove unnecessary override methods - posted by "Ryan Tao (Jira)" <ji...@apache.org> on 2020/08/18 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18983) Job doesn't changed to failed if close function has blocked - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/08/18 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18984) Add tutorial documentation for Python DataStream API - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/18 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18985) Update the Sphinx doc for Python DataStream API. - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/18 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/18 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18987) Sort global job parameters in WebUI job configuration view - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/18 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/08/18 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18989) Write input and output channel state to separate files - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/08/18 16:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18990) Optimize reading ResultSubpartition state - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/08/18 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18991) Optimize reading InputChannel state - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/08/18 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18992) Table API renameColumns method annotation error - posted by "tzxxh (Jira)" <ji...@apache.org> on 2020/08/19 01:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18993) Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java - posted by "Peng (Jira)" <ji...@apache.org> on 2020/08/19 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18994) There is one typo in "Set up TaskManager Memory" - posted by "Peng (Jira)" <ji...@apache.org> on 2020/08/19 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18995) Some Hive functions fail because they need to access SessionState - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/19 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18996) Avoid disorder for time interval join - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/08/19 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18997) Rename type_info to result_type to make it more clear - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/08/19 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2020/08/19 07:34:00 UTC, 0 replies.
- [DISCUSS] FLIP-136: Improve interoperability between DataStream and Table API - posted by Timo Walther <tw...@apache.org> on 2020/08/19 08:22:10 UTC, 2 replies.
- [jira] [Created] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/19 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19000) Forward JobStatus.INITIALIZING timestamp to ExecutionGraph - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/19 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19001) Add data-stream integration for stateful functions - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/08/19 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19002) Support to only read changelogs of specific database and table for canal-json format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/19 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19003) Add micro-benchmark for unaligned checkpoints - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/08/19 12:03:00 UTC, 0 replies.
- Re: [VOTE] FLIP-102: Add More Metrics to TaskManager - posted by Matthias <ma...@ververica.com> on 2020/08/19 15:43:22 UTC, 3 replies.
- [jira] [Created] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/20 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19005) used metaspace grow on every execution - posted by "Guillermo Sánchez (Jira)" <ji...@apache.org> on 2020/08/20 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19006) project transformation does not support conversion to Tuple25 type - posted by "ming li (Jira)" <ji...@apache.org> on 2020/08/20 12:50:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.10.2, release candidate #2 - posted by Zhu Zhu <re...@gmail.com> on 2020/08/20 13:47:32 UTC, 1 replies.
- [jira] [Created] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/20 19:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb) - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2020/08/20 21:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19009) wrong way to calculate the "downtime" metric - posted by "Zhinan Cheng (Jira)" <ji...@apache.org> on 2020/08/21 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19010) Add a system metric to show the checkpoint restore time - posted by "Zhinan Cheng (Jira)" <ji...@apache.org> on 2020/08/21 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19011) Parallelize the restoreOperation in OperatorStateBackend - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/08/21 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument." - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/21 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19013) Log start/end of state restoration - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/21 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19014) Investigate minimum e2e test duration - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/21 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19015) java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15' - posted by "jack sun (Jira)" <ji...@apache.org> on 2020/08/21 10:05:00 UTC, 0 replies.
- Unclean S3 checkpointing using Presto plugin - posted by vishalovercome <vi...@moengage.com> on 2020/08/21 10:29:52 UTC, 0 replies.
- [jira] [Created] (FLINK-19016) Checksum mismatch when restore from RocksDB - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/08/21 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19017) Increases the visibility of a remote function call retry - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/08/21 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19018) Add connection timeout to remote functions. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/08/21 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19019) Add HDFS / S3 / GCS support to Flink-StateFun Docker image. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/08/21 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19020) Add more metrics around async operations and backpressure - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/08/21 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19021) Cleanups of the ResultPartition components - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/21 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19022) AkkaRpcActor failed to start but no exception information - posted by "tartarus (Jira)" <ji...@apache.org> on 2020/08/21 14:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-19023) Remove pruning of Record Serializer Buffer - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/21 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19024) Remove unused "releaseMemory" from ResultSubpartition - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/21 16:07:00 UTC, 0 replies.
- SDK vs Connectors - posted by Prasanna kumar <pr...@gmail.com> on 2020/08/21 18:00:51 UTC, 2 replies.
- [jira] [Created] (FLINK-19025) table sql write orc file but hive2.1.1 can not read - posted by "McClone (Jira)" <ji...@apache.org> on 2020/08/22 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19026) Improve threading model of Unaligner - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/08/22 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/23 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19028) Translate the "application_parameters.zh.md" into Chinese - posted by "pp (Jira)" <ji...@apache.org> on 2020/08/23 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19029) Collect mulitple jobs in 1 UI - posted by "Nikola (Jira)" <ji...@apache.org> on 2020/08/24 04:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19030) Support lookup source for filesystem connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/24 05:22:00 UTC, 0 replies.
- [DISCUSS] FLIP-137: Support Pandas UDAF in PyFlink - posted by Xingbo Huang <hx...@gmail.com> on 2020/08/24 06:24:31 UTC, 2 replies.
- Next Stateful Functions Release - posted by Igal Shilman <ig...@ververica.com> on 2020/08/24 08:15:26 UTC, 6 replies.
- OutOfMemoryError: Metaspace on Batch Task When Write into Clickhouse - posted by 耿延杰 <gy...@qq.com> on 2020/08/24 08:20:42 UTC, 5 replies.
- 回复：OutOfMemoryError: Metaspace on Batch Task When Write into Clickhouse - posted by 耿延杰 <gy...@qq.com> on 2020/08/24 08:33:01 UTC, 1 replies.
- [DISCUSS] Introduce partitioning strategies to Table/SQL - posted by Jingsong Li <ji...@gmail.com> on 2020/08/24 08:54:26 UTC, 1 replies.
- [jira] [Created] (FLINK-19031) Remove deprecated setStateBackend(AbstactStateBackend) - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/24 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19032) Remove deprecated RuntimeContext#getAllAcumullators - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/24 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19033) Cleanups of DataStream API - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/24 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/24 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19035) Remove deprecated DataStream#fold() method and all related classes - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/24 09:30:00 UTC, 0 replies.
- [VOTE] FLIP-134: DataStream Semantics for Bounded Input - posted by Kostas Kloudas <kk...@gmail.com> on 2020/08/24 09:33:59 UTC, 0 replies.
- [jira] [Created] (FLINK-19036) Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/24 10:01:00 UTC, 0 replies.
- Flink kubernetes autoscale - posted by Mazen <ma...@etu.unice.fr> on 2020/08/24 10:18:10 UTC, 2 replies.
- [jira] [Created] (FLINK-19037) Introduce proper IO executor in Dispatcher - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/24 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19038) It doesn't support to call Table.fetch() continuously - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/24 12:14:00 UTC, 0 replies.
- [DISCUSS] Remove Kafka 0.10.x connector (and possibly 0.11.x) - posted by Aljoscha Krettek <al...@apache.org> on 2020/08/24 14:46:45 UTC, 7 replies.
- [jira] [Created] (FLINK-19039) Parallel Flink Kafka Consumers compete with each other - posted by "Ayrat Hudaygulov (Jira)" <ji...@apache.org> on 2020/08/24 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19040) SourceOperator is not closing SourceReader - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/08/24 15:50:00 UTC, 0 replies.
- [VOTE] FLIP-132: Temporal Table DDL and Temporal Table Join - posted by Leonard Xu <xb...@gmail.com> on 2020/08/24 15:54:53 UTC, 5 replies.
- Re: How jobmanager and task manager communicates with each other ? - posted by sidhant gupta <si...@gmail.com> on 2020/08/24 16:26:00 UTC, 3 replies.
- [jira] [Created] (FLINK-19041) Add dependency management for ConnectedStream in Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/25 01:40:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.10.2 released - posted by Zhu Zhu <re...@gmail.com> on 2020/08/25 03:36:30 UTC, 10 replies.
- [jira] [Created] (FLINK-19042) HiveTableSourceITCase fails if object reuse is enabled - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/25 07:10:00 UTC, 0 replies.
- [DISCUSS] Whether catalog table factory should be used for temporary tables - posted by Rui Li <li...@gmail.com> on 2020/08/25 07:37:21 UTC, 6 replies.
- [jira] [Created] (FLINK-19043) Translate the page 'Logging' of 'Debugging & Monitoring' into Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/08/25 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19044) Web UI reports incorrect timeline for the FINISHED state of a subtask - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/08/25 08:27:00 UTC, 0 replies.
- [DISCUSS] FLIP-138: Declarative Resource management - posted by Chesnay Schepler <ch...@apache.org> on 2020/08/25 08:48:30 UTC, 11 replies.
- [flink-sql-connector-elasticsearch]相关问题 - posted by "Li,Qian(DXM,PB)" <li...@duxiaoman.com> on 2020/08/25 09:38:45 UTC, 2 replies.
- [jira] [Created] (FLINK-19045) Remove obsolete option 'taskmanager.network.partition.force-release-on-consumption' - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/25 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19046) Introduce separate classes for PipelinedResultPartition and BoundedBlockingResultPartition - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/25 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19047) Move unaligned checkpoint methods from ResultPartition to separate interface. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/25 10:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-19048) suuport line format for table connector - posted by "badqiu (Jira)" <ji...@apache.org> on 2020/08/25 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19049) TableEnvironmentImpl.executeInternal() does not wait for the final job status - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/25 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19050) Doc of MAX_DECIMAL_PRECISION should be DECIMAL - posted by "Pua (Jira)" <ji...@apache.org> on 2020/08/25 12:23:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/31-34 - posted by Konstantin Knauf <kn...@apache.org> on 2020/08/25 20:22:41 UTC, 1 replies.
- HadoopOutputFormat has issues with LocalExecutionEnvironment? - posted by Ken Krugler <kk...@transpac.com> on 2020/08/25 23:10:28 UTC, 0 replies.
- [DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API - posted by Wei Zhong <we...@gmail.com> on 2020/08/26 03:27:43 UTC, 4 replies.
- [jira] [Created] (FLINK-19051) Exception message should be reserved in log When the Job Manager failed - posted by "Pua (Jira)" <ji...@apache.org> on 2020/08/26 07:38:00 UTC, 0 replies.
- [ANNOUNCE] Introducing the GSoD 2020 Participants. - posted by Marta Paes Moreira <ma...@ververica.com> on 2020/08/26 09:12:22 UTC, 6 replies.
- [DISCUSS] FLIP-141: Intra-Slot Managed Memory Sharing - posted by Xintong Song <to...@gmail.com> on 2020/08/26 09:31:47 UTC, 4 replies.
- [jira] [Created] (FLINK-19052) Performance issue with PojoSerializer - posted by "Roman Grebennikov (Jira)" <ji...@apache.org> on 2020/08/26 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19053) Flink Kafka Connector Dependency Error - posted by "liugh (Jira)" <ji...@apache.org> on 2020/08/26 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19054) KafkaTableITCase.testKafkaSourceSink hangs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/26 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19055) MemoryManagerSharedResourcesTest contains three tests running extraordinary long - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/08/26 11:45:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API) - posted by Aljoscha Krettek <al...@apache.org> on 2020/08/26 15:29:02 UTC, 0 replies.
- [jira] [Created] (FLINK-19056) Investigate multipart upload performance regression - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/08/26 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19057) Avoid usage of GlobalConfiguration in ResourceManager - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/08/27 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19058) Dataset transformations document page error - posted by "Fin-chan (Jira)" <ji...@apache.org> on 2020/08/27 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19059) Support to consume retractions for OVER WINDOW operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/08/27 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19060) Checkpoint not triggered when use broadcast stream - posted by "henvealf (Jira)" <ji...@apache.org> on 2020/08/27 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/27 09:14:00 UTC, 0 replies.
- [ANNOUNCE] New PMC member: Dian Fu - posted by jincheng sun <su...@gmail.com> on 2020/08/27 09:23:09 UTC, 27 replies.
- [jira] [Created] (FLINK-19062) Improve alter table DDL - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/08/27 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19063) Support join late event from dimension table side in temporal table join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/27 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19064) HBaseRowDataInputFormat is leaking resources - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/27 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join - posted by "Maris (Jira)" <ji...@apache.org> on 2020/08/27 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19066) InnerJoinITCase.testBigForSpill failed with "java.lang.ClassCastException: org.apache.flink.table.runtime.util.ResettableExternalBuffer$BufferIterator cannot be cast to org.apache.flink.table.data.binary.BinaryRowData" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/28 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19067) FileNotFoundException when run flink examples on standby JobManager - posted by "JieFang.He (Jira)" <ji...@apache.org> on 2020/08/28 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19068) Filter verbose pod events for KubernetesResourceManagerDriver - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/08/28 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/08/28 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19070) Hive connector should throw a meaningful exception if user reads/writes ACID tables - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/28 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19071) Some Hive window functions are not supported - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/08/28 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19072) Import Temporal Table join rule - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19074) Materialize timeindicator in the right input of temporal join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19073) Improve streamExecTemporalJoinRule - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19075) Infer changelog trait for temporal join node - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19078) Import rowtime join temporal operator - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19076) Import rule to deal Temporal Join condition - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19077) Improve process time temporal join operator - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19079) Support row time deduplicate operator - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19080) Materialize timeindicator data type in the right input of temporal join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19082) Add docs for temporal table and temporal table join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19081) Deprecate TemporalTableFunction and Table$createTemporalTableFunction() - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/28 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19083) Remove deprecated DataStream#split - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/28 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19084) Remove deprecated methods in ExecutionConfig - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/28 07:00:12 UTC, 0 replies.
- [jira] [Created] (FLINK-19085) Remove deprecated methods for writing CSV and Text files from DataStream - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/28 07:11:00 UTC, 0 replies.
- [VOTE] Remove deprecated DataStream#fold and DataStream#split in 1.12 - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/08/28 07:41:43 UTC, 5 replies.
- [jira] [Created] (FLINK-19086) Performance regressin 2020-08-28 in globalWindow benchmark - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/08/28 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19087) ReaultPartitionWriter should not expose subpartition but only subpartition-readers - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/08/28 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19088) flink sql 1.11 HbaseTableSource Supports FilterPushDown - posted by "sijun.huang (Jira)" <ji...@apache.org> on 2020/08/28 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19089) Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue - posted by "dugenkui (Jira)" <ji...@apache.org> on 2020/08/29 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19090) Translate "Local Cluster" of "Clusters & Depolyment" page into Chinese - posted by "Huang Xiao (Jira)" <ji...@apache.org> on 2020/08/29 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19091) Introduce expression DSL for Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/29 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19092) Parse comment on computed column failed - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/29 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19093) "Elasticsearch (v6.3.1) sink end-to-end test" failed with "SubtaskCheckpointCoordinatorImpl was closed without closing asyncCheckpointRunnable 1" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/08/30 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19094) Revise the description watermark strategy in Flink Table document - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/08/31 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19095) Add expire mode for remote function state TTL - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/08/31 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19096) Simplify PersistedStateRegistry state registration methods - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/08/31 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19097) Support add_jar() for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/08/31 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19098) Make Rowdata converters public - posted by "Brian Zhou (Jira)" <ji...@apache.org> on 2020/08/31 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19099) consumer kafka message repeat - posted by "zouwenlong (Jira)" <ji...@apache.org> on 2020/08/31 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19100) Fix note about hadoop dependency from flink-avro - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/08/31 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19101) The SelectivityEstimator throw an NullPointerException when convertValueInterval with string type - posted by "fa zheng (Jira)" <ji...@apache.org> on 2020/08/31 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19102) Make StateBinder a per-FunctionType entity - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/08/31 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19103) The PushPartitionIntoTableSourceScanRule will lead a performance problem when there are still many partitions after pruning - posted by "fa zheng (Jira)" <ji...@apache.org> on 2020/08/31 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19104) how to run Fraud Detection walkthrough in Eclipse - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/08/31 10:10:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/35 - posted by Konstantin Knauf <kn...@apache.org> on 2020/08/31 11:30:55 UTC, 0 replies.
- Re: FileSystemHaServices and BlobStore - posted by Khachatryan Roman <kh...@gmail.com> on 2020/08/31 12:51:27 UTC, 0 replies.