dev@flink.apache.org, 2021-08

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

- About [FLINK-22405] Support fixed-lengh chars in the LeadLag built-in function - posted by liwei li <hi...@gmail.com> on 2021/08/01 06:30:30 UTC, 2 replies.
- Re: [VOTE] Release 1.13.2, release candidate #3 - posted by Leonard Xu <xb...@gmail.com> on 2021/08/01 07:10:19 UTC, 1 replies.
- Re: [VOTE] Release 1.12.5, release candidate #3 - posted by Jark Wu <im...@gmail.com> on 2021/08/01 07:24:48 UTC, 4 replies.
- [jira] [Created] (FLINK-23570) Some of the maven dependencies in the documentation seem to have some problems and cannot be used directly - posted by "erick.liu (Jira)" <ji...@apache.org> on 2021/08/01 07:43:00 UTC, 0 replies.
- Re: [VOTE] Release 1.11.4, release candidate #1 - posted by Leonard Xu <xb...@gmail.com> on 2021/08/01 08:17:24 UTC, 2 replies.
- [jira] [Created] (FLINK-23571) The internal query-start options missed when convert exec graph to transformation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/08/01 08:26:00 UTC, 0 replies.
- Re: [VOTE] FLIP-177: Extend Sink API - posted by Thomas Weise <th...@apache.org> on 2021/08/01 23:42:12 UTC, 2 replies.
- [RESULT] [VOTE] Release 1.13.2, release candidate #3 - posted by Yun Tang <my...@LIVE.COM> on 2021/08/02 02:57:01 UTC, 0 replies.
- Re: Looking for Maintainers for Flink on YARN - posted by Xintong Song <to...@gmail.com> on 2021/08/02 03:01:47 UTC, 7 replies.
- [FLINK-23555] needs your attention - posted by 卫博文 <we...@163.com> on 2021/08/02 03:16:36 UTC, 2 replies.
- [jira] [Created] (FLINK-23572) KubernetesSharedInformerITCase JVM crash on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/02 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23573) Tests fail with AdaptiveScheduler due to exceptions in logs trying to offer slots after JobMaster shutdown - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/02 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23574) test_pandas_udaf hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/02 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23575) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with AsynchronousException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/02 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23576) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to Artificial Failure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/02 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23577) CoordinatedSourceRescaleITCase.testUpscaling fails with NoSuchFileException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/02 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23578) Remove Python operators PythonFlatMapOperator/PythonMapOperator/PythonPartitionCustomOperator and use PythonProcessOperator instead - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/02 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23579) SELECT SHA2(NULL, CAST(NULL AS INT)) AS ref0 can't compile - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/08/02 06:17:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.12.5, release candidate #3 - posted by Jingsong Li <ji...@gmail.com> on 2021/08/02 07:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-23580) Cannot handle such jdbc url - posted by "chenpeng (Jira)" <ji...@apache.org> on 2021/08/02 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23581) The link to the Flink download page is broken - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/02 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23582) Add document for session window - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/02 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23583) Easy way to remove metadata before serializing row data for connector implementations - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/02 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23584) Introduce PythonCoProcessOperator and remove PythonCoFlatMapOperator & PythonCoMapOperator - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/02 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23585) The "stable version" link in the document should lead to the corresponding document page of the stable version, instead of to the front page - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/02 09:25:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-177: Extend Sink API - posted by Guowei Ma <gu...@gmail.com> on 2021/08/02 09:31:25 UTC, 0 replies.
- [jira] [Created] (FLINK-23586) Further enhancements for pluggable shuffle service framework - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/08/02 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23587) Set Deployment's Annotation when using kubernetes - posted by "KarlManong (Jira)" <ji...@apache.org> on 2021/08/02 10:28:00 UTC, 0 replies.
- Re: [VOTE] FLIP-179: Expose Standardized Operator Metrics - posted by Becket Qin <be...@gmail.com> on 2021/08/02 10:36:34 UTC, 6 replies.
- Re: Julia SDK for Stateful Functions - posted by Igal Shilman <ig...@ververica.com> on 2021/08/02 11:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-23588) Class not found - posted by "Abhishek Jain (Jira)" <ji...@apache.org> on 2021/08/02 12:23:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.11.4, release candidate #1 - posted by godfrey he <go...@gmail.com> on 2021/08/02 13:37:31 UTC, 0 replies.
- Re: Security Vulnerabilities with Flink OpenJDK Docker Image - posted by Konstantin Knauf <kn...@apache.org> on 2021/08/02 14:40:52 UTC, 1 replies.
- [jira] [Created] (FLINK-23589) Support Avro Microsecond precision - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/08/02 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/08/02 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23591) [DOCS]The link to the 'deployment/config' page is invalid because several characters are written in page 'deployment/memory/mem_tuning/' - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/02 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23592) Format of the "Table API & SQL >> Concepts & Common API" Chinese document is a mess - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/03 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23593) Performance regression on 15.07.2021 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/03 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23594) Unstable test_from_and_to_data_stream_event_time failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/03 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23595) Allow JSON format deserialize non-numeric numbers - posted by "loyi (Jira)" <ji...@apache.org> on 2021/08/03 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23596) flink on k8s can create more than one instance - posted by "zhouwenyang (Jira)" <ji...@apache.org> on 2021/08/03 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23597) support Add Jar in Table api - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/08/03 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice - posted by "nihileon (Jira)" <ji...@apache.org> on 2021/08/03 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23599) Remove JobVertex#connectIdInput - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/08/03 08:30:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-183: Dynamic buffer size adjustment - posted by Piotr Nowojski <pn...@apache.org> on 2021/08/03 08:32:35 UTC, 0 replies.
- [jira] [Created] (FLINK-23600) Rework StateFun's remote module parsing and binding - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/03 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23601) TPC-DS end-to-end test fail with "File upload failed." - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/08/03 09:45:00 UTC, 0 replies.
- Compilation error - Execution of spotless-check goal failed in flink-annotations project - posted by Muhammad Haseeb Asif <mh...@kth.se> on 2021/08/03 10:00:04 UTC, 2 replies.
- why i am receiving every email after unsubscribed - posted by R Bhaaagi <bh...@gmail.com> on 2021/08/03 10:16:52 UTC, 1 replies.
- [jira] [Created] (FLINK-23602) org.codehaus.commons.compiler.CompileException: Line 84, Column 78: No applicable constructor/method found for actual parameters "org.apache.flink.table.data.DecimalData - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/08/03 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23603) 动态查询sql后，使用toAppendStream将动态表转化为流时报错，org.apache.flink.table.api.TableException - posted by "liuhong (Jira)" <ji...@apache.org> on 2021/08/03 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23604) 'csv.disable-quote-character' can not take effect during deserialization for old csv format - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/08/03 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23605) An exception was thrown when the metric was reported by PrometheusPushGatewayReporter - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/08/03 13:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23606) Add safety guards in StreamTask(s) if a global failover for a synchronous savepoint should've happen - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/08/03 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/03 17:51:00 UTC, 0 replies.
- Re: Unable to read state Witten by Beam application with Flink runner using Flink's State Processor API - posted by "Kathula, Sandeep" <Sa...@intuit.com.INVALID> on 2021/08/03 19:44:03 UTC, 2 replies.
- [jira] [Created] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory - posted by "张祥兵 (Jira)" <ji...@apache.org> on 2021/08/04 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23609) Codeine error of "Infinite or NaN at java.math.BigDecimal.(BigDecimal.java:898)" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/08/04 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23610) DefaultSchedulerTest.testProducedPartitionRegistrationTimeout fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/04 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/04 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23612) SELECT ROUND(CAST(1.2345 AS FLOAT), 1) cannot compile - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/04 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23613) debezium and canal support read medata op and type - posted by "Ward Harris (Jira)" <ji...@apache.org> on 2021/08/04 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/04 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23615) Documentation of the TRUNCATE SQL function is not correct - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/04 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23616) Support to chain for the Python operators as much as possible - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/04 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23617) Co-locate sink operators with same parallelism - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/04 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23618) Commpilation error for MeasurementInfoProviderTest - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/08/04 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23619) Remove PythonTimestampsAndWatermarksOperator - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/04 09:53:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-179: Expose Standardized Operator Metrics - posted by Arvid Heise <ar...@apache.org> on 2021/08/04 11:59:38 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-177: Extend Sink API - posted by Arvid Heise <ar...@apache.org> on 2021/08/04 12:01:34 UTC, 0 replies.
- [jira] [Created] (FLINK-23620) Introduce proper YAML parsing to Flink's configuration - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2021/08/04 12:05:00 UTC, 0 replies.
- [ANNOUNCE] RocksDB Version Upgrade and Performance - posted by Stephan Ewen <se...@apache.org> on 2021/08/04 12:08:28 UTC, 11 replies.
- [jira] [Created] (FLINK-23621) FLIP-177: Extend Sink API - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/04 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23622) Default filesystem scheme improvement - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/08/04 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23623) Over expression should allow to order by any fields in batch mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/08/04 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23624) Migrate all TaskManagerMG instantiations to factory method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/04 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23625) Migrate all TaskManagerJobMG instantiations to factory method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/04 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23626) Migrate all TaskMG instantiations to factory method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/04 15:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23627) Migrate all OperatorMG instantiations to factory method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/04 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23628) MeasurementInfoProviderTest fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/08/04 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23629) Remove redundant test cases in EventTimeWindowCheckpointingITCase - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/08/04 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23630) Make EventTimeWindowCheckpointingITCase and LocalRecoveryITCase run on Windows. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/08/04 16:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23631) [docs-zh] The name attribute of GH_link in shortcodes was lost. As a result, the Link to Flink-examexam-batch failed - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/04 17:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23632) [DOCS]The link to setup-Pyflink-virtual-env.sh is broken for page dev/python/faq - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/04 18:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/08/04 20:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23634) BatchingStateChangeUploaderTest.testDelay fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/05 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23635) PrestoS3FileSystemITCase.testConfigKeysForwarding - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/05 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23636) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/05 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23637) MeasurementInfoProviderTest.testNormalizingTags fails on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/05 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23638) Field names are not kept after apply ProjectToWindowRule#ProjectToLogicalProjectAndWindowRule - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/05 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23639) Migrate Table API to new KafkaSink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/05 08:55:00 UTC, 0 replies.
- [DISCUSS] FLIP-186: Refactor DataStreamUtils#reinterpretAsKeyedStream - posted by Senhong Liu <se...@gmail.com> on 2021/08/05 08:58:35 UTC, 0 replies.
- [jira] [Created] (FLINK-23640) Create a KafkaRecordSerializationSchemas valueOnly helper - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/05 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23641) A bad data should not stop and fail the job - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/08/05 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23642) A result of SELECT (not (CAST (((CAST (IS_ALPHA(-421305765) AS BOOLEAN)) OR (CAST ((SHA1(CAST ('鲇T' AS STRING ))) AS BOOLEAN))) AS BOOLEAN))) IS NULL should return true - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/08/05 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2021/08/05 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23644) Resolve maven warnings for duplicate dependencies/plugins - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/05 09:48:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-180: Adjust StreamStatus and Idleness definition - posted by Till Rohrmann <tr...@apache.org> on 2021/08/05 10:21:58 UTC, 2 replies.
- [jira] [Created] (FLINK-23645) Sqlclient doesn't response CTRL-C correctly before Executor ResultView opening. - posted by "loyi (Jira)" <ji...@apache.org> on 2021/08/05 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23646) Use pipeline name consistently across DataStream API and Table API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/05 11:00:15 UTC, 0 replies.
- [jira] [Created] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/05 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23648) Drop StreamTwoInputProcessor in favour of StreamMultipleInputProcessor - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/05 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23649) Add RocksDB packages to parent-first classloading patterns. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/08/05 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23650) A sql contains 'Case when' could not run successfully when choose Hive Dialect - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/05 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23651) Support RabbitMQ connectors in Python DataStream API - posted by "Eelis Kostiainen (Jira)" <ji...@apache.org> on 2021/08/05 13:37:00 UTC, 0 replies.
- [VOTE] FLIP-180: Adjust StreamStatus and Idleness definition - posted by Arvid Heise <ar...@apache.org> on 2021/08/05 19:08:36 UTC, 4 replies.
- [jira] [Created] (FLINK-23652) Implement FLIP-179 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/05 19:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23653) improve training exercises and tests so they are better examples - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/08/05 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23654) Allow configuration for number of jobmanager-future threads - posted by "Nicolas Raga (Jira)" <ji...@apache.org> on 2021/08/05 20:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content display directly. - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/08/06 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23656) flink-sql-parser compile failed - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/08/06 04:53:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.13.2 released - posted by Yun Tang <my...@LIVE.COM> on 2021/08/06 05:51:41 UTC, 5 replies.
- [jira] [Created] (FLINK-23658) Cleanup JMX reporter - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/06 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23657) Cleanup metric reporter modules - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/06 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23659) Cleanup Prometheus reporter - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/06 06:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML) - posted by Becket Qin <be...@gmail.com> on 2021/08/06 07:45:01 UTC, 14 replies.
- Flink 1.14 Bi-weekly 2021-08-03 - posted by Xintong Song <xt...@apache.org> on 2021/08/06 07:54:19 UTC, 0 replies.
- [jira] [Created] (FLINK-23660) Hive Catalog support truncate table - posted by "lixu (Jira)" <ji...@apache.org> on 2021/08/06 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23661) Fix protobuf plugin proxy issue - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2021/08/06 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23662) Port Scala code in flink-rpc-akka to Java - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/06 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23663) Reduce state size in ChangelogNormalize through filter push down - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/06 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23664) Write documentation for new KafkaSink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/06 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23665) Flaky test: BlockingShuffleITCase.testBoundedBlockingShuffle - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/08/06 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23666) Flaky test: SQLClientSchemaRegistryITCase.testWriting - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/08/06 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23667) Fix training exercises IDE setup description for Scala - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/06 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23668) Check Log Pollution for 1.14 release - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/06 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23669) Avoid using Scala >= 2.12.8 in Flink Training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/06 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23670) Add Scala formatting checks to training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/06 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23671) Failed to inference type in correlate - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/08/06 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23672) Add smoke-e2e-java for Java SDK smoke test - posted by "Evans Ye (Jira)" <ji...@apache.org> on 2021/08/06 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23673) [DOCS-zh]In many Chinese pages, the prompt or warning text block does not take effect - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/07 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception - posted by "meetsong (Jira)" <ji...@apache.org> on 2021/08/08 05:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-23675) flink1.13 cumulate 函数不能和部分比较函数连用 - posted by "lihangfei (Jira)" <ji...@apache.org> on 2021/08/09 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23676) ReduceOnNeighborMethodsITCase.testSumOfOutNeighborsNoValue fails due to AskTimeoutException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23677) KafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue fails due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23678) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23679) PyFlink end-to-end test fail due to test script contains errors - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23680) StreamTaskTimerTest.testOpenCloseAndTimestamps fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23681) Rename the field name of OperatorIDPair to avoid the confusion - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/09 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23682) HAQueryableStateFsBackendITCase.testCustomKryoSerializerHandling fails due to AskTimeoutException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23683) KafkaSinkITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23684) KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with NoSuchElementException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/09 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23685) Translate "Java Lambda Expressions" page into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/09 05:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23686) KafkaSource metric "commitsSucceeded" should count per-commit instead of per-partition - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/08/09 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/09 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23688) Make JaasModule.getAppConfigurationEntries public - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/08/09 10:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23689) TestProcessingTimeService.setCurrentTime(long) not delay the firing timer by 1ms delay - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/08/09 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23690) Processing timers can be triggered more efficiently - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/08/09 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23691) flink sql submit job blob parallelism - posted by "Peihui He (Jira)" <ji...@apache.org> on 2021/08/09 12:53:00 UTC, 0 replies.
- Incompatible RAW types in Table API - posted by Dominik Wosiński <wo...@gmail.com> on 2021/08/09 13:13:36 UTC, 5 replies.
- [jira] [Created] (FLINK-23692) Clarify text on "Cancel Job" confirmation buttons - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2021/08/09 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23693) Add principal creation possibilities to SecureTestEnvironment - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/08/09 15:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23694) KafkaWriterITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/10 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23695) DispatcherFailoverITCase.testRecoverFromCheckpointAfterJobGraphRemovalOfTerminatedJobFailed fails due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/10 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/10 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23697) flink standalone Isolation is poor, why not do as spark does - posted by "jackylau (Jira)" <ji...@apache.org> on 2021/08/10 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23698) Pass watermarks in finished on restore operators - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/10 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23699) The code comment's reference is wrong for the function isUsingFixedMemoryPerSlot - posted by "Liu (Jira)" <ji...@apache.org> on 2021/08/10 07:45:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.5 released - posted by Jingsong Lee <lz...@apache.org> on 2021/08/10 08:54:09 UTC, 2 replies.
- [jira] [Created] (FLINK-23700) Add `since` field to configuration options - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/08/10 08:57:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.11.4 released - posted by godfrey he <go...@gmail.com> on 2021/08/10 09:08:05 UTC, 2 replies.
- [jira] [Created] (FLINK-23701) Fix Error translation in "Builtin Watermark Generators" page - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2021/08/10 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23703) Support unrecoverable exception class list in configuration - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/08/10 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23702) SQL casting to decimal which cannot hold its original value throws 'Column 'EXPR$0' is NOT NULL, however, a null value is being written into it' - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2021/08/10 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23704) FLIP-27 sources are not generating LatencyMarkers - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/10 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23705) Unregister MetricGroup after shard closes in Kinesis connector - posted by "Elphas Toringepi (Jira)" <ji...@apache.org> on 2021/08/10 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23706) temporary join versioned table , state TTL Setting - posted by "tao.yang03 (Jira)" <ji...@apache.org> on 2021/08/10 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23707) Use consistent managed memory weights for StreamNode - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/10 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23708) When task is finishedOnRestore Operators shouldn't be used - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/10 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23709) Remove SanityVerificationE2E and ExactlyOnceRemoteE2E - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/10 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23710) Move sink to org.apache.kafka.conntor.kafka.sink package - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/10 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23711) Add an asynchronous HTTP transport for the RequestReply function - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/08/10 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23712) Improve Protobuf serialization performance - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/08/10 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23713) SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted failed with "Stop with savepoint operation could not be completed" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/11 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23714) Expose both master and worker logs when using StatefulFunctionsAppContainers - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/11 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23715) Support for reading fields that do not exist in Parquet files - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/08/11 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23716) Translate the 'Zipping Elements in a DataSet' page inito Chinese - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/08/11 04:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23717) Allow setting configs using plain strings in StatefulFunctionsAppContainers - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/11 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23718) Manage StateFun Python SDK as a Maven module - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/11 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23719) Support switch WAL in Flink SQL DDL options - posted by "Carl (Jira)" <ji...@apache.org> on 2021/08/11 05:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23720) Migrate ModuleFactory to the new factory stack - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/11 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend - posted by "Q Kang (Jira)" <ji...@apache.org> on 2021/08/11 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23722) S3 Tests fail on AZP: Unable to find a region via the region provider chain. Must provide an explicit region in the builder or setup environment to supply a region. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/11 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23723) Look up join support PROCTIME() function - posted by "silence (Jira)" <ji...@apache.org> on 2021/08/11 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23724) Network buffer leak when ResultPartition is released (failover) - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/08/11 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23725) HadoopFsCommitter， Prompt for file rename failure - posted by "todd (Jira)" <ji...@apache.org> on 2021/08/11 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23726) Buffer debloat configuration is taken from the wrong configuration - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/08/11 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23727) Skip null values in SimpleStringSchema - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/08/11 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23728) Support new state backend factory stack in State Processor API - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/08/11 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23729) sql-client.sh fails on Git Bash for Windows, MinGW & MSYS2 - posted by "Derek Moore (Jira)" <ji...@apache.org> on 2021/08/11 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23730) Source from hive sink hbase lost data - posted by "Carl (Jira)" <ji...@apache.org> on 2021/08/12 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23731) Streaming File Sink s3 end-to-end test fail due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/12 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23732) StatefulJobSavepointMigrationITCase.testRestoreSavepoint fails due to LoggerInitializationException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/12 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23733) sdsd - posted by "kaohaonan (Jira)" <ji...@apache.org> on 2021/08/12 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23734) Migrate ComponentFactory to the new Factory stack - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/12 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23735) Migrate BufferedUpsertSinkFunction to FLIP-143 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/12 07:22:00 UTC, 0 replies.
- Feature Freeze and Release Testing for 1.14 - posted by Xintong Song <xt...@apache.org> on 2021/08/12 08:52:28 UTC, 1 replies.
- [jira] [Created] (FLINK-23736) Delete unnecessary test line in page `Deployment/Resource Providers/Yarn` - posted by "Liebing Yu (Jira)" <ji...@apache.org> on 2021/08/12 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/12 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23738) Hide any configuration, API or docs - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/12 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23739) PrintTableSink do not implement SupportsPartitioning interface - posted by "Xianxun Ye (Jira)" <ji...@apache.org> on 2021/08/12 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23740) SQL Full Outer Join bug - posted by "Fu Kai (Jira)" <ji...@apache.org> on 2021/08/12 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23741) Waiting for final checkpoint can deadlock job - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/12 16:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23742) test_keyed_co_process test failed in py36 and py37 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/13 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23743) Test the fine-grained resource management - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/08/13 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23744) CliClientTest.testCancelExecutionInteractiveMode fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/13 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23745) Python test_keyed_co_process fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/13 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23746) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure fails due to AskTimeoutException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/13 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23747) Teting Window TVF offset - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/13 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23748) Testing session window - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/13 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23749) Testing Window Join - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/13 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23750) Add document for Window Top-N after Windowing TVF - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/13 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23751) Testing Window Top-N after Windowing TVF - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/13 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23752) Add document for using HiveSource API - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/08/13 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23753) Add documentation about Python DataStream API chaining optimization - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/13 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23754) Testing Python DataStream API chaining functionality - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/13 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23755) Modify the default value of table.dynamic-table-options.enabled to true - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/08/13 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23756) Release FRocksDB-6.20.3 binaries - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/13 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23757) Support JSON methods in pyFlink - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/13 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23758) PyFlink __invert__ has wrong semantics - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/13 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/13 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23760) Static methods in interface require -target:jvm-1.8 - posted by "liyongguang (Jira)" <ji...@apache.org> on 2021/08/13 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result - posted by "zhengjiewen (Jira)" <ji...@apache.org> on 2021/08/13 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23762) Revisit RequestReplyFunctionTest unit tests - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/13 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23763) Use yarn config in sql but not yarn magic properties file - posted by "wangzeyu (Jira)" <ji...@apache.org> on 2021/08/13 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23764) add RuntimeContext to SourceReaderContext - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/08/13 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23765) PythonTableFunctionOperatorTestBase - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/08/13 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23766) test_data_stream.py failed with flake8 checks - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/13 09:58:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-180: Adjust StreamStatus and Idleness definition - posted by Arvid Heise <ar...@apache.org> on 2021/08/13 12:00:26 UTC, 0 replies.
- [jira] [Created] (FLINK-23767) FLIP-180: Adjust StreamStatus and Idleness definition - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/13 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23768) Test StreamTableEnvironment batch mode in Python - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/13 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23769) [doc]Delete the superfluous Chinese text for the English page "deployment/reaource-providers/yarn" - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/13 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23770) Unable to recover after source fully finished - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/13 17:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23771) FLIP-147 Checkpoint N has not been started at all - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/13 18:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23772) Double check if non-keyed FullyFinishedOperatorState can be mixed up with non finished OperatorState on recovery - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/13 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23773) KafkaPartitionSplitReader should remove empty splits from fetcher - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/08/14 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23774) Error doc's function name of datastream api - posted by "Jiajie Zhong (Jira)" <ji...@apache.org> on 2021/08/14 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23775) Provide a method to create StreamExecutionEnvironment with Configuration in scala api - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/08/14 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23776) Performance regression on 14.08.2021 in FLIP-27 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/14 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23777) Support dynamic parameters for sink table in multiple connectors - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/08/15 08:00:08 UTC, 0 replies.
- [NOTICE] - Moving and Upgrading of Buildbot Jobs - posted by Gavin McDonald <gm...@apache.org> on 2021/08/15 08:44:51 UTC, 0 replies.
- [jira] [Created] (FLINK-23778) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/15 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23779) SEOTeeeeeLink1 - posted by "sdfsdfsd (Jira)" <ji...@apache.org> on 2021/08/15 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23780) SEOTeeeeeLink2 - posted by "sdfsdfsd (Jira)" <ji...@apache.org> on 2021/08/15 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23782) SEOTeeeeeLink4 - posted by "sdfsdfsd (Jira)" <ji...@apache.org> on 2021/08/15 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23781) SEOTeeeeeLink3 - posted by "sdfsdfsd (Jira)" <ji...@apache.org> on 2021/08/15 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23784) SEOTeeeeeLink - posted by "sdfsdfsd (Jira)" <ji...@apache.org> on 2021/08/15 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23783) SEOTeeeeeLink5 - posted by "sdfsdfsd (Jira)" <ji...@apache.org> on 2021/08/15 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23785) SinkITCase.testMetrics fails with ConcurrentModification on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/15 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23786) Avoid multiple authentication - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/08/16 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23787) Providing utility class for initializing various process function test harnesses - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/16 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23788) sql-client.sh cannot run on Windows 10 PRO Edition - posted by "Xi (Jira)" <ji...@apache.org> on 2021/08/16 03:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23789) Remove unnecessary setTotalOrderForSeek for Rocks iterator - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/16 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23790) Python test_udtf.py fail on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23791) Enable RocksDB log again - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/16 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23792) Python test_udf.py fail on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 04:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23794) JdbcExactlyOnceSinkE2eTest JVM crash on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 04:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 05:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 05:14:00 UTC, 0 replies.
- [NOTICE] StateFun docs have been migrated to new ASF Buildbot at ci2.apache.org - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/08/16 06:59:43 UTC, 3 replies.
- [jira] [Created] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/16 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23799) application mode not support pyflink - posted by "zhou (Jira)" <ji...@apache.org> on 2021/08/16 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23800) Expose newly added RocksDB native metrics - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/16 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23801) Add FLIP-33 metrics to KafkaSource - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/08/16 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23802) [kinesis][efo] Reduce ReadTimeoutExceptions for Kinesis Consumer - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/08/16 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23803) Improve instantiation of InMemoryReporter - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/16 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23804) Restructure documentation of built-in functions - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/16 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23805) Refer to flink-packages.org from documentation - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/16 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23806) StackOverflowException can happen if a large scale job failed to acquire enough slots in time - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/08/16 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23807) Use metrics to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/16 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23808) Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/16 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23809) Respect the finished flag when extracting operator states due to skip in-flight data - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/16 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23810) Print sql when parse failed , which is convenient to find error - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/08/16 10:29:00 UTC, 0 replies.
- [DISCUSS] Stateful Functions 3.1.0 release? - posted by Igal Shilman <ig...@apache.org> on 2021/08/16 10:56:32 UTC, 3 replies.
- [jira] [Created] (FLINK-23811) Handle FINISHED subtasks in CommonTestUtils.waitForAllTaskRunning - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/16 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23812) Support configuration of the RocksDB logging via configuration - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/16 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23813) DeleteExecutor NPE - posted by "Junning Liang (Jira)" <ji...@apache.org> on 2021/08/16 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23814) Test FLIP-143 KafkaSink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/16 15:08:00 UTC, 0 replies.
- [DISCUSS] Backport HybridSource to 1.13.x - posted by Thomas Weise <th...@apache.org> on 2021/08/16 15:26:00 UTC, 6 replies.
- [jira] [Created] (FLINK-23815) Follow-up code improvement regarding final checkpoint. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/16 16:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23816) Test new (Kafka) metrics in cluster - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/16 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23817) Write documentation for standardized operator metrics - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/16 20:20:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.14 Feature Freeze - posted by Xintong Song <xt...@apache.org> on 2021/08/16 22:49:07 UTC, 0 replies.
- [jira] [Created] (FLINK-23818) Add documentation about tgz files support for python archives - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/16 23:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23819) Testing tgz file for python archives - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/16 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23820) Test profiling for Python user-defined functions - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/17 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/17 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23822) Test config state ttl in Python DataStream API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/17 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23823) Test specifying python client interpreter used to compile jobs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/17 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23824) Test interoperability between DataStream and Table API in PyFlink Table API - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/08/17 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23825) Test SQL Client manually - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/08/17 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23826) Verify optimized scheduler performance for large-scale jobs - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/08/17 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23827) Fix ModifiedMonotonicity inference for some node - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/08/17 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/17 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23829) SavepointITCase JVM crash on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/17 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23830) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/17 04:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23831) Verify the final checkpoint and stop-with-savepoint --drain - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/17 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23832) Add documentation for batch mode in StreamTableEnvironment - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/17 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23833) Cache of ShuffleDescriptors should be individually cleaned up - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/08/17 07:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-23834) Test StreamTableEnvironment batch mode manually - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/17 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23835) Test upsert sink with upsert keys - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/08/17 08:02:00 UTC, 0 replies.
- [DISCUSS] Merge the Last Piece of FLIP-147 After Code Freeze - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/08/17 08:43:17 UTC, 3 replies.
- [jira] [Created] (FLINK-23836) [doc-zh]Translate "/dev/datastream/execution/execution_configuration.md" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/17 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23837) Differences between documentation and implementation for taskmanager.memory.network.max - posted by "Wawrzyniec Nowak (Jira)" <ji...@apache.org> on 2021/08/17 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23838) Add FLIP-33 metrics to new KafkaSink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/17 11:21:00 UTC, 0 replies.
- [DISCUSS] Merging FLINK-21867 after feature freeze - posted by David Morávek <dm...@apache.org> on 2021/08/17 14:40:46 UTC, 3 replies.
- [jira] [Created] (FLINK-23839) Unclear severity of Kafka transaction recommit warning in logs - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/17 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23840) Confusing message from MemCheckpointStreamFactory#checkSize - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/08/17 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration' - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/17 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23842) Add log messages for reader registrations and split requests. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/08/17 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/08/17 17:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23844) Fix spelling mistakes for "async" - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/17 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23845) [DOCS]PushGateway metrics group not delete when job shutdown - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/08/18 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23846) [DOCS]PushGatewayReporter config description obscure - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/08/18 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23847) [DOCS] Error msg are obscure when KafkaConsumer init, valueDeserializer is null - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/08/18 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23848) PulsarSourceITCase is failed on Azure - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/08/18 02:33:00 UTC, 0 replies.
- Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job - posted by Wenhao Ji <pr...@gmail.com> on 2021/08/18 03:40:34 UTC, 0 replies.
- [jira] [Created] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/08/18 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23850) Test Kafka table connector with new runtime provider - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/08/18 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23851) AggregationsITCase.testDistinctAfterAggregate fails due to AskTimeoutException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/18 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23852) In sql-client mode ，could not change the properties. - posted by "Shuaishuai Guo (Jira)" <ji...@apache.org> on 2021/08/18 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23853) Update StateFun's Flink dependency to 1.13.2 - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/08/18 07:56:00 UTC, 0 replies.
- Flink 1.14 Bi-weekly 2021-08-17 Feature Freeze done, now stabilise! - posted by Johannes Moser <jo...@ververica.com> on 2021/08/18 08:53:05 UTC, 0 replies.
- Configuring flink-python in IntelliJ - posted by Ingo Bürk <in...@ververica.com> on 2021/08/18 09:03:08 UTC, 5 replies.
- [jira] [Created] (FLINK-23854) KafkaSink error when restart from the checkpoint with a lower parallelism - posted by "Hang Ruan (Jira)" <ji...@apache.org> on 2021/08/18 09:21:00 UTC, 0 replies.
- 回复：[DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML) - posted by "洪帆(既起)" <ho...@alibaba-inc.com.INVALID> on 2021/08/18 09:33:29 UTC, 0 replies.
- [jira] [Created] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/08/18 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23856) Support all JSON methods in PyFlink - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/18 11:43:00 UTC, 0 replies.
- [DISCUSS] Merge FLINK-23757 after feature freeze - posted by Ingo Bürk <in...@ververica.com> on 2021/08/18 11:46:13 UTC, 6 replies.
- [jira] [Created] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data - posted by "lixu (Jira)" <ji...@apache.org> on 2021/08/18 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23858) Clarify StreamRecord#timestamp. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/18 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes - posted by "lixu (Jira)" <ji...@apache.org> on 2021/08/18 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23859) [typo][flink-core][flink-connectors]fix typo for code - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/08/18 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23861) flink sql client support dynamic params - posted by "zhangbinzaifendou (Jira)" <ji...@apache.org> on 2021/08/18 12:49:00 UTC, 0 replies.
- [DISCUSS] Merge Kafka-related PRs after feature freeze - posted by Arvid Heise <ar...@apache.org> on 2021/08/18 12:58:48 UTC, 1 replies.
- [jira] [Created] (FLINK-23862) Race condition while cancelling task during initialization - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/18 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23863) AVRO Raw types do not match for UDFs - posted by "Dominik Wosiński (Jira)" <ji...@apache.org> on 2021/08/18 13:52:00 UTC, 0 replies.
- Common type required when creating TableSchema - posted by Dominik Wosiński <wo...@gmail.com> on 2021/08/18 14:08:15 UTC, 1 replies.
- [jira] [Created] (FLINK-23864) The document for Pulsar Source - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2021/08/18 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/08/19 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23866) KafkaTransactionLogITCase.testGetTransactionsToAbort fails with IllegalStateException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/19 04:00:11 UTC, 0 replies.
- [jira] [Created] (FLINK-23867) FlinkKafkaInternalProducerITCase.testCommitTransactionAfterClosed fails with IllegalStateException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/19 04:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/08/19 05:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/19 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23870) Test the ability for ignoring in-flight data on recovery - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/08/19 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23871) Dispatcher should handle finishing job exception when recover - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/08/19 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/08/19 09:52:00 UTC, 5 replies.
- [jira] [Created] (FLINK-23873) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/08/19 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23874) JM did not store latest checkpiont id into Zookeeper, silently - posted by "Youjun Yuan (Jira)" <ji...@apache.org> on 2021/08/19 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23875) ReducingUpsertSink can loose record during failover - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/19 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23876) Remove limitation about JDBC exactly once sink about multiple connections per transaction - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/19 12:31:00 UTC, 0 replies.
- Were Bundles meant to be internal? - posted by David Anderson <da...@apache.org> on 2021/08/19 13:56:45 UTC, 2 replies.
- [jira] [Created] (FLINK-23877) Embedded Pulsar broker backend for testing - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2021/08/19 19:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23878) Minor improvements to golang sdk - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/08/19 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23879) Benchmark not compiling - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/08/20 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23880) WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/20 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23881) SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/20 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/20 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23883) Following bug fix and code improvement for FLIP-147 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/20 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23884) Fix the concurrent problem between triggering savepoint with drain and finish - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/20 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23885) DataStream#map(int value -> row value).getType() produces a generic type info of row instead of row type info - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/08/20 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23886) An exception is thrown out when recover job timers from savepoint file - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/20 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23887) Check thread pollution for 1.14 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23888) Flink azure fs doesn't work - posted by "Liviu Firu (Jira)" <ji...@apache.org> on 2021/08/20 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23889) Unnecessary logging from FineGrainedSlotManager - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2021/08/20 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23891) Support 'sink.partition-commit.policy.kind'='metastore,success-file' config for batch Hive sink - posted by "Yik San Chan (Jira)" <ji...@apache.org> on 2021/08/20 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23892) FineGrainedSlotManager is not sending signal for lacking resources - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23893) Fine-grained resource allocation may fail depending on slot allocation order - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23894) Resolve/hide akka warning regarding ActorRefProvider - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23895) Upsert materializer is not inserted for all sink providers - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/20 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23896) The new KafkaSink drops data if job fails between checkpoint and transaction commit. - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/08/20 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23897) Fix obsolete doc about creating hive table with flink - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/08/20 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23898) WARN log level not mapped correctly to akka log levels - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23899) Translate the "Elastic Scaling" page into chinese - posted by "Wenhao Ji (Jira)" <ji...@apache.org> on 2021/08/20 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23900) Migrate to ClusterActorRefProvider - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/20 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23901) Fink with HA, upgrade from 1.12.1 to 1.13.2 causes NPE - posted by "Parag Somani (Jira)" <ji...@apache.org> on 2021/08/20 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23902) Support Hive version 2.3.8 - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2021/08/20 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23903) ZooKeeperLeaderRetrievalConnectionHandlingTest.testSuspendedConnectionDoesNotClearLeaderInformationIfClearanceOnLostConnection fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/20 10:52:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-171: Async Sink - posted by "Hausmann, Steffen" <sh...@amazon.de.INVALID> on 2021/08/20 11:34:36 UTC, 1 replies.
- Projection pushdown for metadata columns - posted by Ingo Bürk <in...@ververica.com> on 2021/08/20 11:55:49 UTC, 6 replies.
- [jira] [Created] (FLINK-23904) Add a parameter to flink's startup command that points to the directory named jobid containing all versions of checkpoint - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/08/20 15:12:00 UTC, 0 replies.
- Scala 2.12 End to End Tests - posted by Danny Cranmer <da...@apache.org> on 2021/08/20 20:59:09 UTC, 6 replies.
- [jira] [Created] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar - posted by "huntercc (Jira)" <ji...@apache.org> on 2021/08/21 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23906) Increase akka.ask.timeout for tests using the MiniCluster - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/21 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23907) Type Migration: introducing primitive functional interfaces - posted by "Oleg Smirnov (Jira)" <ji...@apache.org> on 2021/08/21 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23908) Hint user about possibly non-deterministic key - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/08/22 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23909) Remove redundant variables and improve some style format in coding. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/08/22 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23910) RichAsyncFunction counter message inconsistent with counter type - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/08/22 22:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23911) Projections are not considered when pushing readable metadata into a source - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/23 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23912) Remove unnecessary "Clearing resource requirements of job" - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/08/23 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/08/23 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23914) Make connector testing framework more verbose on test failure - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/08/23 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23915) Propagate unique keys for temporary tables - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/23 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23916) Add documentation for how to configure the CheckpointFailureManager - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/23 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23917) Project metadata columns to apply to sources which do not implement projection pushdown - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/23 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem - posted by "li wei (Jira)" <ji...@apache.org> on 2021/08/23 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF - posted by "Yuval Itzchakov (Jira)" <ji...@apache.org> on 2021/08/23 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23920) SchemaTranslator looses primary key if schema is inferred - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/23 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23921) WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/08/23 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23922) -pyexec is not working correctly - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/23 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23923) Log command when starting python processes - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/23 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23924) Distribution is lacking Python Datastream examples - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/23 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23925) HistoryServer: Archiving job with more than one attempt fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/08/23 14:29:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 3.1.0, release candidate #1 - posted by Igal Shilman <ig...@apache.org> on 2021/08/23 15:37:39 UTC, 10 replies.
- [jira] [Created] (FLINK-23926) change TaxiRide data model to have a single timestamp - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/08/23 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23927) Fix go.mod file for SDK release - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/08/23 17:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23928) Test the buffer debloating - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/08/23 18:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23929) Chaining optimization doesn't handle properly for transformations with multiple inputs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/24 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23930) can not open web ui - posted by "钟洋洋 (Jira)" <ji...@apache.org> on 2021/08/24 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23931) Format the exception message shown in PythonDriver - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/24 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/24 05:53:00 UTC, 0 replies.
- Enable ssl authentication in kafka client - posted by "Seth, Abhilasha" <ab...@amazon.com.INVALID> on 2021/08/24 06:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-23933) flink-json formats support a option to parse nested json as a String - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2021/08/24 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23934) table doc timezone page 'table.local-time-zone' Configuration error - posted by "simenliuxing (Jira)" <ji...@apache.org> on 2021/08/24 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23935) Flink docs - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2021/08/24 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23936) Python UDFs instances are released and reinitialized if there is no input for more than 1 minute - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/24 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23937) Fix PQ comment in KeyGroupPartitionedPriorityQueue - posted by "Liu (Jira)" <ji...@apache.org> on 2021/08/24 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23938) Do not resume channels if the barrier is received via RPC - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/24 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23939) The result of validation and parsing failure does not match the document description - posted by "Carl (Jira)" <ji...@apache.org> on 2021/08/24 08:41:00 UTC, 0 replies.
- [DISCUSS] Merge FLINK-23755 after feature freeze - posted by Jingsong Li <ji...@gmail.com> on 2021/08/24 08:48:22 UTC, 3 replies.
- [jira] [Created] (FLINK-23940) Improve the documentation about how to use logging in PyFlink jobs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/24 09:19:00 UTC, 0 replies.
- [ANNOUNCE] Dropping "CheckpointConfig.setPreferCheckpointForRecovery()" - posted by Stephan Ewen <se...@apache.org> on 2021/08/24 09:56:10 UTC, 1 replies.
- [jira] [Created] (FLINK-23941) pyflink.datastream.connectors module not documented in PyDocs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/24 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/24 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/08/24 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/24 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23945) 无法打开Flink dashboard界面 - posted by "钟洋洋 (Jira)" <ji...@apache.org> on 2021/08/24 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23946) Application mode fails fatally when being shut down - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/24 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23947) DefaultDispatcherRunner does not log when the Dispatcher gains and loses leadership - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/24 12:52:00 UTC, 0 replies.
- Flink 1.14 Weekly 2021-08-24 - posted by Johannes Moser <jo...@ververica.com> on 2021/08/24 13:29:33 UTC, 1 replies.
- [jira] [Created] (FLINK-23948) Python Client Executable priority incorrect for PYFLINK_CLIENT_EXECUTABLE environment variable - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2021/08/24 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/08/24 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23950) Revert FLINK-23738 (i.e. unhide config, API, docs) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/24 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23951) Add golang examples to playground - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/08/24 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23952) Taskmanager fails to start complaining about missing configuration option - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2021/08/24 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23953) AvroSerializerSnapshot causes state migration even though the old and the new schemas are compatible - posted by "Iaroslav Zeigerman (Jira)" <ji...@apache.org> on 2021/08/24 22:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23954) Queryable state (rocksdb) with TM restart end-to-end test fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/25 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/08/25 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/25 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23958) parent-first class orders configuration not effect - posted by "waywtdcc (Jira)" <ji...@apache.org> on 2021/08/25 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23957) KafkaProducerAtLeastOnceITCase.testOneToOneAtLeastOnceRegularSink fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/25 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23959) FLIP-175: Add GraphBuilder to compose Estimator/Transformer/AlgoOperator from a DAG of stages - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/08/25 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/25 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23961) Give a more descriptive exception message for unset kubernetes options - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/08/25 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23962) UpdateKind trait is not propagated properly in changeLog inference for DAG optimizing - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/08/25 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23963) Configuration to only log instead of throwing "Writing records to JDBC failed." - posted by "Hady Januar Willi (Jira)" <ji...@apache.org> on 2021/08/25 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23964) Add Shaded Netty TCnative to lib/ in the docker image - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/08/25 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23965) E2E do not execute locally on MacOS - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/25 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23966) Don't try to add swifts filesystem plugins in the Dockerfile - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/08/25 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23967) Remove scala references in OneInputStreamTaskTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/25 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23968) Remove unused code in TestBaseUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/25 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23969) Test Pulsar source end 2 end - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/08/25 14:11:00 UTC, 0 replies.
- 【Announce】Zeppelin 0.10.0 is released, Flink on Zeppelin Improved - posted by Jeff Zhang <zj...@gmail.com> on 2021/08/25 14:48:22 UTC, 2 replies.
- [jira] [Created] (FLINK-23970) Future refactoring for the behavior of the tasks marked as finished on recovery - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/25 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/08/25 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23972) NoClassDefFoundError: Jars from yarn.ship-files are missing in the classpath of the client - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2021/08/25 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23973) FLIP-183: Buffer debloat 1.1 - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/08/25 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23974) Low throughput for buffer debloat in case of different load profile - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/08/25 16:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23975) High checkpoint time for unaligned checkpoint when throthling in source - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/08/25 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23976) Add additional availability timing metrics to Job lifecycle events - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/08/25 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23977) Add Support for Dynamic Elastic Index Routing - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2021/08/25 19:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23978) FieldAccessor has direct scala dependency - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/25 19:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23979) Exceptions with Kotlin 1.5.0 and higher - posted by "Hank (Jira)" <ji...@apache.org> on 2021/08/25 19:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23980) Jobmanager dies upon receiving REST API plan request - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2021/08/25 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23981) Delete file request returns an error even though the operation succeeded - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2021/08/25 22:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23982) Compiling error in WindowOperatorTest with JDK11 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/26 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23983) JVM crash when running RocksDBStateBackendConfigTest - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/26 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23984) 'Run kubernetes pyflink application test' fail with "Package 'python3.7' has no installation candidate" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/26 05:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-23985) Add document for adding new language SDK Smoke E2E. - posted by "Evans Ye (Jira)" <ji...@apache.org> on 2021/08/26 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23986) Add support for opting-out of Scala - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/26 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23987) Move Powered By section into separate page - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/26 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23988) Test corner cases - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/26 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23989) Flink SQL visibility - posted by "wangzhihao (Jira)" <ji...@apache.org> on 2021/08/26 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23990) Replace custom monaco editor component - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/26 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23991) Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme - posted by "Junfan Zhang (Jira)" <ji...@apache.org> on 2021/08/26 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23992) Update doc version in release-1.13 to 1.13.2 - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/26 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23993) Describe eventually-consistency of materializing upserts - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/26 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23994) ArrayDataSerializer and MapDataSerializer doesn't handle correctly for Null values - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/26 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23995) Hive dialect: `insert overwrite table partition if not exists` will throw exception when tablename is like 'database.table' - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2021/08/26 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23996) Make Scala 2.12 default build target - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/08/26 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23997) SQL windowing table-valued function improvement - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/26 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23998) Scopt not mentioned in flink-dist NOTICE file - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/26 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-23999) Support evaluating individual window table-valued function - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/26 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24000) window aggregate support allow lateness - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/26 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24001) Support evaluating individual window table-valued function in runtime - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/26 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24002) Support count window with the window TVF in planner - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/26 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24003) Lookback mode doesn't work when mixing use of Python Table API and Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/26 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24004) Introduce a source/sink testing harness - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/26 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24005) Resource requirements declaration may be incorrect if JobMaster disconnects with a TaskManager with available slots in the SlotPool - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/08/26 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24006) MailboxExecutorImplTest#testIsIdle does not test the correct behaviour - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/26 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24007) Support Avro timestamp conversion with precision greater than three - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2021/08/26 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24008) Support state cleanup based on unique keys - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/26 16:29:00 UTC, 0 replies.
- How heap state backend serialization happens during snapshotting - posted by Muhammad Haseeb Asif <mh...@kth.se> on 2021/08/26 18:41:11 UTC, 1 replies.
- [jira] [Created] (FLINK-24009) Upgrade to Apache pom parent 24 - posted by "Kevin Ratnasekera (Jira)" <ji...@apache.org> on 2021/08/26 20:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24010) HybridSourceReader needs to forward checkpoint notifications - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/08/26 22:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24011) SET 'sql-client.verbose' = 'true'; on Flink SQL client does not give full stack trace - posted by "James Kim (Jira)" <ji...@apache.org> on 2021/08/26 23:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24012) PulsarSourceITCase.testTaskManagerFailure fails due to NoResourceAvailableException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/27 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24013) Add IssueNavigationLink for IDEA - posted by "gaoyajun02 (Jira)" <ji...@apache.org> on 2021/08/27 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24014) Filters pushed through ChangelogNormalize cause incorrect results - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/27 07:00:06 UTC, 0 replies.
- [jira] [Created] (FLINK-24015) Dispatcher does not log JobMaster initialization error on info level - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/27 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24016) Restore 1.12 SQL docs page on state retention - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/27 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24017) Pin registration IDs of Java serializers - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/27 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24018) Remove Scala dependencies from flink-cep/flink-streaming-java - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/27 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24019) Separately package Scala-reliant modules - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/27 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24020) Aggregate HTTP requests before custom netty handers getting the data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2021/08/27 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24021) Potential job unrecoverable due to Network failure - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/08/27 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24022) Re-Enable Scala checks in flink-training CI - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/08/27 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24023) metris的列表中，指标的名称看不全 - posted by "linqichen (Jira)" <ji...@apache.org> on 2021/08/27 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24024) Fix syntax mistake in session Window TVF - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/08/27 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24025) The components on which Flink depends may contain vulnerabilities. If yes, fix them. - posted by "mixedfruit (Jira)" <ji...@apache.org> on 2021/08/27 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24026) Fix FLIP-XXX link can't be recognized correctly by IDEA - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/08/27 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24027) FileSystems list excessive dependencies in NOTICE - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/27 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24028) NoticeFileChecker complains about dependencies being mentioned in NOTICE file but are not listed in the Maven output - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/08/27 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24029) Update doc example sql field in release-1.13.2 to dept_id - posted by "wangke (Jira)" <ji...@apache.org> on 2021/08/27 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24030) PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits failed - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/08/27 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception - posted by "Julio Pérez (Jira)" <ji...@apache.org> on 2021/08/27 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24032) StreamSink does not receive periodic watermarks - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/27 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24033) Propagate unique keys for fromChangelogStream - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/27 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24034) Upgrade commons-compress to 1.21 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/27 14:29:00 UTC, 0 replies.
- Support decimal types with larger precisions - posted by Xingcan Cui <xi...@gmail.com> on 2021/08/27 22:21:40 UTC, 5 replies.
- [ANNOUNCE] release-1.14 branch cut - posted by Xintong Song <xt...@apache.org> on 2021/08/28 01:50:57 UTC, 0 replies.
- [jira] [Created] (FLINK-24035) Notify the buffer listeners when the local buffer pool receives available notification from the global pool - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2021/08/28 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24036) SSL cannot be installed on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/28 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24037) Allow wildcards in ENABLE_BUILT_IN_PLUGINS - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/08/28 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/08/28 17:50:00 UTC, 0 replies.
- Do we still maintain travis build system? - posted by tison <wa...@gmail.com> on 2021/08/29 02:47:51 UTC, 1 replies.
- [jira] [Created] (FLINK-24039) DatadogHttpReporter#report not thread-safe - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/08/29 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24040) Slf4jReporter#report need catch NoSuchElementException - posted by "camilesing (Jira)" <ji...@apache.org> on 2021/08/29 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/08/29 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24042) DataStream printToErr doc indicates that it writes to standard output - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/08/29 22:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24043) Reuse the code of 'check savepoint preconditions'. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/08/30 00:52:00 UTC, 0 replies.
- [ANNOUNCE] Release 1.14.0, release candidate #0 - posted by Xintong Song <xt...@apache.org> on 2021/08/30 02:57:36 UTC, 0 replies.
- [jira] [Created] (FLINK-24044) Errors are output when compiling flink-runtime-web - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/08/30 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24045) KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/30 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/08/30 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24047) SavepointITCase.testStopWithSavepointWithDrainCallsFinishBeforeSnapshotState fails due to 'Service temporarily unavailable due to an ongoing leader election.' - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/30 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24048) Move changeLog inference out of optimizing phase - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/08/30 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24049) TupleTypeInfo doesn't handle correctly for data types need conversion - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/30 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24050) Support primary keys on metadata columns - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/08/30 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24051) Make consumer.group-id optional for KafkaSource - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/30 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24052) Flink SQL reads S3 bucket data. - posted by "Moses (Jira)" <ji...@apache.org> on 2021/08/30 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24053) stop with savepoint timeout - posted by "刘方奇 (Jira)" <ji...@apache.org> on 2021/08/30 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/30 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24055) Deprecate FlinkKafkaConsumer - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/30 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24056) Remove unused ZooKeeperUtilityFactory - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/08/30 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24057) Flink SQL client Hadoop is not in the classpath/dependencies error even thugh Hadoop S3 File system plugin was added - posted by "James Kim (Jira)" <ji...@apache.org> on 2021/08/30 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/31 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24059) SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation - posted by "Brian Zhou (Jira)" <ji...@apache.org> on 2021/08/31 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24060) Move ZooKeeperUtilTest to right place - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/08/31 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24061) RMQSourceITCase.testAckFailure fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/31 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24062) Exception encountered during timer serialization in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/31 05:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/08/31 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24064) HybridSource recovery from savepoint fails - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/08/31 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24065) Upgrade the TwoPhaseCommitSink to support empty transaction after finished - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/31 06:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24066) Provides a new stop entry for Kubernetes session mode - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2021/08/31 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24067) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/31 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24068) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/08/31 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24069) IgnoreInFlightDataITCase.testIgnoreInFlightDataDuringRecovery hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/31 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24070) Support different over window aggregates in streaming queries - posted by "zl (Jira)" <ji...@apache.org> on 2021/08/31 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24071) Flink 1.12 HDFS sink have a problem,reported as OOM - posted by "zhuzhengjun (Jira)" <ji...@apache.org> on 2021/08/31 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24072) Add support for setting default headers in elasticsearch connector - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/08/31 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24073) Statefun 2.2 documentation build fails on buildbot - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/31 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24074) Check 1.14 licensing - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/31 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24075) Apache Flink 1.13.1 Docker images are published for linux/arm - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/08/31 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24076) Implement Table API walkthrough in flink-playground - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/08/31 09:11:00 UTC, 0 replies.
- Flink 1.14 Weekly 2021-08-31 - posted by Johannes Moser <jo...@ververica.com> on 2021/08/31 09:21:12 UTC, 1 replies.
- [jira] [Created] (FLINK-24077) HBaseConnectorITCase.testTableSink - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/31 10:38:00 UTC, 0 replies.
- flink-runtime-web build failing locally - posted by Piotr Nowojski <pn...@apache.org> on 2021/08/31 10:43:43 UTC, 0 replies.
- [jira] [Created] (FLINK-24078) Remove brackets around variables - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/08/31 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24079) BufferedUpsertSinkFunction can loose records during failover - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/08/31 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances: - posted by "leishuiyu (Jira)" <ji...@apache.org> on 2021/08/31 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/08/31 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24082) Python UDTF throws exception when the result type is generator of Row - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/31 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24083) The result isn't as expected when the result type is generator of string for Python UDTF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/08/31 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24084) The example in sql join document missed primary key - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/08/31 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24085) The `versioned table` and `Timezone` pages missed the first class subject - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/08/31 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job - posted by "ming li (Jira)" <ji...@apache.org> on 2021/08/31 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24087) Kafka connector StartupMode requires a table dependency - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/08/31 14:50:00 UTC, 0 replies.
- Re: 退订 - posted by Leonard Xu <xb...@gmail.com> on 2021/08/31 14:59:55 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.1.0 released - posted by Igal Shilman <ig...@apache.org> on 2021/08/31 15:09:43 UTC, 1 replies.
- [jira] [Created] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/08/31 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test - posted by "Nicolaus Weidner (Jira)" <ji...@apache.org> on 2021/08/31 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24090) Document ability to ignore in-flight data on recovery - posted by "Joe Moser (Jira)" <ji...@apache.org> on 2021/08/31 18:54:00 UTC, 0 replies.