You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-20428) ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization failed with "No result is expected since there was no leader elected before stopping the server, yet" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/01 01:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20429) KafkaTableITCase.testKafkaTemporalJoinChangelog failed with unexpected results - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/01 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20430) Broken links in deployment/index.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/01 01:47:00 UTC, 0 replies.
- flink 1.9 Restore from a checkpoint taken in 1.11 - posted by Lu Niu <qq...@gmail.com> on 2020/12/01 01:53:51 UTC, 1 replies.
- [jira] [Created] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1> - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/01 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20432) SQLClientSchemaRegistryITCase hangs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/01 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/01 05:09:00 UTC, 0 replies.
- [VOTE] Release 1.12.0, release candidate #2 - posted by Robert Metzger <rm...@apache.org> on 2020/12/01 06:35:38 UTC, 1 replies.
- [jira] [Created] (FLINK-20434) Getting The desired archetype does not exist - posted by "Avi Levi (Jira)" <ji...@apache.org> on 2020/12/01 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20435) Refactor ExecNode - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/01 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20436) Simplify type parameter of ExecNod - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/01 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20437) Port ExecNode to Java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/01 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20438) org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest fails due to missing output - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/01 08:40:00 UTC, 0 replies.
- Re: [DISCUSS] Moving to JUnit5 - posted by Khachatryan Roman <kh...@gmail.com> on 2020/12/01 08:53:45 UTC, 0 replies.
- [jira] [Created] (FLINK-20439) Consider simplifying or removing mechanism to scheduleOrUpdateConsumers - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/12/01 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in Hop window - posted by "zouyunhe (Jira)" <ji...@apache.org> on 2020/12/01 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20441) Deprecate CheckpointConfig.setPreferCheckpointForRecovery - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/01 10:41:00 UTC, 0 replies.
- [CANCELLED][VOTE] Release 1.12.0, release candidate #2 - posted by Robert Metzger <rm...@apache.org> on 2020/12/01 12:22:55 UTC, 0 replies.
- [jira] [Created] (FLINK-20442) Fix license documentation mistakes in flink-python.jar - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/12/01 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20443) ContinuousProcessingTimeTrigger lost data in last interval in per window - posted by "Gee (Jira)" <ji...@apache.org> on 2020/12/01 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20444) Chain AsyncWaitOperator to new sources - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/12/01 13:03:00 UTC, 0 replies.
- State Processor API SQL State - posted by Dominik Wosiński <wo...@gmail.com> on 2020/12/01 13:05:40 UTC, 2 replies.
- [jira] [Created] (FLINK-20445) NoMatchingTableFactoryException - posted by "Ke Li (Jira)" <ji...@apache.org> on 2020/12/01 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20446) NoMatchingTableFactoryException - posted by "Ke Li (Jira)" <ji...@apache.org> on 2020/12/01 13:17:00 UTC, 0 replies.
- [DISCUSS]Select Chinese words from table union all get java.lang.OutOfMemoryError: Java heap space on Flink 1.9.x with Blink planner - posted by Smile <LE...@163.com> on 2020/12/01 13:21:45 UTC, 1 replies.
- [jira] [Created] (FLINK-20447) Querying grouy by PK does not work - posted by "Zhenwei Feng (Jira)" <ji...@apache.org> on 2020/12/02 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20448) Obsolete generated avro classes - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/02 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20449) UnalignedCheckpointITCase times out - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/12/02 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20450) Missing usage information on "run-application" in Flink CLI - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/02 09:21:00 UTC, 0 replies.
- [VOTE] Release 1.12.0, release candidate #3 - posted by Robert Metzger <rm...@apache.org> on 2020/12/02 10:19:26 UTC, 15 replies.
- [jira] [Created] (FLINK-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:` - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/02 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2020/12/02 13:58:00 UTC, 0 replies.
- [DISCUSS] FLIP-152: Hive Query Syntax Compatibility - posted by Rui Li <li...@gmail.com> on 2020/12/02 14:01:35 UTC, 5 replies.
- [jira] [Created] (FLINK-20453) Move checkpointing classes to a the appropriate package - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/12/02 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/02 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20455) Add check to LicenseChecker for top level /LICENSE files in shaded jars - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/12/02 15:51:00 UTC, 0 replies.
- Running Flink job as a rest - posted by dhurandar S <dh...@gmail.com> on 2020/12/02 21:31:41 UTC, 2 replies.
- [jira] [Created] (FLINK-20456) Make streaming SQL concepts more approachable - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/12/03 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/03 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20458) Translate page 'SQL-gettingStarted' into Chinese - posted by "CaoZhen (Jira)" <ji...@apache.org> on 2020/12/03 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20459) Handle null message correctly in JSON RowData deserializer - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/12/03 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20460) Support async lookup for HBase connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/03 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/03 05:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/03 05:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20463) flink-1.11.2 -sql cannot ignore exception record - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/12/03 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20464) Some Table examples have wrong program-class defined - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/12/03 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/03 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20466) Table 'EXPR$1' not found with UNION ALL - posted by "wxmimperio (Jira)" <ji...@apache.org> on 2020/12/03 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20467) Fix the Example in Python DataStream Doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/03 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20468) Enable leadership control in MiniCluster to test JM failover - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/12/03 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20469) Enable TaskManager start and terminate in MiniCluster - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/12/03 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/03 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20471) flink1.10SQL中decimal精度溢出返回null的问题 - posted by "sadfdddd (Jira)" <ji...@apache.org> on 2020/12/03 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20472) Change quickstarts to have a dependency on "flink-dist" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/12/03 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20473) when get metrics option, its hard to see the full name unless u choosed - posted by "tonychan (Jira)" <ji...@apache.org> on 2020/12/04 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20474) flink cep results of doc is not right - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/12/04 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20475) Broken Link in gettingStarted.zh.md - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/04 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20476) New File Sink end-to-end test Failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/04 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20477) Maven: Could not find the selected project in the reactor: flink-shaded-netty-tcnative-static - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/04 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20478) Show "Optimized Execution Plan" instead of "Physical Execution Plan" in explain result - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/04 03:11:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Apache Flink 1.11.3 - posted by Xintong Song <to...@gmail.com> on 2020/12/04 03:46:04 UTC, 2 replies.
- [jira] [Created] (FLINK-20479) Support Row-based Operations in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/04 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final - posted by "lidesheng (Jira)" <ji...@apache.org> on 2020/12/04 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/12/04 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20482) Support Map Operation in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/04 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20483) Support Pandas UDF for Map Operation in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/04 08:25:00 UTC, 0 replies.
- Flink 1.9Version State TTL parameter configuration it does not work - posted by Yang Peng <ya...@gmail.com> on 2020/12/04 08:26:49 UTC, 0 replies.
- [jira] [Created] (FLINK-20484) Improve hive temporal table exception - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/12/04 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/04 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20485) Map views are deserialized multiple times - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/12/04 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20487) FLINK SQL GROUP BY TUMBLE AND OVER FUNCTION - posted by "jiayue.yu (Jira)" <ji...@apache.org> on 2020/12/04 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20488) Supporting changes (UI, conf) for timing out aligned checkpoints - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/12/04 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20489) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.10.2 - posted by "Partha Pradeep Mishra (Jira)" <ji...@apache.org> on 2020/12/04 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20490) Don't share inputs between FlinkPhysicalRel and ExecNode - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/04 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20491) Support Broadcast State in BATCH execution mode - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/12/04 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask() - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/12/05 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20493) SQLClientSchemaRegistryITCase test failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/05 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20494) SQLClientHBaseITCase Task Timeout - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/05 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/05 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20496) RocksDB partitioned index filter option - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/12/05 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20497) FlinkKafkaProducerITCase testRestoreToCheckpointAfterExceedingProducersPool Timeout expired after 60000milliseconds while awaiting InitProducerId - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/06 04:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20498) SQLClientSchemaRegistryITCase testReading test timed out after 120000 milliseconds - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/06 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20499) ES7 ElasticsearchSinkITCase hangs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/06 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/07 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20501) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed with "Delete test topic : flink-kafka-producer-fail-and-recover-same-checkpoint-twice" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/07 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/12/07 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20503) Internal cpu configuration option is leaked in logs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/12/07 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20504) NPE when writing to hive and fail over happened - posted by "zhuxiaoshang (Jira)" <ji...@apache.org> on 2020/12/07 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20505) Yarn provided lib does not work with http paths. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/12/07 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20506) Support FlatMap Operation in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/07 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20507) Support Aggregate Operation in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/07 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20508) Introduce PythonStreamGroupTableAggregateOperator - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/07 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20509) Refactor verifyPlan method in TableTestBase - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/07 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20510) Enable log4j2 monitor interval by default - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/07 10:58:00 UTC, 0 replies.
- Urgent help on S3 CSV file reader DataStream Job - posted by DEEP NARAYAN Singh <ab...@gmail.com> on 2020/12/07 11:10:59 UTC, 3 replies.
- [jira] [Created] (FLINK-20511) Deprecate the classes in scala `nodes.exec` package - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/07 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20512) Introduce getDescription, getOutputType, replaceInputEdge methods for ExecNode - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/07 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20514) Introduce StreamExecPythonGroupTableAggregateRule and StreamExecGroupTableAggregate - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/07 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20513) Separate the implementation of BatchExecExchange and StreamExecExchange - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/07 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20515) Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/07 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20516) Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/07 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20517) Disallow operators with mixed key/non-keyed inputs with BATCH state backend - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/12/07 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20518) WebUI should escape characters in metric names - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/07 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20519) Extend HBase notice with transitively bundled dependencies - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/07 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20520) Document that metric names can contain characters that need to be escaped - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/07 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20521) Null result values are being swallowed by RPC system - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/07 13:56:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.12.0, release candidate #3 - posted by Dian Fu <di...@gmail.com> on 2020/12/07 15:07:32 UTC, 0 replies.
- [jira] [Created] (FLINK-20522) Make implementing a built-in function straightforward - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/12/07 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20523) OffsetsInitializerTest test failed with "java.net.BindException: Address already in use" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/08 01:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20524) Package KafkaTestEnvironment into Kafka connector test JAR - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/12/08 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20525) Fix StreamArrowPythonGroupWindowAggregateFunctionOperator's incorrect handling of rowtime and proctime fields - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/08 04:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20526) Enable logback scan configuration by default - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/08 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20527) how to add a side output for flink sql watermaker? - posted by "tonychan (Jira)" <ji...@apache.org> on 2020/12/08 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20528) Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/08 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20529) Publish Dockerfiles for release 1.12.0 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/08 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20530) Invalid metric named `lastCheckpointExternalPath` - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/08 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20531) Flink docs are not building anymore due to builder change - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/12/08 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20532) generate-stackbrew-library.sh in flink-docker doesn't properly prune the java11 tag - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/12/08 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20533) Add histogram support to Datadog reporter - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/08 10:58:00 UTC, 0 replies.
- [DISCUSS] Programmatically submit Flink job jar to session cluster - posted by Fabian Paul <fa...@data-artisans.com> on 2020/12/08 11:00:30 UTC, 4 replies.
- [jira] [Created] (FLINK-20534) Add Flink 1.12 MigrationVersion - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/08 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20535) "GROUPING SETS" query result cannot upsert to table - posted by "richt richt (Jira)" <ji...@apache.org> on 2020/12/08 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20536) Update migration tests in master to cover migration from release-1.12 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/08 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20537) Failed to call Hive UDF with string literal arguments - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/08 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20538) sink.rolling-policy.file-size does not work in filesystem connector - posted by "zhuxiaoshang (Jira)" <ji...@apache.org> on 2020/12/08 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20539) Type mismatch when using ROW in computed column - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/12/08 14:42:00 UTC, 0 replies.
- [DISCUSS] Make SQL docs Blink only - posted by Seth Wiesman <sj...@gmail.com> on 2020/12/08 15:36:16 UTC, 10 replies.
- [jira] [Created] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC - posted by "zhangzhao (Jira)" <ji...@apache.org> on 2020/12/09 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20541) ClusterID is not used in the method! - posted by "lixiaobao (Jira)" <ji...@apache.org> on 2020/12/09 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/12/09 03:04:00 UTC, 0 replies.
- [VOTE] Release 1.11.3, release candidate #1 - posted by Xintong Song <xt...@apache.org> on 2020/12/09 03:14:55 UTC, 3 replies.
- [jira] [Created] (FLINK-20543) Fix typo in upsert kafka docs - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/09 04:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20544) ConcurrentModificationException when writing to hive and fail over happened - posted by "zhuxiaoshang (Jira)" <ji...@apache.org> on 2020/12/09 07:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2020/12/09 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest - posted by "zoucao (Jira)" <ji...@apache.org> on 2020/12/09 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20547) Batch job fails due to the exception in network stack - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2020/12/09 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20548) Provide an option to disable propagation of timed out barriers - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/12/09 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/09 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20550) Wrong savepoint config in some docs - posted by "Han (Jira)" <ji...@apache.org> on 2020/12/09 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20551) Make SQL documentation Blink only - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/12/09 14:45:00 UTC, 0 replies.
- [DISCUSS] Pod template for native K8s integration - posted by Yang Wang <da...@gmail.com> on 2020/12/09 15:43:29 UTC, 1 replies.
- [jira] [Created] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint - posted by "mei jie (Jira)" <ji...@apache.org> on 2020/12/10 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20553) Add end-to-end test case for new Kafka source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/12/10 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI - posted by "ming li (Jira)" <ji...@apache.org> on 2020/12/10 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20555) 404 url dependency error in Flink Website - posted by "DaiXinyu (Jira)" <ji...@apache.org> on 2020/12/10 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20556) org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. - posted by "Zezheng Qin (Jira)" <ji...@apache.org> on 2020/12/10 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20557) Support statement set in SQL CLI - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/10 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/10 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20559) history-server: don't add caching headers for /jobs/overview.json - posted by "yazgoo (Jira)" <ji...@apache.org> on 2020/12/10 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20560) history-server: update archives while they're being loaded - posted by "yazgoo (Jira)" <ji...@apache.org> on 2020/12/10 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20561) Add documentation for `records-lag-max` metric. - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/10 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/10 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20563) Support built-in functions for Hive versions prior to 1.2.0 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/10 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20564) Add metrics for ElasticSearch connector - posted by "Peidian Li (Jira)" <ji...@apache.org> on 2020/12/10 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20565) Fix typo in EXPLAIN Statements docs. - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/10 11:32:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.0 released - posted by Robert Metzger <rm...@apache.org> on 2020/12/10 12:17:17 UTC, 19 replies.
- [jira] [Created] (FLINK-20566) Fix typo in `Cassandra Connector` docs. - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/10 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20567) Document Error - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/12/10 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20568) Kerberized YARN per-job on Docker test failed with "Hadoop security with Kerberos is enabled but the login user does not have Kerberos credentials or delegation tokens!" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/11 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20569) testKafkaSourceSinkWithMetadata hangs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/11 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20570) `/docs/stream/operators/process_function.md`, line 252. The `NOTE tip` css style is different from the others. - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/12/11 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20571) Add dynamic open/close LatencyMarksEmitter to support online debug and monitoring - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/12/11 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20572) HiveCatalog should be a standalone module - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/11 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20573) Set the function of abnormal event time filter - posted by "Xiao Cai (Jira)" <ji...@apache.org> on 2020/12/11 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/12/11 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20575) flink application failed to restore from check-point - posted by "Yu Yang (Jira)" <ji...@apache.org> on 2020/12/11 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20576) Flink Temporal Join Hive Dim Error - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2020/12/11 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20577) Flink Temporal Join Hive Dim Error - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2020/12/11 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20578) Cannot create empty array using ARRAY[] - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/12/11 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20579) eash es sink will have - posted by "donglei (Jira)" <ji...@apache.org> on 2020/12/11 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20580) Missing null value handling for SerializedValue's getByteArray() - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/11 13:09:00 UTC, 0 replies.
- [DISCUSS] FLIP-153: Support state access in Python DataStream API - posted by Shuiqiang Chen <ac...@gmail.com> on 2020/12/11 13:43:35 UTC, 6 replies.
- [jira] [Created] (FLINK-20581) java.lang.NoClassDefFoundError: Could not initialize class org.apache.flink.util.JavaGcCleanerWrapper - posted by "huzeming (Jira)" <ji...@apache.org> on 2020/12/11 14:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-20582) Fix typos in `CREATE Statements` docs - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/12 04:04:00 UTC, 0 replies.
- [VOTE] Release 1.11.3, release candidate #2 - posted by Xintong Song <xt...@apache.org> on 2020/12/13 01:37:28 UTC, 10 replies.
- [jira] [Created] (FLINK-20583) Support to define the data range of decimal types in datagen table source connector - posted by "tonychen0716 (Jira)" <ji...@apache.org> on 2020/12/13 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20584) Document: Streaming File Sink - ORC Format, example of Scala, file is empty after being written - posted by "lundong he (Jira)" <ji...@apache.org> on 2020/12/13 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20585) the release note has some minor bug - posted by "Georger (Jira)" <ji...@apache.org> on 2020/12/14 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20586) Flink 1.12 release notes mark error - posted by "venn wu (Jira)" <ji...@apache.org> on 2020/12/14 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20587) INSERT INTO TIMESTAMP WITH LOCAL TIME ZONE VALUES, THROW Unsupported type - posted by "Forward Xu (Jira)" <ji...@apache.org> on 2020/12/14 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20588) Add docker-compose as appendix to Mesos documentation - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/14 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20589) Remove old scheduling strategies - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20590) flink sql support hive dynamic configuration - posted by "YIWEIPING (Jira)" <ji...@apache.org> on 2020/12/14 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20591) Remove JobManagerOptions.SCHEDULING_STRATEGY - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20592) Remove LazyFromSourcesSchedulingStrategy - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20593) Remove EagerSchedulingStrategy - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20594) Remove DefaultExecutionSlotAllocator - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20595) Remove SlotProviderStrategy - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20596) Remove Scheduler - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20597) Update flink training exercises to 1.12 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/12/14 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20598) Update playgrounds for Flink 1.12 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/12/14 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20599) Update operations playground for 1.12 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/12/14 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20600) Remove SlotSharingManager - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/14 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20601) Rework PyFlink CLI documentation - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/14 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20602) Getting exception Connecting kinesis with mfa - posted by "Avi Levi (Jira)" <ji...@apache.org> on 2020/12/14 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20603) Update pyflink walkthrough playground for 1.12 release - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/12/14 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20604) Update table walkthrough playground for 1.12 - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/12/14 13:44:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2020/12/14 15:33:11 UTC, 3 replies.
- [jira] [Created] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/14 18:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20606) sql client cannot create function using user classes from jar which specified by -j option - posted by "akisaya (Jira)" <ji...@apache.org> on 2020/12/14 23:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20607) a wrong example in udfs page. - posted by "shizhengchao (Jira)" <ji...@apache.org> on 2020/12/15 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20608) Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/15 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20609) Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/15 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20610) Separate the implementation of BatchExecCalc and StreamExecCalc - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/15 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20611) Support mini batch for window aggregate operation - posted by "Suhan Mao (Jira)" <ji...@apache.org> on 2020/12/15 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20612) Add benchmarks for scheduler - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2020/12/15 10:28:00 UTC, 0 replies.
- Unexpected latency across operator instances - posted by Antonis Papaioannou <pa...@ics.forth.gr> on 2020/12/15 10:34:28 UTC, 0 replies.
- [jira] [Created] (FLINK-20613) Update TableResult.collect()/TableResult.print() to the new type system - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/12/15 13:49:00 UTC, 0 replies.
- Fwd: Unit Test modify SourceFunction() Instance? Is this possible? - posted by chrisgopherrong <si...@gmail.com> on 2020/12/15 15:26:03 UTC, 0 replies.
- [jira] [Created] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2020/12/16 00:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/16 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20616) Support Row-based Operation Accept Function Name - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/16 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode - posted by "Georger (Jira)" <ji...@apache.org> on 2020/12/16 06:39:00 UTC, 0 replies.
- Kafka Consumer Deserializer Exception on application mode - posted by han guoguo <ku...@outlook.com> on 2020/12/16 06:39:35 UTC, 1 replies.
- [jira] [Created] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/12/16 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20619) Remove InputDependencyConstraint and InputDependencyConstraintChecker - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/12/16 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20620) Port StreamExecPythonCalc to java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/16 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20621) Refactor the TypeInformation implementation in Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/12/16 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20622) Separate the implementation of StreamExecChangelogNormalize - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/16 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20623) Separate the implementation of StreamExecWatermarkAssigner - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/16 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20624) Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule - posted by "wangsan (Jira)" <ji...@apache.org> on 2020/12/16 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27 - posted by "Jakob Edding (Jira)" <ji...@apache.org> on 2020/12/16 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20626) Canceling a job when it is failing will result in job hanging in CANCELING state - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/12/16 11:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20627) Cancel Job button overlaps text in smaller windows - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/16 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API - posted by "Jan Westphal (Jira)" <ji...@apache.org> on 2020/12/16 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20629) [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/12/16 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Consumer fails to consume from Latest - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2020/12/16 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20631) cannot find native-k8s when deploying flink using native kubernetes - posted by "renming.qi (Jira)" <ji...@apache.org> on 2020/12/16 16:12:00 UTC, 0 replies.
- Changing application configuration when restoring from checkpoint/savepoint - posted by vishalovercome <vi...@moengage.com> on 2020/12/16 17:41:37 UTC, 2 replies.
- Re: [DISCUSS] Enforce common opinionated coding style using Spotless - posted by Aljoscha Krettek <al...@apache.org> on 2020/12/16 18:20:56 UTC, 14 replies.
- Will job manager restarts lead to repeated savepoint restoration? - posted by vishalovercome <vi...@moengage.com> on 2020/12/16 18:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-20632) Missing docker images for 1.12 releas - posted by "Piotr Gwiazda (Jira)" <ji...@apache.org> on 2020/12/16 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20633) test_configuration. test_add_all test failed in py35 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/17 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20634) Flink with Scala 2.12 that scala shell is not supported still provides start-scala-shell.sh - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2020/12/17 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20635) Scala REPL with java.lang.NoSuchMethod: Errorjava.lang.NoSuchMethodError - posted by "Lu Guoqing (Jira)" <ji...@apache.org> on 2020/12/17 03:19:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.11.3, release candidate #2 - posted by Xintong Song <xt...@apache.org> on 2020/12/17 03:38:09 UTC, 0 replies.
- [jira] [Created] (FLINK-20636) Require unaligned checkpoints to be disabled in StateFun applications - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/12/17 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20637) Table convert to dataStream twice will result in two data streams - posted by "Wu (Jira)" <ji...@apache.org> on 2020/12/17 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20638) Flink hive modules Function with the same name bug - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2020/12/17 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20639) Use list to optimize the Row used by Python UDAF intermediate results - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/17 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20640) Use cython to optimize the logic of Python UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/17 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20641) flink-connector-elasticsearch6 will deadlock - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2020/12/17 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/17 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2020/12/17 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit - posted by "shiyu (Jira)" <ji...@apache.org> on 2020/12/17 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20645) Extra space typo when assembling dynamic configs - posted by "Li Wang (Jira)" <ji...@apache.org> on 2020/12/17 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/12/17 09:00:24 UTC, 0 replies.
- [jira] [Created] (FLINK-20647) Use yield to generate output datas in ProcessFunction for Python DataStream - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/12/17 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services - posted by "David Morávek (Jira)" <ji...@apache.org> on 2020/12/17 09:34:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20649) StreamTask closeAllOperators stuck - posted by "weiyunqing (Jira)" <ji...@apache.org> on 2020/12/17 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20650) Rename "native-k8s" command to "generic" in docker-entrypoint.sh - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/12/17 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20651) Use Spotless/google-java-format for code formatting/enforcement - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/12/17 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20652) Improve the document for making the user could write a DataStream job that could be execute in the batch execution mode. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/12/17 11:38:00 UTC, 0 replies.
- [DISCUSS] Releasing Apache Flink 1.12.1 - posted by Xintong Song <xt...@apache.org> on 2020/12/17 12:19:52 UTC, 17 replies.
- [jira] [Created] (FLINK-20653) SharedState should be registered after PendingCheckpoint storeCheckpoint - posted by "weiyunqing (Jira)" <ji...@apache.org> on 2020/12/17 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/12/17 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/12/17 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20656) Update docs for new KafkaSource connector. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/12/17 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2020/12/17 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20658) Make sure jdbc connection is established by target driver - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2020/12/17 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20659) YARNSessionCapacitySchedulerITCase.perJobYarnClusterOffHeap test failed with NPE - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/18 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20660) Time window operator with computed column triggers an exception in batch mode - posted by "sujun (Jira)" <ji...@apache.org> on 2020/12/18 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20661) Elasticsearch6DynamicSinkITCase.testWritingDocuments test failed with ConnectException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/18 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/18 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/12/18 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20664) Support setting service account for TaskManager pod - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/12/18 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint - posted by "zhuxiaoshang (Jira)" <ji...@apache.org> on 2020/12/18 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20666) Fix the deserialized Row losing the field_name information in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/18 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20667) Configurable batch size for vectorized reader - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/18 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20668) Introduce translateToExecNode method for FlinkPhysicalRel - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/18 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20669) Add the jzlib LICENSE file in flink-python module - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/18 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20670) Support query hints for Flink SQL - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2020/12/18 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20671) Partition doesn't commit until the end of partition - posted by "zhuxiaoshang (Jira)" <ji...@apache.org> on 2020/12/18 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20672) CheckpointAborted RPC failure can fail JM - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/12/18 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20673) ExecNode#getOutputType method should return LogicalType instead of RowType - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/18 10:06:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.11.3 released - posted by Xintong Song <xt...@apache.org> on 2020/12/18 11:20:32 UTC, 2 replies.
- [jira] [Created] (FLINK-20674) Wrong send/received stats with UNION ALL - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/12/18 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/12/18 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20676) Remove deprecated command "native-k8s" in docker-entrypoint.sh - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/12/18 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20677) Let JobManagerRunner return JobManagerRunnerResult to better distinguish result cases - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/18 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20678) JobManagerRunnerImpl does not notice unexpected JobMasterService termination - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/18 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20679) JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering test failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/19 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20680) Fails to call var-arg function with no parameters - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/19 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20681) Support specifying the hdfs path when ship archives or files - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2020/12/19 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20682) Add configuration options related to hadoop - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2020/12/19 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20683) TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotTimeout test failed with "The slot timeout should have been deactivated." - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/20 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20684) Add compression type option in RocksDBConfigurableOptions - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/12/20 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20685) Flink connect incorrect address of yarn's resouceManager scheduler - posted by "Spongebob (Jira)" <ji...@apache.org> on 2020/12/20 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20686) Valid actions add in the help tip - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2020/12/20 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20687) Missing 'yarn-application' target in CLI help message - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2020/12/20 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/12/21 02:06:00 UTC, 0 replies.
- [DISCUSS] Make Temporal Join syntax easier to use - posted by Shuo Cheng <nj...@gmail.com> on 2020/12/21 02:15:48 UTC, 2 replies.
- [jira] [Created] (FLINK-20689) Upgrade StateFun to Flink 1.11.3 - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/12/21 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20690) Separate the implementation of BatchExecCorrelate and StreamExecCorrelate - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/21 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20691) flink-1.12.0 job shutdown but metrics group not delete - posted by "谢波 (Jira)" <ji...@apache.org> on 2020/12/21 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20692) Allow set line delimiter using CsvRowDeserializationSchema - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2020/12/21 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20693) Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/21 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20694) Declarative resource management can get stuck in a loop - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/21 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished - posted by "lidesheng (Jira)" <ji...@apache.org> on 2020/12/21 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20696) Yarn Session Blob Directory is not deleted. - posted by "Mulan Wong (Jira)" <ji...@apache.org> on 2020/12/21 08:47:00 UTC, 0 replies.
- [DISCUSS] Releasing StateFun hotfix version 2.2.2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/12/21 10:17:07 UTC, 2 replies.
- [jira] [Created] (FLINK-20697) Correct "lookup.cache.ttl" of Type and Default in jdbc.md/jdbc.zh.md - posted by "jiawen xiao (Jira)" <ji...@apache.org> on 2020/12/21 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20698) A single ojbect is reused among windows with different key - posted by "Yordan Pavlov (Jira)" <ji...@apache.org> on 2020/12/21 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20699) Feedback invocation_id must not be constant. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/12/21 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20700) Default value type does not match the return type of method input() - posted by "ZhangWei (Jira)" <ji...@apache.org> on 2020/12/21 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20701) print connector supports outputting seriailzed record - posted by "zoucao (Jira)" <ji...@apache.org> on 2020/12/21 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20702) Support Map Operation Chained Together in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/22 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20703) HiveSinkCompactionITCase test timeout - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/12/22 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20704) Some rel data type does not implement the digest correctly - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/12/22 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20705) Separate the implementation of BatchExecValues and StreamExecValues - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/22 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20706) Separate the implementation of BatchExecUnion and StreamExecUnion - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/22 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20707) Separate the implementation of BatchExecExpand and StreamExecExpand - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/22 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20708) Separate the implementation of StreamExecDropUpdateBefore - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/22 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20709) Separate the implementation of StreamExecMiniBatchAssigner - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/22 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20710) HiveTableInputFormat throws IllegalArgumentException when creating splits for tables with partitions on different hdfs nameservices - posted by "laystax (Jira)" <ji...@apache.org> on 2020/12/22 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20711) Parameter enumeration value error in ES doc - posted by "孙铮 (Jira)" <ji...@apache.org> on 2020/12/22 04:13:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 2.2.2, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/12/22 06:45:55 UTC, 1 replies.
- [jira] [Created] (FLINK-20712) Add row-based support in join_lateral/left_outer_join_lateral in Python Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/22 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20713) out/err file support rolling - posted by "muzimusi (Jira)" <ji...@apache.org> on 2020/12/22 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job - posted by "jackwangcs (Jira)" <ji...@apache.org> on 2020/12/22 07:50:00 UTC, 0 replies.
- [DISCUSS] Allow streaming operators to use managed memory - posted by Jark Wu <im...@gmail.com> on 2020/12/22 09:14:53 UTC, 0 replies.
- [jira] [Created] (FLINK-20715) pyflink DataStream filter error. - posted by "Enter (Jira)" <ji...@apache.org> on 2020/12/22 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20716) Pluggable shuffle service public interface IndexedInputGate mixed with Netty shuffle service implementation. - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2020/12/22 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20717) Create isBackPressuredRatio metric - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/12/22 11:37:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20718) Create isCausingBackPressureRatio and isCausingBackPressure metrics - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/12/22 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20719) Change BatchExecNode & StreamExecNode to interface and make each node extended from ExecNodeBase directly - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/22 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20720) Add documentation for ProcessFunction in Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2020/12/22 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20721) Remove unknown input channels and process to update partitions - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/12/22 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20722) Fail to insert into hive table due to ClassCastException - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/22 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20723) testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed due to NoHostAvailableException - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/22 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20724) Create a http handler for aggregating metrics from whole job - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/12/22 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20725) TableFunction#getTypeInference is not work well for JdbcRowDataLookupFunction, it's always throws Exception - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2020/12/22 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20726) Support Pulsar connector - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20727) Pulsar SourceFunction - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20728) Pulsar SinkFunction - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20729) Pulsar DynamicTable - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20730) Pulsar Catalog - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20731) Pulsar Source - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20732) Pulsar Sink - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20733) Introduce the upsert-pulsar Connector - posted by "Jianyun Zhao (Jira)" <ji...@apache.org> on 2020/12/22 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20734) SQL client error when running joining query - posted by "owr (Jira)" <ji...@apache.org> on 2020/12/23 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20735) Support configurable log level - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/12/23 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20736) Separate the implementation of BatchExecLimit and StreamExecLimit - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/12/23 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20737) Separate the implementation of stream aggregate nodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/23 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20738) Separate the implementation of batch aggregate nodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/23 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20739) Ban `if` from HiveModule - posted by "jinfeng (Jira)" <ji...@apache.org> on 2020/12/23 04:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20740) Use managed memory to avoid direct memory OOM error - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/12/23 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20741) StateFun's DataStream interop SDK module is missing a valid NOTICE file - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/12/23 05:04:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 2.2.2, release candidate #2 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/12/23 05:58:49 UTC, 6 replies.
- [jira] [Created] (FLINK-20742) Skip deployment of StateFun example artifacts - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/12/23 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20743) Print ContainerId For RemoteTransportException - posted by "yang gang (Jira)" <ji...@apache.org> on 2020/12/23 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20744) org.apache.flink.test.checkpointing.UnalignedCheckpointITCase fails due to java.lang.ArrayIndexOutOfBoundsException - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/23 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20745) Clean useless codes: Never push calcProgram to correlate - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/12/23 08:49:00 UTC, 0 replies.
- [DISCUSS][FLINK-20726] Introduce Pulsar connector - posted by 赵 建云 <zh...@outlook.com> on 2020/12/23 09:37:06 UTC, 1 replies.
- [jira] [Created] (FLINK-20746) Support ignore-first-line option for CSV format - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/12/23 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20747) max 函数冲突报ClassCastException异常 - posted by "zengjinbobo (Jira)" <ji...@apache.org> on 2020/12/23 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20748) Remap excess slots to outstanding requirements - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/23 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20749) Allow to register new slots listener at DeclarativeSlotPool - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/23 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20750) Port stream python aggregate nodes to Java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/23 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20751) Port batch python aggregate nodes to Java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/23 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20752) FailureRateRestartBackoffTimeStrategy allows one less restart than configured - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/23 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20753) Duplicates With Exactly-once Kafka -> Kakfa Producer - posted by "Nazar Volynets (Jira)" <ji...@apache.org> on 2020/12/23 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20754) Flink 1.12 docker images not present on Dockerhub - posted by "David Pichler (Jira)" <ji...@apache.org> on 2020/12/23 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20755) proctime 在yaml配置中启动sql-clinet报错 - posted by "yunsky (Jira)" <ji...@apache.org> on 2020/12/24 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20756) PythonCalcSplitConditionRule is not working as expected - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/12/24 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20757) Optimize data broadcast for sort-merge shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/12/24 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20758) Use region file mechanism for shuffle data reading before we switch to managed memory - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/12/24 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20759) The separator causes job submission to fail through the flink command line - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2020/12/24 05:13:00 UTC, 0 replies.
- 来自李奇的邮件 - posted by 李奇 <li...@163.com> on 2020/12/24 07:47:38 UTC, 0 replies.
- [jira] [Created] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/12/24 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20761) Cannot read hive table/partition whose location path contains comma - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/24 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20762) Remove unused checkpointStorage path after job finished - posted by "Liu (Jira)" <ji...@apache.org> on 2020/12/24 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20763) canal format parse update record with null value get wrong result - posted by "WangRuoQi (Jira)" <ji...@apache.org> on 2020/12/24 16:13:00 UTC, 0 replies.
- Insufficient number of network buffers after restarting - posted by Yufei Liu <li...@gmail.com> on 2020/12/24 16:54:30 UTC, 3 replies.
- [jira] [Created] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/25 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20766) Separate the implementation of stream sort nodes - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/12/25 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20767) add nested field support for SupportsFilterPushDown - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/12/25 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20768) Support routing field for Elasticsearch connector - posted by "wangsan (Jira)" <ji...@apache.org> on 2020/12/25 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20769) Support minibatch to optimize Python UDAF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/25 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20770) Incorrect description for config option kubernetes.rest-service.exposed.type - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/12/25 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20771) Hive partition is not added when there is a lot of data - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/12/25 10:18:00 UTC, 0 replies.
- (无主题) - posted by 刘力文 <li...@163.com> on 2020/12/25 10:24:00 UTC, 2 replies.
- [jira] [Created] (FLINK-20772) [DISCUSS] RocksDBValueState with TTL occurs NullPointerException when calling update(null) method - posted by "Seongbae Chang (Jira)" <ji...@apache.org> on 2020/12/25 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20773) Support allow-unescaped-control-chars option for JSON format - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/25 12:28:01 UTC, 0 replies.
- [VOTE] Release 1.12.1, release candidate #1 - posted by Xintong Song <xt...@apache.org> on 2020/12/26 00:53:05 UTC, 12 replies.
- [jira] [Created] (FLINK-20774) Test - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/27 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20775) Missed Docker Images Flink 1.12 - posted by "Nazar Volynets (Jira)" <ji...@apache.org> on 2020/12/27 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20776) Error message is incomplete in JSON format - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/27 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2020/12/27 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20778) the comment for kafka split offset type is wrong - posted by "Jeremy Mei (Jira)" <ji...@apache.org> on 2020/12/27 17:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20779) Add documentation for row-based operation in Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/28 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20780) Flink-sql-client query hive - posted by "xx chai (Jira)" <ji...@apache.org> on 2020/12/28 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20781) Unal - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/28 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20782) Separate the implementation of BatchExecRank - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/12/28 07:07:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20783) Separate the implementation of BatchExec nodes for Join - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/12/28 07:09:00 UTC, 0 replies.
- 回复： (无主题) - posted by Ball's Holy <87...@qq.com> on 2020/12/28 07:44:05 UTC, 0 replies.
- [jira] [Created] (FLINK-20784) .staging_xxx does not exist, when insert into hive - posted by "macdoor615 (Jira)" <ji...@apache.org> on 2020/12/28 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20785) MapRelDataType for legacy planner has wrong digest - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/12/28 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20786) flink-playgrounds Git branch(release-1.12) does not exist - posted by "billyxie (Jira)" <ji...@apache.org> on 2020/12/28 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20787) Improve the Table API to make it usable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/28 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/28 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20789) Add a metric named `deserializeFaildCount` for kafka connectors - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2020/12/28 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20790) Generated classes should not be put under src/ directory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/28 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20791) Support local aggregate push down for Blink batch planner - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2020/12/28 16:43:00 UTC, 0 replies.
- Support local aggregate push down for Blink batch planner - posted by Sebastian Liu <li...@gmail.com> on 2020/12/28 16:48:41 UTC, 2 replies.
- [Discussion][FLINK-20416] Need a cached catalog for batch SQL job - posted by Sebastian Liu <li...@gmail.com> on 2020/12/28 17:07:36 UTC, 0 replies.
- [ANNOUNCE] New formatting rules are now in effect - posted by Chesnay Schepler <ch...@apache.org> on 2020/12/28 17:28:34 UTC, 9 replies.
- [jira] [Created] (FLINK-20792) Allow shorthand invocation of spotless - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/28 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20793) Fix NamesTest due to code style refactor - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/29 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20794) Support to select distinct columns in the Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/29 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20795) add a parameter to decide whether or not print dirty record when `ignore-parse-errors` is true - posted by "zoucao (Jira)" <ji...@apache.org> on 2020/12/29 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20796) Support unnest in the Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/29 05:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2020/12/29 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20798) Service temporarily unavailable due to an ongoing leader election. Please refresh. - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2020/12/29 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20799) Restructure TOC of the "Working with state" documentation page - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2020/12/29 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20800) HadoopViewFileSystemTruncateTest failure caused by AssumptionViolatedException - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/12/29 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20801) Using asynchronous methods in operators causes serialization problems - posted by "lafeier (Jira)" <ji...@apache.org> on 2020/12/29 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20802) force-shading does not declare flink-parent as it's parent - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/29 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20803) Version nismatch between spotless-maven-plugin and google-java-format plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/29 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20804) Add SwiftFS end-to-end test - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/29 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20805) Blink runtime classes partially ignored by spotless - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/29 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20806) Correct error message when calling TaskExecutor.disconnectJobManagerConnection - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/29 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20807) Cleanup checkstyle suppressions files - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/29 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20808) Remove redundant checkstyle rules - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/29 20:01:00 UTC, 0 replies.
- Did Flink 1.11 break backwards compatibility for the table environment? - posted by Guenther Starnberger <fl...@sysfrog.org> on 2020/12/30 02:30:05 UTC, 6 replies.
- [jira] [Created] (FLINK-20809) the limit push down invalid when use filter - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2020/12/30 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20810) abstract JdbcSchema structure and derive it from JdbcDialect. - posted by "jiawen xiao (Jira)" <ji...@apache.org> on 2020/12/30 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20811) Support HTTP paths for yarn ship files/archives - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/12/30 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided - posted by "WeiNan Zhao (Jira)" <ji...@apache.org> on 2020/12/30 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20813) SQL Client should create modules with user class loader - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/30 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20814) The CEP code is not running properly - posted by "little-tomato (Jira)" <ji...@apache.org> on 2020/12/30 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20815) Elasticsearch7DynamicSinkITCase failed caused by pulling docker image error - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2020/12/30 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout - posted by "Matthias (Jira)" <ji...@apache.org> on 2020/12/30 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20817) kafka source have 200 field,Causes the class to be generated failed - posted by "WeiNan Zhao (Jira)" <ji...@apache.org> on 2020/12/30 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20818) End to end test produce excessive amount of logs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/12/30 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20819) flink : Connectors : JDBC test failing on Red Hat 8.x PowerPC Linux - posted by "Priya (Jira)" <ji...@apache.org> on 2020/12/30 11:33:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20820) Rename o.a.f.table.runtime.generated package in blink runtime - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/12/30 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20821) `select row(map[1,2],'ab')` parses failed - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/12/31 00:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20822) Don't check whether a function is generic in hive catalog - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/12/31 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20823) Update documentation to mention Table/SQL API doesn't provide cross-major-version state compatibility - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/12/31 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20824) BlockingShuffleITCase. testSortMergeBlockingShuffle test failed with "Inconsistent availability: expected true" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/12/31 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20825) Upsert-kafka should throw a better exception when the key of the record is NULL - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/12/31 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20826) Fix bug in streaming SQL examples - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2020/12/31 10:30:00 UTC, 0 replies.