dev@flink.apache.org, 2022-09

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

- Re: [DISCUSS] FLIP-254 Guarantee binary compatibility for Public/-Evolving APIs between patch releases - posted by Yu Li <ca...@gmail.com> on 2022/09/01 01:49:24 UTC, 2 replies.
- [jira] [Created] (FLINK-29160) 在windows 编译flink 1.15.rc-2时出现问题 - posted by "mindest liu (Jira)" <ji...@apache.org> on 2022/09/01 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/09/01 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29162) missCounter and loadCount metrics also increase even if cache hint - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/09/01 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29163) There is a problem when compiling Flink 1.15.rc-2 and flink-1.14.3-rc1 in Windows operations - posted by "mindest liu (Jira)" <ji...@apache.org> on 2022/09/01 03:51:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api - posted by Zheng Yu Chen <ja...@gmail.com> on 2022/09/01 04:08:03 UTC, 4 replies.
- Re: [DISCUSS] Switch docker iamge base to Eclipse Temurin - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/01 04:55:19 UTC, 4 replies.
- [jira] [Created] (FLINK-29164) There is a problem when compiling Flink 1.15.rc-2 in Windows operations - posted by "mindest liu (Jira)" <ji...@apache.org> on 2022/09/01 06:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29165) Operator quickstart examples using code - posted by "Gaurav Miglani (Jira)" <ji...@apache.org> on 2022/09/01 06:29:00 UTC, 0 replies.
- Re: Flink Table Task question - posted by Sergey Nuyanzin <sn...@gmail.com> on 2022/09/01 07:32:51 UTC, 1 replies.
- Re: [DISCUSS] Support 'DYNAMIC MetadataColumn' in flink table - posted by Ran Tao <ch...@gmail.com> on 2022/09/01 08:32:16 UTC, 0 replies.
- [jira] [Created] (FLINK-29166) 多流合并成一个的方案优化 - posted by "zhangyang (Jira)" <ji...@apache.org> on 2022/09/01 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream - posted by "zhangyang (Jira)" <ji...@apache.org> on 2022/09/01 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29168) Add Transformer for NGram - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/09/01 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29169) Add Transformer and Estimator for UnivariateFeatureSelector - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/09/01 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29170) Add Transformer and Estimator for VarianceThresholdSelector - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/09/01 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29171) Add docs of MaxAbs, FeatureHasher, Interaction, VectorSlicer, ElementwiseProduct and Binarizer. - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/09/01 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29172) Add built-in string_split function. - posted by "Yongming Zhang (Jira)" <ji...@apache.org> on 2022/09/01 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29173) Upgrade curator - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/01 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29174) Add document for ML algorithms - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/09/02 00:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29175) Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/09/02 01:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29176) Add python source/test for ChiSqTest - posted by "Zhipeng Zhang (Jira)" <ji...@apache.org> on 2022/09/02 01:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29177) Shade the org.apache.commons in flink-sql-connector-hive to avoid the class conflict - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/02 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29178) flink - on -yarn out-off-memory - posted by "zhangyang (Jira)" <ji...@apache.org> on 2022/09/02 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29179) Translate "Temporal Table Function" page of "Streaming Concepts" into Chinese - posted by "ChunJi (Jira)" <ji...@apache.org> on 2022/09/02 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29180) Show subtask metrics as default in vertex detail - posted by "Junhan Yang (Jira)" <ji...@apache.org> on 2022/09/02 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29181) log.system can be congiured by dynamic options - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/02 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29182) SumAggFunction redundant computations - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/09/02 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29183) flink job ended before window time up while using bounded stream source - posted by "Lu (Jira)" <ji...@apache.org> on 2022/09/02 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29184) SQL Gateway should remove the downloaded resources - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/09/02 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29185) Failed to execute USING JAR in Hive Dialect - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/09/02 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29186) Store summarized results in internal nodes of BKD for time series points - posted by "Rishabh Maurya (Jira)" <ji...@apache.org> on 2022/09/02 13:59:00 UTC, 0 replies.
- RE: [DISCUSS] FLIP-246: Multi Cluster Kafka Source - posted by Ryan van Huuksloot <ry...@shopify.com.INVALID> on 2022/09/02 15:57:27 UTC, 0 replies.
- [RESULT][VOTE] FLIP-243: Dedicated Opensearch connectors - posted by Andriy Redko <dr...@gmail.com> on 2022/09/02 16:02:36 UTC, 0 replies.
- RE: [DISCUSS] Contribution of Multi Cluster Kafka Source - posted by Ryan van Huuksloot <ry...@shopify.com.INVALID> on 2022/09/02 16:30:25 UTC, 0 replies.
- HELP: New repository 'flink-connector-opensearch' under ASF organization - posted by Andriy Redko <dr...@gmail.com> on 2022/09/02 17:43:06 UTC, 2 replies.
- [jira] [Created] (FLINK-29187) mvn spotless:apply to format code in Windows - posted by "hjw (Jira)" <ji...@apache.org> on 2022/09/03 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29188) The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/09/05 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29189) Pass KeyValue to MergeFunction - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/05 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29190) flink hive left join mysql error - posted by "zck (Jira)" <ji...@apache.org> on 2022/09/05 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29191) Hive dialect can't get value for the variables set by set command - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/05 08:12:00 UTC, 0 replies.
- [ANNOUNCE] release-1.16 branch cut - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/05 08:16:40 UTC, 0 replies.
- [jira] [Created] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2022/09/05 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29193) Add Transformer for Normalizer - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/09/05 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29194) Add LoggingResourceListener as default - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/05 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29195) Expose lastCheckpointId metric - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2022/09/05 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29196) Check 1.16 licensing - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/09/05 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29197) Translate the "setting up of maben wrapper" into Chinese - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/05 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29198) RetryExtension doesn't make the test fail if the retries are exhausted - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/05 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29199) Support blue-green deployment type - posted by "Oleg Vorobev (Jira)" <ji...@apache.org> on 2022/09/05 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29200) Provide the way to delay the pod deletion for debugging purpose - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/09/05 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29201) Some tests from flink-sql-client, flink-connector-hive are not compiling in IntellijIdea with new maven - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/05 22:06:00 UTC, 0 replies.
- Flink Kinesis Connector EFO not working for cross-accounts - posted by Iris Grace Endozo <ie...@atlassian.com> on 2022/09/06 04:36:59 UTC, 2 replies.
- [jira] [Created] (FLINK-29202) CliClient fails with NPE during start (after calcite update to 1.27) - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/06 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29203) SetOperatorsITCase#testUnionAllWithCommonType is failing after Calcite update to 1.27 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/06 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29204) JoinITCase#testUncorrelatedScalar fails with Cannot generate a valid execution plan for the given query after calcite update 1.27 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/06 06:54:00 UTC, 0 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-09-06 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/06 08:08:00 UTC, 2 replies.
- [jira] [Created] (FLINK-29205) FlinkKinesisConsumer not respecting Credential Provider configuration for EFO - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/06 08:38:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.14.6 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/06 08:42:08 UTC, 5 replies.
- [jira] [Created] (FLINK-29206) Default Flink configuration contains irrelevant settings - posted by "Arseniy Tashoyan (Jira)" <ji...@apache.org> on 2022/09/06 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29207) Pulsar message eventTime may be incorrectly set to a negative number - posted by "Wenbing Shen (Jira)" <ji...@apache.org> on 2022/09/06 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29208) Logs and stdout endpoints not mentioned on OpenAPI spec - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2022/09/06 09:30:00 UTC, 0 replies.
- [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases - posted by Chesnay Schepler <ch...@apache.org> on 2022/09/06 09:51:00 UTC, 10 replies.
- [jira] [Created] (FLINK-29209) Fail to connect HiveServer endpoint with TProtocolException - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/06 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29210) Documented SQL Client setup when using Docker Compose doesn't work - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/09/06 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29211) Hive 2.3.9 NOTICE is incorrect - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/06 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29212) Properly load Hadoop native libraries in Flink docker iamges - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2022/09/06 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29213) Pretty schema json file - posted by "MOBIN (Jira)" <ji...@apache.org> on 2022/09/06 16:23:00 UTC, 0 replies.
- [DISCUSS] Re: Energy/performance research questions - posted by "Sharma, Sanskriti, Rakesh" <sa...@bu.edu> on 2022/09/06 19:49:34 UTC, 1 replies.
- [jira] [Created] (FLINK-29214) Remove usages of deprecated agg.indicator - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/06 21:34:00 UTC, 0 replies.
- redis subscriber source - posted by Pramod Immaneni <pr...@gmail.com> on 2022/09/06 21:46:16 UTC, 1 replies.
- [jira] [Created] (FLINK-29215) Use config based constructors for flink calcite Converter rules - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/06 22:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29216) rows belong to update rowkind are transfered into delete and insert - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/09/07 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/09/07 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29218) ADD JAR syntax could not work with Hive catalog in SQL client - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/09/07 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29219) CREATE TABLE AS statement blocks SQL client's execution - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/09/07 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29220) Skip ci tests on docs-only-PRs - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/09/07 09:07:00 UTC, 0 replies.
- Re: Sink V2 interface replacement for GlobalCommitter - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2022/09/07 09:14:56 UTC, 12 replies.
- [jira] [Created] (FLINK-29221) Adding join hint in sql may cause imcompatible state - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/09/07 09:18:00 UTC, 0 replies.
- Migrating Sink v1 to v2 - posted by Krzysztof Chmielewski <kr...@gmail.com> on 2022/09/07 10:18:17 UTC, 5 replies.
- [jira] [Created] (FLINK-29222) Wrong behavior for Hive's load data inpath - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/07 12:07:00 UTC, 0 replies.
- [NEWS][DISCUSS] Akka moves to BSL licence - posted by Etienne Chauchot <ec...@apache.org> on 2022/09/07 13:03:01 UTC, 7 replies.
- [jira] [Created] (FLINK-29223) Missing debug output for when filtering JobGraphs based on their persisted JobResult - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/07 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29224) flink-mirror does not pick up the new release branch 1.16 - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/09/07 22:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29225) Delete message incorrectly ignored in SinkUpsertMaterializer - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/09/08 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29226) Throw exception for streaming insert overwrite - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/08 03:17:00 UTC, 0 replies.
- Code Review Request - posted by ganlute <ga...@163.com> on 2022/09/08 03:19:43 UTC, 0 replies.
- [jira] [Created] (FLINK-29227) shoud package disruptor(com.lmax) to flink lib for aync logger when xxconnector using it. - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/09/08 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29228) Align the schema of the HiveServer2 getMetadata with JDBC - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/09/08 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29229) Fix HiveServer2 Endpoint doesn't support execute statements in sync mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2022/09/08 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29230) Publish blogpost about the Akka license change - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/08 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29231) PyFlink udtaf produces different results in the same sliding window - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2022/09/08 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29232) File store continuous reading support from_timestamp scan mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/08 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29233) Flink Kubernetes Operator example/kustomize not running - posted by "ShiminHuang (Jira)" <ji...@apache.org> on 2022/09/08 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29234) Dead lock in DefaultLeaderElectionService - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2022/09/08 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29235) CVE-2022-25857 on flink-shaded - posted by "Sergio Sainz (Jira)" <ji...@apache.org> on 2022/09/08 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29236) TableFactory wildcard options are not supported - posted by "Krishnaiah Narukulla (Jira)" <ji...@apache.org> on 2022/09/08 22:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29237) CalcITCase.testOrWithIsNullPredicate fails after update to calcite 1.27 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/08 22:57:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Caizhi Weng - posted by Jingsong Lee <lz...@apache.org> on 2022/09/09 01:40:56 UTC, 19 replies.
- [VOTE] Release 1.14.6, release candidate #1 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/09 01:55:44 UTC, 2 replies.
- [jira] [Created] (FLINK-29238) Wrong index information will be obtained after the downstream failover in hybrid full mode - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/09/09 02:43:00 UTC, 0 replies.
- Re: Rescuing Queryable State from deprecation - posted by Yuan Mei <yu...@gmail.com> on 2022/09/09 05:50:38 UTC, 0 replies.
- [jira] [Created] (FLINK-29239) KafkaSerializerWrapper.config should be Map for full configurability. - posted by "Bill G (Jira)" <ji...@apache.org> on 2022/09/09 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29240) Unify the ClassLoader in StreamExecutionEnvironment and TableEnvironment - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/09/09 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29241) Can not overwrite from empty input - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/09 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29242) [flink-filesystems] flink-gs-fs-hadoop Read time out when close write channel - posted by "Jian Zheng (Jira)" <ji...@apache.org> on 2022/09/09 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29243) Introduce a COW mode for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/09 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29244) Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup - posted by "Feifan Wang (Jira)" <ji...@apache.org> on 2022/09/09 09:23:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-254 Redis Streams connector - posted by Martijn Visser <ma...@apache.org> on 2022/09/09 09:33:40 UTC, 1 replies.
- [jira] [Created] (FLINK-29245) Remove RetryRule - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/09 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29246) Setup DynamoDB Connector Project Structure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/09 12:47:00 UTC, 0 replies.
- PMC support for setting up DynamoDB connector in Jira - posted by Danny Cranmer <da...@apache.org> on 2022/09/09 13:08:08 UTC, 2 replies.
- [jira] [Created] (FLINK-29247) Streamline RpcService interface - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/09 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29248) Remove RpcService#fenceRpcServer - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/09 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29249) Remove RpcService#execute/scheduleRunnable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/09 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29250) Remove RpcService#getTerminationFuture - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/09 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29251) Send CREATED status and Cancel event via FlinkResourceListener - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/09 15:05:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser - posted by Timo Walther <tw...@apache.org> on 2022/09/09 15:08:06 UTC, 23 replies.
- Recommended way to Enable SSL Flink Kubernetes Operator - posted by Hao t Chang <ht...@us.ibm.com> on 2022/09/09 16:24:48 UTC, 4 replies.
- [jira] [Created] (FLINK-29252) Support create table-store table with 'connector'='table-store' - posted by "MOBIN (Jira)" <ji...@apache.org> on 2022/09/09 19:18:00 UTC, 0 replies.
- [VOTE] Release 1.14.6, release candidate #2 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/10 11:04:49 UTC, 7 replies.
- [VOTE] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api - posted by Zheng Yu Chen <ja...@gmail.com> on 2022/09/11 04:02:27 UTC, 6 replies.
- [jira] [Created] (FLINK-29253) DefaultJobmanagerRunnerRegistry#localCleanupAsync calls close instead of closeAsync - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/12 06:27:00 UTC, 0 replies.
- [VOTE] FLIP-254 Redis Streams connector - posted by Martijn Visser <ma...@apache.org> on 2022/09/12 07:58:19 UTC, 6 replies.
- [RESULT][VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases - posted by Chesnay Schepler <ch...@apache.org> on 2022/09/12 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29254) RpcGateway should have some form of Close() method - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29255) FLIP-258 - Enforce binary compatibility in patch releases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29256) Docs for k8s operator webhook - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2022/09/12 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29257) Kubernetes operator docs are vague about upgrade mode - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/09/12 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29258) Add SAVEPOINT_ONLY upgrade mode - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2022/09/12 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29259) Update release guide - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29260) Auto-wipe exclusion list after updating reference version - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29261) Consider using FAIL_ON_UNKNOWN_PROPERTIES in the Operator - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/12 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29262) Update documentation - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29263) Remove ElasticSearch connector from apache/flink repo - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29264) Give ES parent module a proper artifact ID - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 14:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29265) Update ES version to 3.0-SNAPSHOT - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29266) Cleanup ES root pom - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29267) Support external type systems in DDL - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/09/12 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29268) Sync 1.16.0 code to ES repo - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 19:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29269) Setup CI logging - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/12 19:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29270) Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE - posted by "Muhammad Hilmi Al Fatih (Jira)" <ji...@apache.org> on 2022/09/13 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file - posted by "jiangjiguang0719 (Jira)" <ji...@apache.org> on 2022/09/13 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29272) Document DataStream API (DataStream to Table) for table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/13 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29273) Page not enough Exception in SortBufferMemTable - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/13 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29274) HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/09/13 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29275) Temporal Table function: Cannot add expression of different type to set - posted by "Tally (Jira)" <ji...@apache.org> on 2022/09/13 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29276) Flush all memory in SortBufferMemTable.clear - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/13 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29277) Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented' - posted by "Jiankun Feng (Jira)" <ji...@apache.org> on 2022/09/13 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29278) BINARY type is not supported in table store - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/13 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29279) ElasticsearchWriterITCase fails without logging enabled - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/13 09:56:00 UTC, 0 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-09-13 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/13 10:08:50 UTC, 0 replies.
- [jira] [Created] (FLINK-29280) Hint will not be propagated in subquery - posted by "xuyang (Jira)" <ji...@apache.org> on 2022/09/13 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29281) Replace Akka - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/13 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29282) Decouple Quickstart E2E test from Elasticsearch - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/13 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29283) Remove hardcoded apiVersion from operator unit test - posted by "Tony Garrard (Jira)" <ji...@apache.org> on 2022/09/13 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29284) Bump derby in flink-connector-hive to v10.14.2.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/09/13 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29285) Public ParameterProperty and TestUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/13 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29286) Potential compatibility risk between snapshot binary and jars - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/13 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29287) Add PackagingTestUtils - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/13 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29288) Can't start a job with a jar in the system classpath - posted by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2022/09/13 21:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29289) SequencefileInputFormat based on the new Source API - posted by "Jing Ge (Jira)" <ji...@apache.org> on 2022/09/13 22:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29290) Produce changelog during full compaction in Table Store - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/09/14 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29291) Change DataFileWriter into a factory to create writers - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/09/14 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29292) Change MergeFunction to produce not only KeyValues - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/09/14 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29293) Introduce a MergeFunction for full compaction - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/09/14 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29294) Introduce a CompactTask for full compaction - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/09/14 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29295) Clear RecordWriter slower to avoid causing frequent compaction conflicts - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/14 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29296) OperatorCoordinatorHolder.create throws NPE - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2022/09/14 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29297) Group Table Store file writers into SingleFileWriter and RollingFileWriter - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2022/09/14 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29298) LocalBufferPool request buffer from NetworkBufferPool hanging - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/09/14 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29299) Fix the network memory size calculation issue in fine-grained resource mode - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/09/14 03:22:00 UTC, 0 replies.
- [ANNOUNCE] Release 1.16.0, release candidate #0 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/14 05:59:05 UTC, 0 replies.
- [DISCUSS] FLIP-260: Expose Finish Method For UserDefinedFunction - posted by Lincoln Lee <li...@gmail.com> on 2022/09/14 06:21:19 UTC, 10 replies.
- [jira] [Created] (FLINK-29300) Upgrade python version to 3.10.3 - posted by "Bilna (Jira)" <ji...@apache.org> on 2022/09/14 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29301) Publish java-ci-tools - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/14 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29302) Support DNS policy and configuration in helm chart - posted by "Joao Coutinho (Jira)" <ji...@apache.org> on 2022/09/14 10:40:00 UTC, 0 replies.
- [DISCUSS] Stale PR action for flink and flink-kubernetes-operator repos - posted by Gabor Somogyi <ga...@gmail.com> on 2022/09/14 12:57:57 UTC, 5 replies.
- [jira] [Created] (FLINK-29303) Add DockerImageVersions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/14 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29304) Set timeout on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/14 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29305) UpsertTestSinkWriter fails if parent of output file does not exist - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/14 16:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh - posted by "LiuZeshan (Jira)" <ji...@apache.org> on 2022/09/14 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29307) Fix timeInQueue in CheckpointRequestDecider - posted by "chenzihao (Jira)" <ji...@apache.org> on 2022/09/15 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29308) NoResourceAvailableException fails the batch job - posted by "Aitozi (Jira)" <ji...@apache.org> on 2022/09/15 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29309) Relax allow-client-job-configurations for Table API and parameters - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/09/15 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29310) Setup license checks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/15 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally - posted by "Nicolas Pocock (Jira)" <ji...@apache.org> on 2022/09/15 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29312) Performance problems encountered when using StatementSetImpl#addInsertSql in Flink SQL - posted by "shouzuo meng (Jira)" <ji...@apache.org> on 2022/09/15 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29313) Some config overrides are ignored when set under spec.flinkConfiguration - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/15 11:14:00 UTC, 0 replies.
- [DISCUSS] Externalized connector release details&workflow - posted by Chesnay Schepler <ch...@apache.org> on 2022/09/15 15:06:44 UTC, 15 replies.
- [jira] [Created] (FLINK-29314) AskTimeoutException for more than two partition with FileSource API on S3 - posted by "Satyasheel Satyasheel (Jira)" <ji...@apache.org> on 2022/09/15 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/15 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29316) Replicate packaging tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/15 16:19:00 UTC, 0 replies.
- Metrics for ElasticsearchSink and JdbcTableSource - posted by Satish Saley <sa...@apache.org> on 2022/09/15 23:22:23 UTC, 1 replies.
- [jira] [Created] (FLINK-29317) Add WebSocket in Dispatcher to support olap query submission and push results in session cluster - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/09/16 02:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29318) Add Transformer for PolynomialExpansion - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/09/16 03:48:00 UTC, 0 replies.
- Re: [Discuss] Let's Session Cluster JobManager take a breather (FLIP-257: Flink JobManager Process Split) - posted by Shammon FY <zj...@gmail.com> on 2022/09/16 05:32:34 UTC, 1 replies.
- [jira] [Created] (FLINK-29319) Upgrade Calcite version to 1.32 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/09/16 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29320) Setup release scripts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/16 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29321) Release connector - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/16 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29322) Expose savepoint format on Web UI - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/16 08:57:00 UTC, 0 replies.
- [DISCUSS] Restructure FLIP pages with page properties - posted by Chesnay Schepler <ch...@apache.org> on 2022/09/16 09:55:42 UTC, 6 replies.
- [jira] [Created] (FLINK-29323) Refine Transformer for VectorAssembler - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/09/16 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29324) Calling Kinesis connector close method before subtask starts running results in NPE - posted by "Anthony Pounds-Cornish (Jira)" <ji...@apache.org> on 2022/09/16 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29325) Fix documentation bug on how to enable batch mode - posted by "Jun He (Jira)" <ji...@apache.org> on 2022/09/16 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29326) EndOfDataDecoderException observed when uploading a jar - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/16 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29327) Operator configs are showing up among standard Flink configs - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/16 16:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29328) 【flink在使用状态过期设置时出现问题】 - posted by "Jason (Jira)" <ji...@apache.org> on 2022/09/19 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29329) Checkpoint can not be triggered if encountering OOM - posted by "Yuxin Tan (Jira)" <ji...@apache.org> on 2022/09/19 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/19 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29331) pre-aggregated merge supports changelog inputs - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/19 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29332) Flink SQL Planner Module doesn't read config from flink-conf.yaml - posted by "Dhananjay Badaya (Jira)" <ji...@apache.org> on 2022/09/19 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29333) Flink SQL Planner Module doesn't read config from flink-conf.yaml - posted by "Dhananjay Badaya (Jira)" <ji...@apache.org> on 2022/09/19 10:57:00 UTC, 0 replies.
- Kubernetes Operator 1.2.0 release - posted by Gyula Fóra <gy...@gmail.com> on 2022/09/19 11:37:03 UTC, 4 replies.
- [jira] [Created] (FLINK-29334) StateHandleStore#releaseAndTryRemoveAll is not used and can be removed - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/19 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29335) OperatorSubtaskState swallows exception - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/19 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29336) SubtaskState#discardState swallows exceptions - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/19 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29337) Fix fail to use HiveDialect for non-hive table - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/19 12:18:00 UTC, 0 replies.
- Re: [DISCUSS] TLS issues - posted by Jean-Damien Hatzenbuhler <je...@contentsquare.com.INVALID> on 2022/09/19 13:29:04 UTC, 1 replies.
- [jira] [Created] (FLINK-29338) Try to unify observe/deploy config handling in the operator - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/19 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/19 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29340) ResourceManagerTest#testProcessResourceRequirementsWhenRecoveryFinished prone to race condition - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/19 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29341) Upgrade Apache Kafka version to 7.1.1-ccs to resolve CVE-2021-38153 - posted by "Sanjay Nathani (Jira)" <ji...@apache.org> on 2022/09/19 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29342) Do not query writer.length() per record in RollingFileWriter - posted by "Jane Chan (Jira)" <ji...@apache.org> on 2022/09/20 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29343) Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/20 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2022/09/20 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29345) Too many open files in table store orc writer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/20 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29346) File naming configuration for filesink output - posted by "Kwang-in (Dennis) JUNG (Jira)" <ji...@apache.org> on 2022/09/20 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29347) Failed to restore from list state with empty protobuf object - posted by "shen (Jira)" <ji...@apache.org> on 2022/09/20 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/09/20 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29349) Use state ttl instead of timer to clean up state in proctime over aggregate - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/09/20 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29350) Add a note for swapping planner jar in Hive dependencies page - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/20 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29351) Enable input buffer floating for blocking shuffle - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/09/20 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29352) Support CONVERT_TZ built-in function in Table API - posted by "Luning Wang (Jira)" <ji...@apache.org> on 2022/09/20 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29353) Support UNIX_TIMESTAMP built-in function in Table API - posted by "Luning Wang (Jira)" <ji...@apache.org> on 2022/09/20 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29354) Support TO_DATE and TO_TIMESTAMP built-in function in the Table API - posted by "Luning Wang (Jira)" <ji...@apache.org> on 2022/09/20 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29355) Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/09/20 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29356) Pulsar Table Source code :implementation - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/09/20 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29357) Pulsar Table Sink code: implementation - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/09/20 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29359) Pulsar Table Connector pom config and packaging - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/09/20 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29360) Pulsar Table Connector Documentation - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/09/20 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29358) Pulsar Table Connector testing - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/09/20 12:58:00 UTC, 0 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-09-20 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/20 13:18:37 UTC, 0 replies.
- [jira] [Created] (FLINK-29361) How to set headers with the new Flink KafkaSink - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/09/20 13:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29362) Allow loading dynamic config for kerberos authentication in CliFrontend - posted by "Biao Geng (Jira)" <ji...@apache.org> on 2022/09/20 15:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29363) Allow web ui to fully redirect to other page - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2022/09/20 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29364) Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed". - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/09/20 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29365) Millisecond behind latest jumps after Flink 1.15.2 upgrade - posted by "Wilson Wu (Jira)" <ji...@apache.org> on 2022/09/20 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29366) Use flink shaded jacson to parse flink-conf.yaml - posted by "Yuan Kui (Jira)" <ji...@apache.org> on 2022/09/21 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29367) Avoid manifest corruption for incorrect checkpoint recovery - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/21 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29368) Modify DESCRIBE statement docs for now syntax - posted by "Yunhong Zheng (Jira)" <ji...@apache.org> on 2022/09/21 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29369) Commit delete file failure due to Checkpoint aborted - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/21 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2022/09/21 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29371) org.apache.calcite.sql.validate.SqlValidatorException: No match found for function signature to_timestamp(, ) - posted by "sun (Jira)" <ji...@apache.org> on 2022/09/21 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29372) Add a suffix to keys that violate YAML spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/21 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29373) DataStream to table not support BigDecimalTypeInfo - posted by "hk__lrzy (Jira)" <ji...@apache.org> on 2022/09/21 07:13:00 UTC, 0 replies.
- 来自ji_longzhang的邮件 - posted by ji_longzhang <ji...@163.com> on 2022/09/21 07:36:44 UTC, 0 replies.
- [jira] [Created] (FLINK-29374) RpcConnectionTest may pass invalid rpc URL - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/21 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29375) Move getSelfGateway into RpcService - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/21 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29376) Deployment already exists error if Flink version is not set correctly - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/21 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29377) Make RPC timeout extraction reusable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/21 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29378) Misleading logging in Execution for failed state trannsitions - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/21 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2022/09/21 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29380) Two streams union, watermark error, not the minimum value - posted by "xiechenling (Jira)" <ji...@apache.org> on 2022/09/21 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29381) Key_Shared subscription isn't works in the latest Pulsar connector - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/09/21 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29382) Flink fails to start when created using quick guide for flink operator - posted by "Barisa (Jira)" <ji...@apache.org> on 2022/09/21 13:36:00 UTC, 0 replies.
- [DISCUSS][FLINK-29372] Add a suffix to keys that violate YAML spec - posted by Chesnay Schepler <ch...@apache.org> on 2022/09/21 14:06:26 UTC, 7 replies.
- [jira] [Created] (FLINK-29383) Add additionalPrinterColumns for some status fields - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/09/21 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29384) snakeyaml version 1.30 in flink-kubernetes-operator-1.2-SNAPSHOT-shaded.jar has vulnerabilities - posted by "James Busche (Jira)" <ji...@apache.org> on 2022/09/21 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29385) AddColumn in flink table store should check the duplicate field names - posted by "Shammon (Jira)" <ji...@apache.org> on 2022/09/22 03:04:00 UTC, 0 replies.
- [VOTE] FLIP-260: Expose Finish Method For TableFunction - posted by Lincoln Lee <li...@gmail.com> on 2022/09/22 06:21:00 UTC, 4 replies.
- [jira] [Created] (FLINK-29386) Fix fail to compile flink-connector-hive when profile is hive3 - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/22 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/22 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29388) Fix args in JobSpec not being passed through to Flink in Standalone mode - posted by "Usamah Jassat (Jira)" <ji...@apache.org> on 2022/09/22 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29389) Update documentation of JDBC and HBase lookup table for new caching options - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2022/09/22 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29390) Pulsar SQL Connector: SQLClient E2E testing - posted by "Yufei Zhang (Jira)" <ji...@apache.org> on 2022/09/22 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29391) Add option to set labels and annotations in kubernetes deployment - posted by "Barisa (Jira)" <ji...@apache.org> on 2022/09/22 11:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29392) SessionJobs are lost when Session FlinkDeployment is upgraded without HA - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/22 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29393) Upgrade Kubernetes operator examples to use the latest Flink base image - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/22 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29394) Flink k8s operator observe Flink job restart count - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2022/09/22 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2022/09/22 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29396) Race condition in JobMaster shutdown can leak resource requirements - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/22 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29397) Race condition in StreamTask can lead to NPE if changelog is disabled - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/22 14:36:00 UTC, 0 replies.
- [DISCUSS] FLIP-262 MongoDB Connector - posted by 孙家宝 <ji...@xtransfer.cn.INVALID> on 2022/09/22 16:01:56 UTC, 5 replies.
- [jira] [Created] (FLINK-29398) Utilize Rack Awareness in Flink Consumer - posted by "Jeremy DeGroot (Jira)" <ji...@apache.org> on 2022/09/22 20:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29399) TableITCase is unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/22 21:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29400) Default Value of env.log.max in documentation is incorrect - posted by "Dhruv Patel (Jira)" <ji...@apache.org> on 2022/09/22 22:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29401) Improve observer structure - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/23 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB - posted by "Donatien (Jira)" <ji...@apache.org> on 2022/09/23 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29403) Streamline SimpleCondition usage - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/23 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29404) Fix build failure due to unavailable dependency - posted by "Brian Yue (Jira)" <ji...@apache.org> on 2022/09/24 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29405) InputFormatCacheLoaderTest is unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/25 17:24:00 UTC, 0 replies.
- [RESULT][VOTE]FLIP-260: Expose Finish Method For TableFunction - posted by Lincoln Lee <li...@gmail.com> on 2022/09/26 01:19:26 UTC, 0 replies.
- [jira] [Created] (FLINK-29406) Expose Finish Method For TableFunction - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2022/09/26 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29407) HiveCatalogITCase.testCsvTableViaSQL failed with FileNotFoundException - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/26 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29408) HiveCatalogITCase failed with NPE - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/26 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29409) Add Transformer and Estimator for VarianceThresholdSelector - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/09/26 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29410) Add checks to guarantee the non-deprecated options not conflicting with standard YAML - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2022/09/26 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29411) DESCRIPTOR in flink_fn_execution_pb2.py always None? - posted by "Kristian Grimsby (Jira)" <ji...@apache.org> on 2022/09/26 07:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29412) Connection leak in orc reader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2022/09/26 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29413) Make it possible to associate triggered and completed savepoints - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/26 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29414) Setup license checks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/26 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29415) InitializationFailure when recovering from a checkpoint in Application Mode leads to the cleanup of all HA data - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/26 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29416) One or more fetchers have encountered exception - posted by "liuchenhong (Jira)" <ji...@apache.org> on 2022/09/26 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29417) One or more fetchers have encountered exception - posted by "liuchenhong (Jira)" <ji...@apache.org> on 2022/09/26 10:22:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.14.6, release candidate #2 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/26 11:04:42 UTC, 0 replies.
- [jira] [Created] (FLINK-29418) Update flink-shaded - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/26 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/26 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29420) Add support for Zookeeper 3.7 / 3.8 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/26 14:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29421) Support python 3.10 - posted by "Eric Sirianni (Jira)" <ji...@apache.org> on 2022/09/26 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29422) Production tests return/argument types do not take transitivity into account - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/26 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29423) JobDetails is incorrect OpenAPI spec - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/26 18:17:00 UTC, 0 replies.
- [VOTE] Apache Flink Table Store 0.2.1, release candidate #1 - posted by Jingsong Li <ji...@gmail.com> on 2022/09/27 03:00:49 UTC, 1 replies.
- [jira] [Created] (FLINK-29424) Add Pull Request Template for flink-ml Project - posted by "Jiang Xin (Jira)" <ji...@apache.org> on 2022/09/27 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29425) Hybrid full spilling strategy triggering spilling frequently - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/09/27 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29426) Flink ML 2.1.0 Installation - posted by "Tony Sun (Jira)" <ji...@apache.org> on 2022/09/27 04:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29427) LookupJoinITCase failed with classloader problem - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/27 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29428) got an ambigious exception in flinksql - posted by "Spongebob (Jira)" <ji...@apache.org> on 2022/09/27 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29429) Add DataType for Flink ML linear algorithm classes - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/09/27 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29430) Sanity check in InternalKeyContextImpl#setCurrentKeyGroupIndex - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2022/09/27 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29431) Exceptions during job grapg serialization lock up client - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/27 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29432) Replace GenericUDFNvl with GenericUDFCoalesce - posted by "Prabhu Joseph (Jira)" <ji...@apache.org> on 2022/09/27 11:05:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 16.0, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2022/09/27 11:33:00 UTC, 4 replies.
- [SUMMARY] Flink 1.16 release sync of 2022-09-27 - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/27 11:33:41 UTC, 0 replies.
- [jira] [Created] (FLINK-29433) Support Auth through the builder pattern in Pulsar connector - posted by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/09/27 17:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29434) Add AlgoOperator for Splitter - posted by "weibo zhao (Jira)" <ji...@apache.org> on 2022/09/28 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29435) securityConfiguration supports dynamic configuration - posted by "Bo Cui (Jira)" <ji...@apache.org> on 2022/09/28 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29436) Upgrade Spotless Maven Plugin to 2.27.0 for running on Java 17 - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2022/09/28 02:42:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.14.6 released - posted by Xingbo Huang <hx...@gmail.com> on 2022/09/28 02:51:32 UTC, 1 replies.
- [jira] [Created] (FLINK-29437) The partition of data before and after the Kafka Shuffle are not aligned - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2022/09/28 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29438) Setup DynamoDB Connector Project Structure - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29439) Add DynamoDB project readme - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29440) Setup CI Logging - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29441) Setup dependency convergence check - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29443) Replicate packaging tests - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29442) Setup license checks - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29444) Setup release scripts - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2022/09/28 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29445) When the decimal table column field is printed，program is error - posted by "liuzhiyong (Jira)" <ji...@apache.org> on 2022/09/28 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29446) Remove Calcite classes which were fixed in 1.24 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/28 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29447) Add doc for federation query using Hive dialect - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2022/09/28 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29448) Aggregate (Min/Max/Count) push down for ORC - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/09/28 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29449) Aggregate (Min/Max/Count) push down for Parquet - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/09/28 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29450) Push down filter by partition column for Aggregate (Min/Max/Count) for Parquet - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/09/28 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29451) Push down group by partition column for Aggregate (Min/Max/Count) for Parquet and Orc - posted by "dalongliu (Jira)" <ji...@apache.org> on 2022/09/28 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29452) RetryOnExceptionExtensionTest is implemented in a way that doesn't allow the successful execution of individual tests - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/28 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29453) Add uidHash support to State Processor API - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/28 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29454) Deduplicate code in SavepointReader - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/28 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29455) Add OperatorIdentifier - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/28 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29456) Add methods that acept OperatorIdentifier - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/28 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29457) Add a uid(hash) remapping function - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/28 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29458) When two tables have the same field, do not specify the table name,Exception will be thrown：SqlValidatorException :Column 'currency' is ambiguous - posted by "ZuoYan (Jira)" <ji...@apache.org> on 2022/09/28 12:59:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #1 - posted by Gyula Fóra <gy...@apache.org> on 2022/09/28 14:00:13 UTC, 1 replies.
- [DISCUSS] Repeatable cleanup of checkpoint data - posted by Matthias Pohl <ma...@aiven.io.INVALID> on 2022/09/28 14:07:56 UTC, 0 replies.
- [jira] [Created] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/09/28 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29460) HsResultPartitionTest.testRelease failed with AssertionFailedError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/29 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/29 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29462) LookupJoinITCase failed on azure due to classloader leaking - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2022/09/29 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29463) InputFormatCacheLoaderTest.checkCounter failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/09/29 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29464) JobID generation logic could lead to state loss - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/29 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29465) Supports limit factor in the resource definition - posted by "Xin Hao (Jira)" <ji...@apache.org> on 2022/09/29 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29466) Update org.postgresql:postgresql to 42.5.0 - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/09/29 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29467) Sync RabbitMQ CI setup with Elasticsearch CI setup - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/09/29 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29468) Update jackson-bom to 2.13.4 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/09/29 09:46:00 UTC, 0 replies.
- [GitHub] [flink-connector-rabbitmq] MartijnVisser commented on pull request #2: [FLINK-29467][CI] Update CI workflow - posted by GitBox <gi...@apache.org> on 2022/09/29 10:19:12 UTC, 0 replies.
- [GitHub] [flink-connector-rabbitmq] MartijnVisser merged pull request #2: [FLINK-29467][CI] Update CI workflow - posted by GitBox <gi...@apache.org> on 2022/09/29 10:36:03 UTC, 0 replies.
- [jira] [Created] (FLINK-29469) Generate noop.jar instead of committing into source - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/29 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29470) Setup shared utils for connector externalization - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/29 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29471) Create a flink-connector-parent pom - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/29 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29472) Create shared release scripts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/29 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29473) Move Flink CI utils into separate project - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/29 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29474) Name collision: Group already contains a Metric with the name - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/29 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29475) Add WARNING/ERROR checker for the operator in e2e tests - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2022/09/29 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/09/29 14:39:00 UTC, 0 replies.
- Running Flink in FIPS mode - posted by Hao t Chang <ht...@us.ibm.com> on 2022/09/29 21:29:52 UTC, 0 replies.
- [jira] [Created] (FLINK-29477) ClassCastException when collect primitive array to Python - posted by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/09/30 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29478) Flink sql Connector hive to support 3.1.3 - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2022/09/30 04:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29479) support whether using system env for pythonpath - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/09/30 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29480) Skip invalid messages when writing - posted by "Salva (Jira)" <ji...@apache.org> on 2022/09/30 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29481) Show JobType on WebUI - posted by "LI Mingkun (Jira)" <ji...@apache.org> on 2022/09/30 06:56:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2 - posted by Gyula Fóra <gy...@apache.org> on 2022/09/30 08:09:45 UTC, 0 replies.
- [jira] [Created] (FLINK-29482) Ingress always forces ClusterIP rest service type - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2022/09/30 08:45:00 UTC, 0 replies.
- [VOTE] FLIP-262: MongoDB Connector - posted by "jiabao.sun" <ji...@xtransfer.cn.INVALID> on 2022/09/30 09:02:36 UTC, 1 replies.
- [jira] [Created] (FLINK-29483) flink python udf arrow in thread model bug - posted by "jackylau (Jira)" <ji...@apache.org> on 2022/09/30 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29484) Support orderless check of elements in SourceTestSuiteBase and SinkTestSuiteBase - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2022/09/30 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29485) TypeSerializerUpgradeTestBase doesn't use FlinkVersions.current() - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/09/30 09:17:00 UTC, 0 replies.
- [VOTE] Release 1.16.0, release candidate #1 - posted by Xingbo Huang <hx...@apache.org> on 2022/09/30 09:22:08 UTC, 5 replies.
- [jira] [Created] (FLINK-29486) Enable SQL Client to Connect SQL Gateway in Remote Mode - posted by "yuzelin (Jira)" <ji...@apache.org> on 2022/09/30 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29487) RpcService should implement AutoCloseableAsync - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/30 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29488) MetricRegistryImpl should implement AutoCloseableAsync - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2022/09/30 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-29489) Display issue when querying complex, deeply nested fields - posted by "Justin (Jira)" <ji...@apache.org> on 2022/09/30 14:47:00 UTC, 0 replies.