You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-22541) add json format filter params - posted by "sandy du (Jira)" <ji...@apache.org> on 2021/05/01 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22542) npm update automatic - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2021/05/01 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22543) layout of exception history tab isn't very usable with Flink SQL - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/05/01 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22544) Add the missing documentation about the command line options for PyFlink - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/05/01 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/03 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22546) testKafkaSourceSinkWithKeyAndFullValue failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/03 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/03 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/03 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22549) Flink HA with Zk in kubernetes standalone mode deployment is not working - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/05/03 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22550) Flink-docker dev-master works against 1.11-SNAPSHOT - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/05/03 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22551) checkpoints: strange behaviour - posted by "buom (Jira)" <ji...@apache.org> on 2021/05/03 12:00:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.13.0 released - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/05/03 13:38:42 UTC, 8 replies.
- [jira] [Created] (FLINK-22552) Rebase StateFun on Flink 1.13 - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/05/03 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22553) Improve error reporting on TM connection failures - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/05/03 15:16:00 UTC, 0 replies.
- Flink(1.12.2/scala 2.11) HA with Zk in kubernetes standalone mode deployment is not working - posted by "bhagi@R" <bh...@gmail.com> on 2021/05/03 15:21:16 UTC, 1 replies.
- [jira] [Created] (FLINK-22554) Support Kafka Topic Patterns in Kafka Ingress - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/05/03 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22555) LGPL-2.1 files in flink-python jars - posted by "Henri Yandell (Jira)" <ji...@apache.org> on 2021/05/03 20:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22556) Extend license checker to scan for traces of (L)GPL licensed code - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/05/04 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22557) Japicmp fails on 1.12 branch - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/04 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22558) testcontainers fail to start ResourceReaper - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/04 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/04 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22560) Filter maven metadata from all jars - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/05/04 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22561) Restore checkpoint from another cluster - posted by "zhang haoyan (Jira)" <ji...@apache.org> on 2021/05/04 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/05/04 10:26:00 UTC, 0 replies.
- Presence of Jars in Flink reg security - posted by Prasanna kumar <pr...@gmail.com> on 2021/05/04 13:00:08 UTC, 2 replies.
- Can we use ZK as HA for flink JM cluster(deployed in k8s standalone session mode) - posted by "bhagi@R" <bh...@gmail.com> on 2021/05/04 13:08:25 UTC, 1 replies.
- Escape # character in containerized.master.env - posted by Lukáš Drbal <lu...@gmail.com> on 2021/05/04 13:08:27 UTC, 2 replies.
- Re: [DISCUSS] Using timeouts in JUnit tests - posted by Piotr Nowojski <pn...@apache.org> on 2021/05/04 15:24:50 UTC, 2 replies.
- Re: [ANNOUNCE] Apache Flink 1.12.3 released - posted by Piotr Nowojski <pn...@apache.org> on 2021/05/04 15:26:20 UTC, 0 replies.
- Re: [DISCUSS] Add async backpressure support to FlinkKafkaProducer - posted by Piotr Nowojski <pi...@gmail.com> on 2021/05/04 15:51:38 UTC, 2 replies.
- [jira] [Created] (FLINK-22563) Add migration guide for new StateBackend interfaces - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/05/04 17:59:00 UTC, 0 replies.
- Flink SQL Cdc with schema changing - posted by Taher Koitawala <ta...@gmail.com> on 2021/05/05 05:33:58 UTC, 4 replies.
- [jira] [Created] (FLINK-22564) ITCASE_KUBECONFIG is not exported - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/05 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22565) Running Kerberized YARN application on Docker test (custom fs plugin) unstable - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/05 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22566) Running Kerberized YARN application on Docker test (default input) fails with no resources - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/05 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22567) OrcFsStreamingSinkITCase crashes JVM - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/05 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22568) RescalingITCase. testSavepointRescalingInPartitionedOperatorStateList fails with TimeoutException - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/05 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22569) Limit #tickets touched by Flink Jira Bot per run - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/05/05 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22570) Reduce #notifications of Flink Jira Bot by combining API requests - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/05/05 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22571) SavepointITCase.testSavepointForJobWithIteration fails with Timeout - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/05 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22572) JsonFsStreamSinkITCase.testPart fails running in a timeout - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/05 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22573) AsyncIO can timeout elements after completion - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/05/05 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/05/05 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22575) Offer a more recent flink-shaded-hadoop-2-uber - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/05 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22576) Jira bot does not set the status to Open if it unassigns people - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/05/05 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22577) KubernetesLeaderElectionAndRetrievalITCase is failing - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/05 16:01:00 UTC, 0 replies.
- Configmaps not deleted Kubernetes HA - posted by Enrique <en...@gmail.com> on 2021/05/05 16:27:06 UTC, 4 replies.
- Re: [DISCUSS] Backport FLIP-27 Kafka source connector fixes with API change to release-1.12. - posted by Thomas Weise <th...@apache.org> on 2021/05/05 17:20:28 UTC, 2 replies.
- [jira] [Created] (FLINK-22578) deployment configuration page miss content navigate menu - posted by "谢波 (Jira)" <ji...@apache.org> on 2021/05/06 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22579) The description content of Kubernetes config Incomplete display - posted by "dong (Jira)" <ji...@apache.org> on 2021/05/06 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22580) web404 - posted by "dong (Jira)" <ji...@apache.org> on 2021/05/06 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22581) Keyword 'CATALOG' is missing in sql client doc - posted by "YoungWoo Kim (Jira)" <ji...@apache.org> on 2021/05/06 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22582) Scrollbar "jumps" when clicking on tabs for Scala and Python - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/06 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22583) Flink UI is not showing completed jobs once JM Leader is deleted - posted by "Bhagi (Jira)" <ji...@apache.org> on 2021/05/06 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22584) Use protobuf-shaded in StateFun core. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/05/06 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/05/06 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22586) Improve precision derivation for decimal arithmetics - posted by "Shuo Cheng (Jira)" <ji...@apache.org> on 2021/05/06 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22587) Support aggregations in batch mode with DataStream API - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/05/06 12:21:00 UTC, 0 replies.
- Re: [Parquet support] - posted by Etienne Chauchot <ec...@apache.org> on 2021/05/06 12:23:04 UTC, 3 replies.
- [jira] [Created] (FLINK-22588) flink - posted by "forideal (Jira)" <ji...@apache.org> on 2021/05/07 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22589) There are quite a few Python classes doesn't appear in the Python docs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/05/07 07:37:00 UTC, 0 replies.
- How to comsume and send data with two different kerberos cetified kafka in one flink task? - posted by "1095193290@qq.com" <10...@qq.com> on 2021/05/07 08:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-22590) Add Scala implicit conversions for new API methods - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/07 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22591) add sub interface MapColumnVector for ColumnVector - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/05/07 10:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-22592) numBuffersInLocal is always zero when using unaligned checkpoints - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/05/07 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/05/07 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22594) Report oom killed pod in k8s resource manager - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/05/07 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/07 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22596) Active timeout is not triggered if there were no barriers - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/07 12:51:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.12.4 - posted by Arvid Heise <ar...@apache.org> on 2021/05/07 13:46:33 UTC, 4 replies.
- [jira] [Created] (FLINK-22597) JobMaster cannot be restarted - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/05/07 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22598) Examples use deprecated forms of writeAsText - posted by "Al-assad (Jira)" <ji...@apache.org> on 2021/05/08 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22599) Point to `client.timeout` in error messages where it is used for rpc timeout - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/05/08 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22600) TableSourceTable: extraDigests should be consistent with abilitySpecs - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/05/08 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/05/08 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2021/05/08 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22603) The digest can be produced by SourceAbilitySpec - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/05/08 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22604) NPE on bundle close when task failover after a failed task open - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/05/08 05:46:00 UTC, 0 replies.
- About the windowOperator and Watermark - posted by 曲洋 <qu...@126.com> on 2021/05/08 06:03:26 UTC, 1 replies.
- Re: Activate bloom filter in RocksDB State Backend via Flink configuration - posted by maver1ck <ma...@brynski.pl> on 2021/05/08 06:12:50 UTC, 0 replies.
- [jira] [Created] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked - posted by "Yik San Chan (Jira)" <ji...@apache.org> on 2021/05/08 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22606) Simplify the usage of SessionState - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/05/08 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor - posted by "Al-assad (Jira)" <ji...@apache.org> on 2021/05/08 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22608) Flink Kryo deserialize read wrong bytes - posted by "Si Chen (Jira)" <ji...@apache.org> on 2021/05/08 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22609) Generify AllVerticesIterator.java - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/05/09 00:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22610) The test-jar of flink-connector-kafka should include all test classes - posted by "LIU Xiao (Jira)" <ji...@apache.org> on 2021/05/09 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22611) add documentation about the semantics of event time for time window output - posted by "Zhenhao Li (Jira)" <ji...@apache.org> on 2021/05/09 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22612) Reconstruct coders in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/10 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/10 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22614) Provide build artifacts for YARN e2e tests - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/10 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22615) can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction - posted by "Zhenhao Li (Jira)" <ji...@apache.org> on 2021/05/10 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22616) flink1.13提交任务后,出现以下问题 - posted by "Leo (Jira)" <ji...@apache.org> on 2021/05/10 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22617) Add log when create bulk format - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2021/05/10 09:07:00 UTC, 0 replies.
- Re: Task Local Recovery with mountable disks in the cloud - posted by Till Rohrmann <tr...@apache.org> on 2021/05/10 09:26:04 UTC, 1 replies.
- [jira] [Created] (FLINK-22618) Fix incorrect free resource metrics of task managers - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/05/10 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22619) Drop usages of BatchTableEnvironment - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/10 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22620) Uncouple OrcTableSource from legacy planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/10 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/05/10 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22622) Drop BatchTableSource ParquetTableSource - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/10 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22623) Drop BatchTableSource HBaseTableSource - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/10 13:10:00 UTC, 0 replies.
- [VOTE] Release 1.12.4, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2021/05/10 21:34:28 UTC, 7 replies.
- [jira] [Created] (FLINK-22624) Default resource allocation strategy will allocate more pending task managers than demand - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/05/11 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22625) FileSinkMigrationITCase unstable - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/11 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/11 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22627) Remove SlotManagerImpl - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/05/11 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22628) Modify web page display problem - posted by "quyanghaoren (Jira)" <ji...@apache.org> on 2021/05/11 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22629) table api sql ask - posted by "Leo (Jira)" <ji...@apache.org> on 2021/05/11 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22630) Different com.squareup.okhttp3:okhttp dependency versions might lead to version conflicts with io.fabric8:kubernetes-server-mock - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/11 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22631) Metrics are incorrect when task finished - posted by "Li (Jira)" <ji...@apache.org> on 2021/05/11 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22632) CatalogFunctionImpl.isGeneric should use ContextClassLoader - posted by "Zhong Zhuang (Jira)" <ji...@apache.org> on 2021/05/11 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22633) Add a Harness example to flink-statefun-playground - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/05/11 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22634) tableEnvironment executeSql - posted by "Leo (Jira)" <ji...@apache.org> on 2021/05/11 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22635) Checkpoint history lost across parallelism changes - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/05/11 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22636) Group job specific ZooKeeper HA services under common jobs/ zNode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/05/11 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/11 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22638) Keep channels blocked on alignment timeout - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/11 16:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22639) ClassLoaderUtil cannot print classpath of FlinkUserCodeClassLoader - posted by "Adrian Zhong (Jira)" <ji...@apache.org> on 2021/05/12 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22640) DataGen SQL Connector does not support defining fields min/max option of decimal type field - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2021/05/12 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22641) flink 1.13.0 文档 Concepts 下的 Timely Stream Processing 目录下有关waterMark描述 - posted by "金翔 (Jira)" <ji...@apache.org> on 2021/05/12 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22642) UI issue with flame graph - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/05/12 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/05/12 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22644) Translate "Native Kubernetes" page into Chinese - posted by "Yuchen Cheng (Jira)" <ji...@apache.org> on 2021/05/12 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22645) "ALTER VIEW" DDL is not supported for Flink dialect - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/05/12 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22646) Accessing DeclarativeSlotManager metrics during unregister throws NPE - posted by "David Morávek (Jira)" <ji...@apache.org> on 2021/05/12 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22647) The time unit of state access latency on the Flink UI is incorrect - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2021/05/12 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22648) docker-entrypoint.sh categorically overwrites numberOfTaskSlots - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/05/12 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22649) Support StreamExecPythonCalc json serialization/deserialization - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/12 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22650) Support StreamExecPythonCorrelate json serialization/deserialization - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/12 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22651) Support StreamExecPythonGroupAggregate json serialization/deserialization - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/12 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22652) Support StreamExecPythonGroupWindowAggregate json serialization/deserialization - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/12 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22653) Support StreamExecPythonOverAggregate json serialization/deserialization - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/12 12:43:00 UTC, 0 replies.
- Status of a savepoint operation returns Completed but an error was thrown - posted by Diogo Santos <di...@gmail.com> on 2021/05/12 16:00:59 UTC, 1 replies.
- Beam Summit 2021 - Call for Proposals - posted by Mara Ruvalcaba <ma...@sg.com.mx> on 2021/05/13 00:49:17 UTC, 0 replies.
- [jira] [Created] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks - posted by "youxianq (Jira)" <ji...@apache.org> on 2021/05/13 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with -- - posted by "JasonLee (Jira)" <ji...@apache.org> on 2021/05/13 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22656) Fix spelling mistakes - posted by "LeeJiangchuan (Jira)" <ji...@apache.org> on 2021/05/13 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22657) HiveParserDDLSemanticAnalyzer can directly return operations - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/05/13 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22658) Remove Deprecated util class TableConnectorUtil - posted by "Xianghu Wang (Jira)" <ji...@apache.org> on 2021/05/13 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc - posted by "wangqinghuan (Jira)" <ji...@apache.org> on 2021/05/13 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22660) Incorrect flink documentation example - posted by "Tejas Budukh (Jira)" <ji...@apache.org> on 2021/05/13 20:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22661) HiveInputFormatPartitionReader can return invalid data - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/05/14 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/14 04:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown - posted by "Jinhong Liu (Jira)" <ji...@apache.org> on 2021/05/14 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22664) Task metrics are not properly unregistered during region failover - posted by "Guokuai Huang (Jira)" <ji...@apache.org> on 2021/05/14 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22665) Add a Flink BigQuery Connector - posted by "Jörn Kottmann (Jira)" <ji...@apache.org> on 2021/05/14 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22666) Add more test cases for brigding to Scala DataStream API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/14 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22667) Fix the wrong file system ln java doc and documentation - posted by "Yishuang Lu (Jira)" <ji...@apache.org> on 2021/05/14 20:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22668) FLIP-150: Introduce Hybrid Source - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/05/15 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22669) Support date format in a path when use filesytem as source - posted by "wangqinghuan (Jira)" <ji...@apache.org> on 2021/05/15 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22670) Initial HybridSource DataStream Implementation - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/05/16 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22671) xxx - posted by "王彬 (Jira)" <ji...@apache.org> on 2021/05/16 09:57:00 UTC, 0 replies.
- Help. Who can add permission in FLIP. - posted by wa...@sina.cn on 2021/05/17 01:30:27 UTC, 1 replies.
- [jira] [Created] (FLINK-22672) Some enhancements for pluggable shuffle service framework - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/05/17 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22674) Provide JobID when apply shuffle resource by ShuffleMaster - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/05/17 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22673) Add document about add jar related commands - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/05/17 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22675) Add an interface method ShuffleMaster#close - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/05/17 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22676) The partition tracker should support remote shuffle properly - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/05/17 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/05/17 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/05/17 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22679) code optimization:Transformation.equals - posted by "huzeming (Jira)" <ji...@apache.org> on 2021/05/17 07:30:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Nicholas Jiang <pr...@163.com> on 2021/05/17 08:03:18 UTC, 1 replies.
- [DISCUSS] Releasing Flink 1.13.1 - posted by Konstantin Knauf <kn...@apache.org> on 2021/05/17 08:03:26 UTC, 10 replies.
- [jira] [Created] (FLINK-22680) An IndexOutOfBoundsException is thrown out after apply WatermarkAssignerChangelogNormalizeTransposeRule - posted by "Andy (Jira)" <ji...@apache.org> on 2021/05/17 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22681) how can i get flink job status from prometheus(PrometheusPushGateway) - posted by "yuwei zhan (Jira)" <ji...@apache.org> on 2021/05/17 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22682) Checkpoint interval too large for higher DOP - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/05/17 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22683) The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/05/17 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22684) Add the ability to ignore in-flight data on recovery - posted by "Anton Kalashnikov (Jira)" <ji...@apache.org> on 2021/05/17 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22685) Write data to hive table in batch mode throws FileNotFoundException. - posted by "Moses (Jira)" <ji...@apache.org> on 2021/05/17 10:21:00 UTC, 0 replies.
- Helm chart for Flink - posted by Pedro Silva <pe...@gmail.com> on 2021/05/17 11:13:55 UTC, 2 replies.
- [jira] [Created] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/05/17 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22687) unified the org.apache.flink.runtime.jobmaster.slotpool.SlotPool and org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPool - posted by "lqjacklee (Jira)" <ji...@apache.org> on 2021/05/17 17:50:00 UTC, 0 replies.
- [DISCUSS] Watermark propagation with Sink API - posted by Eron Wright <ew...@streamnative.io.INVALID> on 2021/05/17 20:44:36 UTC, 13 replies.
- [jira] [Created] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0 - posted by "Gary Wu (Jira)" <ji...@apache.org> on 2021/05/18 01:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22689) Table API Documentation Row-Based Operations Example Fails - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2021/05/18 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22690) kerberos integration with flink,kerberos tokens will expire - posted by "kevinsun (Jira)" <ji...@apache.org> on 2021/05/18 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22691) On Aliyun ECS, docker deployed flink (1.13.0), which was scanned to Mirai DDOS Trojan - posted by "Magina.Shan (Jira)" <ji...@apache.org> on 2021/05/18 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22692) CheckpointStoreITCase.testRestartOnRecoveryFailure fails with RuntimeException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/05/18 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type - posted by "sadfdddd (Jira)" <ji...@apache.org> on 2021/05/18 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22694) Refactor TPCH end to end tests - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/05/18 09:44:00 UTC, 0 replies.
- The timeline of Flink support Reactive mode in Yarn - posted by Bing Jiang <ji...@gmail.com> on 2021/05/18 11:00:32 UTC, 1 replies.
- [jira] [Created] (FLINK-22695) Update Flink's Code Style and Quality Guide to match the Google Java Format style introduced - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/18 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22696) Enable Confluent Schema Registry Test on jdk 11 - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/05/18 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22697) Clean up examples to not use legacy planner anymore - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/18 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue - posted by "Austin Cawley-Edwards (Jira)" <ji...@apache.org> on 2021/05/18 20:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22699) Make ConstantArgumentCount public API - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/05/18 22:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22700) Propagate watermarks to Sink API - posted by "Eron Wright (Jira)" <ji...@apache.org> on 2021/05/18 22:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg - posted by "Jinliang Guo (Jira)" <ji...@apache.org> on 2021/05/18 22:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/19 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22703) SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/19 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22704) ZooKeeperHaServicesTest.testCleanupJobData failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/19 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22705) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/19 04:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22706) The NOTICE file of Flink repo should be updated - posted by "Fuyao Li (Jira)" <ji...@apache.org> on 2021/05/19 04:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22707) StatementSet support exectue(jobName) - posted by "silence (Jira)" <ji...@apache.org> on 2021/05/19 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22708) Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/19 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22709) Drop usages of EnvironmentSettings.useOldPlanner() - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/19 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22710) ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/19 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22711) NoClassDefFoundError when running Flink 1.11.1 in openJDK8u292-b10 - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/05/19 08:17:00 UTC, 0 replies.
- [DISCUSS] Component labels in PR/commit messages - posted by Arvid Heise <ar...@apache.org> on 2021/05/19 08:31:23 UTC, 4 replies.
- [jira] [Created] (FLINK-22712) Support accessing Row fields by attribute name in PyFlink Row-based Operation - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/05/19 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22713) Correct grammatical mistakes in 'Kafka' page of 'DataStream Connectors' - posted by "weizheng (Jira)" <ji...@apache.org> on 2021/05/19 09:29:00 UTC, 0 replies.
- [ANNOUNCE] Jira Bot live again. - posted by Konstantin Knauf <kn...@apache.org> on 2021/05/19 11:22:59 UTC, 0 replies.
- Re: [DISCUSS] Feedback Collection Jira Bot - posted by Konstantin Knauf <ko...@ververica.com> on 2021/05/19 11:30:10 UTC, 5 replies.
- [jira] [Created] (FLINK-22714) Simplify `StreamPhysicalWindowTableFunction` to `StreamPhysicalWindowAssignerFunction` which is only a simple window assigner table function if successor node with `WindowAttachedWindowingStrategy` in planner - posted by "Andy (Jira)" <ji...@apache.org> on 2021/05/19 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22715) Implement streaming window assigner tablefunction operator - posted by "Andy (Jira)" <ji...@apache.org> on 2021/05/19 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22716) Add metrics watermarkAlignedChannelNum - posted by "tartarus (Jira)" <ji...@apache.org> on 2021/05/19 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22717) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fails with Adaptive Scheduler - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/05/19 17:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22718) java.lang.Exception: Could not create actor system - posted by "HYUNHOO KWON (Jira)" <ji...@apache.org> on 2021/05/20 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/05/20 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22720) UpsertKafkaTableITCase.testAggregate fail due to ConcurrentModificationException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/20 04:44:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.12.4, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2021/05/20 08:07:32 UTC, 0 replies.
- [jira] [Created] (FLINK-22721) Breaking HighAvailabilityServices interface by adding new method - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/05/20 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22722) Add Documentation for Kafka New Source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/05/20 10:00:20 UTC, 0 replies.
- [jira] [Created] (FLINK-22723) multi-field-dynamic index is not supported by elasticsearch connector - posted by "Xiang Yang (Jira)" <ji...@apache.org> on 2021/05/20 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22724) NoSuchMethodError PackagedProgramUtils.isPython (Application mode in native kubernetes) - posted by "HYUNHOO KWON (Jira)" <ji...@apache.org> on 2021/05/20 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22725) SlotManagers should unregister metrics at the start of suspend() - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/05/20 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22726) Hive GROUPING__ID returns different value in older versions - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/05/20 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22727) SerializableAvroSchema cannot handle large schema - posted by "Serge Travin (Jira)" <ji...@apache.org> on 2021/05/20 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22728) a problem of loading udf - posted by "JYXL (Jira)" <ji...@apache.org> on 2021/05/20 13:25:00 UTC, 0 replies.
- Issue with using siddhi extension function with flink - posted by Dipanjan Mazumder <ja...@yahoo.com.INVALID> on 2021/05/20 13:42:43 UTC, 1 replies.
- [jira] [Created] (FLINK-22729) Truncated Messages in Python workers - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/05/20 14:44:00 UTC, 0 replies.
- Re: [Statefun] Truncated Messages in Python workers - posted by Stephan Ewen <se...@apache.org> on 2021/05/20 14:48:59 UTC, 2 replies.
- [jira] [Created] (FLINK-22730) Lookup join condition with CURRENT_DATE fails to filter records - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/05/20 16:00:09 UTC, 0 replies.
- [jira] [Created] (FLINK-22731) Environment variables are not passed to TM (YARN) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/05/20 20:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22732) Restrict ALTER TABLE from setting empty table options - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2021/05/21 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22733) Type mismatch thrown in KeyedStream.union in Python DataStream API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/05/21 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22734) ExtractionUtils#getClassReader causes "open too many files" error - posted by "zhiping lin (Jira)" <ji...@apache.org> on 2021/05/21 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/21 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22736) Flink-SQL-Client HiveModuleFactory has been compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0 - posted by "张建 (Jira)" <ji...@apache.org> on 2021/05/21 07:08:00 UTC, 0 replies.
- upsert kafka sink why not send all data that contain update_before,delete - posted by Jocean shi <jo...@gmail.com> on 2021/05/21 07:50:43 UTC, 0 replies.
- [jira] [Created] (FLINK-22737) Add support for CURRENT_WATERMARK to SQL - posted by "David Anderson (Jira)" <ji...@apache.org> on 2021/05/21 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22738) org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on downloading docker image - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/21 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/21 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22740) Drop legacy planner from docs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/21 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22741) Hide Flink complexity from Stateful Functions - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/05/21 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22742) Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/05/21 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22743) Adding offsets for TUMBLE* functions for more flexible window start and end time. - posted by "fhan (Jira)" <ji...@apache.org> on 2021/05/21 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22744) Simplify TableEnvironment.create() - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/21 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22745) MesosWorkerStore is started with an illegal namespace - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/05/21 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22746) Links to connectors in docs are broken - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/05/21 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22747) Update commons-io to 2.8 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/21 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22748) Allow dynamic target topic selection in Kafka sinks - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/21 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22749) Apply a robust default State Backend Configuration - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/05/21 15:01:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.4 released - posted by Arvid Heise <ar...@apache.org> on 2021/05/21 15:27:02 UTC, 0 replies.
- [jira] [Created] (FLINK-22750) Simplify Unit Testing of Remote Functions - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/05/21 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22751) Reduce JVM Metaspace memory for StateFun - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/05/21 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22752) Add robust default state configuration to StateFun - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/05/21 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22753) Activate log-based Checkpoints for StateFun - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2021/05/21 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22754) Finished job not always archived properly - posted by "Mathieu DESPRIEE (Jira)" <ji...@apache.org> on 2021/05/22 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22755) SequenceStreamingFileSinkITCase.testWriteSequenceFile fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/22 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22756) DispatcherTest.testJobStatusIsShownDuringTermination fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/22 15:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22757) Update GCS documentation - posted by "Ankush Khanna (Jira)" <ji...@apache.org> on 2021/05/23 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader - posted by "ighack (Jira)" <ji...@apache.org> on 2021/05/24 00:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22759) Correct the applicability of RocksDB related options as per operator - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/05/24 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22760) HiveParser::setCurrentTimestamp fails with hive-3.1.2 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/05/24 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22761) Cannot remove POJO fields - posted by "Ygor Allan de Fraga (Jira)" <ji...@apache.org> on 2021/05/24 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22762) cannot use set table.sql-dialect=hive; - posted by "xueluo (Jira)" <ji...@apache.org> on 2021/05/25 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registery - posted by "Samuel Fiddis (Jira)" <ji...@apache.org> on 2021/05/25 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22764) Disable Values Source node in streaming plan optimization - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/05/25 06:47:00 UTC, 0 replies.
- Re: [DISCUSS] Moving to JUnit5 - posted by Qingsheng Ren <re...@gmail.com> on 2021/05/25 06:52:42 UTC, 2 replies.
- [jira] [Created] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/05/25 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/05/25 08:00:11 UTC, 0 replies.
- [jira] [Created] (FLINK-22767) Optimize the initialization of ExecutionSlotSharingGroupBuilder - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/05/25 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22768) ShuffleMaster supports to promote partitions - posted by "Jin Xing (Jira)" <ji...@apache.org> on 2021/05/25 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22769) yarnship do not support symbolic directory - posted by "Adrian Zhong (Jira)" <ji...@apache.org> on 2021/05/25 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22770) Expose SET/RESET from the parser - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/05/25 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22771) Add TestContext to Java SDK - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/05/25 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22772) Add TestContext to Python SDK - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/05/25 11:00:11 UTC, 0 replies.
- [jira] [Created] (FLINK-22773) Optimize the construction of pipelined regions - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/05/25 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22774) Package flink-sql-connector-kinesis with newer Guava version - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/25 12:53:00 UTC, 0 replies.
- [VOTE] Release 1.13.1, release candidate #1 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/05/25 13:32:46 UTC, 11 replies.
- [jira] [Created] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/26 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22776) Delete casting to byte[] - posted by "Ada Wong (Jira)" <ji...@apache.org> on 2021/05/26 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22777) Recover lost parts of Datastream API Try Flink example - posted by "Stefan Gloutnikov (Jira)" <ji...@apache.org> on 2021/05/26 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22778) Upgrade to JUnit 4.13 - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/05/26 03:28:00 UTC, 0 replies.
- The partition tracker should support remote shuffle properly - posted by XING JIN <ji...@gmail.com> on 2021/05/26 03:52:16 UTC, 0 replies.
- [jira] [Created] (FLINK-22779) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/05/26 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22780) Performance regression on 25.05 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/26 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/05/26 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22782) Remove legacy planner from Chinese docs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/26 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22783) Flink Jira Bot effectively does not apply all rules anymore due to throtteling - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2021/05/26 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22784) Jepsen tests broken due to change in zNode layout - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/05/26 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22785) Kafka transaction failing when there are two producers - posted by "Ygor Allan de Fraga (Jira)" <ji...@apache.org> on 2021/05/26 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22786) sql-client can not create .flink-sql-history file - posted by "Zhiwen Sun (Jira)" <ji...@apache.org> on 2021/05/27 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22787) Fix parse error when input statement has inline comments - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/05/27 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22788) Code of equals method grows beyond 64 KB - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2021/05/27 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22789) flink1.10 Support Hive version 2.3.7 - posted by "houshitao (Jira)" <ji...@apache.org> on 2021/05/27 12:48:00 UTC, 0 replies.
- [DISCUSS] SQL CTAS Syntax - posted by Danny Chan <da...@apache.org> on 2021/05/27 13:14:32 UTC, 4 replies.
- [jira] [Created] (FLINK-22790) HybridSource end-to-end test - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/05/27 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22791) HybridSource user documentation - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/05/27 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22792) Limit size of already processed files in File Source SplitEnumerator - posted by "Tianxin Zhao (Jira)" <ji...@apache.org> on 2021/05/28 01:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22793) HybridSource Table Implementation - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2021/05/28 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22794) flink-sql-parser and flink-sql-hive-parser - posted by "WeiNan Zhao (Jira)" <ji...@apache.org> on 2021/05/28 04:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22795) flink sql 1.13 通过 -f 执行位于hdfs上的SQL文件失败。 - posted by "manguozhi (Jira)" <ji...@apache.org> on 2021/05/28 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22796) Update mem_setup_tm documentation - posted by "Wei-Che Wei (Jira)" <ji...@apache.org> on 2021/05/28 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22797) Improve incremental checkpoints documentation - posted by "Nicolaus Weidner (Jira)" <ji...@apache.org> on 2021/05/28 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22798) Exception handling of transactional producer - posted by "Jin Xu (Jira)" <ji...@apache.org> on 2021/05/28 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22799) Missing documentation: No state backwards compatibility is not support for Flink SQL - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/05/28 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22800) Default EXACTLY_ONCE consumer (FLINK-6988) has not set isolation.level - posted by "Jin Xu (Jira)" <ji...@apache.org> on 2021/05/28 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22801) Support for property file injection in module.yaml - posted by "Ejaskhan (Jira)" <ji...@apache.org> on 2021/05/28 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22802) Bump Fabric8 Kubernetes Client to - posted by "Enrique Lacal (Jira)" <ji...@apache.org> on 2021/05/28 15:48:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.13.1, release candidate #1 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/05/28 16:47:01 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.13.1 released - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/05/28 16:49:01 UTC, 5 replies.
- [jira] [Created] (FLINK-22803) Running multiple CEP patterns - posted by "Tejas Budukh (Jira)" <ji...@apache.org> on 2021/05/28 18:25:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-91 - Support SQL Client Gateway - posted by Sonam Mandal <so...@gmail.com> on 2021/05/28 22:38:43 UTC, 0 replies.
- [jira] [Created] (FLINK-22804) "CREATE VIEW" statement loses computed columns, metadata columns, watermark and table constraint - posted by "tim yu (Jira)" <ji...@apache.org> on 2021/05/29 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22805) Dynamic configuration of Flink checkpoint interval - posted by "Fu Kai (Jira)" <ji...@apache.org> on 2021/05/31 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2021/05/31 03:25:00 UTC, 0 replies.
- (无主题) - posted by 陈海剑 <13...@163.com> on 2021/05/31 04:39:46 UTC, 0 replies.
- 回复:(无主题) - posted by Tang Jinxin <xi...@gmail.com> on 2021/05/31 04:49:24 UTC, 0 replies.
- [DISCUSS][Statebackend][Runtime] Changelog Statebackend Configuration Proposal - posted by Yuan Mei <yu...@gmail.com> on 2021/05/31 06:39:16 UTC, 1 replies.
- [jira] [Created] (FLINK-22807) AttributeError: 'Builder' object has no attribute 'is_streaming_mode' - posted by "Yao Li (Jira)" <ji...@apache.org> on 2021/05/31 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22808) Log metadata - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/05/31 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22809) Improve the exception message when a KafkaIngress receives a NULL key. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/05/31 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22810) Drop usages of flink-table-planner in Elasticsearch modules - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/31 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22811) Drop usages of legacy planner in Avro module - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/31 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22812) Fix hive issues in sql-connector-hive jars - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/05/31 13:07:00 UTC, 0 replies.
- [DISCUSS] Dashboard/HistoryServer authentication - posted by Márton Balassi <mb...@apache.org> on 2021/05/31 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22813) Drop usages of legacy planner in Hive module - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/05/31 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22814) New sources are not defining/exposing checkpointStartDelayNanos metric - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/05/31 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/05/31 15:42:00 UTC, 0 replies.
- How to use or configure flink checkpointing with siddhi internal state - posted by Dipanjan Mazumder <ja...@yahoo.com.INVALID> on 2021/05/31 17:27:14 UTC, 0 replies.