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

---

- [jira] [Created] (FLINK-20827) Just read record correlating to join key in FilesystemLookUpFunc - posted by "zoucao (Jira)" <ji...@apache.org> on 2021/01/01 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20828) Fix some aggregate and flat_aggregate tests failed in py35 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/01 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20829) flink.jm.downtime metric is inaccurate in flink 1.9.1 and 1.11.1 - posted by "Yu Yang (Jira)" <ji...@apache.org> on 2021/01/01 22:44:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 2.2.2 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/01/02 02:36:51 UTC, 2 replies.
- [jira] [Created] (FLINK-20830) Add a type of HEADLESS_CLUSTER_IP for rest service type - posted by "Aitozi (Jira)" <ji...@apache.org> on 2021/01/03 04:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20831) Introduce the in memory topN buffer - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2021/01/03 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20832) flink.apache.org siete Typography exception - posted by "谢波 (Jira)" <ji...@apache.org> on 2021/01/04 03:25:00 UTC, 0 replies.
- letter of application - posted by zhouenning <zh...@aliyun.com.INVALID> on 2021/01/04 03:32:07 UTC, 1 replies.
- [jira] [Created] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2021/01/04 03:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/04 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20835) Implement FineGrainedSlotManager - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/04 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/04 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20837) Assign an increasing number larger than the numberOfSlot to dynamic slots - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/04 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20838) Implement SlotRequestAdapter for the FineGrainedSlotManager - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/04 07:11:00 UTC, 0 replies.
- Task manger isn’t initiating with defined values in Flink 1.11 version as part of EMR 6.1.0 - posted by DEEP NARAYAN Singh <ab...@gmail.com> on 2021/01/04 07:25:17 UTC, 4 replies.
- Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API - posted by Yu Li <ca...@gmail.com> on 2021/01/04 08:14:45 UTC, 3 replies.
- [jira] [Created] (FLINK-20839) some mistakes in state.md and state_zh.md - posted by "wym_maozi (Jira)" <ji...@apache.org> on 2021/01/04 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/01/04 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20841) Fix compile error due to duplicated generated files - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/04 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20842) Data row is smaller than a column index, internal schema representation is probably out of sync with real database schema - posted by "zhouenning (Jira)" <ji...@apache.org> on 2021/01/04 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20843) UnalignedCheckpointITCase is unstable - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2021/01/04 11:54:00 UTC, 0 replies.
- [DISCUSS] FLIP-155: Introduce a few convenient operations in Table API - posted by Dian Fu <di...@gmail.com> on 2021/01/04 12:03:10 UTC, 7 replies.
- Re: [DISCUSS] Allow streaming operators to use managed memory - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/04 12:43:36 UTC, 9 replies.
- [jira] [Created] (FLINK-20844) Support add jar in SQL client - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/01/04 14:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-20845) Drop support for Scala 2.11 - posted by "Nick Burkard (Jira)" <ji...@apache.org> on 2021/01/04 14:11:00 UTC, 0 replies.
- [ANNOUNCE] Changes to generated avro files - posted by Chesnay Schepler <ch...@apache.org> on 2021/01/04 14:52:52 UTC, 0 replies.
- [jira] [Created] (FLINK-20846) Decouple checkpoint services from CheckpointCoordinator - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/04 16:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-20847) Update CompletedCheckpointStore.shutdown() signature - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/04 16:32:00 UTC, 0 replies.
- Re: Support local aggregate push down for Blink batch planner - posted by Kurt Young <yk...@gmail.com> on 2021/01/05 01:51:42 UTC, 23 replies.
- [DISCUSS]Some thoughts about CatalogPartitionSpec - posted by Jun Zhang <zh...@gmail.com> on 2021/01/05 05:42:58 UTC, 4 replies.
- [Discussion] Let catalog manage temporary catalog objects - posted by Rui Li <li...@gmail.com> on 2021/01/05 05:51:22 UTC, 0 replies.
- [jira] [Created] (FLINK-20848) Kafka consumer ID is not specified correctly in new KafkaSource - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/01/05 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/01/05 07:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished - posted by Arvid Heise <ar...@ververica.com> on 2021/01/05 09:16:14 UTC, 27 replies.
- [PSA] Configure "Save Actions" only for Java files - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/05 09:59:09 UTC, 1 replies.
- [CVE-2020-17518] Apache Flink directory traversal attack: remote file writing through the REST API - posted by Robert Metzger <rm...@apache.org> on 2021/01/05 11:13:20 UTC, 0 replies.
- [CVE-2020-17519] Apache Flink directory traversal attack: reading remote files through the REST API - posted by Robert Metzger <rm...@apache.org> on 2021/01/05 11:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-20850) Analyze whether CoLocationConstraints and CoLocationGroup can be removed - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/05 11:21:00 UTC, 0 replies.
- Apache Pinot Sink - posted by "Poerschke, Mats" <Ma...@student.hpi.uni-potsdam.de> on 2021/01/05 12:21:13 UTC, 9 replies.
- [jira] [Created] (FLINK-20851) flink datagen produce NULL value - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2021/01/05 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20852) Enrich back pressure stats per subtask in the WebUI - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/01/05 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord - posted by "hailong wang (Jira)" <ji...@apache.org> on 2021/01/05 14:15:00 UTC, 0 replies.
- Re: [DISCUSS] Drop Scala 2.11 - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/05 15:01:49 UTC, 1 replies.
- [jira] [Created] (FLINK-20854) Introduce BytesMultiMap to support buffering records - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/05 15:12:00 UTC, 0 replies.
- Re: [ANNOUNCE] Weekly Community Update 2020/44-45 - posted by chohan <ch...@stripe.com.INVALID> on 2021/01/05 23:36:11 UTC, 0 replies.
- [jira] [Created] (FLINK-20855) Calculating numBuckets exceeds the maximum value of int and got a negative number - posted by "JieFang.He (Jira)" <ji...@apache.org> on 2021/01/06 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20856) Separate the implementation of stream window aggregate nodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/06 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20857) Separate the implementation of batch window aggregate nodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/06 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20858) Port StreamExecPythonGroupWindowAggregate and BatchExecPythonGroupWindowAggregate to Java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/06 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20859) java.lang.NoClassDefFoundError: org/apache/parquet/avro/AvroParquetWriter - posted by "jack sun (Jira)" <ji...@apache.org> on 2021/01/06 03:16:00 UTC, 0 replies.
- [VOTE] FLIP-153: Support state access in Python DataStream API - posted by Shuiqiang Chen <ac...@gmail.com> on 2021/01/06 05:12:36 UTC, 7 replies.
- [jira] [Created] (FLINK-20860) Allow streaming operators to use managed memory - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/06 05:45:00 UTC, 0 replies.
- Task scheduling of Flink - posted by "penguin." <bx...@126.com> on 2021/01/06 05:57:44 UTC, 4 replies.
- [jira] [Created] (FLINK-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation - posted by "Q Kang (Jira)" <ji...@apache.org> on 2021/01/06 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20862) Add a converter from TypeInformation to DataType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/06 09:00:22 UTC, 0 replies.
- [jira] [Created] (FLINK-20863) Exclude network memory from ResourceProfile - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/06 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20864) Apply exact matching rules in fulfilling resource requirement with slot resource - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/06 09:39:00 UTC, 0 replies.
- Re: [DISCUSS][FLINK-20726] Introduce Pulsar connector - posted by Sijie Guo <sg...@streamnative.io.INVALID> on 2021/01/06 10:28:16 UTC, 4 replies.
- [jira] [Created] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/06 10:43:00 UTC, 0 replies.
- Re: [VOTE] Release 1.12.1, release candidate #1 - posted by Robert Metzger <rm...@apache.org> on 2021/01/06 11:35:14 UTC, 2 replies.
- [jira] [Created] (FLINK-20866) Add how to list jobs in Yarn deployment documentation when HA enabled - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/01/06 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20867) support ship files from local/remote path to k8s pod - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2021/01/06 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20868) Pause the idle/back pressure timers during processing mailbox actions - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/01/06 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20869) Support TIMESTAMP WITH TIME ZONE - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/06 17:39:00 UTC, 0 replies.
- Is development in FlinkML still active? - posted by Badrul Chowdhury <ba...@gmail.com> on 2021/01/06 18:09:28 UTC, 6 replies.
- [jira] [Created] (FLINK-20870) FlinkKafkaSink - posted by "xx chai (Jira)" <ji...@apache.org> on 2021/01/07 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20871) Make DataStream#executeAndCollectWithClient public - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2021/01/07 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled - posted by "Liu (Jira)" <ji...@apache.org> on 2021/01/07 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20874) Python DataStreamTests.test_key_by_on_connect_stream test failed with "ArrayIndexOutOfBoundsException" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/07 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20873) Upgrade Calcite version to 1.27 - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/07 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20875) Could patch CVE-2020-17518 to version 1.10 - posted by "Wong Mulan (Jira)" <ji...@apache.org> on 2021/01/07 02:56:00 UTC, 0 replies.
- [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements - posted by Yangze Guo <ka...@gmail.com> on 2021/01/07 03:07:39 UTC, 21 replies.
- [jira] [Created] (FLINK-20876) Separate the implementation of StreamExecTemporalJoin - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/01/07 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20877) Refactor BytesHashMap and BytesMultiMap to support window key - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/07 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20878) Flink 1.12作业job Name修改 - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/01/07 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20879) Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/07 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20880) Turn Json String into Row - posted by "tonychan (Jira)" <ji...@apache.org> on 2021/01/07 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20881) flink sql and flink sink must be run in one stream - posted by "donglei (Jira)" <ji...@apache.org> on 2021/01/07 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20882) Add better error message for illegal import checks - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/07 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20883) Separate the implementation of BatchExecOverAggregate and StreamExecOverAggregate - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/07 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20884) NullPointerException in create statements with computed columns which the subQuery is SqlNodeList - posted by "allan.hou (Jira)" <ji...@apache.org> on 2021/01/07 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/07 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2021/01/07 11:25:00 UTC, 0 replies.
- [DISCUSS] Backport broadcast operations in BATCH mode to Flink - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/07 11:39:23 UTC, 4 replies.
- [jira] [Created] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/01/07 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close() - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/07 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20889) How does flink 1.12 support modifying jobName - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/01/07 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20890) flink-state-processor-api: differents serializers being taken from Flink & State processor api - posted by "Felipe Silvestre Santos de Morais (Jira)" <ji...@apache.org> on 2021/01/07 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20891) SystemResourcesCounterTest may caused endless loop when some error occured - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/01/07 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20892) Remove ScheduledUnit interface - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/07 14:09:00 UTC, 0 replies.
- Kafka producer exactly once - posted by Pramod Immaneni <pr...@apache.org> on 2021/01/07 22:17:00 UTC, 5 replies.
- About JobMananger metrics scope - posted by Lu Niu <qq...@gmail.com> on 2021/01/07 22:58:33 UTC, 1 replies.
- [jira] [Created] (FLINK-20893) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel test failed with "TestTimedOutException" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/08 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20894) [Local Agg Pushdown] Introduce SupportsAggregatePushDown interface - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2021/01/08 09:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20895) [Local Agg Pushdown] Support LocalAggregatePushDown in Blink planner - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2021/01/08 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20896) [Local Agg Pushdown] Support SupportsAggregatePushDown for JDBC TableSource - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2021/01/08 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20897) Support DataStream batch mode in StreamTableEnvironment - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/08 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20898) Code of BatchExpand & LocalNoGroupingAggregateWithoutKeys grows beyond 64 KB - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2021/01/08 10:51:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-150: Introduce Hybrid Source - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/08 12:07:04 UTC, 0 replies.
- [jira] [Created] (FLINK-20899) encounter ClassCastException when calculating cost in HepPlanner - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/08 12:12:00 UTC, 0 replies.
- Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/08 12:23:17 UTC, 2 replies.
- [jira] [Created] (FLINK-20900) Extend documentation guidelines to cover formatting of commands - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/08 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20901) Introduce DeclarativeSlotPool methods to set resource requirements to absolute values - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/08 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20902) Please remove my email id - posted by "Suryanarayana Murthy Maganti (Jira)" <ji...@apache.org> on 2021/01/08 14:45:00 UTC, 0 replies.
- Core limit exceeded in GridGain Control Center - posted by Carsten <ca...@ccmanalysis.de> on 2021/01/08 14:53:01 UTC, 2 replies.
- [jira] [Created] (FLINK-20903) Remove SchedulerNG.initialize method - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/08 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20904) Maven enforce goal dependency-convergence failed on flink-avro-glue-schema-registry - posted by "Linyu Yao (Jira)" <ji...@apache.org> on 2021/01/09 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20905) Format the description of 'kubernetes.container.image' option - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2021/01/09 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20906) Update copy right year to 2021 for NOTICE files - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/01/09 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20907) Table API documentation promotes deprecated syntax - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/01/09 15:33:12 UTC, 0 replies.
- [VOTE] Release 1.12.1, release candidate #2 - posted by Xintong Song <xt...@apache.org> on 2021/01/10 01:23:25 UTC, 14 replies.
- [jira] [Created] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/10 03:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate. - posted by "Andy (Jira)" <ji...@apache.org> on 2021/01/10 04:02:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20910) Remove restriction on StreamPhysicalGroupWindowAggregate that StreamPhysicalGroupWindowAggregate only support insert-only input node - posted by "Andy (Jira)" <ji...@apache.org> on 2021/01/10 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20911) Support to modify RocksDB LOG level - posted by "fanrui (Jira)" <ji...@apache.org> on 2021/01/10 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20912) Increase Log and Metric: Time consumed by Checkpoint Restore - posted by "fanrui (Jira)" <ji...@apache.org> on 2021/01/10 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20913) Got TTransportException while querying Hive tables - posted by "Xingxing Di (Jira)" <ji...@apache.org> on 2021/01/10 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20914) Format the description of 'security.ssl.internal.session-cache-size' option - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2021/01/10 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20915) Move docker-entrypoint.sh logic into disrtibution - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/11 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20916) Typo in test for CVE-2020-17519 - posted by "nate (Jira)" <ji...@apache.org> on 2021/01/11 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20917) can not drop hive partition on flink - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/01/11 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20918) Avoid excessive flush of Hadoop output stream - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/01/11 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed. - posted by "Wu (Jira)" <ji...@apache.org> on 2021/01/11 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20920) Document how to connect to kerberized HMS - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/01/11 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20921) Support SqlTimeTypeInfo in Python DataStream - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/11 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20922) row() function cannot accpet . as arguments - posted by " Kevin Ma (Jira)" <ji...@apache.org> on 2021/01/11 07:00:16 UTC, 0 replies.
- [jira] [Created] (FLINK-20923) insert hive failed using old planner - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/01/11 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20924) Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/11 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20925) Separate the implementation of StreamExecLookup and BatchExecLookup - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/01/11 09:34:00 UTC, 0 replies.
- Re: Roadmap for Execution Mode (Batch/Streaming) and interaction with Table/SQL APIs - posted by Aljoscha Krettek <al...@apache.org> on 2021/01/11 10:29:14 UTC, 0 replies.
- [jira] [Created] (FLINK-20927) Update configuration option in YarnConfigOptions class - posted by "Ruguo Yu (Jira)" <ji...@apache.org> on 2021/01/11 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20926) Allow to read metadata for maxwell-json format - posted by "Q Kang (Jira)" <ji...@apache.org> on 2021/01/11 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/11 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20929) Add automated deployment of nightly docker images - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/11 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20930) Remove AbstractExecutionSlotAllocator - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/01/11 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20931) Remove globalModVersion from ExecutionGraph - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2021/01/11 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20932) sql client.blink streaming to make it checkpoint enabled [HOw |supported now?] - posted by "Norman He (Jira)" <ji...@apache.org> on 2021/01/11 23:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20933) Config Python Operator Use Managed Memory In Python DataStream - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/12 04:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20934) CsvFileCompactionITCase.testSingleParallelism test failure - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2021/01/12 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode - posted by "yuemeng (Jira)" <ji...@apache.org> on 2021/01/12 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20936) Improvements in custom partition extractor - posted by "zhoukui (Jira)" <ji...@apache.org> on 2021/01/12 06:54:00 UTC, 0 replies.
- [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/01/12 08:48:08 UTC, 17 replies.
- [jira] [Created] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax - posted by "wangzq (Jira)" <ji...@apache.org> on 2021/01/12 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20938) Implement Flink's own tencent COS filesystem - posted by "hayden zhou (Jira)" <ji...@apache.org> on 2021/01/12 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20939) Missing images in Docker hub - posted by "Damian G (Jira)" <ji...@apache.org> on 2021/01/12 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20940) The LOCALTIME/LOCALTIMSTAMP functions should use session time zone - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/01/12 10:35:00 UTC, 0 replies.
- [DISCUSS] Releasing Apache Flink 1.10.3 - posted by Matthias Pohl <ma...@ververica.com> on 2021/01/12 11:15:16 UTC, 7 replies.
- [jira] [Created] (FLINK-20941) Separate the implementation of StreamExecMatch - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/12 12:10:00 UTC, 0 replies.
- Compiling flink-runtime module of Flink - posted by "penguin." <bx...@126.com> on 2021/01/12 13:54:43 UTC, 1 replies.
- [jira] [Created] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/12 15:09:00 UTC, 0 replies.
- [DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn - posted by 王 杰 <ja...@Outlook.com> on 2021/01/12 15:12:22 UTC, 0 replies.
- [jira] [Created] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/12 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception - posted by "Jason Brome (Jira)" <ji...@apache.org> on 2021/01/12 21:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20945) flink hive insert heap out of memory - posted by "Bruce GAO (Jira)" <ji...@apache.org> on 2021/01/13 01:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/13 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20947) Unable to trigger Hive partition commit when use table sql to write data from Kafka into a Hive table - posted by "Weijia Xu (Jira)" <ji...@apache.org> on 2021/01/13 03:00:00 UTC, 0 replies.
- 7UUNA`SE$DZI74Y)S)T)GZB - posted by "penguin." <bx...@126.com> on 2021/01/13 05:16:47 UTC, 2 replies.
- Idea import Flink source code - posted by "penguin." <bx...@126.com> on 2021/01/13 05:18:16 UTC, 4 replies.
- [jira] [Created] (FLINK-20948) Separate the implementation of StreamExecDeduplicate - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/13 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20949) Separate the implementation of sink nodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/13 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/13 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20951) Flink SQL cli queries the partition table with hive as two fields. If the where condition does not specify all the two fields, an exception will occur - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2021/01/13 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20952) Changelog json formats should support inherit options from JSON format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/13 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20953) canal-json.table.include Supports regular or wildcard characters - posted by "wangfei (Jira)" <ji...@apache.org> on 2021/01/13 07:53:00 UTC, 0 replies.
- Re: [DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn - posted by Till Rohrmann <tr...@apache.org> on 2021/01/13 08:51:29 UTC, 2 replies.
- [jira] [Created] (FLINK-20954) Optimize State with Cross Bundle State Cache In PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/13 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27 - posted by "Moritz Manner (Jira)" <ji...@apache.org> on 2021/01/13 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20956) SQLClientSchemaRegistryITCase.testWriting unstable - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/13 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20957) StreamTaskTest.testProcessWithUnAvailableOutput unstable - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/13 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20958) Starting flink doc build script in preview mode occur version error - posted by "ZhaoLiming (Jira)" <ji...@apache.org> on 2021/01/13 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20959) How to close Apache Flink REST API - posted by "wuchangwen (Jira)" <ji...@apache.org> on 2021/01/13 10:12:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20960) Add warning in 1.12 release notes about potential corrupt data stream with unaligned checkpoint - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/01/13 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks - posted by "Yuval Itzchakov (Jira)" <ji...@apache.org> on 2021/01/13 11:13:00 UTC, 0 replies.
- InfluxDB Source Sink Connector - posted by Leon Papke <le...@student.hpi.de> on 2021/01/13 11:16:51 UTC, 2 replies.
- [jira] [Created] (FLINK-20962) Rewrite the example in 'flink-python/pyflink/shell.py' - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/13 12:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20963) Rewrite the example under 'flink-python/pyflink/table/examples' - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/13 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20964) Introduce PythonStreamGroupWindowAggregateOperator - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/13 12:44:00 UTC, 0 replies.
- [DISCUSS] Planning Flink 1.13 - posted by Dawid Wysakowicz <dw...@apache.org> on 2021/01/13 14:47:56 UTC, 15 replies.
- [DISCUSS] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo - posted by Seth Wiesman <sj...@gmail.com> on 2021/01/13 16:14:16 UTC, 14 replies.
- [jira] [Created] (FLINK-20965) BigDecimalTypeInfo can not be converted. - posted by "Wong Mulan (Jira)" <ji...@apache.org> on 2021/01/14 03:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20966) Rename StreamExecIntermediateTableScan to StreamPhysicalIntermediateTableScan - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/14 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20967) Add Documentation for hbase connector new Function - posted by "WeiNan Zhao (Jira)" <ji...@apache.org> on 2021/01/14 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20968) Remove legacy exec nodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/14 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20969) Update Scala 2.12 version to 2.12.13 - posted by "Erwan Loisant (Jira)" <ji...@apache.org> on 2021/01/14 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20970) DECIMAL(10, 0) can not be GROUP BY key. - posted by "Wong Mulan (Jira)" <ji...@apache.org> on 2021/01/14 09:08:00 UTC, 0 replies.
- 转发：flink-sql字段类型问题 - posted by 郝文强 <18...@163.com> on 2021/01/14 09:23:41 UTC, 0 replies.
- [jira] [Created] (FLINK-20971) Allow SQL expressions in Table API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/14 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData - posted by "huajiewang (Jira)" <ji...@apache.org> on 2021/01/14 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20973) failed to submit flink-on-yarn job on Windows due to error of classPath - posted by "kunnni (Jira)" <ji...@apache.org> on 2021/01/14 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20974) docker容器pyflink中stream任务取消之后会留下几个僵尸进程 - posted by "he jie (Jira)" <ji...@apache.org> on 2021/01/14 10:36:01 UTC, 0 replies.
- [jira] [Created] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/14 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20976) Unify Binary format for Keyed State savepoints - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/14 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20977) can not use `use` command to switch database - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/01/14 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20978) Implement HeapSavepointRestoreOperation - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/14 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions' - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/14 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20980) ResourceCounter#withResources accepts negative count - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/14 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20981) ArchivedExecutionGraph#createFromInitializingJob should support SUSPENDED as final state - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/14 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA - posted by "Levani Kokhreidze (Jira)" <ji...@apache.org> on 2021/01/14 20:21:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.12.1, release candidate #2 - posted by Xintong Song <xt...@apache.org> on 2021/01/15 00:48:39 UTC, 0 replies.
- [Discussion] More Deep Learning usages on Apache Flink - posted by Qing Lan <la...@live.com> on 2021/01/15 02:11:52 UTC, 3 replies.
- [jira] [Created] (FLINK-20983) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 60000milliseconds while awaiting InitProducerId - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/01/15 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20984) can not convert an array into Table - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/01/15 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20986) GenericTypeInfo equality issue - posted by "Tianshi Zhu (Jira)" <ji...@apache.org> on 2021/01/15 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20985) end the stream-job in docker container will remain some zombie processes in 1.11, these useless processes not be maked as zombie but still exist in 1.12 - posted by "he jie (Jira)" <ji...@apache.org> on 2021/01/15 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20987) Upgrade Stateful Functions to use Flink 1.12 - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/01/15 06:10:00 UTC, 0 replies.
- [DISCUSS] FLIP-158: Generalized incremental checkpoints - posted by Khachatryan Roman <kh...@gmail.com> on 2021/01/15 06:47:53 UTC, 4 replies.
- [jira] [Created] (FLINK-20988) Various resource allocation improvements for active resource managers - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/01/15 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/15 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20990) Service account property ignored for Kubernetes Standalone deployment - posted by "Damian G (Jira)" <ji...@apache.org> on 2021/01/15 09:53:00 UTC, 0 replies.
- outdated version of com.esotericsoftware.kryo - posted by "Teunissen, F.G.J. (Fred)" <Fr...@ing.com.INVALID> on 2021/01/15 10:40:58 UTC, 4 replies.
- [jira] [Created] (FLINK-20991) Create 1.12.1 official image - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/01/15 11:19:00 UTC, 0 replies.
- [DISCUSS] Dealing with deprecated and legacy code in Flink - posted by Timo Walther <tw...@apache.org> on 2021/01/15 12:55:34 UTC, 9 replies.
- [jira] [Created] (FLINK-20992) Checkpoint cleanup can kill JobMaster - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/15 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20993) Cleaning up checkpoint during shutdown may fail JM - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/15 13:09:00 UTC, 0 replies.
- [VOTE] FLIP-147: Support Checkpoint After Tasks Finished - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2021/01/15 14:55:52 UTC, 5 replies.
- [jira] [Created] (FLINK-20994) Add public method to create TableEnvironment in PyFlink - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/01/15 19:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception - posted by "Robert Cullen (Jira)" <ji...@apache.org> on 2021/01/15 19:52:00 UTC, 0 replies.
- Flink performance issue with Google Cloud Storage- (Small Parquet Files) - posted by "Sivaraman Venkataraman, Aswin Ram" <as...@sap.com> on 2021/01/15 22:32:58 UTC, 1 replies.
- [jira] [Created] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG) - posted by "Ya Xiao (Jira)" <ji...@apache.org> on 2021/01/16 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20997) YarnTestBaseTest fails due to NPE - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2021/01/16 10:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-20998) flink-raw-1.12.jar does not exist - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/01/16 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys - posted by "Svend Vanderveken (Jira)" <ji...@apache.org> on 2021/01/16 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21000) set MetricGroup in SourceCoordinatorContext - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2021/01/16 22:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join - posted by "Wu (Jira)" <ji...@apache.org> on 2021/01/17 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/17 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21003) Flink add Sink to AliyunOSS doesn't work - posted by "zhangyunyun (Jira)" <ji...@apache.org> on 2021/01/18 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21004) test_process_mode_boot.py tes hangs - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/18 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21005) Introduce new provider for unified Sink API and implement in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/18 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21007) flink sql sink 支持更新目标表的部分字段以及提供null值处理选项 - posted by "sky (Jira)" <ji...@apache.org> on 2021/01/18 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21006) HBaseTablePlanTest tests failed in haoop 3.1.3 with "java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/18 07:36:00 UTC, 0 replies.
- [ANNOUNCE] Stateful Functions Docker images are now hosted on Dockerhub at apache/flink-statefun - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/01/18 08:08:48 UTC, 0 replies.
- [jira] [Created] (FLINK-21008) ClusterEntrypoint#shutDownAsync may not be fully executed - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/01/18 09:50:00 UTC, 0 replies.
- [DISCUSS] Flink configuration from environment variables - posted by Ingo Bürk <in...@ververica.com> on 2021/01/18 10:10:39 UTC, 13 replies.
- [jira] [Created] (FLINK-21009) Can not disable certain options in Elasticsearch 7 connector - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/18 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21010) Separete the implementation of StreamExecJoin - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/01/18 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21011) Separete the implementation of StreamExecJoin - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2021/01/18 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/01/18 14:05:00 UTC, 0 replies.
- [Vote] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo - posted by Seth Wiesman <sj...@gmail.com> on 2021/01/18 14:29:13 UTC, 14 replies.
- [jira] [Created] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/18 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21014) Different timeouts for savepoints and checkpoints - posted by "Rex Remind (Jira)" <ji...@apache.org> on 2021/01/18 17:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21015) Wait for checkpoint cleanup completion during shutdown - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/18 18:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21016) Upload missing packages to PyPI for release 1.12.1 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2021/01/19 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21017) Fix missing backquote in table connectors docs - posted by "Han (Jira)" <ji...@apache.org> on 2021/01/19 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2021/01/19 03:40:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.1 released - posted by Xintong Song <xt...@apache.org> on 2021/01/19 03:53:20 UTC, 7 replies.
- [jira] [Created] (FLINK-21019) Bump Netty 4 to 4.1.58 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/01/19 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21020) Bump Jackson to 2.12.1 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/01/19 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21021) Bump Beam to 2.27.0 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/01/19 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking - posted by "Zheng WEI (Jira)" <ji...@apache.org> on 2021/01/19 06:36:01 UTC, 0 replies.
- [DISCUSS] Correct time-related function behavior in Flink SQL - posted by Leonard Xu <xb...@gmail.com> on 2021/01/19 08:22:03 UTC, 3 replies.
- [jira] [Created] (FLINK-21023) Task Manager uses the container dir of Job Manager when running flink job on yarn-cluster. - posted by "Tang Yan (Jira)" <ji...@apache.org> on 2021/01/19 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/19 08:43:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/19 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21026) Align column list specification with Hive in INSERT statement - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2021/01/19 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21027) Add isKeyValueImmutable() method to KeyedStateBackend interface - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/19 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21028) Streaming application didn't stop properly - posted by "Theo Diefenthal (Jira)" <ji...@apache.org> on 2021/01/19 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21029) Failure of shutdown lead to restart of (connected) pipeline - posted by "Theo Diefenthal (Jira)" <ji...@apache.org> on 2021/01/19 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21030) Broken job restart for job with disjoint graph - posted by "Theo Diefenthal (Jira)" <ji...@apache.org> on 2021/01/19 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21031) JobMasterStopWithSavepointIT test is not run due to wrong name - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/19 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21032) JsonFileCompactionITCase fails on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/19 14:53:00 UTC, 0 replies.
- [Announce] SQL docs are now Blink only - posted by Seth Wiesman <sj...@gmail.com> on 2021/01/19 15:29:55 UTC, 2 replies.
- [jira] [Created] (FLINK-21033) Remove PendingCheckpoint.statsCallback - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/19 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21034) Rework jemalloc switch to use an environment variable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/19 23:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21035) Deduplicate copy_plugins_if_required calls - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/19 23:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21036) Consider removing automatic configuration fo number of slots from docker - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/20 00:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21037) Deduplicate configuration logic in docker entrypoint - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/20 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21038) jobmanager.sh may misinterpret webui-port argument - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/20 00:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21039) Broken links in "dev/table/legacy_planner.zh.md" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/20 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21040) The exception of "Unknown consumerTag" may throw when RMQSource close() is called. - posted by "pcalpha (Jira)" <ji...@apache.org> on 2021/01/20 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21041) Introduce ExecNodeGraph to wrap the ExecNode topology - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/20 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21042) Correct the error in the code example in page 'aggregate-functions'. - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2021/01/20 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21043) SemanticXidGeneratorTest.testXidsUniqueAmongGenerators test failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/20 05:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21044) SemanticXidGeneratorTest.testXidsUniqueAmongGenerators test failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/20 05:11:00 UTC, 0 replies.
- [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer - posted by Kurt Young <yk...@gmail.com> on 2021/01/20 05:34:14 UTC, 27 replies.
- [jira] [Created] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax - posted by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2021/01/20 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21046) test_map_view and test_map_view_iterate test failed - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/20 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21047) Expose the correct registered/free resources information in SlotManager - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/20 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21048) Refactor documentation related to switch memory allocator - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/01/20 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21049) query_configuration.html content out date - posted by "谢波 (Jira)" <ji...@apache.org> on 2021/01/20 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21050) Add an example for complex UDFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/20 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21051) SQLClientSchemaRegistryITCase unstable with InternalServerErrorException: Status 500 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/20 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21052) Wrong FlinkKafkaProducer Constructor described in docs - posted by "akisaya (Jira)" <ji...@apache.org> on 2021/01/20 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21053) Prevent further RejectedExecutionExceptions in CheckpointCoordinator failing JM - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/20 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21054) Implement mini-batch optimized slicing window aggregate operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/20 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21055) Allow TIMESTAMP WITH LOCAL TIME ZONE (Instant) to be rowtime - posted by "Vladislav Protsenko (Jira)" <ji...@apache.org> on 2021/01/20 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21056) Streaming checkpointing is failing occasionally - posted by "Nazar Volynets (Jira)" <ji...@apache.org> on 2021/01/20 23:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21057) Streaming checkpointing with small interval leads app to hang - posted by "Nazar Volynets (Jira)" <ji...@apache.org> on 2021/01/20 23:36:00 UTC, 0 replies.
- [VOTE] Release 1.10.3, release candidate #1 - posted by Xintong Song <xt...@apache.org> on 2021/01/21 01:49:56 UTC, 8 replies.
- [jira] [Created] (FLINK-21058) The Show Partitinos command is supported under the Flink dialect to show all partitions - posted by "孙铮 (Jira)" <ji...@apache.org> on 2021/01/21 04:11:00 UTC, 0 replies.
- Re: [DISCUSS] Correct time-related function behavior in Flink SQL - posted by Kurt Young <yk...@gmail.com> on 2021/01/21 04:11:42 UTC, 2 replies.
- 回复： [DISCUSS] Correct time-related function behavior in Flink SQL - posted by zhisheng <17...@qq.com> on 2021/01/21 04:54:20 UTC, 0 replies.
- [jira] [Created] (FLINK-21059) KafkaSourceEnumerator does not honor consumer properties - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/01/21 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21060) Could not create the DispatcherResourceManagerComponent - posted by "Spongebob (Jira)" <ji...@apache.org> on 2021/01/21 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21061) Introduce RemotePersistedValue construct in Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/01/21 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21062) Meeting NPE when using the dynamic Index in elasticsearch connector - posted by "xiaozilong (Jira)" <ji...@apache.org> on 2021/01/21 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21063) ElasticsearchSinkITCase fails while setting up ES cluster - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/21 07:50:00 UTC, 0 replies.
- [DISCUSS] FLIP-161: Configuration through environment variables - posted by Ingo Bürk <in...@ververica.com> on 2021/01/21 07:57:44 UTC, 34 replies.
- [jira] [Created] (FLINK-21064) Format docs incorrectly contain "format" property - posted by "Ingo Bürk (Jira)" <ji...@apache.org> on 2021/01/21 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21065) Passing configuration from TableEnvironmentImpl to MiniCluster is not supported - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/21 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21066) Refactor the CheckpointCoordinator to compute the tasks to trigger/wait/commit dynamically - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/21 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21067) Modify the logic of computing tasks to trigger/wait/commit to consider finished tasks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/21 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21068) Add new timeout options for Elasticsearch connector - posted by "jinfeng (Jira)" <ji...@apache.org> on 2021/01/21 10:24:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21069) Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/21 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21070) Overloaded aggregate functions cause converter errors - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/21 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21071) Kubernetes e2e test failed - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/21 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21072) Refactor the SnapshotStrategy hierarchy - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/21 11:42:00 UTC, 0 replies.
- Flink Table from KeyedStream - posted by Dominik Wosiński <wo...@gmail.com> on 2021/01/21 13:37:10 UTC, 2 replies.
- [jira] [Created] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/21 14:48:00 UTC, 0 replies.
- [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior - posted by Leonard Xu <xb...@gmail.com> on 2021/01/21 15:50:54 UTC, 17 replies.
- [jira] [Created] (FLINK-21074) Document how to use the reactive mode - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/21 16:51:02 UTC, 0 replies.
- [jira] [Created] (FLINK-21075) FLIP-160: Declarative scheduler - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/21 16:59:02 UTC, 0 replies.
- [jira] [Created] (FLINK-21076) Document how to use the declarative scheduler and its limitations - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/21 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21077) Abstract SlotPool from JobManager by introducing SlotPoolService - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/21 17:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21078) Add DeclarativeSlotPoolService - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/21 18:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21079) Fink startup failed when $JAVA_HOME have space - posted by "Raghav Kumar Gautam (Jira)" <ji...@apache.org> on 2021/01/22 00:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21080) Identify JobVertex containing legacy source operators and abort checkpoint with legacy source operators partially finished - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 01:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21082) Document how to start multiple JobManagers in HA mode for Kubernetes deployment - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/01/22 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21083) Streaming write partitioned table needs to handle null partition value - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/01/22 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21084) Allows tasks to report operator subtask finish state - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21085) Refactor StreamTask hierarchy to support triggering checkpoint via RPC for non-source tasks - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21086) CheckpointBarrierHandler Insert barriers into channels received EndOfPartition - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21087) StreamTask waits for all the asynchronous step of pending checkpoint to finish - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21088) CheckpointCoordinator pass the flag about whether a operator is fully finished on recovery - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21089) Skip the execution of the fully finished operators after recovery - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21090) Enable Checkpoints after tasks finished - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21091) Support ExecNode json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/22 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21092) Introduce getJsonPlan, explainJsonPlan and executeJsonPlan in TableEnvironmentInternal - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/22 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21093) Support StreamExecTableSource json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/22 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21094) Support StreamExecSink json serialization/deserialization - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/22 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21095) Remove legacy slotmanagement profile - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/22 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21096) Introduce ExecNodeGraphJsonPlanGenerator to serialize ExecNodeGraph to json plan and deserialize json plan to ExecNodeGraph - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/22 09:59:00 UTC, 0 replies.
- [ANNOUNCE] 1.12.1 may still produce corrupted checkpoints - posted by Arvid Heise <ar...@apache.org> on 2021/01/22 11:40:32 UTC, 4 replies.
- [jira] [Created] (FLINK-21097) Introduce e2e test framework for json plan test - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/22 13:34:00 UTC, 0 replies.
- [DISCUSS] FLIP-160: Declarative scheduler - posted by Till Rohrmann <tr...@apache.org> on 2021/01/22 15:03:30 UTC, 9 replies.
- [jira] [Created] (FLINK-21098) Add SlotAllocator - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/22 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21099) Introduce JobType to distinguish between batch and streaming jobs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/22 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21100) Add DeclarativeScheduler skeleton - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/22 15:25:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21101) Set up cron job to run CI with declarative scheduler - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/22 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21102) Add ScaleUpController - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/22 15:28:00 UTC, 0 replies.
- [DISCUSS] FLIP-159: Reactive Mode - posted by Robert Metzger <rm...@apache.org> on 2021/01/22 16:41:50 UTC, 10 replies.
- [jira] [Created] (FLINK-21103) E2e tests time out on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/22 16:45:00 UTC, 0 replies.
- I want to contribute to Apache Flink - posted by nicygan <re...@163.com> on 2021/01/23 01:02:18 UTC, 1 replies.
- [jira] [Created] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException" - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/23 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21105) Rename ExecEdge to InputProperty - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/23 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/23 19:13:00 UTC, 0 replies.
- Re: [ANNOUNCE] New formatting rules are now in effect - posted by Matthias Pohl <ma...@ververica.com> on 2021/01/23 19:32:15 UTC, 4 replies.
- [jira] [Created] (FLINK-21107) Move test base classes from flink-tests to flink-test-utils - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2021/01/24 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication. - posted by "Xiaoguang Sun (Jira)" <ji...@apache.org> on 2021/01/24 15:46:00 UTC, 0 replies.
- Re: [DISCUSS] Support obtaining Hive delegation tokens when submitting application to Yarn - posted by 王 杰 <ja...@Outlook.com> on 2021/01/25 02:32:32 UTC, 0 replies.
- about flink calcite implement - posted by "laughing.sheng@qq.com" <la...@qq.com> on 2021/01/25 03:01:38 UTC, 1 replies.
- [jira] [Created] (FLINK-21109) Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/25 04:31:00 UTC, 0 replies.
- [DISCUSS] FLINK-21109: Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API - posted by Jark Wu <im...@gmail.com> on 2021/01/25 06:02:43 UTC, 1 replies.
- [jira] [Created] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/01/25 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21111) Support State access in Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2021/01/25 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21112) Add ValueState/ListState/MapState and corresponding StateDescriptors for Python DataStream API - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2021/01/25 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21113) Add State access API for KeyedStream RuntimeContext. - posted by "Shuiqiang Chen (Jira)" <ji...@apache.org> on 2021/01/25 06:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21114) Support ReducingState in Python DataStream API - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/25 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21115) Add AggregatingState and corresponding StateDescriptor for Python DataStream API - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/25 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21116) DefaultDispatcherRunnerITCase hangs on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/25 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21117) KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable failure threshold." - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/25 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21118) TPC-DS end-to-end test (Blink planner) fails with "no more allocated slots" - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/25 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21119) Building Flink Azure FS Hadoop hangs during python CI - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2021/01/25 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21120) Add support for ignore abnormal watermark - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/01/25 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21121) TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api - posted by "binguo (Jira)" <ji...@apache.org> on 2021/01/25 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21122) Update docs/ops/monitoring/checkpoint_monitoring.zh.md - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/25 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21123) Upgrade Beanutils 1.9.x to 1.9.4 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/25 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21124) Checkpoint abort RPC can be ignored in some cases - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/25 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21125) Sum or Sum0 overflow quietly - posted by "Sebastian Liu (Jira)" <ji...@apache.org> on 2021/01/25 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21126) Reconsider FLINK_PROPERTIES - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/25 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21127) Stores finished status for fully finished operators - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/25 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21128) Rethink how Kubernetes interfaces with our docker image - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/25 12:17:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21129) Long metric names cause Graphite to not store them - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/25 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21130) Add bin/ directory to PATH in docker image - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/25 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21131) Show alignment timeout in checkpoint configuration (web UI) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2021/01/25 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/01/25 15:21:02 UTC, 0 replies.
- [jira] [Created] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint - posted by "Kezhu Wang (Jira)" <ji...@apache.org> on 2021/01/25 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21134) Introduce execution mode configuration key and check for supported ClusterEntrypoint type - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/25 15:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21135) Reactive Mode: Change Declarative Scheduler to set infinite parallelism in JobGraph - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/25 15:32:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21136) Reactive Mode: Adjust timeout behavior in declarative scheduler - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/25 15:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21137) Maven plugin surefire failed due to test failure - posted by "Linyu Yao (Jira)" <ji...@apache.org> on 2021/01/25 18:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21138) KvStateServerHandler is not invoked with user code classloader - posted by "Maciej Prochniak (Jira)" <ji...@apache.org> on 2021/01/25 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21139) java.lang.AssertionError: Expected: a numeric value within <1.0E-6> of <40.0> but: <0.0> differed by <39.999999> - posted by "Ivan Serdyuk (Jira)" <ji...@apache.org> on 2021/01/25 23:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21140) Extract zip file dependencies before adding to PYTHONPATH - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/01/26 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21141) Timeout bug in data stream connect operation - posted by "HUANG Hong (Jira)" <ji...@apache.org> on 2021/01/26 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21142) Flink guava Dependence problem - posted by "YUJIANBO (Jira)" <ji...@apache.org> on 2021/01/26 05:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21143) 【runtime】flink job use the lib jars instead of the `yarn.provided.lib.dirs` config jars - posted by "zhisheng (Jira)" <ji...@apache.org> on 2021/01/26 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21144) KubernetesResourceManagerDriver#tryResetPodCreationCoolDown causes fatal error - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2021/01/26 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21145) Flink Temporal Join Hive optimization - posted by "HideOnBush (Jira)" <ji...@apache.org> on 2021/01/26 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21146) 【SQL】Flink SQL Client not support specify the queue to submit the job - posted by "zhisheng (Jira)" <ji...@apache.org> on 2021/01/26 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21147) Resuming Savepoint (file, async, no parallelism change) fails with UnknownHostException - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/26 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/26 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21149) Remove deprecated CatalogTable.getProperties - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/26 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21150) Introduce ExecEdge to connect two ExecNodes - posted by "godfrey he (Jira)" <ji...@apache.org> on 2021/01/26 12:00:03 UTC, 0 replies.
- [DISCUSS] Removal of flink-swift-fs-hadoop module - posted by Robert Metzger <rm...@apache.org> on 2021/01/26 13:11:15 UTC, 5 replies.
- [jira] [Created] (FLINK-21151) Extract common full-snapshot writer from RocksDB full-snapshot strategy - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2021/01/26 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21152) Bump flink-shaded to 13.0 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/26 15:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21153) yarn-per-job deployment target ignores yarn options - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/26 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21154) Move the shared request-reply protobuf files to a separate artifact. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/01/26 17:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21155) FileSourceTextLinesITCase.testBoundedTextFileSourceWithTaskManagerFailover does not pass - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2021/01/26 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21156) org.apache.flink.connector.jdbc.catalog.PostgresCatalogITCase Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/27 04:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21157) "Running HA per-job cluster (rocks, incremental) end-to-end test" gets stuck - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/27 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21158) wrong jjvm - posted by "pengkangjing (Jira)" <ji...@apache.org> on 2021/01/27 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21159) KafkaSourceEnumerator not sending NoMoreSplitsEvent to unassigned reader - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/01/27 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2021/01/27 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21161) Investigate Datadog OOM on timeout - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/27 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21162) FLINK SQL IF function semantic incorrect - posted by "谢波 (Jira)" <ji...@apache.org> on 2021/01/27 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21163) Python dependencies specified via CLI should not override the dependencies specified in configuration - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2021/01/27 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21164) Jar handlers don't cleanup temporarily extracted jars - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/27 12:00:18 UTC, 0 replies.
- [jira] [Created] (FLINK-21165) Timestamps/Watermarks chained erroneously with previous operator - posted by "zlzhang0122 (Jira)" <ji...@apache.org> on 2021/01/27 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21166) NullPointer in CheckpointMetricsBuilder surfacing in "Resuming Savepoint" e2e - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2021/01/27 18:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21167) Make StateTable snapshots iterable - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/27 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21168) Add support for general python group window aggregate function in Physical Rule and Node - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/28 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21169) Kafka flink-connector-base dependency should be scope compile - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2021/01/28 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21170) Add internal state hierarchy in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/28 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21171) Introduce TypedValue to the StateFun request-reply protocol - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2021/01/28 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21172) canal-json format include es field - posted by "jiabao sun (Jira)" <ji...@apache.org> on 2021/01/28 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21173) "Streaming SQL end-to-end test (Old planner)" e2e test failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/28 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808> - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/28 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21174) Optimize the performance of ResourceAllocationStrategy - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/28 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21176) Translate updates on Confluent Avro Format page - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/28 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21177) Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2021/01/28 06:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21178) Task failure will not trigger master hook's reset() - posted by "Brian Zhou (Jira)" <ji...@apache.org> on 2021/01/28 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21179) Split the base class of Python DataStream Function to 'Function' and 'RichFunction' - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/28 06:45:00 UTC, 0 replies.
- [VOTE] FLIP-159: Reactive Mode - posted by Robert Metzger <rm...@apache.org> on 2021/01/28 06:49:51 UTC, 5 replies.
- [jira] [Created] (FLINK-21180) Move the state module from 'pyflink.common' to 'pyflink.datastream' - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2021/01/28 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/01/28 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21182) Make HeapPriorityQueueStateSnapshot iterable - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/28 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21183) Support watermark for Hive streaming source - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/01/28 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21184) Support temporary table/function for hive connector - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/01/28 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21185) Introduce a new interface for catalog to listen on temporary object operations - posted by "Rui Li (Jira)" <ji...@apache.org> on 2021/01/28 09:14:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.10.3, release candidate #1 - posted by Xintong Song <xt...@apache.org> on 2021/01/28 09:20:31 UTC, 0 replies.
- [jira] [Created] (FLINK-21186) RecordWriterOutput swallows interrupt state when interrupted. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/01/28 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21187) RootException history implementation in DefaultScheduler - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/28 10:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21188) Introduce wrapper class to hold information besides ArchivedExecutionGraph - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/28 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21189) Extend exception history to collect concurrent task failure that have a common root cause - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/28 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21190) Expose extended exception history through REST handler and adapt UI accordingly - posted by "Matthias (Jira)" <ji...@apache.org> on 2021/01/28 10:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21191) Support reducing buffer for upsert-kafka sink - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2021/01/28 11:45:00 UTC, 0 replies.
- [DISCUSS]FLIP-163: SQL Client Improvements - posted by Shengkai Fang <fs...@gmail.com> on 2021/01/28 12:54:01 UTC, 6 replies.
- [jira] [Created] (FLINK-21192) Support setting namespace in RemoteKeyedStateBackend - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/28 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21193) Migrate Flink Docs to Hugo - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2021/01/28 15:05:02 UTC, 0 replies.
- [Announce] Documentation Freeze Feb 2nd - posted by Seth Wiesman <sj...@gmail.com> on 2021/01/28 15:07:21 UTC, 0 replies.
- [jira] [Created] (FLINK-21194) TaskExecutorITCase.testJobRecoveryWithFailingTaskExecutor Fail - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/29 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21195) LimitableBulkFormat is invalid when format is orc - posted by "sujun (Jira)" <ji...@apache.org> on 2021/01/29 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21196) Sensitive information(password) is not masked in configuration file - posted by "Suchithra V N (Jira)" <ji...@apache.org> on 2021/01/29 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21197) DESC command in sql-client should show the column comment - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/01/29 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21198) Add show create table command support for flink sql client - posted by "Jun Zhang (Jira)" <ji...@apache.org> on 2021/01/29 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21199) Introduce InternalTimerService In PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/29 07:02:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.10.3 released - posted by Xintong Song <xt...@apache.org> on 2021/01/29 07:05:10 UTC, 4 replies.
- [jira] [Created] (FLINK-21200) User defined functions refuse to accept multi-set arguments without type hints - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2021/01/29 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2021/01/29 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21202) Introduce TimeWindow and CountWindow in PyFlink - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2021/01/29 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction - posted by "wangpeibin (Jira)" <ji...@apache.org> on 2021/01/29 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21204) Remove LogicalSlot#getSlotSharingGroupId - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/29 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21205) Maybe remove Locality enum - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/29 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21206) Implement HeapKeyValueStateIterator - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2021/01/29 13:45:00 UTC, 0 replies.
- [VOTE] FLIP-160: Declarative scheduler - posted by Till Rohrmann <tr...@apache.org> on 2021/01/29 14:23:00 UTC, 3 replies.
- [jira] [Created] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization - posted by "sharkd tu (Jira)" <ji...@apache.org> on 2021/01/29 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21208) pyarrow exception when using window with pandas udaf - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2021/01/29 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21209) Update stackbrew maintainer field - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/29 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21210) ApplicationClusterEntryPoints should explicitly close PackagedProgram - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2021/01/29 18:40:00 UTC, 0 replies.
- [DISCUSS] FLINK-21045: Support 'load module' and 'unload module' SQL syntax - posted by Jane Chan <qi...@gmail.com> on 2021/01/29 19:59:44 UTC, 0 replies.
- [jira] [Created] (FLINK-21211) Looking for reviews on a framework based on flink-statefun - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2021/01/29 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21212) Can no longer cast INT to DATE - posted by "Rex Remind (Jira)" <ji...@apache.org> on 2021/01/30 04:32:00 UTC, 0 replies.
- Proposal to add Google Cloud Storage FileSystem with RecoverableWriter - posted by Galen Warren <ga...@cvillewarrens.com> on 2021/01/30 18:42:53 UTC, 0 replies.
- [jira] [Created] (FLINK-21213) Elasticsearch (v5.3.3) sink end-to-end test' failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21215) UnalignedCheckpointITCase.execute - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21216) StreamPandasConversionTests Fails - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 02:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-21217) Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/01/31 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-21218) "state.checkpoints.dir" should be required only when "execution.checkpointing.interval" is specified - posted by "Dongwon Kim (Jira)" <ji...@apache.org> on 2021/01/31 07:11:00 UTC, 0 replies.