dev  

Messages by Thread

• [jira] [Created] (FLINK-18126) Correct the exception handling of the Python CompletableFuture Dian Fu (Jira)
• [jira] [Created] (FLINK-18125) Skip CI execution on documentation pull requests Robert Metzger (Jira)
• [jira] [Created] (FLINK-18124) Add documentation for new FLIP-27 source interface Stephan Ewen (Jira)
• [jira] [Created] (FLINK-18123) KubernetesClusterDescriptorTest.testDeployApplicationCluster:135->checkUpdatedConfigAndResourceSetting:194 expected:<my-flink-cluster1.test> but was:<null> Robert Metzger (Jira)
• [jira] [Created] (FLINK-18122) Kubernetes test fails with "error: timed out waiting for the condition on jobs/flink-job-cluster" Robert Metzger (Jira)
• [jira] [Created] (FLINK-18121) Support creating Docker image from local Flink distribution Till Rohrmann (Jira)
• [jira] [Created] (FLINK-18120) Don't expand documentation sections by default Aljoscha Krettek (Jira)
• [jira] [Created] (FLINK-18119) Fix unlimitedly growing state for time range bounded over aggregate Hyeonseop Lee (Jira)
• [jira] [Created] (FLINK-18118) Some SQL Jobs with two input operators are loosing data with unaligned checkpoints Jark Wu (Jira)
• [jira] [Created] (FLINK-18117) "Kerberized YARN per-job on Docker test" "Could not start hadoop cluster." Robert Metzger (Jira)
• [jira] [Created] (FLINK-18116) E2E performance test Aihua Li (Jira)
• [jira] [Created] (FLINK-18115) StabilityTest Aihua Li (Jira)
• [jira] [Created] (FLINK-18114) Expose more details in logs for debugging bulk slot allocation failures Zhu Zhu (Jira)
• [jira] [Created] (FLINK-18113) Single Task Failure Recovery API Abstraction Yuan Mei (Jira)
• [jira] [Created] (FLINK-18112) Single Task Failure Recovery Prototype Yuan Mei (Jira)
• [jira] [Created] (FLINK-18111) LATERAL query failed when use create view syntax YufeiLiu (Jira)
• [jira] [Created] (FLINK-18110) Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery Yun Gao (Jira)
• [jira] [Created] (FLINK-18109) Manually test external resource framework with GPUDriver Yangze Guo (Jira)
• [jira] [Created] (FLINK-18108) Wheel package consistency checks sunjincheng (Jira)
• [jira] [Created] (FLINK-18107) Performance tests for PyFlink UDFs sunjincheng (Jira)
• [jira] [Created] (FLINK-18106) Tests Python UDTF support sunjincheng (Jira)
• [jira] [Created] (FLINK-18105) Test submitting Java SQL job with Python UDF sunjincheng (Jira)
• [jira] [Created] (FLINK-18104) Test pyflink on windows sunjincheng (Jira)
• [jira] [Created] (FLINK-18103) Test Pandas DataFrame and Flink Table conversion sunjincheng (Jira)
• [jira] [Created] (FLINK-18102) Test Pandas UDF support sunjincheng (Jira)
• [jira] [Created] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator sunjincheng (Jira)
• [jira] [Created] (FLINK-18100) Test different user-defined metrics for Python UDF sunjincheng (Jira)
• [jira] [Created] (FLINK-18099) Release guard for PyFlink sunjincheng (Jira)
• [jira] [Created] (FLINK-18098) Legacy Task application are missing app.run.id for both batch & stream mode Sanil Jain (Jira)
• [jira] [Created] (FLINK-18097) History server doesn't clean all job json files Milan Nikl (Jira)
• [jira] [Created] (FLINK-18096) Generated avro formats should support user specified name and namespace Seth Wiesman (Jira)
• [jira] [Created] (FLINK-18095) Custom Execution Environment for TableEnvironment Satyam Shekhar (Jira)
• [jira] [Created] (FLINK-18094) Index offset not consistent in CheckpointedInputGate for unaligned checkpoints. Arvid Heise (Jira)
• [jira] [Created] (FLINK-18093) E2E tests manually for Elasticsearch Sink Jark Wu (Jira)
• [jira] [Created] (FLINK-18092) E2E tests manually for HBase Jark Wu (Jira)
• [DISCUSS] Leverage Maven Wrapper tison
• [jira] [Created] (FLINK-18091) Test Relocatable Savepoints Stephan Ewen (Jira)
• [jira] [Created] (FLINK-18090) Support RowKind in Row.toString Timo Walther (Jira)
• [jira] [Created] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline Yun Gao (Jira)
• [jira] [Created] (FLINK-18088) Umbrella for features testing in release-1.11.0 Zhijiang (Jira)
• [jira] [Created] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work Yang Wang (Jira)
• [jira] [Created] (FLINK-18086) Migrate SQLClientKafkaITCase to use DDL and new options to create tables Jark Wu (Jira)
• [jira] [Created] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s Yang Wang (Jira)
• [jira] [Created] (FLINK-18084) Create documentation for the Application Mode Kostas Kloudas (Jira)
• [jira] [Created] (FLINK-18083) DDL TIMESTAMP(9) defined on HBase table lost nano seconds Leonard Xu (Jira)
• [jira] [Created] (FLINK-18082) UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop Robert Metzger (Jira)
• [jira] [Created] (FLINK-18081) Fix broken links in "Kerberos Authentication Setup and Configuration" doc Yangze Guo (Jira)
• [jira] [Created] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese Yangze Guo (Jira)
• [jira] [Created] (FLINK-18079) KafkaShuffle Manual Tests Yuan Mei (Jira)
• [jira] [Created] (FLINK-18078) E2E tests manually for Hive streaming dim join Jingsong Lee (Jira)
• [jira] [Created] (FLINK-18077) E2E tests manually for Hive streaming source Jingsong Lee (Jira)
• [jira] [Created] (FLINK-18076) Sql client uses wrong class loader when parsing queries Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema Seth Wiesman (Jira)
• [jira] [Created] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out Yun Tang (Jira)
• [jira] [Created] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable Seth Wiesman (Jira)
• [jira] [Created] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData Leonard Xu (Jira)
• [jira] [Created] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI Robert Metzger (Jira)
• [jira] [Created] (FLINK-18070) Time attribute been materialized after sub graph optimize YufeiLiu (Jira)
• [jira] [Created] (FLINK-18069) Scaladocs not building since inner Java interfaces cannot be recognized Tzu-Li (Gordon) Tai (Jira)
• [jira] [Created] (FLINK-18068) Job stuck after IllegalStateException in scheduling Jiayi Liao (Jira)
• [jira] [Created] (FLINK-18067) Invalid default value for yarnMinAllocationMB in YarnClusterDescriptor Jiayi Liao (Jira)
• Questions around MemoryStateBackend size limits vishalovercome
  • Re: Questions around MemoryStateBackend size limits Yun Tang
• [jira] [Created] (FLINK-18066) Add documentation for how to develop a new table source/sink Timo Walther (Jira)
• [jira] [Created] (FLINK-18065) Add documentation for new scalar/table functions Timo Walther (Jira)
• [jira] [Created] (FLINK-18064) Update documentation taking unaligned checkpoints into the account Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-18063) Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner#processEndOfPartition Zhijiang (Jira)
• [jira] [Created] (FLINK-18062) prometheus metrics reporter support custom labels Luke Sun (Jira)
• [jira] [Created] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak godfrey he (Jira)
• [Discussion] flink elasticsearch connector supports Jacky Lau
  • Re: [Discussion] flink elasticsearch connector supports Robert Metzger
  • Re: [Discussion] flink elasticsearch connector supports Jacky Lau
  • Re: [Discussion] flink elasticsearch connector supports Yangze Guo
• [jira] [Created] (FLINK-18060) Add notice for heap-based state backend of state access reference problem Yun Tang (Jira)
• [jira] [Created] (FLINK-18059) Can not execute create/drop catalog statement in sql client godfrey he (Jira)
• [jira] [Created] (FLINK-18058) MesosResourceManagerTest.testWorkerStarted:656 » NullPointer Robert Metzger (Jira)
• [jira] [Created] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2> Robert Metzger (Jira)
• [jira] [Created] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists. Yun Gao (Jira)
• [jira] [Created] (FLINK-18055) Catalog does not exist in SQL Client godfrey he (Jira)
• [jira] [Created] (FLINK-18054) Environment should provide API to resume from savepoint Sergii Mikhtoniuk (Jira)
• [jira] [Created] (FLINK-18053) Savepoints do not preserve watermarks Sergii Mikhtoniuk (Jira)
• [jira] [Created] (FLINK-18052) Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE Robert Metzger (Jira)
• [jira] [Created] (FLINK-18051) Fail Maven setup on AZP if download fails Robert Metzger (Jira)
• [jira] [Created] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch Zhijiang (Jira)
• [jira] [Created] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema Zheng Hu (Jira)
• [ANNOUNCE] Weekly Community Update 2020/22 Konstantin Knauf
• [jira] [Created] (FLINK-18048) "--host" option could not take effect for standalone application cluster Yang Wang (Jira)
• I want to contribute to Apache Flink 以梦为马
  • Re: I want to contribute to Apache Flink Yangze Guo
• [jira] [Created] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect pengnengsong (Jira)
• [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Tzu-Li (Gordon) Tai
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Igal Shilman
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Congxian Qiu
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Hequn Cheng
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Tzu-Li (Gordon) Tai
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Tzu-Li (Gordon) Tai
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Hequn Cheng
  • Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 Tzu-Li (Gordon) Tai
• [jira] [Created] (FLINK-18046) Decimal column stats not supported for Hive table Rui Li (Jira)
• [jira] [Created] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR Jira
• [jira] [Created] (FLINK-18044) Add the subtask index information to the SourceReaderContext. Jiangjie Qin (Jira)
• [jira] [Created] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese Yubin Li (Jira)
• [ANNOUNCE] Apache Flink-shaded 11.0 released Chesnay Schepler
  • Re: [ANNOUNCE] Apache Flink-shaded 11.0 released Till Rohrmann
  • Re: [ANNOUNCE] Apache Flink-shaded 11.0 released Yu Li
• [jira] [Created] (FLINK-18042) Bump flink-shaded version to 11.0 Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-18041) Make a little bit improvement for DEFAULT_FLUSH_MAX_SIZE and DEFAULT_FLUSH_INTERVAL_MILLS of AbstractJdbcOutputFormat sunjincheng (Jira)
• [jira] [Created] (FLINK-18040) Remove the wrong punctuation in dev/training/index.md Yichao Yang (Jira)
• [jira] [Created] (FLINK-18039) Change SourceCoordinator to handle resetToCheckpoint() call after started. Jiangjie Qin (Jira)
• [jira] [Created] (FLINK-18038) StateBackendLoader logs application-defined state before it is fully configured Steve Bairos (Jira)
• [jira] [Created] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status' ZhuShang (Jira)
• [jira] [Created] (FLINK-18036) Chinese documentation build is broken Aljoscha Krettek (Jira)
• [jira] [Created] (FLINK-18035) Executors#newCachedThreadPool could not work as expected Yang Wang (Jira)
• [jira] [Created] (FLINK-18034) Introduce PreferredLocationsRetriever Zhu Zhu (Jira)
• [jira] [Created] (FLINK-18033) Improve e2e test execution time Chesnay Schepler (Jira)
• Fwd: pyflink Table Api连接 外部系统问题 Xingbo Huang
• [jira] [Created] (FLINK-18032) Remove outdated sections in migration guide Aljoscha Krettek (Jira)
• [NOTICE] Release guide updated for updating japicmp configuration Chesnay Schepler
  • Re: [NOTICE] Release guide updated for updating japicmp configuration Piotr Nowojski
  • Re: [NOTICE] Release guide updated for updating japicmp configuration Zhijiang
  • Re: [NOTICE] Release guide updated for updating japicmp configuration Yu Li
  • Re: [NOTICE] Release guide updated for updating japicmp configuration Till Rohrmann
• [jira] [Created] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo Hequn Cheng (Jira)
• [jira] [Created] (FLINK-18030) Hive UDF doesn't accept empty string literal parameter Rui Li (Jira)
• [jira] [Created] (FLINK-18029) Add more ITCases for Kafka with new formats Danny Chen (Jira)
• [jira] [Created] (FLINK-18027) ROW value constructor cannot deal with complex expressions Benchao Li (Jira)
• [jira] [Created] (FLINK-18028) E2E tests manually for Kafka 2 all kinds of other connectors Danny Chen (Jira)
• [jira] [Created] (FLINK-18026) E2E tests manually for new SQL connectors and formats Danny Chen (Jira)
• [jira] [Created] (FLINK-18025) E2E tests manually for Hive integrate streaming Danny Chen (Jira)
• [jira] [Created] (FLINK-18024) E2E tests manually for new Hive dependency jars Danny Chen (Jira)
• [jira] [Created] (FLINK-18023) E2E tests manually for new filesystem connector Danny Chen (Jira)
• [jira] [Created] (FLINK-18022) Add e2e test for new streaming file sink Danny Chen (Jira)
• Subscription mail kartheek annamaneni
  • 回复：Subscription mail 夏帅
  • Re: Subscription mail tison
  • Re: Subscription mail Marta Paes Moreira
  • Re: Subscription mail tison
  • Re: Subscription mail Marta Paes Moreira
• [jira] [Created] (FLINK-18021) Complement tests for 1.11 SQL Danny Chen (Jira)
• [jira] [Created] (FLINK-18020) SQLClientKafkaITCase.testKafka failed on Travis Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-18019) The configuration specified in TableConfig may not take effect Dian Fu (Jira)
• [jira] [Created] (FLINK-18018) Bundle GPU plugin in "plugins/" directory Yangze Guo (Jira)
• [jira] [Created] (FLINK-18017) improve Kafka connector to handle record deserialization exception and report related metrics Yu Yang (Jira)
• [jira] [Created] (FLINK-18016) Document Unix Socket Remote Functions Seth Wiesman (Jira)
• [jira] [Created] (FLINK-18015) Document State TTL Seth Wiesman (Jira)
• [jira] [Created] (FLINK-18014) JSONDeserializationSchema: removed in Flink 1.8, but still in the docs David Anderson (Jira)
• [jira] [Created] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module Sivaprasanna Sethuraman (Jira)
• [jira] [Created] (FLINK-18012) Deactivate slot timeout if TaskSlotTable.tryMarkSlotActive is called Till Rohrmann (Jira)
• [jira] [Created] (FLINK-18011) Make WatermarkStrategy/WatermarkStrategies more ergonomic Aljoscha Krettek (Jira)
• [jira] [Created] (FLINK-18010) Add more logging to HistoryServer Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-18009) Select an invalid column crashes the SQL CLI Rui Li (Jira)
• [jira] [Created] (FLINK-18008) HistoryServer does not log environment information on startup Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-18007) Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese Yubin Li (Jira)
• [jira] [Created] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format Shengkai Fang (Jira)
• [jira] [Created] (FLINK-18005) Implement type inference for CAST Timo Walther (Jira)
• [ANNOUNCE] Stateful Functions 2.1.0 feature freeze Tzu-Li (Gordon) Tai
  • Re: [ANNOUNCE] Stateful Functions 2.1.0 feature freeze Seth Wiesman
  • Re: [ANNOUNCE] Stateful Functions 2.1.0 feature freeze Tzu-Li (Gordon) Tai
• [jira] [Created] (FLINK-18004) Update checkpoint UI related pictures in documentation Yun Tang (Jira)
• [jira] [Created] (FLINK-18003) Table hints support multi Options hailong wang (Jira)
• [jira] [Created] (FLINK-18002) Support forcing varchar type in Json format Benchao Li (Jira)
• [jira] [Created] (FLINK-18001) Add a new test base for evaluating expressions Timo Walther (Jira)
• [jira] [Created] (FLINK-18000) Flink-job-manger Get a X509 error, when I try to delpoy flink on kubelet 1.18.2 Max (Jira)
• [jira] [Created] (FLINK-17999) Translate "Query Configuration" page of "Streaming Concepts" into Chinese Yubin Li (Jira)
• [jira] [Created] (FLINK-17998) Support limiting job history size Daniel Laszlo Magyar (Jira)
• [jira] [Created] (FLINK-17997) Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact Tzu-Li (Gordon) Tai (Jira)
• [jira] [Created] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method godfrey he (Jira)
• [jira] [Created] (FLINK-17995) Add a new overview page for the new SQL connectors Jark Wu (Jira)
• [jira] [Created] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived Zhijiang (Jira)
• [jira] [Created] (FLINK-17993) read schema from orc file dingli123 (Jira)
• [jira] [Created] (FLINK-17992) Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler Zhijiang (Jira)
• [jira] [Created] (FLINK-17991) Add JdbcAsyncLookupFunction Jira
• [jira] [Created] (FLINK-17990) ArrowSourceFunctionTestBase.testParallelProcessing is instable Dian Fu (Jira)
• [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Israel Ekpo
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Israel Ekpo
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Guowei Ma
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Israel Ekpo
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Till Rohrmann
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Israel Ekpo
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Till Rohrmann
  • Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter Israel Ekpo
• [jira] [Created] (FLINK-17989) java.lang.NoClassDefFoundError: org/apache/flink/fs/azure/common/hadoop/HadoopRecoverableWriter Israel Ekpo (Jira)
• [jira] [Created] (FLINK-17988) Checkpointing slows down after reaching state.checkpoints.num-retained Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field Robert Metzger (Jira)
• [jira] [Created] (FLINK-17986) Erroneous check in FsCheckpointStateOutputStream#write(int) Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-17985) Consolidate Connector Documentation Seth Wiesman (Jira)
• [jira] [Created] (FLINK-17984) Update Flink sidebar nav Seth Wiesman (Jira)
• [jira] [Created] (FLINK-17983) Add new Flink docs homepage (style) Seth Wiesman (Jira)
• [jira] [Created] (FLINK-17982) Finish Flink concepts docs Seth Wiesman (Jira)
• [jira] [Created] (FLINK-17981) Add new Flink docs homepage content Seth Wiesman (Jira)
• [jira] [Created] (FLINK-17980) Simplify Flink Getting Started Material Seth Wiesman (Jira)
• [jira] [Created] (FLINK-17979) Support rescaling for Unaligned Checkpoints Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-17978) Test Hadoop dependency change Till Rohrmann (Jira)
• [jira] [Created] (FLINK-17977) Check log sanity Till Rohrmann (Jira)
• [jira] [Created] (FLINK-17976) Test native K8s integration Till Rohrmann (Jira)
• [jira] [Created] (FLINK-17975) Test ZooKeeper 3.5 support Till Rohrmann (Jira)
• [jira] [Created] (FLINK-17974) Test new Flink Docker image Till Rohrmann (Jira)
• [jira] [Created] (FLINK-17973) Test memory configuration of Flink cluster Till Rohrmann (Jira)
• [jira] [Created] (FLINK-17972) Consider restructuring channel state Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion Joey Pereira (Jira)

• Earlier messages