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

---

- [jira] [Created] (FLINK-24091) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/01 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24092) OrcFsStreamingSinkITCase.testPart times out on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/01 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24093) Supports setting the percentage of kubernetes Request resources - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2021/09/01 03:26:00 UTC, 0 replies.
- One idea for Graceful Application Evolvement - posted by zhihao wang <ha...@chopin.fm> on 2021/09/01 03:27:36 UTC, 4 replies.
- [jira] [Created] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31) - posted by "lixu (Jira)" <ji...@apache.org> on 2021/09/01 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24095) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails due to socket timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/01 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24096) JoinITCase.testNullFullOuterJoin fails due to NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/01 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24097) Remove the streaming check in StreamTableEnvironment in PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/01 06:34:00 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink Stateful Functions 3.1.0 released - posted by Johannes Moser <jo...@ververica.com> on 2021/09/01 07:05:32 UTC, 2 replies.
- [jira] [Created] (FLINK-24098) Document FLIP-147 capabiliites and limitations - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/01 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24099) Update documentation links to point to nightlies.apache.org - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/01 07:36:00 UTC, 0 replies.
- [NOTICE] Documentation at ci.apache.org temporarily frozen - posted by Chesnay Schepler <ch...@apache.org> on 2021/09/01 08:11:26 UTC, 1 replies.
- [jira] [Created] (FLINK-24100) test_connectors.py fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/01 08:38:00 UTC, 0 replies.
- [DISCUSS] Automated architectural tests - posted by Ingo Bürk <in...@ververica.com> on 2021/09/01 09:03:02 UTC, 15 replies.
- Re: Do we still maintain travis build system? - posted by Chesnay Schepler <ch...@apache.org> on 2021/09/01 09:09:25 UTC, 1 replies.
- [jira] [Created] (FLINK-24101) Support to generate PyDocs without Flink distribution - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/01 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24102) unknown Fields error when flink doesn't recognize a field on protobuf - posted by "Gabriele Lorencini (Jira)" <ji...@apache.org> on 2021/09/01 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/01 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24104) incorrect validation of sink schema - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/09/01 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24105) state TTL might not take effect for pyflink - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/09/01 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24106) Remove notice that python does not support state TTL - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/09/01 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11 - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/01 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24108) Translate KafkaSink documentation to Chinese - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/01 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24109) Correct egress string serialization - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/01 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24110) Filter null ComponentJsonObjects - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/01 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24111) UnsignedTypeConversionITCase fails locally - posted by "Nicolaus Weidner (Jira)" <ji...@apache.org> on 2021/09/01 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/09/01 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24113) Introduce option in Application Mode to request cluster shutdown - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/01 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24114) Make CompletedOperationCache.COMPLETED_OPERATION_RESULT_CACHE_DURATION_SECONDS configurable (at least for savepoint trigger operations) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/01 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24115) Outdated SQL Temporal Join Example - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/09/01 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24116) PRIMARY KEY declaration on insert-only table is not validated globally - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/01 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24117) Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/09/01 15:46:00 UTC, 0 replies.
- [DISCUSS] FLINK-23972: Customizable classpath of the flink client - posted by ta...@gmail.com on 2021/09/01 17:41:54 UTC, 0 replies.
- [jira] [Created] (FLINK-24118) enable TaxiFareGenerator to produce a bounded stream - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/09/01 22:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/02 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24120) The memory will rise a little after each savepoint ends - posted by "no nO (Jira)" <ji...@apache.org> on 2021/09/02 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24121) There are spelling mistakes in the notes。 - posted by "lixiaobao (Jira)" <ji...@apache.org> on 2021/09/02 03:02:00 UTC, 0 replies.
- contribute to Apache Flink - posted by 如故 <ru...@dingtalk.com.INVALID> on 2021/09/02 03:18:11 UTC, 1 replies.
- [jira] [Created] (FLINK-24122) Add support to do clean in history server - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/09/02 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24123) test_dependency.py fails due to 'Failed to close remote bundle' - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/02 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24124) Use explicit pool size to construct thread pool instead of Hardware.getNumberCPUCores() - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/09/02 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24125) Rethink relationship between DeclarativeSlotPool and *Bridge - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/02 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24126) Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/09/02 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24127) Asynchronous I/O documentation should be updated - posted by "Oleg Novoyavchev (Jira)" <ji...@apache.org> on 2021/09/02 10:53:00 UTC, 0 replies.
- Deploying Stateful functions with an existing Ververica cluster - posted by Barry Higgins <ba...@gmail.com> on 2021/09/02 11:06:23 UTC, 0 replies.
- [jira] [Created] (FLINK-24128) StreamingFileCommiter receive commit message but checkpoint did't ready - posted by "zhuzhengjun (Jira)" <ji...@apache.org> on 2021/09/02 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24129) TopicRangeTest.rangeCreationHaveALimitedScope fails on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/02 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24130) RowDataSerializerTest fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/02 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24131) KafkaSinkITCase "Detected producer leak" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/02 14:20:00 UTC, 0 replies.
- ContinuousProcessingTimeTrigger doesn't fire at the end of the window - posted by liwei li <hi...@gmail.com> on 2021/09/02 14:37:24 UTC, 0 replies.
- [jira] [Created] (FLINK-24132) directory-maven-plugin fails on Github action - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/02 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24133) PartitionRequestClientFactoryTest.testThrowsWhenNetworkFailure fails on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/02 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds - posted by "Adam Pearce (Jira)" <ji...@apache.org> on 2021/09/02 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24135) Add support for metric group tags in StatsDReporter - posted by "Prakhar Mathur (Jira)" <ji...@apache.org> on 2021/09/02 21:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24136) OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with NPE - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/09/03 01:50:00 UTC, 0 replies.
- [ANNOUNCE] Documentation now available at nightlies.apache.org - posted by Chesnay Schepler <ch...@apache.org> on 2021/09/03 06:03:55 UTC, 5 replies.
- [jira] [Created] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/03 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24138) Automated architectural tests - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/03 06:41:00 UTC, 0 replies.
- Re: Question about ZooKeeper HA new structure [FLINK-22636] - posted by Till Rohrmann <tr...@apache.org> on 2021/09/03 06:48:45 UTC, 4 replies.
- [jira] [Created] (FLINK-24139) Push down more predicates through Join in stream mode - posted by "Alexander Trushev (Jira)" <ji...@apache.org> on 2021/09/03 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24140) Enhance the ITCase for FLIP-147 - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/09/03 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24141) table can't have the same name with database or catalog - posted by "jocean.shi (Jira)" <ji...@apache.org> on 2021/09/03 07:23:00 UTC, 0 replies.
- [DISCUSS] About migrating to new mail list archive service - posted by Leonard Xu <xb...@gmail.com> on 2021/09/03 07:42:55 UTC, 7 replies.
- [jira] [Created] (FLINK-24142) Fix Document DataStream Connectors File Sink ORC Format Scala example - posted by "MasonMa (Jira)" <ji...@apache.org> on 2021/09/03 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24143) Invalid validation error for temporary view - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/03 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24144) Improve DataGenerator to prevent excessive creation of new Random objects - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/09/03 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24145) Translate "CREATE Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/03 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24146) Translate "CREATE Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/03 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24147) HDFS lease issues on Flink retry - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/09/03 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2021/09/03 10:00:06 UTC, 0 replies.
- [jira] [Created] (FLINK-24149) Make checkpoint relocatable - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/03 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24150) Support to configure cpu resource request and limit in pod template - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/09/03 12:00:15 UTC, 0 replies.
- [jira] [Created] (FLINK-24151) java.lang.RuntimeException occurs with setMaxConcurrentCheckpoints being enabled - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/09/03 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24152) Exactly-once semantics should be configurable through Flink configuration only - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/09/03 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24153) Unable to use SET command in Flink SQL Shell file submit mode - posted by "Nilanjan Sarkar (Jira)" <ji...@apache.org> on 2021/09/03 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24154) Translate documentation for how to configure the CheckpointFailureManager - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/03 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24155) Translate documentation for how to configure the CheckpointFailureManager - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/03 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24156) BlobServer crashes due to SocketTimeoutException in Java 11 - posted by "Ryan Scudellari (Jira)" <ji...@apache.org> on 2021/09/03 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24157) do you have a plan for support dotnet - posted by "Clement (Jira)" <ji...@apache.org> on 2021/09/04 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24158) Remove useless collector in LimitOperator - posted by "Zhuang Tianyi (Jira)" <ji...@apache.org> on 2021/09/04 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24159) document of entropy injection may mislead users - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/05 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24160) PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.' - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/06 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24161) Can not stop the job with savepoint while a task is finishing - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/09/06 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/06 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/06 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24164) Point website to nightlies.apache.org - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/06 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24165) Comment spelling error - posted by "jianzhang.yjz (Jira)" <ji...@apache.org> on 2021/09/06 08:09:00 UTC, 0 replies.
- [ANNOUNCE] Flink mailing lists archive service has migrated to Apache Archive service - posted by Leonard Xu <xb...@gmail.com> on 2021/09/06 08:39:23 UTC, 0 replies.
- Re: [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2021/09/06 08:53:23 UTC, 0 replies.
- Re: [ANNOUNCE] Flink mailing lists archive service has migrated to Apache Archive service - posted by Jark Wu <im...@gmail.com> on 2021/09/06 08:58:44 UTC, 4 replies.
- [jira] [Created] (FLINK-24166) Local class incompatible error returned when submitting incorrect SQL statement - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/06 09:12:00 UTC, 0 replies.
- Is anyone still using the 1.11-1.13 Burndown/Bugs/Sprint Kanban boards? - posted by Chesnay Schepler <ch...@apache.org> on 2021/09/06 11:13:21 UTC, 1 replies.
- [jira] [Created] (FLINK-24167) Split HeartbeatTarget to HeartbeatReceiver and HeartbeatSender - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/09/06 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate on Match because the output type does not updated after input rowtime attribute changed from rowtime to rowtime_ltz - posted by "JING ZHANG (Jira)" <ji...@apache.org> on 2021/09/06 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24169) Flaky local YARN tests relying on log files - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/09/06 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24170) Building a fresh clone with latest Maven fails - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/06 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24171) Formatting should be enforced for Flink UI - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/06 15:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-24172) Table API join documentation for Java has missing end quote after table name - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/09/06 23:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24173) BatchFileSystemITCaseBase.testProjectPushDown hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/07 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus() - posted by "Liu (Jira)" <ji...@apache.org> on 2021/09/07 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24175) KafkaITCase.testConcurrentProducerConsumerTopology times out - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/07 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24176) Column alias in Flink-SQL is unsuccessful after converting Table to DataStream - posted by "Wang Guanglei (Jira)" <ji...@apache.org> on 2021/09/07 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24177) Add epoll exception check - posted by "rufei xing (Jira)" <ji...@apache.org> on 2021/09/07 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24178) flink on - posted by "frey (Jira)" <ji...@apache.org> on 2021/09/07 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/07 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24180) UnalignedCheckpointRescaleITCase fails due to direct OOM - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/07 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24181) Update org.jsoup.jsoup to 1.14.2 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/07 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24182) Tasks canceler should not immediately interrupt - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/07 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24184) Potential race condition leading to incorrectly issued interruptions - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/07 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24185) flink-s3-fs-presto bundled dependencies not listed in NOTICE file - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/07 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24186) Disable single rowtime column check for collect/print - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/07 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24187) Could not commit s3 file after JM restart during state initialization - posted by "Youjun Yuan (Jira)" <ji...@apache.org> on 2021/09/07 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24188) flink-python NOTICE file contains unnecessary dependencies - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/07 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24189) Debloating buffer for multiply gates - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/07 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24190) Handling large record with buffer debloat - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/07 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24191) Adjusting number of buffers besides buffer size - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/07 10:45:00 UTC, 0 replies.
- Flink 1.14 Weekly 2021-09-07 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/09/07 10:57:01 UTC, 0 replies.
- [jira] [Created] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2021/09/07 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24193) Test service entries cause noise in other tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/07 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24194) resource-providers yarn documentation has Chinese useless characters - posted by "qingbo jiao (Jira)" <ji...@apache.org> on 2021/09/07 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/07 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/07 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/07 16:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24198) KafkaTableITCase#testKafkaTemporalJoinChangelog fail with FlinkJobNotFoundException: Could not find Flink job - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/07 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24199) Expose StreamExecutionEnvironment#configure in Python API - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/07 16:57:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-182: Watermark alignment - posted by Thomas Weise <th...@apache.org> on 2021/09/07 17:17:49 UTC, 3 replies.
- [jira] [Created] (FLINK-24200) CheckpointBarrierTrackerTest.testTwoLastBarriersOneByOne fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/08 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24201) HistoryServer didn't contain TaskManager Logs - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/09/08 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24202) BoundedSourceITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/08 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24203) AbstractServerTest fails due to port conflict - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/08 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24204) Failed to insert nested types using value constructed functions - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/09/08 04:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24205) AggregateReduceGroupingITCase hangs on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/08 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/08 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/09/08 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24208) Allow idempotent savepoint triggering - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/08 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24209) Jdbc connector uses postgres testcontainers in compile scope - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/08 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24210) Window related serailizer should not return 0 as its serialized length - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/09/08 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/08 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory for customer file name - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2021/09/08 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24213) Java deadlock in QueryableState ClientTest - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/08 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24214) A submit job failure crashes the sql client - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/08 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/09/08 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24216) org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/09/08 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24218) Translate "UNLOAD Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/08 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24217) Translate "LOAD Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/08 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24219) Translate "SET Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/08 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24220) Translate "RESET Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/08 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24221) Translate "JAR Statements" page of "SQL" into Chinese - posted by "wuguihu (Jira)" <ji...@apache.org> on 2021/09/08 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24222) Use ContextClassLoaderExtension in ReporterSetupTest - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/09 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24223) Client should throw exception to warn users when the configurations set by program options conflict with those set by -D - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2021/09/09 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24224) Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work by only stream api . - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2021/09/09 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24225) Define and implement UPSERT INTO semantics - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/09 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/09 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24227) [FLIP-171] KDS implementation of Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/09 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24228) [FLIP-171] Firehose implementation of Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/09 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/09 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24230) Buffer debloating microbenchmark for single gate - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/09 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24231) Buffer debloating microbenchmark for multiply gate - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/09 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24232) Archiving of suspended jobs prevents breaks subsequent archive attempts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/09 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24233) Receiving new buffer size before network reader configured - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/09 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24234) [FLIP-171] Byte Based & Time Based Flushing for AsyncSinkBase - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/09 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24235) Restrict reporter support to plugins - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/09 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24236) Migrate tests to reporter factories - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/09 19:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/09 19:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24238) Page title missing - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/09/09 21:08:00 UTC, 0 replies.
- [VOTE] FLIP-173: Support DAG of algorithms - posted by Dong Lin <li...@gmail.com> on 2021/09/10 02:32:41 UTC, 4 replies.
- [jira] [Created] (FLINK-24239) Event time temporal join should support values from array, map, row, etc. as join key - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/09/10 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24240) HA JobGraph deserialization problem when migrate 1.12.4 to 1.13.2 - posted by "Zheren Yu (Jira)" <ji...@apache.org> on 2021/09/10 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24241) test_table_environment_api.py fail with NPE - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/10 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24242) KafkaSinkITCase.testAbortTransactionsOfPendingCheckpointsAfterFailure fails due to NoSuchFileException - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/10 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24243) Clean up the code and avoid warning messages introduced by deprecated API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/10 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24244) Add logging about whether it's executed in loopback mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/10 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24245) Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/09/10 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24246) Bump Pulsar to 2.8.1 - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2021/09/10 09:00:12 UTC, 0 replies.
- [jira] [Created] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/09/10 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24248) flink-clients dependency missing in Gradle Example - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/09/10 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24249) login from keytab fail when disk damage - posted by "YuAngZhang (Jira)" <ji...@apache.org> on 2021/09/10 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24250) Add De/Serialization API to tear-down user code - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/10 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24251) Make default constructor of BinaryStringData private - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/09/10 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24252) HybridSource should return TypeInformation - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/09/10 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24253) Load JdbcDialects via Service Loaders - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/10 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24254) Support hints configuration hints - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/10 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/09/10 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24256) Add JavaScript SDK for Stateful Functions - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/10 14:35:00 UTC, 0 replies.
- 退订 - posted by qq <64...@qq.com.INVALID> on 2021/09/11 08:06:59 UTC, 4 replies.
- [jira] [Created] (FLINK-24257) Using Stateful Blue/Green Deployment to handle Application Evolvement - posted by "Zhihao Wang (Jira)" <ji...@apache.org> on 2021/09/11 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24258) Connection timed out or very slowly when visiting Flink website - posted by "zhangzhao (Jira)" <ji...@apache.org> on 2021/09/12 01:51:00 UTC, 0 replies.
- [DISCUSS] Generalized incremental checkpoint addition monitoring - posted by yu...@gmail.com, yu...@gmail.com on 2021/09/12 14:42:13 UTC, 0 replies.
- [jira] [Created] (FLINK-24259) Exception thrown when Kafka topic is null for FlinkKafkaConsumer - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2021/09/12 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24260) py35-cython fails due to could not find requests>=2.26.0 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/13 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/13 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24262) Remove unused ContainerOverlays - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/09/13 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24263) PulsarSourceITCase.testMultipleSplits fails due to "Consumer not found" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/13 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24264) Streaming File Sink s3 end-to-end test fail with output mismatch - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/13 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24265) Streaming File Sink s3 end-to-end test fails due to Output hash mismatch - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/13 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24266) Log improvement for aborting checkpoint due to tasks are finishing - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/09/13 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24267) PyFlink Table API example from docs does not work. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/13 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24268) Documentation for building PyFlink does not show correctly. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/13 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24269) Rename methods around final checkpoints - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/13 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24270) Rewrite tests for illegal job modification against VertexFinishedStateChecker - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/13 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24271) Add document for special char in JSON_VALUE - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/09/13 07:44:00 UTC, 0 replies.
- [DISCUSS] Purpose of release notes - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/09/13 07:51:18 UTC, 3 replies.
- [jira] [Created] (FLINK-24272) FileSystem compaction should throw unsupported exception in at-least-once mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/09/13 09:44:00 UTC, 0 replies.
- Re: Looking for Maintainers for Flink on YARN - posted by 柳尘 <yu...@gmail.com> on 2021/09/13 12:22:16 UTC, 0 replies.
- [jira] [Created] (FLINK-24273) Relocate io.fabric8 dependency to - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/09/13 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24274) Wrong parameter order in documentation of State Processor API - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/13 18:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24275) Allow idempotent job cancellation - posted by "Austin Cawley-Edwards (Jira)" <ji...@apache.org> on 2021/09/13 19:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24276) Remove unnecessary info in Loopbck mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/09/14 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24277) Offset commit should be disabled if consumer group ID is not specified in KafkaSource - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/09/14 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24278) [FLIP-171] Async Sink Base Sink Developer Guide for Documentation - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/14 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24279) Support withBroadcast in DataStream API - posted by "ZHANG ZHIPENG (Jira)" <ji...@apache.org> on 2021/09/14 10:27:00 UTC, 0 replies.
- Contribute to Flink StateFun - posted by Evans Ye <ev...@apache.org> on 2021/09/14 10:58:35 UTC, 1 replies.
- [jira] [Created] (FLINK-24280) Support manual checkpoints triggering from a MiniCluster - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/14 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24281) Migrate all existing tests to new Kafka Sink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/14 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24282) KafkaRecordSerializationSchema TopicSelector is not serializable - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/14 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2021/09/14 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/14 14:13:00 UTC, 0 replies.
- Beam with Flink runner - Issues when writing to S3 in Parquet Format - posted by "Kathula, Sandeep" <Sa...@intuit.com.INVALID> on 2021/09/14 15:21:32 UTC, 2 replies.
- [jira] [Created] (FLINK-24285) Flink Table API Could not find any format factory for identifier 'csv' in the classpath. - posted by "James Kim (Jira)" <ji...@apache.org> on 2021/09/14 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a' - posted by "James Kim (Jira)" <ji...@apache.org> on 2021/09/14 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24287) Bump virtualenv to the latest version - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/09/15 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24288) YARNITCase.testPerJobWithArchive fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/15 06:00:18 UTC, 0 replies.
- [jira] [Created] (FLINK-24289) Load data repeatedly between different jobs - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/09/15 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24290) Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/15 07:21:00 UTC, 0 replies.
- [VOTE] Release 1.14.0, release candidate #1 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/09/15 07:29:13 UTC, 5 replies.
- [jira] [Created] (FLINK-24291) Decimal precision is lost when deserializing - posted by "xuyangzhong (Jira)" <ji...@apache.org> on 2021/09/15 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24292) Update Flink's Kafka examples to use KafkaSink - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/15 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24293) Tasks share - posted by "huntercc (Jira)" <ji...@apache.org> on 2021/09/15 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24294) Resources leak in the StreamTask constructor - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/09/15 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24295) Too many requestPartitionState may jam the JobManager during task deployment - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/09/15 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24296) Refactor Google PubSub to new Source/Sink interfaces - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/15 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24297) Refactor Google PubSub source to use Source API - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/15 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24298) Refactor Google PubSub sink to use Unified Sink API - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/15 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24299) Make Google PubSub available as Source and Sink for Table API - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/15 12:00:18 UTC, 0 replies.
- [DISCUSS] FLIP-176: Unified Iteration to Support Algorithms (Flink ML) - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/09/15 12:47:30 UTC, 0 replies.
- [jira] [Created] (FLINK-24300) MultipleInputOperator is running much more slowly in TPCDS - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/09/15 15:23:00 UTC, 0 replies.
- Re: About the Unified Sink API (FLIP-143) Committer not commit - posted by 赵 建云 <zh...@outlook.com> on 2021/09/15 15:47:15 UTC, 0 replies.
- [jira] [Created] (FLINK-24301) use Async transport on all statefun playground examples - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/15 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11 - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2021/09/15 17:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24303) SourceCoordinator exception may fail Session Cluster - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/15 20:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24304) ProcessFailureCancelingITCase.testCancelingOnProcessFailure fails due to leader retrieval timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/16 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/16 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24306) group by index throw SqlValidatorException - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/09/16 05:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24307) Some lines in Scala code example end with unnecessary semicolons. Also some Scala code blocks are wrongly typed with Java blocks - posted by "Yao Zhang (Jira)" <ji...@apache.org> on 2021/09/16 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24308) Translate KafkaSink docs to chinese - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/16 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24309) NoClassDefFoundError occurs when using spring-data-redis for event notification in a flink cluster environment - posted by "WangYu (Jira)" <ji...@apache.org> on 2021/09/16 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24310) A bug in the BufferingSink example in the doc - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/09/16 08:55:00 UTC, 0 replies.
- [DISCUSS] Drop Scala Shell - posted by Martijn Visser <ma...@ververica.com> on 2021/09/16 11:21:14 UTC, 5 replies.
- [jira] [Created] (FLINK-24311) Support expression reduction for JSON construction functions - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/16 11:51:00 UTC, 0 replies.
- Re: [flink-statefun-playground] branch dev updated (dffc594 -> cccd603) - posted by Fernando DalSotto <da...@gmail.com> on 2021/09/16 21:42:38 UTC, 0 replies.
- [jira] [Created] (FLINK-24312) 'New File Sink s3 end-to-end test' fails due to timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/17 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24313) JdbcCatalogFactoryTest fails due to "Gave up waiting for server to start after 10000ms" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/17 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24314) Always use memory state backend with RocksDB - posted by "shiwuliang (Jira)" <ji...@apache.org> on 2021/09/17 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24315) Flink native on k8s wacther thread will down，when k8s api server not work or network timeout - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2021/09/17 06:05:00 UTC, 0 replies.
- About PR Review Help - posted by Roc Marshal <fl...@126.com> on 2021/09/17 07:55:56 UTC, 1 replies.
- [jira] [Created] (FLINK-24316) Refactor IntermediateDataSet to have only one consumer - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/09/17 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24317) Optimize the test implementation in test_flat_aggregate - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/09/17 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24318) Casting a number to boolean has different results between 'select' fields and 'where' condition - posted by "xuyangzhong (Jira)" <ji...@apache.org> on 2021/09/17 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24319) Jar not found in ClassLoaderITCase - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/09/17 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24320) Show in the Job / Checkpoints / Configuration if checkpoints are incremental - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/17 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24321) The Pod Template supports replaceable content - posted by "liuzhuo (Jira)" <ji...@apache.org> on 2021/09/17 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24322) Improve TypeScript support for the JS SDK - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/17 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24323) Port ElasticSearch Sink to new Unified Sink API (FLIP-143) - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/17 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24324) Creea ElasticSearch 7 Sink to new Unified Sink API (Flip-143) - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/17 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24325) Create ElasticSearch 6.8 Sink - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/17 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24326) Update Docs with new Sinks - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/17 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24327) Integrate new Sinks with Table API - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/17 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24328) Long term fix for receiving new buffer size before network reader configured - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/17 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24329) PulsarSourceITCase fails due to port conflict - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/18 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24330) HiveRunnerITCase JVM crash - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/18 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24331) PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;" - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/18 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24332) Support to mount a dynamically-created persistent volume claim per TaskManager - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/09/18 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24333) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredOnCheckpoint fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/18 06:01:00 UTC, 0 replies.
- [VOTE] Release 1.14.0, release candidate #2 - posted by Xintong Song <xt...@apache.org> on 2021/09/18 07:31:05 UTC, 3 replies.
- [jira] [Created] (FLINK-24334) Configuration kubernetes.flink.log.dir not working - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/09/18 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24335) Get java.net.MalformedURLException when submit job from python by pyflink table api. - posted by "Xin Yu (Jira)" <ji...@apache.org> on 2021/09/18 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24336) PyFlink - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2021/09/18 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24337) WEB UI failure in Flink 1.15-SNAPSHOT current code - posted by "xusysh (Jira)" <ji...@apache.org> on 2021/09/19 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24338) Provide an interface to validate flinksql - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/09/20 05:09:00 UTC, 0 replies.
- [VOTE] Drop Scala Shell - posted by Martijn Visser <ma...@ververica.com> on 2021/09/20 07:38:31 UTC, 4 replies.
- [jira] [Created] (FLINK-24339) Remove guard against CRLF split across chunks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/20 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24340) Misleading exception logged finished/canceled job restarted once - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/20 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24341) PyFlink Table test module timeout - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/09/20 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24342) Filesystem sink does not escape right bracket in partition name - posted by "Alexander Trushev (Jira)" <ji...@apache.org> on 2021/09/21 04:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/09/21 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24344) Handling of IOExceptions when triggering checkpoints doesn't cause job failover - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/21 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24345) Translate "File Systems" page of "Internals" into Chinese - posted by "Liebing Yu (Jira)" <ji...@apache.org> on 2021/09/21 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24346) Flink on yarn application mode,LinkageError - posted by "李伟高 (Jira)" <ji...@apache.org> on 2021/09/21 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24347) KafkaSource cannot checkpoint if the parallelism is higher than the partition number - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/21 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/21 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24349) Support customized Calalogs via JDBC - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/09/22 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24350) Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/22 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24351) translate "JSON Function" pages into Chinese - posted by "liwei li (Jira)" <ji...@apache.org> on 2021/09/22 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24352) Lookup join + WITH clause throws NPE - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/09/22 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24353) Bash scripts do not respect dynamic configurations when calculating memory sizes - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/22 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24354) FLIP-174: Improve the WithParam interface - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/09/22 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24355) Expose the flag for enabling checkpoints after tasks finish in the Web UI - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/22 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24356) Not able to cancel delayed message using remote stateful function mode - posted by "Julia Pedrycz (Jira)" <ji...@apache.org> on 2021/09/22 11:06:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.13.3 - posted by Martijn Visser <ma...@ververica.com> on 2021/09/22 11:34:34 UTC, 10 replies.
- [VOTE] Release 1.14.0, release candidate #3 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/09/22 13:55:59 UTC, 12 replies.
- [jira] [Created] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/09/22 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with dependency convergence - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/23 03:48:00 UTC, 0 replies.
- [DISCUSS] FLIP-174: Improve the WithParam interface (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2021/09/23 05:32:20 UTC, 0 replies.
- [DISCUSS] FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator (Flink ML) - posted by Dong Lin <li...@gmail.com> on 2021/09/23 05:32:22 UTC, 0 replies.
- Create a public open GitHub org for Flink ecosystem projects. - posted by Becket Qin <be...@gmail.com> on 2021/09/23 06:43:16 UTC, 8 replies.
- [jira] [Created] (FLINK-24359) Migrate FileSystem connector to ResolvedSchema - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/23 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24360) Drop Scala Shell - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/23 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24361) there are only two ways to define a processing time attribute but the time_attributes.md said has thre - posted by "qingbo jiao (Jira)" <ji...@apache.org> on 2021/09/23 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24362) Consider reworking handlers to use composition - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/23 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24363) java.io.FileNotFoundException crashes the standalone session manager - posted by "Francesco Guardiani (Jira)" <ji...@apache.org> on 2021/09/23 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24364) Add a delayed message cancellation to the embedded smoke test - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/09/23 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24365) Support to make Flink job more programmatically controlled via CLI - posted by "Eui Heo (Jira)" <ji...@apache.org> on 2021/09/23 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24366) Unnecessary/misleading error message about failing restores when tasks are already canceled. - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/09/23 16:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24368) Collect logs of Flink container in e2e source test suite - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24367) Add a fallback AkkaRpcSystemLoader for tests in the IDE - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/09/24 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24369) Resource Leak may happen if flink cluster runs abnormally and repeatedly retry - posted by "turtlebin (Jira)" <ji...@apache.org> on 2021/09/24 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase - posted by "Zichen Liu (Jira)" <ji...@apache.org> on 2021/09/24 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24371) Support SinkWriter preCommit without the need of a committer - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/24 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/09/24 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24374) ManualCheckpointITCase.testTriggeringWhenPeriodicDisabled fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/26 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24375) The name of flush thread in RecordWriter should contain subtask index - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2021/09/26 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/09/26 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24377) TM resource may not be properly released after heartbeat timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/26 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24378) Dim table join operator Push down - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2021/09/26 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24379) AWS Glue Schema Registry support doesn't work for table API - posted by "Brad Davis (Jira)" <ji...@apache.org> on 2021/09/27 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/09/27 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24382) RecordsOut metric for sinks is inaccurate - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/27 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24381) Hidden password value when Flink SQL connector throw exception. - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/09/27 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/09/27 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2021/09/27 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24385) Add TRY_CAST function to be able to handle errors - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/27 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/09/27 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24387) Support a "to JSON" function - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24388) Modules can provide a Factory for factory discovery - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/09/27 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24389) getDescription() in `CatalogTableImpl` should check null - posted by "Neng Lu (Jira)" <ji...@apache.org> on 2021/09/28 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24390) Python 'build_wheels mac' fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/28 02:51:00 UTC, 0 replies.
- The Apache Flink should pay more attention to ensuring API compatibility. - posted by OpenInx <op...@gmail.com> on 2021/09/28 04:33:52 UTC, 18 replies.
- [jira] [Created] (FLINK-24391) flink-json formats should support an option to extract the raw message into a column - posted by "Shengnan YU (Jira)" <ji...@apache.org> on 2021/09/28 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24392) Upgrade presto s3 fs implementation to Trinio >= 348 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/28 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24393) Add tests for all currently supported cast combinations - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/28 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24394) Refactor scalar function testing infrastructure to allow testing multiple columns - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/28 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24395) Checkpoint trigger time difference between log statement and web frontend - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/09/28 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24396) Add @Public annotations to Table & SQL API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24397) Reduce TableSchema usage in Table API connectors - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/28 11:03:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.14.0, release candidate #3 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/09/28 11:03:13 UTC, 0 replies.
- [jira] [Created] (FLINK-24398) KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible - posted by "Dong Lin (Jira)" <ji...@apache.org> on 2021/09/28 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24399) Make handling of DataType less verbose - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/28 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest? - posted by "jacky jia (Jira)" <ji...@apache.org> on 2021/09/29 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24401) TM cannot exit after Metaspace OOM - posted by "future (Jira)" <ji...@apache.org> on 2021/09/29 03:55:00 UTC, 0 replies.
- [Flink blogs] - posted by Etienne Chauchot <ec...@apache.org> on 2021/09/29 12:38:54 UTC, 2 replies.
- [jira] [Created] (FLINK-24402) Add back-pressure metrics for the ChangelogStateBackend - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/09/29 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24403) Improve behaviour of CAST - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/29 13:50:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.14.0 released - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/09/29 13:59:47 UTC, 4 replies.
- [DISCUSS] Invitation for recording videos to celebrate the 2nd anniversary of Apache APISIX as the Apache project - posted by yeliang wang <wa...@gmail.com> on 2021/09/29 14:33:55 UTC, 0 replies.
- [jira] [Created] (FLINK-24404) Support to submit job with the ID user provided - posted by "Eui Heo (Jira)" <ji...@apache.org> on 2021/09/29 14:58:00 UTC, 0 replies.
- FLINK-23972: Customizable classpath of the flink client - posted by ta...@gmail.com on 2021/09/29 15:59:28 UTC, 0 replies.
- [jira] [Created] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/30 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24406) JSONKeyValueDeserializationSchema code bug - posted by "胡剑 (Jira)" <ji...@apache.org> on 2021/09/30 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly. - posted by "Aiden Gong (Jira)" <ji...@apache.org> on 2021/09/30 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB - posted by "shengkui leng (Jira)" <ji...@apache.org> on 2021/09/30 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors - posted by "Brad Davis (Jira)" <ji...@apache.org> on 2021/09/30 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24410) Upgrade Confluent Platform OSS version in end-to-end tests - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2021/09/30 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24411) Add docs navigation for release notes - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/09/30 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24412) retract stream join on topN error - posted by "sandy du (Jira)" <ji...@apache.org> on 2021/09/30 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trip the string to the specified precision - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24414) Casting a decimal to a String doesn't do left zero padding - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24415) Casting a STRING to a TIME() results in loss of fractional seconds - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24416) Casting a TIMESTAMP_LTZ to STRING doesn't include timezone id - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24417) Add Flink 1.14 MigrationVersion - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/09/30 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24418) Support cast of RAW() to BINARY/VARBINARY/BYTES - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24419) Casting to a bounded BINARY/VARBANIRY doesn't trim to the specified precision - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24420) Casting to a "narrower" type doesn't throw exception but follows Java overflow - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24421) Casting from a string to a DATE and TIME allows incomplete strings - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24422) When creating a TIMESTAMP_LTZ only allow Instant - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24423) Cast from TIME to TIMESTAMP currently uses Epoch Date - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24424) CAST from invalid CHAR/VARCHAR/STRING to TIMESTAMP_LTZ throws NPE - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24425) Add support for casting from a single type to the corresponding array - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24426) Add support for cast from a string to an INTERVAL - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24427) Hide Scala in flink-table-planner from API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/09/30 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24428) Fix casting between interval types - posted by "Marios Trivyzas (Jira)" <ji...@apache.org> on 2021/09/30 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24429) Port FileSystemTableSink to new Unified Sink API (FLIP-143) - posted by "Alexander Preuss (Jira)" <ji...@apache.org> on 2021/09/30 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24430) Clean up log pollution - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/09/30 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2021/09/30 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method - posted by "Victor Xu (Jira)" <ji...@apache.org> on 2021/09/30 21:10:00 UTC, 0 replies.