dev  

Messages by Thread

• [jira] [Created] (FLINK-22516) ResourceManager cannot establish leadership Ricky Burnett (Jira)
• [jira] [Created] (FLINK-22515) Add Documentation for Flink Glue Schema Registry Integration Linyu Yao (Jira)
• [jira] [Created] (FLINK-22514) TypeExtractor - Improving log message Avishay Balderman (Jira)
• [jira] [Created] (FLINK-22513) Failed to upload compile artifacts Dawid Wysakowicz (Jira)
• Does flink support multi cluster deployment with HA on multi k8s clusters bhagi@R
  • Re: Does flink support multi cluster deployment with HA on multi k8s clusters Till Rohrmann
  • Re: Does flink support multi cluster deployment with HA on multi k8s clusters bhagi@R
  • Re: Does flink support multi cluster deployment with HA on multi k8s clusters Enrique
  • Re: Does flink support multi cluster deployment with HA on multi k8s clusters Till Rohrmann
• [jira] [Created] (FLINK-22512) Can't call current_timestamp with hive dialect for hive-3.1 Rui Li (Jira)
• [jira] [Created] (FLINK-22511) Fix the bug of non-composite result type in Python TableAggregateFunction Huang Xingbo (Jira)
• [jira] [Created] (FLINK-22510) ConfigurationUtils always serializes Duration to nanoseconds Jira
• [jira] [Created] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException Robert Metzger (Jira)
• [jira] [Created] (FLINK-22508) add serialVersionUID for all Serializable class in non-table module lincoln lee (Jira)
• [jira] [Created] (FLINK-22507) add serialVersionUID for all Serializable class in table module lincoln lee (Jira)
• [jira] [Created] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted Paul Lin (Jira)
• [jira] [Created] (FLINK-22505) Limit the precision of Resource Yangze Guo (Jira)
• [jira] [Created] (FLINK-22504) add serialVersionUID for all Serializable class lincoln lee (Jira)
• [jira] [Created] (FLINK-22503) getting eroor on select query in flink sql Bhagi (Jira)
• [jira] [Created] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently Till Rohrmann (Jira)
• [jira] [Created] (FLINK-22501) Flink HiveCatalog ParquetTable join Dim table error zhanglw (Jira)
• [jira] [Created] (FLINK-22500) flink stop 命令找不到00000000000000000000000000000000 Jira
• [jira] [Created] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ? ranqiqiang (Jira)
• flink1.12.1 read hive orc table exception. could not initialize class org.apache.orc.impl.ZlibCodec WSJian
  • Re: flink1.12.1 read hive orc table exception. could not initialize class org.apache.orc.impl.ZlibCodec Rui Li
• [jira] [Created] (FLINK-22498) cast the primary key for source table that has a decimal primary key as string, and then insert into a kudu table that has a string primary key throw the exception : UpsertStreamTableSink requires that Table has a full primary keys if it is updated Carl (Jira)
• [jira] [Created] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed ChangjiGuo (Jira)
• [jira] [Created] (FLINK-22496) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed Guowei Ma (Jira)
• [jira] [Created] (FLINK-22495) Document how to use the reactive mode on K8s Till Rohrmann (Jira)
• [jira] [Created] (FLINK-22494) Avoid discarding checkpoints in case of failure Matthias (Jira)
• [jira] [Created] (FLINK-22493) AdaptiveSchedulerITCase found unexpected files Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22492) KinesisTableApiITCase with wrong results Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22491) JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor Leon Hao (Jira)
• [jira] [Created] (FLINK-22490) YarnApplicationClusterEntryPoint does not pass configuration parameters ZRCoder (Jira)
• [jira] [Created] (FLINK-22489) subtask backpressure indicator shows value for entire job David Anderson (Jira)
• [jira] [Created] (FLINK-22488) KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost" Dong Lin (Jira)
• [jira] [Created] (FLINK-22487) Support `print` to print logs in PyFlink Huang Xingbo (Jira)
• [jira] [Created] (FLINK-22486) Wrong results of the IN operator Shengkai Fang (Jira)
• [jira] [Created] (FLINK-22485) Support client attach on application mode Junfan Zhang (Jira)
• [jira] [Created] (FLINK-22484) Buit-in functions for collections Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-22483) Recover checkpoints when JobMaster gains leadership Robert Metzger (Jira)
• [jira] [Created] (FLINK-22482) ParquetFileSystemITCase fails on Azure Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22481) RocksDBStateBackendWindowITCase times out on Azure Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure Dawid Wysakowicz (Jira)
• Last boarding call for ApacheCon NA/EU and Asia .... CFP closes in a week ... Christofer Dutz
• [jira] [Created] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition Danny Cranmer (Jira)
• [jira] [Created] (FLINK-22478) confluent schema registry avro (de)serialization https support Lars Bachmann (Jira)
• [jira] [Created] (FLINK-22477) Remove DefaultSlotPoolServiceFactory and SlotPoolImpl Till Rohrmann (Jira)
• [jira] [Created] (FLINK-22476) Extend the description of the config option `execution.target` Wei-Che Wei (Jira)
• [DISCUSS] Using timeouts in JUnit tests Dawid Wysakowicz
  • Re: [DISCUSS] Using timeouts in JUnit tests Arvid Heise
  • Re: [DISCUSS] Using timeouts in JUnit tests Till Rohrmann
  • Re: [DISCUSS] Using timeouts in JUnit tests Robert Metzger
  • Re: [DISCUSS] Using timeouts in JUnit tests Till Rohrmann
  • Re: [DISCUSS] Using timeouts in JUnit tests Dong Lin
  • Re: [DISCUSS] Using timeouts in JUnit tests Dong Lin
  • Re: [DISCUSS] Using timeouts in JUnit tests Till Rohrmann
  • Re: [DISCUSS] Using timeouts in JUnit tests Arvid Heise
  • Re: [DISCUSS] Using timeouts in JUnit tests Dong Lin
  • Re: [DISCUSS] Using timeouts in JUnit tests Till Rohrmann
  • Re: [DISCUSS] Using timeouts in JUnit tests Dong Lin
  • Re: [DISCUSS] Using timeouts in JUnit tests Till Rohrmann
  • Re: [DISCUSS] Using timeouts in JUnit tests Piotr Nowojski
  • Re: [DISCUSS] Using timeouts in JUnit tests Dawid Wysakowicz
  • Re: [DISCUSS] Using timeouts in JUnit tests Piotr Nowojski
• [jira] [Created] (FLINK-22475) Datagen connector does not list its available options with placeholders Jira
• [jira] [Created] (FLINK-22474) Display job configuration in web-ui Till Rohrmann (Jira)
• [jira] [Created] (FLINK-22473) Kinesis connector options are not listed by its factory Jira
• [jira] [Created] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Leonard Xu (Jira)
• [jira] [Created] (FLINK-22471) Use formatted descriptions for connector options Jira
• [jira] [Created] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases Dian Fu (Jira)
• [jira] [Created] (FLINK-22469) HistoryServer starts with NoSuchFileException Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-22468) Make StateFun build with Java 11 Tzu-Li (Gordon) Tai (Jira)
• [jira] [Created] (FLINK-22467) OverAggregateITCase.testRowNumberOnOver is unstable Jingsong Lee (Jira)
• [jira] [Created] (FLINK-22466) KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost Guowei Ma (Jira)
• [jira] [Created] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs Guowei Ma (Jira)
• [jira] [Created] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Guowei Ma (Jira)
• [jira] [Created] (FLINK-22463) IllegalArgumentException is thrown in WindowAttachedWindowingStrategy when two phase is enabled for distinct agg godfrey he (Jira)
• [jira] [Created] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients. Guowei Ma (Jira)
• [jira] [Created] (FLINK-22461) Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port fail Guowei Ma (Jira)
• [jira] [Created] (FLINK-22460) Conversion to relational algebra failed caused by '' Haiwei Zhou (Jira)
• [jira] [Created] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT) Guowei Ma (Jira)
• [jira] [Created] (FLINK-22458) Failed when operating empty catalog table Spongebob (Jira)
• [jira] [Created] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout Guowei Ma (Jira)
• [jira] [Created] (FLINK-22456) Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat Li (Jira)
• [jira] [Created] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse tartarus (Jira)
• [jira] [Created] (FLINK-22454) Ignore CAST condition in temporal join Shengkai Fang (Jira)
• [jira] [Created] (FLINK-22453) Can not stop job when not ust "-m" option Liu (Jira)
• [jira] [Created] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer Wenhao Ji (Jira)
• [jira] [Created] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction Yi Tang (Jira)
• [jira] [Created] (FLINK-22450) SQL parser fails to parse subquery containing INTERSECT in a view Caizhi Weng (Jira)
• [jira] [Created] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer Caizhi Weng (Jira)
• [jira] [Created] (FLINK-22448) FlinkRexUtil create Sarg String array elemet supplement space Junning Liang (Jira)
• [jira] [Created] (FLINK-22447) when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library" zlzhang0122 (Jira)
• [jira] [Created] (FLINK-22446) Relocate dependencies in hive connector uber jar Rui Li (Jira)
• when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Tony Wei
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Yangze Guo
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Till Rohrmann
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Yangze Guo
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Till Rohrmann
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Yangze Guo
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Tony Wei
  • Re: when should `FlinkYarnSessionCli` be included for parsing CLI arguments? Tony Wei
• [jira] [Created] (FLINK-22445) Add more examples of row-based operations in PyFlink doc Huang Xingbo (Jira)
• [jira] [Created] (FLINK-22444) Drop async checkpoint description of state backends in Chinese docs Yun Tang (Jira)
• [jira] [Created] (FLINK-22443) can not be execute an extreme long sql under batch mode macdoor615 (Jira)
• [jira] [Created] (FLINK-22442) Using scala api to change the TimeCharacteristic of the PatternStream is invalid Cedric Chen (Jira)
• [jira] [Created] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. thx Jira
• [jira] [Created] (FLINK-22440) UpsertKafkaTableITCase fail due to create topic timeout Guowei Ma (Jira)
• [jira] [Created] (FLINK-22439) UnalignedCheckpointITCase hangs Guowei Ma (Jira)
• [VOTE] Release 1.12.3, release candidate #1 Arvid Heise
  • Re: [VOTE] Release 1.12.3, release candidate #1 Dian Fu
  • Re: [VOTE] Release 1.12.3, release candidate #1 Dawid Wysakowicz
  • Re: [VOTE] Release 1.12.3, release candidate #1 Robert Metzger
  • Re: [VOTE] Release 1.12.3, release candidate #1 Stephan Ewen
  • Re: [VOTE] Release 1.12.3, release candidate #1 Arvid Heise
  • [RESULT][VOTE] Release 1.12.3, release candidate #1 Arvid Heise
• [VOTE] Release 1.13.0, release candidate #2 Dawid Wysakowicz
  • Re: [VOTE] Release 1.13.0, release candidate #2 Rui Li
  • Re: [VOTE] Release 1.13.0, release candidate #2 Jark Wu
  • Re: [VOTE] Release 1.13.0, release candidate #2 Rui Li
  • Re: [VOTE] Release 1.13.0, release candidate #2 Piotr Nowojski
  • Re: [VOTE] Release 1.13.0, release candidate #2 Xintong Song
  • Re: [VOTE] Release 1.13.0, release candidate #2 Caizhi Weng
  • Re: [VOTE] Release 1.13.0, release candidate #2 Stephan Ewen
  • Re: [VOTE] Release 1.13.0, release candidate #2 Caizhi Weng
  • Re: [VOTE] Release 1.13.0, release candidate #2 Stephan Ewen
  • Re: [VOTE] Release 1.13.0, release candidate #2 Matthias Pohl
  • Re: [VOTE] Release 1.13.0, release candidate #2 Guowei Ma
  • Re: [VOTE] Release 1.13.0, release candidate #2 Dawid Wysakowicz
  • Re: [VOTE] Release 1.13.0, release candidate #2 Jark Wu
  • Re: [VOTE] Release 1.13.0, release candidate #2 Dian Fu
  • Re: [VOTE] Release 1.13.0, release candidate #2 Xingbo Huang
  • Re: [VOTE] Release 1.13.0, release candidate #2 Leonard Xu
  • RE: [VOTE] Release 1.13.0, release candidate #2 Zhou, Brian
  • Re: [VOTE] Release 1.13.0, release candidate #2 Yun Tang
  • Re: [VOTE] Release 1.13.0, release candidate #2 Robert Metzger
  • Re: [VOTE] Release 1.13.0, release candidate #2 Dawid Wysakowicz
  • Re: [VOTE] Release 1.13.0, release candidate #2 David Anderson
  • Re: [VOTE] Release 1.13.0, release candidate #2 Zhu Zhu
• [jira] [Created] (FLINK-22438) add numRecordsOut metric for Async IO Zhengqi Zhang (Jira)
• [jira] [Created] (FLINK-22437) Miss adding parallesim for filter operator in batch mode zoucao (Jira)
• [jira] [Created] (FLINK-22435) twitter datastream connector gets Invalid 'expires' attribute Jason Perez (Jira)
• [jira] [Created] (FLINK-22436) twitter datastream connector gets Invalid 'expires' attribute Jason Perez (Jira)
• [jira] [Created] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store Fabian Paul (Jira)
• [jira] [Created] (FLINK-22433) CoordinatorEventsExactlyOnceITCase stalls on Adaptive Scheduler Stephan Ewen (Jira)
• CFP for ApacheCon 2021 closes in ONE WEEK Rich Bowen
• [jira] [Created] (FLINK-22432) Update upgrading.md with 1.13.x Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22431) AdaptiveScheduler does not log failure cause when recovering Till Rohrmann (Jira)
• [jira] [Created] (FLINK-22430) Increase "stale-assigned.stale-days" to 14 Konstantin Knauf (Jira)
• [jira] [Created] (FLINK-22429) Exlude Sub-Tasks in all bot "stale-unassigned" rule of Jira Bot Konstantin Knauf (Jira)
• [DISCUSS] Feedback Collection Jira Bot Konstantin Knauf
• [jira] [Created] (FLINK-22428) Translate timezone page to Chinese Leonard Xu (Jira)
• [jira] [Created] (FLINK-22427) Support default value option to simplify data clean process Jira
• [DISCUSS] Add async backpressure support to FlinkKafkaProducer Wenhao Ji
  • Re: [DISCUSS] Add async backpressure support to FlinkKafkaProducer Piotr Nowojski
  • Re: [DISCUSS] Add async backpressure support to FlinkKafkaProducer Wenhao Ji
  • Re: [DISCUSS] Add async backpressure support to FlinkKafkaProducer Piotr Nowojski
• [jira] [Created] (FLINK-22426) Reduce usage of TableSchema in the planner Timo Walther (Jira)
• [jira] [Created] (FLINK-22425) allowedLateness and sideOutput not having an effect Matthias (Jira)
• [jira] [Created] (FLINK-22424) Writing to already released buffers potentially causing data corruption Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-22423) Log error cause for state transition in ExecutionGraph Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22422) -ynm option doesn't effect when deploying flink on yarn Spongebob (Jira)
• [jira] [Created] (FLINK-22421) Does flink support multi cluster deployment with HA on multi kubernetes clusters Bhagi (Jira)
• [jira] [Created] (FLINK-22420) UnalignedCheckpointITCase failed Guowei Ma (Jira)
• [jira] [Created] (FLINK-22419) testScheduleRunAsync fail Guowei Ma (Jira)
• [jira] [Created] (FLINK-22418) The currently activated tab in the same page isn't consistent Dian Fu (Jira)
• [jira] [Created] (FLINK-22417) OrcFileSystemITCase.testOrcFilterPushDown fails on AZP Till Rohrmann (Jira)
• Flink SQL ordering issues ? Etienne Chauchot
  • Re: Flink SQL ordering issues ? Jark Wu
• [jira] [Created] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22414) Consider {{env.hadoop.conf.dir}} when looking for the hadoop configuration Matthias (Jira)
• [jira] [Created] (FLINK-22415) JsonBatchFileSystemITCase fails on Azure Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs Robert Metzger (Jira)
• [jira] [Created] (FLINK-22412) SplitAggregateRule support optimization of aggregate function reuse tartarus (Jira)
• [jira] [Created] (FLINK-22411) Checkpoint failed caused by Mkdirs failed to create file, the path for Flink state.checkpoints.dir in docker-compose can not work from Flink Operations Playground lisijie (Jira)
• [jira] [Created] (FLINK-22410) "Resuming Savepoint (rocks, scale up, heap timers)" fails with BindException Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-22409) Rename ResourceProfile class throwUnsupportedOperationExecptionIfUnknown method simenliuxing (Jira)
• [jira] [Created] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error Ma Jun (Jira)
• [ANNOUNCE] Flink Jira Bot fully live (& Useful Filters to Work with the Bot) Konstantin Knauf
  • Re: [ANNOUNCE] Flink Jira Bot fully live (& Useful Filters to Work with the Bot) Matthias Pohl
  • Re: [ANNOUNCE] Flink Jira Bot fully live (& Useful Filters to Work with the Bot) Xintong Song
• [jira] [Created] (FLINK-22407) upgrade log4j to 2.14 Svend Vanderveken (Jira)
• [jira] [Created] (FLINK-22406) ReactiveModeITCase.testScaleDownOnTaskManagerLoss() Stephan Ewen (Jira)
• [jira] [Created] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function Nico Kruber (Jira)
• [jira] [Created] (FLINK-22404) Document inconsistencies around +I and +U generation in retract streams Nico Kruber (Jira)
• [jira] [Created] (FLINK-22403) Update Chinese version of JDBC sink docs Yuan Mei (Jira)
• [jira] [Created] (FLINK-22402) Add hive dialect test in sql-client Rui Li (Jira)
• [ANNOUNCE] New Apache Flink Committer - Rui Li Jark Wu
  • Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Paul Lam
  • Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Qingsheng Ren
  • Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Nicholas Jiang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Yun Gao
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Xintong Song
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Xingbo Huang
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Arvid Heise
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Kurt Young
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Jingsong Li
  • Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Benchao Li
  • Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Leonard Xu

• Earlier messages
• Later messages