dev@flink.apache.org, 2020-11

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Created] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/11/01 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19910) Table API & SQL Data Types Document error - posted by "ZiHaoDeng (Jira)" <ji...@apache.org> on 2020/11/01 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19911) Read checkpoint stream with buffer to speedup restore - posted by "fanrui (Jira)" <ji...@apache.org> on 2020/11/01 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/01 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/11/02 01:41:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Apache Flink 1.11.3 - posted by Steven Wu <st...@gmail.com> on 2020/11/02 02:01:38 UTC, 22 replies.
- [jira] [Created] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/02 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19915) wrong comments of cep test - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/11/02 06:38:00 UTC, 0 replies.
- Re: [DISCUSS][Release 1.12] Stale blockers and build instabilities - posted by Dian Fu <di...@gmail.com> on 2020/11/02 06:43:18 UTC, 0 replies.
- Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu - posted by Danny Chan <da...@apache.org> on 2020/11/02 07:46:06 UTC, 7 replies.
- [jira] [Created] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/02 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19917) RocksDBInitTest.testTempLibFolderDeletedOnFail fails on Windows - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/02 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19918) RocksIncrementalCheckpointRescalingTest.testScalingDown fails on Windows - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/02 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19919) Remove legacy scheduling in ExecutionGraph components - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/02 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19920) Remove legacy FailoverStrategy - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/02 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19921) Remove legacy RestartStrategy - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/02 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19922) Remove SlotProvider from SchedulerNG - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/02 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19923) Remove BulkSlotProvider, its implementation and tests - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/02 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19924) Disallow unaligned checkpoints for iterative jobs - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/11/02 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/11/02 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19926) Wrong results for join post tumble grouping - posted by "Satyam Shekhar (Jira)" <ji...@apache.org> on 2020/11/02 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/02 10:41:00 UTC, 0 replies.
- [DISCUSS] Releasing StateFun hotfix version 2.2.1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/11/02 10:43:02 UTC, 5 replies.
- [jira] [Created] (FLINK-19928) Introduce test configuration to detect instabilities better - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/02 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19929) Upgrade Kinesis dependencies to avoid protobuf 2.6.1 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/02 13:08:01 UTC, 0 replies.
- [jira] [Created] (FLINK-19930) Upgrade cassandra-driver-core to 4.X - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/02 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19931) Do not emit intermediate results for reduce operation BATCH execution mode - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/02 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19932) Add integration test for BATCH execution on DataStream API - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/11/02 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19933) Execute and collect with limit fails on bounded datastream jobs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/11/02 18:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.execute(Runnable) - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2020/11/03 02:02:00 UTC, 0 replies.
- Dependency injection and flink. - posted by santhosh venkat <sa...@gmail.com> on 2020/11/03 02:14:16 UTC, 1 replies.
- [jira] [Created] (FLINK-19935) OOM error occur for sql-client sumit job without JVM heap setting - posted by "harold.miao (Jira)" <ji...@apache.org> on 2020/11/03 02:33:00 UTC, 0 replies.
- Could someone please take a look at mr PR, thanks - posted by JiaTao Tao <ta...@gmail.com> on 2020/11/03 02:35:40 UTC, 2 replies.
- [jira] [Created] (FLINK-19936) Make SinkITCase more stable - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/03 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19937) Support sink parallelism for all connectors - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2020/11/03 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19938) Implement shuffle data read scheduling for sort-merge blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/11/03 05:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19939) Remove redundant union from multiple input node - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/03 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/03 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19941) Support sink parallelism configuration to Kafka connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19942) Support sink parallelism configuration to JDBC connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19944) Support sink parallelism configuration to Hive connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19945) Support sink parallelism configuration to FileSystem connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19946) Support sink parallelism configuration to Hbase connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19947) Support sink parallelism configuration to Print connector - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/03 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19948) CAST(now() as bigint) throws compile exception - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/03 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19949) Unescape CSV format line delimiter character - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/11/03 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19950) LookupJoin can not support view or subquery and so on. o - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/11/03 08:30:00 UTC, 0 replies.
- [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Nicholas Jiang <pr...@163.com> on 2020/11/03 09:34:23 UTC, 0 replies.
- [jira] [Created] (FLINK-19951) PyFlink end-to-end test stuck in "Reading kafka messages" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/03 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19952) flink SecurityOptions.class use depracted method so mant times - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/11/03 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19953) Translation in docs/ops/memory/mem_setup.zh.md - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/03 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19954) Move execution deployment tracking logic from legacy EG code to SchedulerNG - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/03 13:33:00 UTC, 0 replies.
- Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image - posted by Xie Billy <bi...@gmail.com> on 2020/11/03 14:08:15 UTC, 4 replies.
- [jira] [Created] (FLINK-19955) Document cross-version compatibility - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/03 16:10:00 UTC, 0 replies.
- [DISCUSS] FLIP-151: Incremental snapshots for heap-based state backend - posted by Khachatryan Roman <kh...@gmail.com> on 2020/11/04 01:54:25 UTC, 2 replies.
- [jira] [Created] (FLINK-19956) $ does not work on variables without being qualified in Scala - posted by "Rex Remind (Jira)" <ji...@apache.org> on 2020/11/04 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19957) flink-sql-connector-hive incompatible with cdh6 - posted by "Cheng Pan (Jira)" <ji...@apache.org> on 2020/11/04 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19958) Unified exception signature in Sink API - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/04 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19959) Multiple input creation algorithm will deduce an incorrect input order if the inputs are related under PIPELINED shuffle mode - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/04 04:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19960) Introduce PartitionFieldExtractor to extract partition field from split - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/04 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19961) Bash e2e utility run_test_with_timeout is (sometimes?) not properly stopping it's watchdog - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/04 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19962) fix doc: more examples for expanding arrays into a relation - posted by "Mulan (Jira)" <ji...@apache.org> on 2020/11/04 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19963) Let the `SinkWriter` support using the `TimerService` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/04 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19964) Gelly ITCase stuck on Azure - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/04 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19965) Refactor HiveMapredSplitReader to adapt to the new hive source - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/11/04 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19966) Filter push down not work for filesystem connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/04 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19967) Clean legacy classes for Parquet and Orc - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/04 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19968) Exception in thread "main" java.lang.IllegalStateException: No ExecutorFactory found to execute the application. - posted by "PeteZhang (Jira)" <ji...@apache.org> on 2020/11/04 10:05:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 2.2.1, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/11/04 10:20:29 UTC, 4 replies.
- [jira] [Created] (FLINK-19969) CliFrontendParser does not provide any help for run-application - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/11/04 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state) - posted by "Thomas Wozniakowski (Jira)" <ji...@apache.org> on 2020/11/04 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19971) flink-connector-hbase-base depends on hbase-server, instead of hbase-client - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/04 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19972) Provide more details when type serializers are not compatible - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/04 12:25:00 UTC, 0 replies.
- Resource Optimization for Flink Job in AWS EMR Cluster - posted by DEEP NARAYAN Singh <ab...@gmail.com> on 2020/11/04 12:56:32 UTC, 5 replies.
- [jira] [Created] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/11/04 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19974) SQLClientKafkaITCase.testKafka times out while creating topic - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/04 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19975) Bump testconatiners version - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/11/04 14:45:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-136: Improve interoperability between DataStream and Table API - posted by Timo Walther <tw...@apache.org> on 2020/11/04 14:53:56 UTC, 0 replies.
- [jira] [Created] (FLINK-19976) FLIP-136: Improve interoperability between DataStream and Table API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/04 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19977) Add new toDataStream and toDataStream - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/04 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19978) Add StreamStatementSet.attachToStream - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/04 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19980) Add StreamTableEnvironment.to/fromChangelogStream - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/04 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19979) Sanity check after bash e2e tests for no leftover processes - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/04 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19981) Improve dealing with Row in DataStream API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/04 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19982) AggregateReduceGroupingITCase.testSingleAggOnTable_SortAgg - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/04 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/04 18:17:00 UTC, 0 replies.
- [DISCUSS] Planning the 1.12 release testing - posted by Robert Metzger <rm...@apache.org> on 2020/11/04 19:05:08 UTC, 3 replies.
- [jira] [Created] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2020/11/05 00:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19985) job went into zombie state after ZK session timeout - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2020/11/05 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19986) The automatic license check failed - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/05 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19987) HBaseDynamicTableFactoryTest.testTableSourceFactory failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/05 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/11/05 04:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19989) Add collect operation in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/05 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19990) MultipleInputNodeCreationProcessor#isChainableSource should consider DataStreamScanProvider - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/05 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19991) UnalignedCheckpointITCase#shouldPerformUnalignedCheckpointMassivelyParallel fails on Azure Pipeline - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/11/05 08:35:00 UTC, 0 replies.
- Re: [VOTE] Remove flink-connector-filesystem module. - posted by Kostas Kloudas <kk...@gmail.com> on 2020/11/05 08:40:41 UTC, 0 replies.
- [jira] [Created] (FLINK-19992) Integrate new orc to Hive source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/05 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19993) Remove the flink-connector-filesystem module - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/11/05 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/05 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19995) 【Flink SQL Client】Use Flink Kafka Connector has more one exception - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/11/05 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19996) Add end-to-end IT case for Debezium + Kafka + temporal join - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/05 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19997) Implement an e2e test for sql-client with Confluent Registry Avro format - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/05 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19998) Invalid Link to checkpoints and Savepoints in stateful stream processing concepts - posted by "Aditya Agarwal (Jira)" <ji...@apache.org> on 2020/11/05 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-19999) State Processor API classes leaking into savepoint - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/05 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20000) Extend the license checker to ensure that 3rd party licenses are shipped - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/05 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20001) Don't use setAllVerticesInSameSlotSharingGroupByDefault in StreamGraphGenerator - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/11/05 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20002) Add a StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/05 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20003) Improve slot report logging messages - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/05 13:03:00 UTC, 0 replies.
- [DISCUSS] Move license check utility to a new repository to share it with flink-statefun - posted by Robert Metzger <rm...@apache.org> on 2020/11/05 13:53:30 UTC, 2 replies.
- [jira] [Created] (FLINK-20004) UpperLimitExceptionParameter description is misleading - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/11/05 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20005) "Kerberized YARN application" test unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/05 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8> - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/05 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20007) SinkTransformationTranslator fail to handle the PartitionTransformation - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/05 16:38:00 UTC, 0 replies.
- Investigating flinK - posted by Diana El-Masri <di...@polymtl.ca.INVALID> on 2020/11/05 18:01:58 UTC, 3 replies.
- [jira] [Created] (FLINK-20008) Java Deadlock in ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement() - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/05 18:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20009) Add 404 check to docs build - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/11/05 19:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20010) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on Azure Pipeline - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/11/06 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20012) Hive 3.1 integration exception - posted by "Dino Zhang (Jira)" <ji...@apache.org> on 2020/11/06 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/06 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/11/06 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20014) Resolve CVE-2020-11022 and CVE-2020-11023 in scala-compiler - posted by "Alan Leong (Jira)" <ji...@apache.org> on 2020/11/06 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20015) Failure to execute streaming query - posted by "Satyam Shekhar (Jira)" <ji...@apache.org> on 2020/11/06 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20016) Support TimestampAssigner and WatermarkGenerator for Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/11/06 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20017) Promote the error message for join two windowed stream with time attributes - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/11/06 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20018) pipeline.cached-files option cannot escape ':' in path - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2020/11/06 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20019) Support all conversion classes in Row.equals/hashCode - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/06 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/11/06 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20021) Cleanup several "Dispatcher"/"Jobmanager" misuses in the docs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/06 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20022) Move statebackend tradeoffs to from production readiness checklist to statebackend page - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/06 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20023) Remove note about matching hadoop version from standalone setup docs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/06 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20024) Link to flink-docker repository in the docker documentation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/06 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20025) Add flink-docker and flink-statefun-docker to repository overview page - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/11/06 09:58:00 UTC, 0 replies.
- [VOTE] Adopt jemalloc as default memory allocator in docker image - posted by Yun Tang <my...@LIVE.COM> on 2020/11/06 11:18:02 UTC, 6 replies.
- [jira] [Created] (FLINK-20026) Jdbc connector support regular expression - posted by "Peihui He (Jira)" <ji...@apache.org> on 2020/11/06 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20027) testSlotRequestTimeoutWhenNoSlotOffering unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/06 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20028) FileCompactionITCase is unstable - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/06 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20029) Define the computed column on the metadata column - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/06 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/11/06 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20031) Keep the uid of SinkWriter same as the SinkTransformation - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/06 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20032) Make FileSink support processing time - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/06 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20033) Job fails when stopping JobMaster - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/06 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20034) Add maxwell-json format document - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/06 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/06 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20036) Join Has NoUniqueKey when using mini-batch - posted by "Rex Remind (Jira)" <ji...@apache.org> on 2020/11/06 20:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20037) there is a comment problem in fromValues(AbstractDataType rowType, Object... values) method of TableEnvironment - posted by "yandufeng (Jira)" <ji...@apache.org> on 2020/11/06 23:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker. - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2020/11/07 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20039) Streaming File Sink end-to-end test is unstable on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/07 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20040) Hive streaming sink does not support static partition inserting well - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/07 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20041) Support Watermark push down for kafka connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/07 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20042) Add end-to-end tests for Kinesis Table sources and sinks - posted by "Alexander Alexandrov (Jira)" <ji...@apache.org> on 2020/11/07 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20043) Add flink-sql-connector-kinesis package - posted by "Alexander Alexandrov (Jira)" <ji...@apache.org> on 2020/11/07 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20044) Disposal of RocksDB could last forever - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/11/07 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20045) ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 200000ms" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/08 01:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20046) StreamTableAggregateTests.test_map_view_iterate is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/08 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20047) DefaultLeaderRetrievalService should only notify the LeaderRetrievalListener when leader truly changed - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/11/08 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/11/08 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20049) Simplify handling of "request split". - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/09 00:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/09 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/09 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20052) kafka/gelly pre-commit test failed due to process hang - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/11/09 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20053) Add document for file compaction - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/09 02:38:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function - posted by Jark Wu <im...@gmail.com> on 2020/11/09 04:22:19 UTC, 1 replies.
- [ANNOUNCE] Feature Freeze of Flink 1.12 - posted by Robert Metzger <rm...@apache.org> on 2020/11/09 05:21:15 UTC, 1 replies.
- [jira] [Created] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2020/11/09 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20055) Datadog API Key exposed in Flink JobManager logs - posted by "Florian Szabo (Jira)" <ji...@apache.org> on 2020/11/09 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20056) Add collector to KinesisDeserializationSchema - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/09 08:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-20057) Use docker images instead of direct downloads in all end to end tests - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/09 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20058) Improve kafka per-partition-watermark tests - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/09 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20059) Outdated SQL docs on aggregate functions' merge - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/09 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/09 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20061) Row constructor unsupported in aggregation function - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/09 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20062) ContinuousHiveSplitEnumerator should be lock-free - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/11/09 12:15:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.0, release candidate #1 - posted by Dian Fu <di...@gmail.com> on 2020/11/09 14:24:23 UTC, 1 replies.
- [jira] [Created] (FLINK-20063) File Source requests an additional split on every restore. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/09 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20064) Broken links in the documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/11/10 00:56:00 UTC, 0 replies.
- [reminder] Build and check the documentation when reviewing - posted by Seth Wiesman <sj...@gmail.com> on 2020/11/10 01:03:22 UTC, 4 replies.
- [jira] [Created] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/10 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20066) BatchPandasUDAFITTests.test_group_aggregate_with_aux_group unstable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/10 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/10 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/10 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20069) docs_404_check doesn't work properly - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/10 06:59:00 UTC, 0 replies.
- [VOTE] FLIP-145: Support SQL windowing table-valued function (2nd) - posted by Jark Wu <im...@gmail.com> on 2020/11/10 06:59:53 UTC, 9 replies.
- [jira] [Created] (FLINK-20070) NPE in SourceCoordinatorProviderTest.testCheckpointAndReset - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/11/10 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20071) Add a dedicated stage to build the PyFlink wheel packges in azure-pipelines.yml - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/10 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20072) Add documentation for FLIP-107 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/10 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20073) Add kerberos setup documentation for native k8s integration - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/11/10 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20074) ChangelogSourceITCase.testRegularJoin fail - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/10 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20075) When the JobMaster is initialized, the JobID of the JobGraph is retrieved again in the createlotpool method - posted by "ZhangAiping (Jira)" <ji...@apache.org> on 2020/11/10 10:44:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Stateful Functions 2.2.1, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/11/10 10:51:53 UTC, 0 replies.
- [jira] [Created] (FLINK-20076) DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles does not test the desired functionality - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/10 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20077) Cannot register a view with MATCH_RECOGNIZE clause - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/10 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/10 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20079) Modified UnalignedCheckpointITCase...MassivelyParallel fails - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/11/10 20:08:00 UTC, 0 replies.
- Register processing time timers when Operator.close() is called - posted by Boyuan Zhang <bo...@apache.org> on 2020/11/11 00:02:52 UTC, 2 replies.
- [jira] [Created] (FLINK-20080) Exceeded checkpoint tolerable failure threshold - posted by "Alex Z (Jira)" <ji...@apache.org> on 2020/11/11 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/11 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1 - posted by "ChangZhuo Chen (陳昌倬 Jira)" <ji...@apache.org> on 2020/11/11 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20083) OrcFsStreamingSinkITCase times out - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/11 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20084) Fix NPE when generating watermark for record whose rowtime field is null after watermark push down - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/11 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20085) Remove RemoteFunctionStateMigrator code paths from StateFun - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/11 07:38:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 2.2.1 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/11/11 08:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-20086) Add documentation for the open method in UserDefinedFunction - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/11 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20087) CheckpointCoordinator waits until all tasks finish initialization of states to trigger checkpoint - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/11/11 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20088) [Kinesis][Polling] Issue using Polling consumer at timestamp with empty shard - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/11/11 12:55:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/44-45 - posted by Konstantin Knauf <kn...@apache.org> on 2020/11/11 13:45:36 UTC, 2 replies.
- [jira] [Created] (FLINK-20089) Avro format fails to serialize map value with null keys - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/11 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/11/11 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/11 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20092) Multi-thread Flink compilation - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2020/11/11 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20093) Create a download page for all optional sql client components - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/11 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20094) Make JobMaster.jobStatusChanged directly called by JobManagerJobStatusListener - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/11 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20095) SchedulerBase.stopWithSavepoint schedules operation after ExecutionGraph terminates - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/11 17:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20096) Clean up PyFlink documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/11/11 17:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/11/11 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20098) Don't add flink-connector-files to flink-dist - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/11/11 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20099) HeapStateBackend checkpoint error hidden under cryptic message - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/11 23:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20100) Lag aggregate function does not return lag, but current row - posted by "Thilo Schneider (Jira)" <ji...@apache.org> on 2020/11/12 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20101) Fix the wrong documentation of FROM_UNIXTIME function - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/12 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20102) Update HBase connector documentation for HBase 2.x supporting - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/12 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20103) Improve test coverage for network stack - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/11/12 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20104) Web UI checkpoint stats "refresh" button has to be clicked twice - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/12 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem) - posted by "Benoît Paris (Jira)" <ji...@apache.org> on 2020/11/12 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20106) flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了 - posted by "赵富午 (Jira)" <ji...@apache.org> on 2020/11/12 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20107) Issues with setting InputChannel.statePersister - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/11/12 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/12 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer - posted by "xuhaoran (Jira)" <ji...@apache.org> on 2020/11/12 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/12 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20111) Update the description of UDAF `merge` method in User-defined function document - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/12 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20112) Test Flink 1.12 release - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20113) Test K8s High Availability Service - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20115) Test Batch execution for the DataStream API - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20114) Test Kafka Source based on the new Source API - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20116) Test Intra-Slot Managed Memory Sharing - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20118) Test New File Source API - Continuous Streaming Execution - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20117) Flink on Mesos Deployment - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20120) Test Handling of metadata in SQL connectors - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20119) Test Temporal Table DDL and Temporal Table Join - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20121) Test the upsert-kafka Connector - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20122) Test Small file compaction - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20124) Test pipelined region scheduler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20123) Test native support of PyFlink on Kubernetes - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20125) Test memory configuration display in the web ui - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20126) Test non-blocking job submission - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/12 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20127) Benchmark unaligned checkpointing times under backpressure - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/11/12 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20128) Data loss for over windows with rows unbounded preceding - posted by "Thilo Schneider (Jira)" <ji...@apache.org> on 2020/11/12 16:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20129) Create a zh download page for all optional sql client components - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/12 17:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-20130) Add ZStandard format to inputs - posted by "João Boto (Jira)" <ji...@apache.org> on 2020/11/12 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20131) Error when using LAST_VALUE on two different datatypes in same query with over window - posted by "Thilo Schneider (Jira)" <ji...@apache.org> on 2020/11/12 20:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20133) Test Pandas UDAF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20132) Test PyFlink new features - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 01:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20134) Test non-vectorized Python UDAF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20135) Test Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20136) Test all other aspects of new features added in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20137) User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/11/13 02:05:00 UTC, 0 replies.
- unsubscribe mail - posted by GeGe <gg...@163.com> on 2020/11/13 03:00:59 UTC, 2 replies.
- [jira] [Created] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted - posted by "wgcn (Jira)" <ji...@apache.org> on 2020/11/13 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20139) Enrich logs when MiniDispatcher shutting down - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2020/11/13 03:46:00 UTC, 0 replies.
- [DISCUSS] Proposal: New feature of flink window UDF - posted by Suhan <ma...@foxmail.com> on 2020/11/13 05:35:21 UTC, 0 replies.
- [jira] [Created] (FLINK-20140) Add documentation of TableResult.collect for Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20141) Add documentation about the FileSink - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/11/13 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/11/13 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/11/13 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20144) Change link format to "{% link ... %}" in docs/ops dir - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2020/11/13 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/13 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20146) Update zh connector and format dependencies link - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/13 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20147) "Invalid lambda deserialization" when trying to read metadata from Kafka in SQL - posted by "Robin Stephenson (Jira)" <ji...@apache.org> on 2020/11/13 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20148) Add contain operator for the array datatype to SQL - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/13 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout." - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/13 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20150) Add documentation for the debezium-avro format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/13 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20151) Test SQL Hive integration - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/13 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20152) Document which execution.target values are supported - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/13 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20153) Add documentation for BATCH execution mode - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/11/13 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20154) Improve error messages when using CLI with wrong target - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/13 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory - posted by "roee hershko (Jira)" <ji...@apache.org> on 2020/11/13 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20156) JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8 - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/13 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20157) SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/13 16:11:02 UTC, 0 replies.
- [jira] [Created] (FLINK-20158) KafkaSource does not implement ResultTypeQueryable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/13 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback - posted by "Sundaram Ananthanarayanan (Jira)" <ji...@apache.org> on 2020/11/13 19:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20160) Implement standard metrics in JDBC connectors. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2020/11/14 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20161) Consider switching from Travis CI to Github Actions for flink-statefun's CI workflows - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/14 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20162) Fix time zone problems of some time related functions - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/14 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20163) Translate page 'raw type' into Chinese - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/15 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20164) Add docs for ProcessFunction and Timer for Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/11/15 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialized - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/16 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Checkpoint was declined." - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/16 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20167) Rework the high availability documentation - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/11/16 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20168) Translate page 'Flink Architecture' into Chinese - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2020/11/16 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20169) Move emitting MAX_WATERMARK out of SourceOperator processing loop - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/16 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20170) json deserialize loses precision - posted by "Mulan (Jira)" <ji...@apache.org> on 2020/11/16 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20171) Improve error message for Flink process memory configuration - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/16 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20172) Unify the behavior for file committers when the source or dest files are not exists - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/16 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20173) CoordinatedSourceITCase.testEnumeratorReaderCommunication fails with - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/16 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20174) Make BulkFormat more extensible - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2020/11/16 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20175) Avro Confluent Registry SQL format does not support adding nullable columns - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/16 19:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20176) CompactionITCaseBase.testNonPartition failed with Timeout - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/16 22:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20177) Liquid Exception: Could not find document 'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connectors/index.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/17 01:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20178) Remote file does not exist -- broken link!!! - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/17 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20179) Support Protobuf serialization and deseriazation schema for RowData type - posted by "Ryo Okubo (Jira)" <ji...@apache.org> on 2020/11/17 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20180) Translation the FileSink Document into Chinese - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/17 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20181) RowData cannot cast to Tuple2 - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2020/11/17 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20182) Add JDK 11 build to StateFun's CI - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/17 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20183) Fix the default PYTHONPATH is overwritten in client side - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/17 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20184) update hive streaming read and temporal table documents - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/11/17 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20185) Containerized environment variables may be misinterpreted in launch script - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2020/11/17 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/17 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/17 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20188) Add Documentation for new File Source - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/17 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20189) Restored feedback events may be silently dropped if per key-group header bytes were not fully read - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/17 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20190) A New Window Trigger that can trigger window operation by event time interval、event count - posted by "GaryGao (Jira)" <ji...@apache.org> on 2020/11/17 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20191) Add document for per-partition-watermark kafka in table api - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/17 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20192) Externalized checkpoint references a checkpoint from a different job - posted by "Antti Kaikkonen (Jira)" <ji...@apache.org> on 2020/11/17 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20193) SourceCoordinator should catch exception thrown from SplitEnumerator.start() - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/17 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20194) KafkaSourceFetcherManager.commitOffsets() should handle the case when there is no split fetcher. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/17 15:26:00 UTC, 0 replies.
- [DISCUSS] Stop adding new bash-based e2e tests to Flink - posted by Robert Metzger <rm...@apache.org> on 2020/11/17 15:35:38 UTC, 14 replies.
- Job Manager is taking very long time to finalize the Checkpointing. - posted by Slim Bouguerra <bs...@apache.org> on 2020/11/17 16:09:28 UTC, 0 replies.
- [jira] [Created] (FLINK-20195) Jobs endpoint returns duplicated jobs - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/11/17 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20196) flink-connector-files needs explicit flink-connector-base dependency to run - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/17 17:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20197) FileSink fails with UnsupportedOperationException when using default values - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/17 17:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20198) Liquid Exception: Could not find document 'dev/table/connectors/formats/index.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/connectors/upsert-kafka.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/18 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20199) PyFlink unstable e2e DataStream test - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/18 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20200) SQL Hints are not supported in "Create View" syntax - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/11/18 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20201) Support automatic adjustment of window parameters - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2020/11/18 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20202) Add the Check of Unsupported Result Type in Pandas UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/18 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20203) Could not find any document about how to build a Flink image from local build. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/18 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20204) Translate page 'upsert-kafka Connector' into Chinese - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2020/11/18 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20205) CDC source shouldn't send UPDATE_BEFORE messages if the downstream doesn't need it - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/18 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20206) Failed to start the session, but there is no clear prompt. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/18 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20207) Improve the error message printed when submitting the pyflink jobs via 'flink run' - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/11/18 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink - posted by "Alexander Trushev (Jira)" <ji...@apache.org> on 2020/11/18 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20210) "RequestFactory" interface in flink elasticsearch connector doesn't support "routing" param - posted by "Oneway Chen (Jira)" <ji...@apache.org> on 2020/11/18 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20209) Add missing checkpoint configuration to Flink UI - posted by "Peidian Li (Jira)" <ji...@apache.org> on 2020/11/18 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20211) Can not get the JobManager web ip according to the document - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/18 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20212) Fail command line interfaces when provided with an unrecognized option - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/18 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20213) Partition commit is delayed when records keep coming - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/18 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20214) Unnecessary warning log when starting a k8s session cluster - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/18 09:54:00 UTC, 0 replies.
- [REMINDER] Build docs before merging - posted by Till Rohrmann <tr...@apache.org> on 2020/11/18 10:08:34 UTC, 6 replies.
- [jira] [Created] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta" - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/18 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20216) Move "Configuration" and "Environment Variables" under "Python API" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/18 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20217) More fine-grained timer processing - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/11/18 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20218) AttributeError: module 'urllib' has no attribute 'parse' - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/18 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20219) Rethink the Kubernetes HA related ConfigMap clean up for session cluster - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/11/18 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/18 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/11/18 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/18 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20223) The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/18 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20224) add username&password to provide a credential for es rest client - posted by "jiang7chengzitc (Jira)" <ji...@apache.org> on 2020/11/18 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20225) Break link in the document - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/18 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20226) Temporal Table Functions cannot be created with a view reference - posted by "Benoît Paris (Jira)" <ji...@apache.org> on 2020/11/18 19:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20227) Kafka transaction IDs exceeding limit - posted by "John Mathews (Jira)" <ji...@apache.org> on 2020/11/18 21:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20228) ESsink accur thread blocked - posted by "liqi316 (Jira)" <ji...@apache.org> on 2020/11/19 00:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20229) duplicate "for" security-kerberos doc - posted by "zhouyongjin (Jira)" <ji...@apache.org> on 2020/11/19 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20230) PARTITIONED TABLE, INSERT INTO EMPTY VALUES, THROW FileNotFoundException - posted by "liu (Jira)" <ji...@apache.org> on 2020/11/19 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20231) Sql UDTF subplan reuse on correlate - posted by "Junning Liang (Jira)" <ji...@apache.org> on 2020/11/19 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20232) Handle object reuse properly in the operators of Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/19 05:40:00 UTC, 0 replies.
- Hive Streaming write compaction - posted by Chen Qin <qi...@gmail.com> on 2020/11/19 06:30:39 UTC, 2 replies.
- [jira] [Created] (FLINK-20233) DataGeneratorSource should increment serialVersionUID - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/19 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20234) Json format supports SE/DE null elements of ARRAY type field - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/11/19 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20235) Missing Hive dependencies - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/19 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar - posted by "CloseRiver (Jira)" <ji...@apache.org> on 2020/11/19 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20237) Do not recommend putting hive-exec in flink/lib - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/19 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20238) flink-sql-connector-elasticsearch does not support Elasticsearch auth - posted by "liu (Jira)" <ji...@apache.org> on 2020/11/19 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20239) Confusing pages: "Hive Read & Write" and "Hive Streaming" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/19 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20240) Add setter in the environment for the `execution.runtime-mode` - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/11/19 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20241) Cannot read/write orc table from Hive - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/19 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20242) Can not set job name in StatementSet.execute() method - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2020/11/19 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20243) Remove useless words in documents - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/11/19 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20244) RMQSource does not ACK duplicated messages - posted by "Thomas Eckestad (Jira)" <ji...@apache.org> on 2020/11/19 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20245) Document how to create a Hive catalog from DDL - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/19 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/19 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20247) Hide unused unaligned checkpoint configuration options - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/11/19 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2020/11/19 13:00:11 UTC, 0 replies.
- [jira] [Created] (FLINK-20249) Rethink the necessity of the k8s internal Service even on non-HA mode - posted by "jiang7chengzitc (Jira)" <ji...@apache.org> on 2020/11/19 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/19 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20251) Can't import all release-signing keys - posted by "Bob (Jira)" <ji...@apache.org> on 2020/11/19 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20252) Manual Test for Approximate Local Recovery - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/11/20 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2020/11/20 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/20 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20255) Nested decorrelate failed - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/11/20 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20256) UDAF type inference will fail if accumulator contains MapView with Pojo value type - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/20 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20257) Flink web-ui metrics page add metrics select Can't see the full name of the metics - posted by "meiminda (Jira)" <ji...@apache.org> on 2020/11/20 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20258) Configured memory sizes on the JM metrics page should be displayed with proper units. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/11/20 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20259) Add explanation that "configured values" for JM/TM memory sizes include automatically derived values - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/11/20 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20260) YAML for SQL client only supports legacy interfaces - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/11/20 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/20 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20262) Building flink-dist docker image does not work without python2 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/20 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20263) Improve exception when metada name mismath - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/20 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20264) Zero-downtime / dynamic function upgrades in Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/20 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20265) Extend invocation protocol to allow functions to indicate incomplete state context - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/20 17:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20266) New FileSource prevents IntelliJ from stopping spawned JVM when running a job - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/20 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20267) JaasModule prevents Flink from starting if working directory is a symbolic link - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/20 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20268) Update Python SDK to implement new invocation protocol - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/21 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20269) The flush happens too frequent in SavepoinV2Serializer - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/11/21 09:34:00 UTC, 0 replies.
- More issues with top-level build for Tika 1.25 rc1 - Waited more than 5 minutes for a SAXParser - posted by Ken Krugler <kk...@transpac.com> on 2020/11/21 22:42:12 UTC, 2 replies.
- [jira] [Created] (FLINK-20270) Fix the regression of missing ExternallyInducedSource support in FLIP-27 Source. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/22 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20271) ArrayIndexOutOfBounds When using Rank - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/22 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20272) Wrong result of Rank Function - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/22 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20273) Fix Table api Kafka connector Sink Partitioner Document Error - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/22 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20274) Translate page 'testing' into Chinese - posted by "Flora Tao (Jira)" <ji...@apache.org> on 2020/11/22 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20275) The path delimiter for add_jars and add_classpaths in Python StreamExecutionEnvironment should be ; - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/11/22 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20276) Transparent DeCompression of streams missing on new File Source - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/22 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/11/23 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20278) Throw a meaningful exception if the Python DataStream API job executes in batch mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/23 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20279) Elasticsearch6DynamicSinkITCase failed caused by pulling docker image error - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/11/23 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20280) Support batch mode for Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/23 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20281) Window aggregation supports changelog stream input - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/23 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20282) Make invalid managed memory fraction errors more advisory in MemoryManager - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/23 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20283) Make invalid managed memory fraction errors of python udf more user friendly - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/23 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20284) Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/23 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/11/23 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20286) Support streaming source for filesystem SQL connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/23 05:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20287) Add documentation of how to switch memory allocator in Flink docker image - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/11/23 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20288) Correct documentation about savepoint self-contained - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/11/23 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/23 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/11/23 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20291) Optimize the exception message of FileSystemTableSink when missing format dependencies - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/23 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20292) Avro format conflicts with Parquet and Orc - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/23 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20293) Remove the useless constructor of ContinuousFileMonitoringFunction - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/11/23 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20294) Expose value format metadata in Kinesis table source - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/23 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20295) File Source lost data when reading from directories created by FileSystemTableSink with JSON format - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/23 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20296) Explanation of keyBy was broken by find/replace of deprecated forms of keyBy - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/11/23 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20297) Make `SerializerTestBase::getTestData` return List - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/23 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20298) Replace usage of {{site.baseurl}} in flink documentation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/23 13:20:00 UTC, 0 replies.
- Temporal Table Ordering - posted by Dominik Wosiński <wo...@gmail.com> on 2020/11/23 13:24:21 UTC, 1 replies.
- Need input on creating s3 source DataStream to filter Json file before pass to actual reader - posted by DEEP NARAYAN Singh <ab...@gmail.com> on 2020/11/23 13:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-20299) Update Chinese table overview - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/11/23 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20300) Create Flink 1.12 release notes - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/23 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20301) Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/11/23 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20302) Suggest DataStream API with BATCH execution mode in DataSet docs - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/11/23 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20303) Add a SmokeE2E test - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/11/23 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20304) Fail hard when trying to run job with broadcast state in BATCH execution mode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/23 18:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/23 18:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20306) Accessing a versioned table as of time fails with a cryptic message - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/23 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20307) Cannot alias versioned table in a join - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/23 18:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20308) Liquid Exception: Could not find document 'dev/table/streaming/time_attributes.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/sql/create.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/24 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/24 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20310) Add Debezium, Canal, Raw support for Filesystem connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/24 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20311) E2E test for Debezium, Canal, Raw of Filesystem connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/24 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20312) The documentation is incomplete - posted by "sxb (Jira)" <ji...@apache.org> on 2020/11/24 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20313) Test the debezium-avro-confluent format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/24 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20314) Flink SQL 多字段查询时异常 - posted by "bugboy (Jira)" <ji...@apache.org> on 2020/11/24 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20315) Optimize the compaction section for the document of table filesystem sink. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/11/24 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20316) update the deduplication section of query page - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/11/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20317) Update Format Overview page to mention the supported connector for upsert-kafka - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/24 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20318) Fix cast question for properies() method in kafka ConnectorDescriptor - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/11/24 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20319) Improving the visitor pattern for operations - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/11/24 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20320) Support start SQL Client with an initialization SQL file - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/24 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/11/24 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20322) Rename table.optimizer.union-all-as-breakpoint-disabled to table.optimizer.union-all-as-breakpoint.enabled - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/11/24 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20323) CorrelateSortToRankRule cannot deal with multiple groupings - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/24 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20324) Support customizing of containers for native kubernetes setup - posted by "Boris Lublinsky (Jira)" <ji...@apache.org> on 2020/11/24 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20325) Move docs_404_check to CI stage - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/24 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20326) Broken links to "How to define LookupableTableSource" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/24 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20327) The Hive's read/write page should redirect to SQL Fileystem connector - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/24 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/25 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/25 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20330) Flink connector has error in support hive external tables (hbase or es) - posted by "liu (Jira)" <ji...@apache.org> on 2020/11/25 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/25 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20332) Add workers recovered from previous attempt to pending resources - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/11/25 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20333) Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/11/25 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/25 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20335) Remove support for eager state specifications in module YAML definitions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/25 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/11/25 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/25 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20338) Make the SinkWriter load previous sink's state. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/25 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/11/25 04:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20340) Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/25 06:54:00 UTC, 0 replies.
- I create a hotfix pull request in `MiniCluster.java`, thanks! - posted by 左元 <zu...@126.com> on 2020/11/25 08:44:30 UTC, 2 replies.
- [jira] [Created] (FLINK-20341) Rework Deployment / Coordination Documentation - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/25 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20342) Revisit page structure - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/25 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20343) Add overview / reference architecture page - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/25 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20344) Modify the default value of the flink-conf savepoint folder to distinguish the checkpoint folder - posted by "OpenOpened (Jira)" <ji...@apache.org> on 2020/11/25 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20345) Adds an Expand node only when there are more then one distinct aggregate function in an Aggregate when executes SplitAggregateRule - posted by "zhangqingru (Jira)" <ji...@apache.org> on 2020/11/25 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20346) Explain ChangelogMode for sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/25 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20347) Rework YARN deployment documentation page - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/25 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/25 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20349) Query fails with "A conflict is detected. This is unexpected." - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/11/25 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20350) [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/11/25 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20351) Execution.transitionState does not properly log slot location - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20352) Rework command line interface documentation page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 18:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20353) Rework logging documentation page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20354) Rework standalone deployment documentation page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 18:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20355) Rework K8s deployment documentation page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20356) Rework Mesos deployment documentation page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 18:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20357) Rework HA documentation page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/25 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20358) Support adding Owner Reference to Job Manager in native kubernetes setup - posted by "Boris Lublinsky (Jira)" <ji...@apache.org> on 2020/11/25 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup - posted by "Boris Lublinsky (Jira)" <ji...@apache.org> on 2020/11/25 19:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20360) AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/25 20:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20361) Using sliding window with duration of hours in Table API returns wrong time - posted by "Aleksandra Cz (Jira)" <ji...@apache.org> on 2020/11/25 20:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20362) Broken Link in dev/table/sourceSinks.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/26 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20363) "Batch SQL end-to-end test" failed during shutdown - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/26 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20364) Add support for scheduling with slot sharing - posted by "Guruh Fajar Samudra (Jira)" <ji...@apache.org> on 2020/11/26 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20365) The native k8s cluster could not be unregistered when executing Python DataStream application attachedly. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/11/26 05:27:00 UTC, 0 replies.
- [ANNOUNCE] release-1.12 branch cut - posted by Dian Fu <di...@gmail.com> on 2020/11/26 06:11:54 UTC, 0 replies.
- [jira] [Created] (FLINK-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/11/26 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20367) Show the in-use config of job to users - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/11/26 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20368) Supports custom operator name for Flink SQL - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/11/26 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20369) Improve the digest of TableSourceScan and Sink node - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/26 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20370) Result is wrong when sink primary key is not the same with query - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/26 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20372) flink sql kafka connector cannot config kerberos - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/11/26 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20371) Add docs for outer interval join - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/11/26 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20373) Flink table jsonArray access all - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2020/11/26 09:00:25 UTC, 0 replies.
- [jira] [Created] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/26 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20375) Add a - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/26 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20376) Error in restoring savepoint when Flink is upgraded from 1.9 to 1.11.2 - posted by "Partha Pradeep Mishra (Jira)" <ji...@apache.org> on 2020/11/26 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/11/26 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20378) Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE - posted by "wxmimperio (Jira)" <ji...@apache.org> on 2020/11/26 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20379) New Kafka Connector does not support DeserializationSchema - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/26 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20380) Problems with creating iceberg Catalog (Catalog -type=hive) using flink-SQL shell - posted by "tianyu guo (Jira)" <ji...@apache.org> on 2020/11/26 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20381) Incorrect use of yarn-session.sh -id vs -yid in log statements. - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/26 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20382) Exception thrown from JobMaster.startScheduling() may be ignored. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/11/26 19:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20383) DataSet allround end-to-end test dies with NullPointerException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/26 20:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20384) Broken Link in deployment/ha/kubernetes_ha.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/27 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20385) Allow to read metadata for Canal-json format - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/11/27 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20387) Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime attribute - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20388) Supports users setting operators' metrics name - posted by "hailong wang (Jira)" <ji...@apache.org> on 2020/11/27 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/27 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20390) Programmatic access to the back-pressure - posted by "Gaël Renoux (Jira)" <ji...@apache.org> on 2020/11/27 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20391) Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/27 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20392) Migrating bash e2e tests to Java/Docker - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/27 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20393) Migrate test_mesos_wordcount.sh - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/27 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20394) Migrate test_mesos_multiple_submissions.sh - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/27 13:00:06 UTC, 0 replies.
- [jira] [Created] (FLINK-20395) Migrate test_netty_shuffle_memory_control.sh - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/11/27 13:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-20396) Replace "OperatorCoordinator.subtaskFailed()" with "subtaskRestored()" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/27 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20397) Pass checkpointId to OperatorCoordinator.resetToCheckpoint(). - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/27 14:22:00 UTC, 0 replies.
- [DISCUSS] Moving to JUnit5 - posted by Arvid Heise <ar...@ververica.com> on 2020/11/27 14:29:53 UTC, 6 replies.
- [jira] [Created] (FLINK-20399) Migrate test_sql_client.sh - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20398) Migrate test_batch_sql.sh - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20400) Migrate test_streaming_sql.sh - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20402) Migrate test_tpch.sh - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20401) Migrate test_tpcds.sh - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20403) Migrate test_table_shaded_dependencies.sh - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/27 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20404) ZooKeeper quorum fails to start due to missing log4j library - posted by "Pedro Miguel Rainho Chaves (Jira)" <ji...@apache.org> on 2020/11/27 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20405) The LAG function in over window is not implements correctly - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/11/27 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20406) Return the Checkpoint ID of the restored Checkpoint in CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks() - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/27 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20408) Migrate test_pyflink_yarn.sh - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/28 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20407) Migrate test_pyflink.sh - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/28 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20409) Migrate test_kubernetes_pyflink_application.sh - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/11/28 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/11/28 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20411) The annotation config do not support complex structure - posted by "Aitozi (Jira)" <ji...@apache.org> on 2020/11/29 05:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/29 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20413) Sources should add splits back in "resetSubtask()", rather than in "subtaskFailed()". - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/11/29 21:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20414) 【HBase】 - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/11/30 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2020/11/30 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20416) Need a cached catalog for batch SQL job - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2020/11/30 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/11/30 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20418) NPE in IteratorSourceReader - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/11/30 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20419) Insert fails due to failure to generate execution plan - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/11/30 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/11/30 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20421) Support canal-protobuf format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/11/30 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2020/11/30 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20423) Remove usage of {{site.baseurl}} from markdown files - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/30 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20424) The percent of acknowledged checkpoint seems incorrect - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/11/30 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20425) Change exit code in FatalExitExceptionHandler to be different from JvmShutdownSafeguard - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/11/30 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20426) Broken links to hadoop.md - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/11/30 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/11/30 16:31:00 UTC, 0 replies.