dev@flink.apache.org, 2021-03

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

- [jira] [Created] (FLINK-21524) Replace scheduler benchmarks with wrapper classes - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/01 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21525) Move scheduler benchmarks to Flink and add unit tests - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/01 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21526) Replace scheduler benchmarks with wrapper classes - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/01 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21527) fromValues function cost enormous network buffer - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/03/01 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21528) Rest Api Support Wildcard - posted by "wxmimperio (Jira)" <ji...@apache.org> on 2021/03/01 04:09:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-163: SQL Client Improvements - posted by Kurt Young <yk...@gmail.com> on 2021/03/01 04:14:32 UTC, 5 replies.
- [jira] [Created] (FLINK-21529) FLIP-152: Hive Query Syntax Compatibility - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/01 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21530) Precompute TypeName's canonical string representation - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/01 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21531) Introduce pluggable Parser - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/01 06:10:00 UTC, 0 replies.
- Re: Re: Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/03/01 06:18:52 UTC, 10 replies.
- [jira] [Created] (FLINK-21532) Make CatalogTableImpl#toProperties and CatalogTableImpl#fromProperties case sensitive - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2021/03/01 07:04:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior - posted by Timo Walther <tw...@apache.org> on 2021/03/01 07:45:31 UTC, 6 replies.
- Re: [DISCUSS] Apache Flink Jira Process - posted by Xintong Song <to...@gmail.com> on 2021/03/01 07:51:04 UTC, 21 replies.
- [jira] [Created] (FLINK-21533) Kafka011ITCase#testAllDeletes fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21534) Test jars are uploaded twice during Flink maven deployment - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/01 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21536) AdaptiveSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21537) SavepointITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 08:21:00 UTC, 0 replies.
- [DISCUSS] Splitting User support mailing list - posted by Roman Khachatryan <ro...@apache.org> on 2021/03/01 08:48:23 UTC, 12 replies.
- [jira] [Created] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 09:11:00 UTC, 0 replies.
- [VOTE] FLIP-151: Incremental snapshots for heap-based state backend - posted by Roman Khachatryan <ro...@apache.org> on 2021/03/01 09:11:13 UTC, 5 replies.
- [jira] [Created] (FLINK-21539) 'SQL Client end-to-end test (Blink planner) Elasticsearch (v6.3.1)' fails during download - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21540) finegrained_resource_management tests hang on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21541) Update the existing K8s application e2e test to also verify pod template - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/03/01 09:37:00 UTC, 0 replies.
- Re: [VOTE] Release 1.12.2, release candidate #2 - posted by Matthias Pohl <ma...@ververica.com> on 2021/03/01 09:57:00 UTC, 6 replies.
- [jira] [Created] (FLINK-21542) Add documentation for supporting INSERT INTO specific columns - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/01 11:43:00 UTC, 0 replies.
- [DISCUSS] Enabling more dynamic, or metadata-driven behaviors - posted by Maciej Obuchowski <ob...@gmail.com> on 2021/03/01 11:57:47 UTC, 1 replies.
- [jira] [Created] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2021/03/01 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21544) Upgrade Jackson databind version from 2.10.1 used in, at least, Flink Python jar - posted by "Adam Roberts (Jira)" <ji...@apache.org> on 2021/03/01 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21545) Running Kerberized YARN per-job on Docker test stalls on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/01 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21546) Upgrade io.netty netty-codec in Flink (four findings) - posted by "Adam Roberts (Jira)" <ji...@apache.org> on 2021/03/01 13:56:00 UTC, 0 replies.
- Watermarks when reading from file - posted by Dominik Wosiński <wo...@gmail.com> on 2021/03/01 16:32:36 UTC, 3 replies.
- [jira] [Created] (FLINK-21547) Fix improper log level in TwoPhaseCommitSinkFunction - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/03/01 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21548) keyBy operation produces skewed event distribution with low-cardinality keys - posted by "Iaroslav Zeigerman (Jira)" <ji...@apache.org> on 2021/03/01 19:03:00 UTC, 0 replies.
- [DISCUSS] FLIP-165: Operator's Flame Graphs - posted by Alexander Fedulov <al...@ververica.com> on 2021/03/01 23:38:25 UTC, 15 replies.
- [jira] [Created] (FLINK-21549) Support json serialization/deserialization for the push-down results - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/02 02:29:00 UTC, 0 replies.
- [VOTE] FLIP-162: Consistent Flink SQL time function behavior - posted by Leonard Xu <xb...@gmail.com> on 2021/03/02 02:41:54 UTC, 4 replies.
- [jira] [Created] (FLINK-21550) ZooKeeperHaServicesTest.testSimpleClose fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/02 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21551) FlinkKafkaProducerITCase.testHappyPath fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/02 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/02 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/02 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21554) Remove the magical classpath setting stuff in docker-entrypoint.sh - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/03/02 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21555) HA does not work when using mesos scheduler - posted by "Qinghui Xu (Jira)" <ji...@apache.org> on 2021/03/02 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21556) StreamingKafkaITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/02 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21557) An error was reported when temp join hive. - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/03/02 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21558) DeclarativeSlotManager starts logging "Could not fulfill resource requirements of job xxx" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/02 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/02 14:22:00 UTC, 0 replies.
- Re: [VOTE] FLIP-163: SQL Client Improvements - posted by Shengkai Fang <fs...@gmail.com> on 2021/03/02 14:27:42 UTC, 5 replies.
- [ANNOUCE][DISCUSS] Roadmap Update for Website - posted by Stephan Ewen <se...@apache.org> on 2021/03/02 14:38:25 UTC, 7 replies.
- [jira] [Created] (FLINK-21560) AkkaRpcServiceTest.testScheduleRunnable fails with "call was not properly delayed" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/02 14:52:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.12.2, release candidate #2 - posted by Roman Khachatryan <ro...@apache.org> on 2021/03/02 15:07:42 UTC, 4 replies.
- [jira] [Created] (FLINK-21561) Introduce cache for binaries downloaded by bash tests - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/02 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21562) Add more informative message on CSV parsing errors - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21563) Support using computed columns when defining (new) computed columns - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/02 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21565) Support more integer types in TIMESTAMPADD - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 16:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21566) Improve error message for "Unsupported casting" - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21567) CSV Format exception while parsing: ArrayIndexOutOfBoundsException: 4000 - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21568) Navigating in SQL client can lead to SqlExecutionException - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21569) Flink SQL with CSV file input job hangs - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/02 17:48:00 UTC, 0 replies.
- [DISCUSS] FLIP-166: Flink/Pinot Connector - posted by Yupeng Fu <yu...@gmail.com> on 2021/03/02 19:22:20 UTC, 1 replies.
- [jira] [Created] (FLINK-21570) Add Job ID to RuntimeContext - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/02 21:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21571) Japicmp reference version does not exist - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/02 23:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21572) USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client. - posted by "Xiaoguang Sun (Jira)" <ji...@apache.org> on 2021/03/03 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21573) Support expression reuse in codegen - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2021/03/03 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21574) WindowDistinctAggregateITCase.testCumulateWindow_GroupingSets unstable - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/03 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21575) Replace InputFormat with BulkFormat in HivePartition Reader - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/03 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21576) Remove ExecutionVertex#getPreferredLocations - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/03/03 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21577) SimpleType.simpleTypeFrom(...) complains with "Collection is empty" - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/03 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/03 07:40:00 UTC, 0 replies.
- 退订 - posted by 吴新乐 <15...@163.com> on 2021/03/03 07:51:40 UTC, 2 replies.
- [jira] [Created] (FLINK-21579) Support "SHOW USER FUNCTIONS" statement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/03 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21580) Remove JobGraph.ScheduleMode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/03 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21581) Add PublicEvolving to RuntimeContext.jobId - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/03 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21582) COALESCE not works when cast a variable return null - posted by "Jerry (Jira)" <ji...@apache.org> on 2021/03/03 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21583) Allow comments in CSV format without having to ignore parse errors - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/03 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21584) Support UNNEST in LEFT JOINs - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/03/03 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21585) Provide a configurable way to skip metrics - posted by "Ashish Khatkar (Jira)" <ji...@apache.org> on 2021/03/03 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21586) Implement ResolvedExpression.asSerializableString for SQL - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/03 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21587) FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources is unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/03 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21588) unable to create catalogs for postgresql - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/03 17:16:00 UTC, 0 replies.
- Update operation encoding/format - posted by nick <ni...@nickkarpov.com> on 2021/03/03 22:44:36 UTC, 0 replies.
- [jira] [Created] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/03 22:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21590) Avoid hive logs in the SQL client console - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/04 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21591) Flink using OSS Backend on Native K8S found some errors - posted by "yufan wang (Jira)" <ji...@apache.org> on 2021/03/04 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21592) RemoveSingleAggregateRule fails due to nullability mismatch - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/04 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21593) RocksDBListStatePerformanceTest.testRocksDbListStateAPI fail because of timeout - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21594) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/04 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21595) DispatcherResourceManagerComponent.deregisterApplication time-out - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21596) CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException" - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21598) testDetachedModeSecureWithPreInstallKeytab fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21599) execute[Parallel union, p = 10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed because of oom. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21600) Resuming Savepoint (rocks, no parallelism change, heap timers) end-to-end test failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/04 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21601) observing errors in jobmanager - after created prometheus metric reporter - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/04 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21602) Creation of ExecutionGraph happens in main thread - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/04 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21603) SQLClientKafkaITCase failed due to unexpected end of file - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/03/04 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21604) Remove adaptive scheduler nightly test profile, replace with more specific testing approach - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/04 11:27:00 UTC, 0 replies.
- Re: [DISCUSS] Deprecation and removal of the legacy SQL planner - posted by Timo Walther <tw...@apache.org> on 2021/03/04 12:40:55 UTC, 3 replies.
- [jira] [Created] (FLINK-21605) Uniform the format of property name in the flink configuration file. - posted by "张超明 (Jira)" <ji...@apache.org> on 2021/03/04 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21606) TaskManager connected to invalid JobManager leading to TaskSubmissionException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/04 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21607) Twitter table source connector - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2021/03/04 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..." - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/04 18:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21609) SimpleRecoveryITCaseBase.testRestartMultipleTimes fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/04 18:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21610) ProcessFailureCancelingITCase failed on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/04 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21611) Japicmp fails with "Could not resolve org.apache.flink:flink-core:jar:1.12.0" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/04 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21612) Support StreamExecGroupAggregate json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/05 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/03/05 03:27:00 UTC, 0 replies.
- [DISCUSSION] Introduce a separated memory pool for the TM merge shuffle - posted by Guowei Ma <gu...@gmail.com> on 2021/03/05 03:32:47 UTC, 8 replies.
- [jira] [Created] (FLINK-21615) Introduce a new integration test framework for SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/05 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21614) Introduce a new integration test framework for SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/05 03:57:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-162: Consistent Flink SQL time function behavior - posted by Leonard Xu <xb...@gmail.com> on 2021/03/05 03:57:29 UTC, 0 replies.
- [jira] [Created] (FLINK-21616) Introduce a new integration test framework for SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/05 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21617) FLIP-162: Consistent Flink SQL time function behavior - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/05 04:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-21618) Introduce a new integration test framework for SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/05 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21619) Remove the optional host and webui-port in jobmanager.sh and use common args instead - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/03/05 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21620) [table-planner/table-parser] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/05 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21621) Support TIMESTAMP_LTZ arithmetic - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/05 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision]) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/05 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21623) Introduce CURRENT_ROW_TIMESTAMP function - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/05 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21624) Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/05 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21625) 5.03.2021 Benchmarks are not compiling - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/03/05 06:32:00 UTC, 0 replies.
- [DISCUSS] FLIP-162 follow-up discussion - posted by Leonard Xu <xb...@gmail.com> on 2021/03/05 07:00:39 UTC, 0 replies.
- [jira] [Created] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/05 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21627) When you insert multiple inserts with statementSet, you modify multiple inserts with OPTIONS('table-name '=' XXX '), but only the first one takes effect - posted by "wangtaiyang (Jira)" <ji...@apache.org> on 2021/03/05 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21628) Support Python UDAF in Tumbling Window - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/05 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21629) Support Python UDAF in Sliding Window - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/05 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21630) Support Python UDAF in Session Window - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/05 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21631) Add CountTrigger for Python group window aggregation - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/05 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21632) Add NamespacedStateView and PerWindowStateDataViewStore - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/05 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21633) Index pending task managers in TaskManagerTracker - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/03/05 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21634) ALTER TABLE statement enhancement - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/05 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21635) Driver name is optional for DriverManager.getConnection but a must in JdbcConnectionOptions - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/05 09:31:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.2 released - posted by Roman Khachatryan <ro...@apache.org> on 2021/03/05 09:40:34 UTC, 6 replies.
- [jira] [Created] (FLINK-21636) Setup a global timeout for all tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/05 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21637) Wrong results when filtering by timestamp type - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/05 12:52:00 UTC, 0 replies.
- [VOTE] FLIP-165: Operator's Flame Graphs - posted by Alexander Fedulov <al...@ververica.com> on 2021/03/05 13:42:49 UTC, 4 replies.
- [RESULT][VOTE] FLIP-151: Incremental snapshots for heap-based state backend - posted by Roman Khachatryan <ro...@apache.org> on 2021/03/05 14:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-21638) Clean up argument order and semantics of all "stopWithSavepoint" calls in the codebase - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/05 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21639) docs still state that AsyncWaitOperator is not chainable - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/03/05 20:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21640) Job fails to be submitted in tenant scenario - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/03/06 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21641) Support 'useModules' and 'listModules' in PyFlink - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/03/06 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21642) RequestReplyFunction recovery fails with a remote SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/06 20:29:00 UTC, 0 replies.
- QUESTION: Local Dev Setup - posted by Jan Brusch <ja...@gmail.com> on 2021/03/06 20:40:08 UTC, 1 replies.
- [jira] [Created] (FLINK-21643) JDBC sink should be able to execute statements on multiple tables - posted by "Maciej Obuchowski (Jira)" <ji...@apache.org> on 2021/03/07 00:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21644) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/07 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21645) Introduce StateDeclaration - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/07 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21646) Support json serialization/deserialization for the states in StreamExecGroupAggregate - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/07 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/07 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/07 19:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21649) Refactor CopyOnWrite state classes - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/07 19:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21650) On heap state restore, skip key groups from other state backends - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/07 19:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21651) Migrate module-related tests in LocalExecutorITCase to new integration test framework - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/03/08 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21652) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeOut Exception during closing stage. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/08 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21653) org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed because of "Not enough resources available for scheduling." - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/08 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21654) YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/08 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21655) Incorrect simplification for coalesce call on a groupingsets' result - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/03/08 06:07:00 UTC, 0 replies.
- How do I call an algorithm written in C++ in Flink? - posted by 苏喜张 <15...@163.com> on 2021/03/08 06:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-21656) Add antlr parser for hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/08 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21657) flink doc fails to display a picture - posted by "zl (Jira)" <ji...@apache.org> on 2021/03/08 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21658) Align flink-benchmarks with job graph builder - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/03/08 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21659) Running HA per-job cluster (rocks, incremental) end-to-end test fails - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/08 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21660) create table can not like with hive catalog table - posted by "liqiang.liu (Jira)" <ji...@apache.org> on 2021/03/08 08:14:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Nicholas Jiang <pr...@163.com> on 2021/03/08 08:15:53 UTC, 3 replies.
- [jira] [Created] (FLINK-21661) SHARD_GETRECORDS_INTERVAL_MILLIS wrong use? - posted by "jiamo (Jira)" <ji...@apache.org> on 2021/03/08 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21662) Reject duplicate ValueSpec registrations under the same state name - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/08 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21663) Reject duplicate StatefulFunction registrations under the same typename - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/08 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21664) Support STATEMENT SET syntax in TableEnvironment - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/08 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21665) Create catalog statement should support [IF NOT EXIST] and [COMMENT] - posted by "humengyu (Jira)" <ji...@apache.org> on 2021/03/08 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21666) Consistent documentation and recommendations regarding Stop vs Cancel with savepoint - posted by "Thomas Eckestad (Jira)" <ji...@apache.org> on 2021/03/08 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21667) Standby RM might remove resources from Kubernetes - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/08 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21668) A writing error in org.apache.flink.sql.parser.ddl.SqlCreateDatabase - posted by "humengyu (Jira)" <ji...@apache.org> on 2021/03/08 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21669) Support "table.dml-sync" option to execute DML statements synchronizely in TableEnvironment and SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/08 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21670) Bump log4j version to 2.8.2 - posted by "Adam Roberts (Jira)" <ji...@apache.org> on 2021/03/08 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21671) some condition expressions can be simplified in org.apache.flink.yarn.YarnClusterDescriptor - posted by "zhangyongquan (Jira)" <ji...@apache.org> on 2021/03/08 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) - posted by "Adam Roberts (Jira)" <ji...@apache.org> on 2021/03/08 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21673) Add extension points to heap backend to read/write incremental snapshots - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/08 18:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21674) JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver - posted by "Fuyao (Jira)" <ji...@apache.org> on 2021/03/08 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/09 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21676) Ensure that state names are valid identifiers in the StateFun Java SDK - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/09 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21677) org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/09 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21678) Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/09 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21679) Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/03/09 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21680) Table Created with LIKE clause may get unexpected options "is_generic" - posted by "Xiaodong Chen (Jira)" <ji...@apache.org> on 2021/03/09 05:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21681) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/03/09 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21682) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/03/09 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21683) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/03/09 06:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-21684) Fix typo in StreamExecDeduplicate - posted by "wangpeibin (Jira)" <ji...@apache.org> on 2021/03/09 06:37:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-162 follow-up discussion - posted by Kurt Young <yk...@gmail.com> on 2021/03/09 07:14:51 UTC, 4 replies.
- [jira] [Created] (FLINK-21685) Flink JobManager failed to restart in K8S HA setup - posted by "Peng Zhang (Jira)" <ji...@apache.org> on 2021/03/09 07:23:00 UTC, 1 replies.
- [jira] [Created] (FLINK-21686) Duplicate code in hive parser file should be abstracted into functions - posted by "humengyu (Jira)" <ji...@apache.org> on 2021/03/09 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21687) e2e "Run kubernetes session test (default input)" timed out due to k8s issue - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/09 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21688) we use setIncreaseParallelism function, can cause slow flush in restore - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2021/03/09 08:45:00 UTC, 0 replies.
- [DISCUSS] FLIP-154: SQL Implicit Type Coercion - posted by Danny Chan <da...@apache.org> on 2021/03/09 10:26:03 UTC, 3 replies.
- [jira] [Created] (FLINK-21689) UnalignedCheckpointITCase does not terminate - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/09 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig - posted by "Zhengqi Zhang (Jira)" <ji...@apache.org> on 2021/03/09 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21691) KafkaSource fails with NPE when setting it up - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/09 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21692) Update the Python SDK to reflect the latest changes in the request-reply protocol - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/09 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21693) TestStreamEnvironment does not implement executeAsync - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/09 18:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21694) Increase default value of "state.backend.rocksdb.checkpoint.transfer.thread.num" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/03/09 20:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21695) Increase default value for number of KeyGroups - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/03/09 21:23:00 UTC, 0 replies.
- [Statefun] Interaction Protocol for Statefun - posted by Guillaume Vauvert <gv...@gmail.com> on 2021/03/09 22:45:22 UTC, 0 replies.
- [jira] [Created] (FLINK-21696) scala code in "Writing WatermarkGenerators" documentation missing/deprecated - posted by "Giacomo Gamba (Jira)" <ji...@apache.org> on 2021/03/09 23:38:00 UTC, 0 replies.
- [DISCUSS] Flink-RocketMQ connector - posted by heng du <du...@apache.org> on 2021/03/10 01:19:26 UTC, 2 replies.
- [jira] [Created] (FLINK-21697) Support StreamExecMiniBatchAssigner json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/10 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21698) Disable problematic cast conversion between NUMERIC type and TIMESTAMP type - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/10 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21699) SecurityUtils JaasModule make JVM dirty - posted by "tonychan (Jira)" <ji...@apache.org> on 2021/03/10 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/03/10 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21701) Extend the `RESET` command in the sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/10 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21702) Support option `sql-client.verbos` to print the exception stack - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/10 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21703) Add option `table.dml-sync` - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/10 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21704) Support StreamExecChangelogNormalize json serde - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/10 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21705) Add a SliceType to the StateFun Java SDK - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/10 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio.BufferUnderflowException" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/10 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/03/10 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21708) CloserCleaner warning - posted by "Avi Levi (Jira)" <ji...@apache.org> on 2021/03/10 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21709) Officially deprecate the legacy planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/10 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21710) FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/10 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/10 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21712) Extract interfaces for the Execution* (classes used by the DefaultExecutonGraph) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/10 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21713) Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/10 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME() - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/10 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21715) Introduce more conversion classes for LocalZonedTimestampType(TIMESTAMP_LTZ) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/10 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21716) Support higher precision for Data Type TIME(p) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/10 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21717) Links to Java/Python docs are Broken - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/03/10 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21718) FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources fails - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/10 13:21:00 UTC, 0 replies.
- Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job - posted by Wenhao Ji <pr...@gmail.com> on 2021/03/10 14:39:40 UTC, 1 replies.
- [jira] [Created] (FLINK-21719) Update statefun developer docs for new protocol - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/03/10 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21720) Rework Documentation Style Guide for the new build system - posted by "Marta Paes Moreira (Jira)" <ji...@apache.org> on 2021/03/10 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21721) Add a generic egress message builder to the SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/10 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21722) Wrong class name used in 'Generating Watermarks' documentation page for the Scala examples - posted by "Thelgis Kotsos (Jira)" <ji...@apache.org> on 2021/03/10 17:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21723) Hadoop integration link is broken on download page - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/10 18:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21724) Remove type annotation from python message.as_type - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/03/10 19:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21725) DataTypeExtractor extracts wrong fields ordering for Tuple12 - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/11 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21726) Fix checkpoint stuck - posted by "fanrui (Jira)" <ji...@apache.org> on 2021/03/11 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21727) Support DDL in HiveParser - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/11 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21728) DegreesWithExceptionITCase crash - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/11 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21729) SimpleRecoveryFailureRateStrategyITBase fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/11 06:17:00 UTC, 0 replies.
- Re: Upgrade calcite version - posted by Danny Chan <da...@apache.org> on 2021/03/11 06:27:36 UTC, 1 replies.
- [jira] [Created] (FLINK-21730) Introduce ExecNodeTranslator - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/11 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21731) Add a benchmark for DefaultScheduler#startScheduling - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/11 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21732) Add apache-flink-libraries module - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/11 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21733) WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/03/11 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21734) Allow BLOCKING result partition to be individually consumable - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/03/11 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21735) Harden JobMaster#updateTaskExecutionState() - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/03/11 12:40:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-165: Operator's Flame Graphs - posted by Alexander Fedulov <al...@ververica.com> on 2021/03/11 13:13:25 UTC, 0 replies.
- [jira] [Created] (FLINK-21736) Introduce latency tracking state - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/03/11 16:17:00 UTC, 0 replies.
- Re: [Parquet support] - posted by Etienne Chauchot <ec...@apache.org> on 2021/03/11 16:17:11 UTC, 5 replies.
- [jira] [Created] (FLINK-21737) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/11 16:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21738) reduce unnecessary method calls in ModuleManager - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/03/11 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21739) TopN with TUMBLE window get Incorrect result - posted by "wxmimperio (Jira)" <ji...@apache.org> on 2021/03/12 04:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21740) CliTableauResultViewTest.testCancelBatchResult fails - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/12 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21742) Support REMOVE JAR statement in SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/12 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21741) Support SHOW JARS statement in SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/12 06:29:00 UTC, 0 replies.
- [DISCUSS] Split PyFlink packages into two packages: apache-flink and apache-flink-libraries - posted by Xingbo Huang <hx...@gmail.com> on 2021/03/12 06:30:55 UTC, 15 replies.
- JIRA Username - posted by 积淀智慧 <dr...@163.com> on 2021/03/12 06:47:13 UTC, 1 replies.
- [jira] [Created] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx - posted by "Wei Hao (Jira)" <ji...@apache.org> on 2021/03/12 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21744) Support StreamExecDeduplicate json serialization/deserialization - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/12 09:11:00 UTC, 0 replies.
- [DISCUSS] Move Flink ML pipeline API and library code to a separate repository named flink-ml - posted by Dong Lin <li...@gmail.com> on 2021/03/12 10:15:36 UTC, 3 replies.
- [jira] [Created] (FLINK-21745) JobMasterTest.testReconnectionAfterDisconnect hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/12 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21746) flink sql fields in row access error about scalarfunction - posted by "Peihui He (Jira)" <ji...@apache.org> on 2021/03/12 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/03/12 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/12 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21749) unable to use scala Shell - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/12 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21750) Support StreamExecWatermarkAssigner json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/12 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21751) Improve handling of freed slots if final requirement message is in flight - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/12 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21752) NullPointerException on restore in PojoSerializer - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/12 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21753) Cycle references between memory manager and gc cleaner action - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/13 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21754) Exception message does not point to the right path. - posted by "ZhangWei (Jira)" <ji...@apache.org> on 2021/03/13 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21755) Remove flink-runtime dependency from metric reporters - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21756) Move JMXServer to flink-core - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21757) Extract LogicalScopeProvider interface from FrontMetricGroup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21758) Add default implementations for all MetricGroup methods accepting ints - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21759) Add TestMetricGroup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21760) Remove dependency from flink-metrics-jmx - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21762) Remove dependency from flink-metrics-prometheus - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21761) Remove dependency from flink-metrics-influxdb - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21763) Extend Data Stream's batch mode to handle partitioning/grouping/ordering - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2021/03/13 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21765) Remove implementation-specific MetricGroup parents - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21766) Remove OperatorMetricGroup#parent - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21767) ComponentMetricGroups should return plain QueryScopeInfos - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21768) Optimize system.exit() logic of CliFrontend - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/03/13 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21769) Encapsulate component meta data - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21770) JobManagerMG should not accept JobGraph - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21771) Replace StreamTaskTestHarness#TestTaskMetricGroup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21772) Remove dependency from flink-metrics-slf4j - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21773) Remove dependency from flink-metrics-statsd - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21774) Do not display column names when retrun set is emtpy in SQL Client - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/13 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21775) Migrate all JobManagerMG instantiations to factory method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21776) Migrate all JobManagerJobMG instantiations to factory method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/13 14:57:00 UTC, 0 replies.
- flink 1.11 class loading question - posted by Chen Qin <qi...@gmail.com> on 2021/03/13 23:21:48 UTC, 3 replies.
- [jira] [Created] (FLINK-21777) Replace the 4M data writing cache of sort-merge shuffle with writev system call - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/14 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21778) Use heap memory instead of direct memory as index entry cache for sort-merge shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/14 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21779) testResourceCanBeAllocatedForDifferentJobWithDeclarationBeforeSlotFree fail because of timeout - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/14 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21780) SourceStreamTaskTest hangs (no output for 900 seconds) - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/14 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21781) Lookup Table based on rowkey ranges - posted by "Felipe Lolas (Jira)" <ji...@apache.org> on 2021/03/14 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21782) Lookup Table based on rowkey ranges - posted by "Felipe Lolas (Jira)" <ji...@apache.org> on 2021/03/14 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21783) Allow extension of HeapBackend SnapshotStrategy - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/14 19:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21784) Allow extension of HeapBackend RestoreOperation - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/14 22:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21785) Support StreamExecCorrelate json serde - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/15 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21786) sample Job execution failed - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/15 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21787) The method $(String) is undefined for the type TableExample - posted by "wangbin (Jira)" <ji...@apache.org> on 2021/03/15 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/15 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directory fairly - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/15 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21790) Shuffle data directories to make data directory section of different TaskManagers fairer - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/15 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21791) Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/15 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21792) Add a PythonFunctionRunnerDescriptor and unify the creation of all the PythonFunctionRunner - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/03/15 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21793) Native K8s does not respect TM memory setups decided by RM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/15 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21794) Support retrieving slot details via rest api - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/15 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21795) Support retrieving slot details via rest api - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/15 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21796) https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14665&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/15 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21797) Performance regression on 03/11/21 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/03/15 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21798) Guard MemorySegment against multiple frees. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/15 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21799) Detect and fail explicitly on managed memory leaking - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/15 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21800) Guard MemorySegment against concurrent frees. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/15 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21801) Update use new schema in Table, TableResult, TableOperation - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/15 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/15 15:52:00 UTC, 0 replies.
- Find many strange measurements in metrics database of influxdb - posted by Tim yu <yu...@163.com> on 2021/03/15 16:06:34 UTC, 0 replies.
- [jira] [Created] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time - posted by "Craig Smoothey (Jira)" <ji...@apache.org> on 2021/03/15 16:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21804) Load Changelog implementation via PluginManager - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/15 20:32:00 UTC, 0 replies.
- Beam College invitation - posted by Mara Ruvalcaba <ma...@sg.com.mx> on 2021/03/15 21:31:29 UTC, 0 replies.
- [jira] [Created] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit Json ser/de - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/16 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/16 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21807) Make ApplicationDeployer interface public - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/03/16 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21808) Support DQL in HiveParser - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/16 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21809) PyFlink end-to-end test fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/16 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21810) PyFlink end-to-end fails with "sorted[*]: unbound variable" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/16 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21811) Support StreamExecJoin json serialization/deserialization - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/16 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21812) How to read data from kafka and sink to Postgresql Database - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/16 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21813) Support StreamExecOverAggregate json ser/de - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/16 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21814) flink CollectSink error info unfriendly - posted by "Peihui He (Jira)" <ji...@apache.org> on 2021/03/16 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21815) Support StreamExecUnion json ser/de - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/16 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21816) Support StreamExecGroupTableAggregate json ser/de - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/16 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21817) FLIP-27 Source might break subtask and split assignment upon rescale - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/16 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21818) Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/03/16 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21819) Remove swift FS filesystem - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/16 10:23:00 UTC, 0 replies.
- Re: [DISCUSS] Removal of flink-swift-fs-hadoop module - posted by Robert Metzger <rm...@apache.org> on 2021/03/16 10:23:15 UTC, 0 replies.
- [jira] [Created] (FLINK-21820) JDBC connector shouldn't read all rows in per statement by default - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/16 12:05:00 UTC, 1 replies.
- [jira] [Created] (FLINK-21821) StreamTask.cancelables was closed concurrent between task canceler and task thread - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/03/16 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21822) Migrate CatalogFactory to the new Factory stack - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/03/16 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21823) RocksDB on FreeBSD - posted by "Mårten Lindblad (Jira)" <ji...@apache.org> on 2021/03/16 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21824) Add a simple Json Kafka producer script - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/16 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21825) AvroInputFormat doesn't honor -1 length on FileInputSplits - posted by "Nicolas Ferrario (Jira)" <ji...@apache.org> on 2021/03/16 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21826) Migrate the shopping-cart-example to the new SDK. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/16 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21827) Migrate the Python examples to the new SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/16 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21828) Add an AWS-λ example to stateful-playground - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/16 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/03/16 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21830) [kinesis][auth] Add support for Session Token - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/03/16 17:22:00 UTC, 0 replies.
- Flink job cannot find recover path after using entropy injection for s3 file systems - posted by Rainie Li <ra...@pinterest.com.INVALID> on 2021/03/16 18:02:34 UTC, 11 replies.
- [jira] [Created] (FLINK-21831) CLONE - Add ChangelogStateBackend (proxy-everything) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/16 20:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21832) Avro Confluent Schema Registry nightly end-to-end fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/17 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21833) TemporalRowTimeJoinOperator State Leak Although configure idle.state.retention.time - posted by "lynn1.zhang (Jira)" <ji...@apache.org> on 2021/03/17 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/17 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21835) RocksDBStateBackendReaderKeyedStateITCase fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/17 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21836) Introduce RegexOperationConverter - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/17 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21837) Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/des - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/17 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21838) Retranslate "JDBC SQL Connector" page into Chinese - posted by "jjiey (Jira)" <ji...@apache.org> on 2021/03/17 05:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21839) SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint - posted by "Darcy Lin (Jira)" <ji...@apache.org> on 2021/03/17 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21840) can't submit flink k8s session job with kubernetes.rest-service.exposed.type=NodePort - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2021/03/17 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21841) Can not find kafka-connect with sql-kafka-connector - posted by "JieFang.He (Jira)" <ji...@apache.org> on 2021/03/17 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21842) Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/03/17 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21843) Support StreamExecGroupWindowAggregate json ser/de - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/17 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive" - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/17 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21845) NOt able to read config in flink Migration - posted by "Yogesh Kumbhare (Jira)" <ji...@apache.org> on 2021/03/17 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21846) Rethink whether failure of ExecutionGraph creation should directly fail the job - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/17 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21847) Introduce DESC grammar in sql parser - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/17 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21848) table api -----window opening for event time。NullPointer - posted by "wangbin (Jira)" <ji...@apache.org> on 2021/03/18 01:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21849) 'SHOW MODULES' tests for CliClientITCase lack the default module test case - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2021/03/18 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21850) Improve document and config description of sort-merge blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/18 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21851) Refactor BinaryRowDataKeySelector in testing - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/03/18 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21852) Introduce SupportsAnyNull to BinaryRowData - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/03/18 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21853) Running HA per-job cluster (rocks, non-incremental) end-to-end test could not finished in 900 seconds - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/18 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21854) WebUI show incorrect value - posted by "junbiao chen (Jira)" <ji...@apache.org> on 2021/03/18 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21855) Document Metrics Limitations - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/18 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21856) Fix the bug of using Python UDF from sub-query as input param of Python UDTF - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/03/18 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21857) StackOverflow for large parallelism jobs when processing EndOfChannelStateEvent - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/18 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks. - posted by "Andrew.D.lin (Jira)" <ji...@apache.org> on 2021/03/18 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active" - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/18 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21860) Support StreamExecExpand json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/18 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21861) Support StreamExecIncrementalGroupAggregate json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/18 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21862) Add a Java SDK showcase tutorial to StateFun playground - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/18 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21863) SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/03/18 15:20:00 UTC, 0 replies.
- [VOTE] Move Flink ML pipeline API and library code to a separate repository named flink-ml - posted by Dong Lin <li...@gmail.com> on 2021/03/19 01:59:39 UTC, 4 replies.
- [jira] [Created] (FLINK-21864) Support StreamExecTemporalJoin json serialization/deserialization - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/19 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21865) Add a Docker Compose greeter example to StateFun playgrounds - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/19 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21866) JMXJobManagerMetricTest crashes on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/19 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21867) Extend UI to expose also concurrent task failures besides the root cause - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/19 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21868) Support StreamExecLookupJoin json serialization/deserialization - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/19 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21869) Support StreamExecTemporalSort json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/19 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21870) RelDataType of TableFunction different in local and CI - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/19 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21871) Support watermark for Hive and Filesystem streaming source - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/19 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21872) Create a utility to create DataStream API's DataType and Schema - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/19 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/19 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21874) Check for out-dated slot allocation confirmations is insufficient - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/19 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21875) GSRKinesisPubsubClient is not compiling in IntelliJ - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/03/19 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21876) Provide a way to handle when the returned value of Python UDF doesn't match the defined result type - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/19 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21877) Add E2E test for upsert-kafka connector - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/19 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21878) JoinJsonPlanITCase#testIsNullInnerJoinWithNullCond fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/19 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/03/19 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21880) UnalignedCheckpointRescaleITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/19 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21881) Support local global optimization for window aggregation - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/19 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21882) Create a Python based greeter example - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/19 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21883) Introduce cooldown period into adaptive scheduler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/19 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21884) Reduce TaskManager failure detection time - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/19 19:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21885) Minor Typo Fix in JDBC Connector Documentation - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2021/03/19 21:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21886) Loosen argument of TableEnvironmentInternal#executeInternal from QueryOperation to Operation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/20 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21887) Add show views test in CliClientITCase - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/20 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21888) Maintain our own ASTNode class - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/20 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21889) source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw NullException - posted by "Carl (Jira)" <ji...@apache.org> on 2021/03/20 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21890) Rename DAGProcessor to ExecNodeGraphProcessor - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/21 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21891) The .staging_xxx directory isn't deleted after writing data to hive table in batch mode - posted by "Re0 Beatrice (Jira)" <ji...@apache.org> on 2021/03/21 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21892) Add documentation for the DESC statement syntax - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/21 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21893) A ValidationException will be thrown out when deriveRowType of Rank if partition key is an expression result of Input Node. - posted by "Andy (Jira)" <ji...@apache.org> on 2021/03/21 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21894) Update type of HiveTablePartition#partitionSpec from Map to Map - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/21 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21895) IncrementalAggregateJsonPlanTest.testIncrementalAggregate fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/22 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/22 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21897) CalcITCase.testPrimitiveMapType[StateBackend=HEAP] fail because of "Not enough resources available for scheduling" - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/22 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21898) JobRetrievalITCase crash - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/22 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21899) Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/22 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21900) flink-statebackend-rocksdb test core dump - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/22 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21901) Update StateFun version to 3.0-SNAPSHOT - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/22 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21902) A deadlock while using K8s HA service - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/03/22 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese - posted by "zhaoxing (Jira)" <ji...@apache.org> on 2021/03/22 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21904) parseJmJvmArgsAndExportLogs: command not found warning when starting StateFun - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/22 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21905) Hive streaming source should use FIFO FileSplitAssigner instead of LIFO - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/22 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21906) Support computed column syntax for Hive DDL dialect - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/22 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21907) Support watermark syntax for Hive DDL dialect - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/22 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21908) Support HiveSource to emit watermarks which is extract from partition values - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/22 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21909) Unify API and implementation for Hive and Filesystem source connector - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/22 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21910) Wrong Checks whether the service has been started. - posted by "pengkangjing (Jira)" <ji...@apache.org> on 2021/03/22 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21911) Support arithmetic MIN/MAX in SQL - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/22 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21912) Introduce Schema and ResolvedSchema in Python API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/22 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21913) Update DynamicTableFactory.Context to use ResolvedCatalogTable - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/22 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21914) Trying to access closed classloader - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/03/22 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21915) Optimize Execution#finishPartitionsAndUpdateConsumers - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/22 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21916) Allows multiple kinds of ManagedMemoryUseCase for the same operator - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/22 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21917) Add back missing zh docs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/23 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21918) Add execution.runtime-mode setter in StreamExecutionEnvironment - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/23 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21919) JsonPlanTestBase should extends AbstractTestBase - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/03/23 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21920) Optimize DefaultScheduler#allocateSlots - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/23 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/03/23 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21922) The method partition_by in Over doesn't work - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/23 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/03/23 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21924) Fine Grained Resource Management - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/23 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21926) Document Fine Grained Resource Management - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/23 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21925) Support configuring fine grained resource requirements via DataStream API - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/23 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21927) ExpressionReducer compile fail when running long term - posted by "runsun (Jira)" <ji...@apache.org> on 2021/03/23 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover - posted by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2021/03/23 08:38:00 UTC, 0 replies.
- [DISCUSS] Feature freeze date for 1.13 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/03/23 11:57:16 UTC, 5 replies.
- [jira] [Created] (FLINK-21929) flink-statebackend-rocksdb crashes with Error occurred in starting fork - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/23 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21930) There are some error for hive_read_writer.md - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/03/23 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21931) Watermark documentation needs to be fixed - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/23 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21932) Add a Python SDK showcase to the playground - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/23 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21933) [kinesis][efo] EFO consumer treats interrupts as retryable exceptions - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/03/23 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21934) Add new StreamTableEnvironment.toDataStream - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/23 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21935) Remove "state.backend.async" option. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/03/23 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/03/23 19:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21937) Support batch mode in Python DataStream API for basic operations - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/24 01:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21938) Add documentation about how to test Python UDFs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/24 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21939) Support batch mode in Python DataStream API for process operation - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/24 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/03/24 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21942) KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/03/24 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21941) testSavepointRescalingOutPartitionedOperatorStateList fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/24 03:58:00 UTC, 0 replies.
- [DISCUSS] Introducing Backpressure for connected streams - posted by Robin KC <ar...@gmail.com> on 2021/03/24 05:46:17 UTC, 3 replies.
- [jira] [Created] (FLINK-21943) Redundant checkNotNull - posted by "ZhangWei (Jira)" <ji...@apache.org> on 2021/03/24 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21944) AbstractArrowPythonAggregateFunctionOperator.dispose should consider whether arrowSerializer is null - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/24 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21945) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/03/24 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21946) FlinkRelMdUtil.numDistinctVals produces exceptional Double.NaN result when domainSize is in range(0,1) - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/03/24 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21947) Support TIMESTAMP_LTZ type in CSV format - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/24 08:57:00 UTC, 0 replies.
- [VOTE] Apache Flink Jira Process (& Bot) - posted by Konstantin Knauf <kn...@apache.org> on 2021/03/24 08:59:12 UTC, 7 replies.
- [jira] [Created] (FLINK-21948) Show Watermarks in Human Friendly Format in the Web User Interface - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/24 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21949) Support collect to array aggregate function - posted by "jiabao sun (Jira)" <ji...@apache.org> on 2021/03/24 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21950) DemultiplexingRecordDeserializerTest fail due to multiple memory freeing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/24 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21951) Fix wrong if condition in BufferReaderWriterUtil#writeBuffers - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/03/24 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/03/24 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21953) Add documentation on batch mode support of Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/24 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21954) JobMasterTest.testRestoringFromSavepoint fails with adaptive scheduler being enabled - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/24 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21955) Remove the old examples - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21956) NPE in Kafka ingress when the key is missing - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21957) Rename statefun-python-sdk => statefun-sdk-python - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21958) Rename statefun-sdk to statefun-sdk-embedded - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21959) Rename Kafka/Kinesis ingress/egress types. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21960) Simplify module.yaml spec - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21961) Add JSON StateFun type to the Python SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/24 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21962) SQL Group Windows do not work on Flink 1.11 - posted by "Barak Ben-Nathan (Jira)" <ji...@apache.org> on 2021/03/24 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21963) ReactiveModelITCase.testScaleDownOnTaskManagerLoss failed - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/24 17:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-21964) HA e2e test failed due to not enough resources being available - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/24 18:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21965) Surefire plugin seems to have failed - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/24 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21966) Support Kinesis connector in Python DataStream API. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2021/03/25 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21967) Add document on the operation of blocking result partition - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/03/25 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21968) Calcite parser doesn't support to parse "-- test" - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/25 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21969) PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/03/25 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21970) DegreesWithExceptionITCase fails on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/25 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21971) Support FLIP-27 based kafka source connector in PyFlink DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/25 08:16:00 UTC, 0 replies.
- [DISCUSS] Releasing Stateful Functions 3.0.0 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/03/25 08:27:28 UTC, 3 replies.
- [jira] [Created] (FLINK-21972) Check whether TemporalTableSourceSpec can be serialized or not - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2021/03/25 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21973) Flink 1.12 has a column bug in creating views - posted by "xuhaiLong (Jira)" <ji...@apache.org> on 2021/03/25 10:08:00 UTC, 0 replies.
- Re: [BULK]Re: [SURVEY] Remove Mesos support - posted by Matthias Pohl <ma...@ververica.com> on 2021/03/25 11:22:34 UTC, 5 replies.
- [jira] [Created] (FLINK-21974) Don't match pattern `SET key= ' '` in SetOperationParseStrategy - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/25 11:52:00 UTC, 0 replies.
- Glob support on file access - posted by Etienne Chauchot <ec...@apache.org> on 2021/03/25 12:12:42 UTC, 4 replies.
- [jira] [Created] (FLINK-21975) Remove hamcrest dependency from SchedulerBenchmarkBase - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/25 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21976) Move Flink ML pipeline API and library code to a separate repository named flink-ml - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/03/25 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21977) Allow bigger offset in SlidingProcessingTimeWindows - posted by "Moritz Manner (Jira)" <ji...@apache.org> on 2021/03/25 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/25 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/25 17:35:00 UTC, 0 replies.
- About metric name truncation - posted by Lu Niu <qq...@gmail.com> on 2021/03/25 18:28:06 UTC, 1 replies.
- [jira] [Created] (FLINK-21980) ZooKeeperRunningJobsRegistry creates an empty znode - posted by "Ricky Burnett (Jira)" <ji...@apache.org> on 2021/03/25 21:29:00 UTC, 0 replies.
- Re: Out of Memory Error-Heap when storing parquet files using Flink Table API (Flink version-1.12.0) in Google Cloud Storage - posted by "Sivaraman Venkataraman, Aswin Ram" <as...@sap.com> on 2021/03/25 22:45:02 UTC, 1 replies.
- [jira] [Created] (FLINK-21981) Increase the priority of the parameter in flink-conf - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/03/26 01:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/03/26 01:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/26 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21983) Test failed because "mvn-${sys/mvn.forkNumber}" is not updated on time. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/26 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21985) Support Explain Query/Modifcation syntax in Calcite Parser - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/26 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/03/26 04:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-21987) testRequestKvStateOfWrongJob failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/26 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21988) testRequestKvStateWithIrrelevantRegistration fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/26 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21989) Add a SupportsSourceWatermark ability interface - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/03/26 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21990) Double check Task status when perform checkpoint. - posted by "ming li (Jira)" <ji...@apache.org> on 2021/03/26 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21991) flink varchar which exposes to users it not unified - posted by "jackylau (Jira)" <ji...@apache.org> on 2021/03/26 09:29:00 UTC, 0 replies.
- What does setExecutionConfig(new ExecutionConfig()) in the constructor of JobGraph for? - posted by ZhangWei <tx...@163.com> on 2021/03/26 10:18:00 UTC, 2 replies.
- [jira] [Created] (FLINK-21992) Investigate potential buffer leak in unaligned checkpoint - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/03/26 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21993) Remove LocalCollectionOutputFormat from code base - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/26 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21994) Support FLIP-27 based FileSource connector in PyFlink DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/26 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown. - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/26 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/03/26 20:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21997) Add back missing jdbc.md zh docs - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/27 03:58:00 UTC, 0 replies.
- Re:Apply for contributor permission - posted by peng2251 <pe...@163.com> on 2021/03/27 15:15:36 UTC, 0 replies.
- [jira] [Created] (FLINK-21998) Copy more code from hive and move them to a dedicated package - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/28 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21999) The logic about whether Checkpoint is enabled. - posted by "ZhangWei (Jira)" <ji...@apache.org> on 2021/03/28 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22000) Set a default character set in InputStreamReader to solve potential garbled problems - posted by "dbgp2021 (Jira)" <ji...@apache.org> on 2021/03/28 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22001) Exceptions from JobMaster initialization are not forwarded to the user - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/28 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22002) AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail because of submitting task time-out. - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/29 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22003) UnalignedCheckpointITCase fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/29 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22004) Translate Flink Roadmap to Chinese. - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/03/29 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/29 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22006) Could not run more than 20 jobs in a native K8s session with K8s HA enabled - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/03/29 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22007) PartitionReleaseInBatchJobBenchmarkExecutor seems to be failing - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/03/29 06:57:00 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 opened a new pull request #1: [Flink-21976] Move Flink ML pipeline API and library code from apache/flink to apache/flink-ml - posted by GitBox <gi...@apache.org> on 2021/03/29 07:31:18 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 commented on pull request #1: [Flink-21976] Move Flink ML pipeline API and library code from apache/flink to apache/flink-ml - posted by GitBox <gi...@apache.org> on 2021/03/29 07:33:03 UTC, 0 replies.
- [jira] [Created] (FLINK-22008) writing metadata is not an atomic operation, we should add a commit logic - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2021/03/29 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22009) when data type is map,we cannot union - posted by "ying zhang (Jira)" <ji...@apache.org> on 2021/03/29 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22010) when flink executed union all opeators,exception occured - posted by "zhou (Jira)" <ji...@apache.org> on 2021/03/29 07:49:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Jira Process (& Bot) - posted by Konstantin Knauf <kn...@apache.org> on 2021/03/29 08:15:21 UTC, 0 replies.
- [jira] [Created] (FLINK-22011) Support local global optimization for window aggregation in runtime - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/03/29 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22012) Add nightly-build pipeline to test flink-ml repo with the latest flink repo snapshot - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/03/29 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22013) Add CI to run tests in Azure DevOps pipeline for every flink-ml pull request - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/03/29 09:09:00 UTC, 0 replies.
- [GitHub] [flink-ml] becketqin merged pull request #1: [Flink-21976] Move Flink ML pipeline API and library code from apache/flink to apache/flink-ml - posted by GitBox <gi...@apache.org> on 2021/03/29 09:57:25 UTC, 0 replies.
- [GitHub] [flink-ml] becketqin commented on pull request #1: [Flink-21976] Move Flink ML pipeline API and library code from apache/flink to apache/flink-ml - posted by GitBox <gi...@apache.org> on 2021/03/29 09:58:06 UTC, 0 replies.
- [jira] [Created] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup - posted by "Mikalai Lushchytski (Jira)" <ji...@apache.org> on 2021/03/29 11:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result. - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/03/29 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22016) PushFilterIntoLegacyTableSourceScanRule fails to deal with NULLs - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/03/29 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22017) Regions may never be scheduled when there are cross-region blocking edges - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/29 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22018) JdbcBatchingOutputFormat should not log SQLException on retry - posted by "Nicolas Deslandes (Jira)" <ji...@apache.org> on 2021/03/29 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/29 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22020) Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/03/30 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/03/30 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22022) Reduce the ExecNode scan scope to improve performance when converting json plan to ExecNodeGraph - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/03/30 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22023) Remove outdated StateFun quickstart archetype - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/30 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22024) Maven: Entry has not been leased from this pool - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/30 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22025) SurefireBooterForkException: ExecutionException Error occurred in starting fork - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/30 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22026) Improved Jira Process & Bot - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22027) Create separate repository for Jira Bot - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22028) Remove "Trivial" Ticket Priority - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22029) Remove "Task", "Wish" and "Test" Issue Types - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22030) Add Technical Debt Issue Type - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22031) Create Jira Account for Jira Bot - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22033) Add Rule 2 - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22032) Implement Rule 3 First (Simplest Rule) - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22034) Add Rule 1 - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22035) Run Jira Bot periodically with Github Actions - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22036) Document Jira Bot in Flink Confluence - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/30 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22037) Remove the redundant blocking queue from DeployingTasksBenchmarkBase - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/03/30 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN - posted by "Andy (Jira)" <ji...@apache.org> on 2021/03/30 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22039) Add Javadocs to StateFun's new Java SDK - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/03/30 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/30 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22041) Configure DataStreamAllroundTest via Configuration instead of ParameterTool - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/30 10:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-22042) Fix reading bigint(20) UNSIGNED type field cannot be cast - posted by "jingzi (Jira)" <ji...@apache.org> on 2021/03/30 10:15:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/03/30 10:29:33 UTC, 1 replies.
- [jira] [Created] (FLINK-22043) Introduce thrift format to (de)serialize thrift message only with table - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/03/30 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22044) running job from Flink client(cli) from outside Flink jobmanager pod - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/30 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22045) Set log level for shaded zookeeper logger - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/30 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22046) org.apache.flink.cep.nfa.State#toString() may has a abnormal format - posted by "shiqihao (Jira)" <ji...@apache.org> on 2021/03/30 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2021/03/30 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22048) Remove unnecessary akka.transport.* configuration options - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/30 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22049) Simplify calculating the starting index of the local key-group range in InternalTimerServiceImpl constructor. - posted by "ZhangWei (Jira)" <ji...@apache.org> on 2021/03/30 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22050) Failed to release input gate (IllegalReferenceCountException) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/03/30 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22051) Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/30 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22052) Add FLIP-142 changes to PyFlink - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/03/30 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22053) Recovery of a completed split in NumberSequenceSource causes fatal exception. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/03/30 20:35:00 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 opened a new pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request - posted by GitBox <gi...@apache.org> on 2021/03/31 02:07:22 UTC, 0 replies.
- [GitHub] [flink-ml] lindong28 commented on pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request - posted by GitBox <gi...@apache.org> on 2021/03/31 02:18:29 UTC, 0 replies.
- [jira] [Created] (FLINK-22054) Using a shared watcher for ConfigMap watching - posted by "Yi Tang (Jira)" <ji...@apache.org> on 2021/03/31 03:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-22055) RPC main thread executor may schedule commands with wrong time unit of delay - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/03/31 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22056) FlinkKafkaProducerITCase failed because of "producer leak". - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/31 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22057) Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/03/31 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22058) Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/31 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2021/03/31 05:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22060) Move null handling from ErrorInfo into Task.notifyFinalState - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/03/31 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22061) The DEFAULT_NON_SPLITTABLE_FILE_ENUMERATOR defined in FileSource should points to NonSplittingRecursiveEnumerator - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/31 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22062) Add "Data Sources" (FLIP-27 sources overview page) page from 1.12x to master - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/03/31 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22063) Lookup Join outputs wrong results for some scenario - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/03/31 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22064) Don't submit statement set when no insert is added in the sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/31 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22065) Beautify the parse error exception when input invalid command in the sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/03/31 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22066) Improve Error Message on unknown Ingress Type - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/03/31 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/03/31 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/31 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22069) Check Log Pollution for 1.13 release - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/03/31 11:03:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 13.0, release candidate #0 - posted by Chesnay Schepler <ch...@apache.org> on 2021/03/31 12:07:39 UTC, 1 replies.
- [jira] [Created] (FLINK-22070) Support FileSink in PyFlink DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/03/31 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism - posted by "Wong Mulan (Jira)" <ji...@apache.org> on 2021/03/31 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22072) Rethink UnfulfillableSlotRequestException class hierarchy - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/03/31 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22073) ParquetFileCompactionITCase fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/03/31 15:12:00 UTC, 0 replies.
- Apply external 3 days for FLINK-20387 after feature freeze - posted by Leonard Xu <xb...@gmail.com> on 2021/03/31 15:56:50 UTC, 1 replies.
- [jira] [Created] (FLINK-22074) testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/03/31 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22075) Incorrect null outputs in left join - posted by "Jamie Brandon (Jira)" <ji...@apache.org> on 2021/03/31 18:11:00 UTC, 0 replies.