[jira] [Commented] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc

[ https://issues.apache.org/jira/browse/FLINK-37906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17956526#comment-17956526 ] Weijie Guo commented on FLINK-37906: release-2.0 via bbdaf48db602107b94c0cdc7b245192

[jira] [Resolved] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc

[ https://issues.apache.org/jira/browse/FLINK-37906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37906. Resolution: Fixed > Bump kafka version to 4.0 for release-2.0 doc > --

[jira] [Assigned] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc

[ https://issues.apache.org/jira/browse/FLINK-37906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-37906: -- Assignee: Weijie Guo > Bump kafka version to 4.0 for release-2.0 doc > --

[jira] [Created] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc

Weijie Guo created FLINK-37906: -- Summary: Bump kafka version to 4.0 for release-2.0 doc Key: FLINK-37906 URL: https://issues.apache.org/jira/browse/FLINK-37906 Project: Flink Issue Type: Technic

[jira] [Comment Edited] (FLINK-37767) Update ref version for es connector

[ https://issues.apache.org/jira/browse/FLINK-37767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950836#comment-17950836 ] Weijie Guo edited comment on FLINK-37767 at 5/30/25 1:52 AM: -

[jira] [Comment Edited] (FLINK-37767) Update ref version for es connector

[ https://issues.apache.org/jira/browse/FLINK-37767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950836#comment-17950836 ] Weijie Guo edited comment on FLINK-37767 at 5/28/25 9:35 AM: -

[jira] [Closed] (FLINK-37767) Update ref version for es connector

[ https://issues.apache.org/jira/browse/FLINK-37767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-37767. -- Fix Version/s: 2.1.0 Resolution: Done master(2.1) via fc1aeb2a537e9e097111af6563e29421e1a5661b.

[jira] [Created] (FLINK-37767) Update ref version for es connector

Weijie Guo created FLINK-37767: -- Summary: Update ref version for es connector Key: FLINK-37767 URL: https://issues.apache.org/jira/browse/FLINK-37767 Project: Flink Issue Type: Technical Debt

[jira] [Assigned] (FLINK-37767) Update ref version for es connector

[ https://issues.apache.org/jira/browse/FLINK-37767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-37767: -- Assignee: Weijie Guo > Update ref version for es connector >

[jira] [Closed] (FLINK-36166) testJoinDisorderChangeLog failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-36166. -- Fix Version/s: 2.1.0 Resolution: Fixed master(2.1) via b8f8d6e602897b7f275f1db36478f5e8f1d6604e

[jira] [Updated] (FLINK-37658) Improve the Datagen connector documentation

[ https://issues.apache.org/jira/browse/FLINK-37658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37658: --- Fix Version/s: 2.1.0 > Improve the Datagen connector documentation > ---

[jira] [Resolved] (FLINK-37658) Improve the Datagen connector documentation

[ https://issues.apache.org/jira/browse/FLINK-37658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37658. Resolution: Done master(2.1) via d14c2d589433bc27d7b90ffdaa5ab5a19cc3842e. > Improve the Datagen

[jira] [Commented] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join

[ https://issues.apache.org/jira/browse/FLINK-35652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945570#comment-17945570 ] Weijie Guo commented on FLINK-35652: add doc in 3cfc211e152a3b86ec5b43e06d3343168afa

[jira] [Resolved] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37659. Resolution: Done > Flink 2.0: update reference data for Migration Tests >

[jira] [Resolved] (FLINK-37694) Update version to 4.1-SNAPSHOT for es main branch

[ https://issues.apache.org/jira/browse/FLINK-37694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37694. Fix Version/s: elasticsearch-4.1.0 Resolution: Done main(4.1) via 54eeaad9b14d39b56c4d69d11

[jira] [Closed] (FLINK-37486) Promote release 2.0

[ https://issues.apache.org/jira/browse/FLINK-37486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-37486. -- Fix Version/s: 2.0.0 Resolution: Done > Promote release 2.0 > --- > >

[jira] [Created] (FLINK-37694) Update version to 4.1-SNAPSHOT for es main branch

Weijie Guo created FLINK-37694: -- Summary: Update version to 4.1-SNAPSHOT for es main branch Key: FLINK-37694 URL: https://issues.apache.org/jira/browse/FLINK-37694 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945223#comment-17945223 ] Weijie Guo commented on FLINK-37659: master(2.1) via 7c03bc834b642ff40828739961a9a41

[jira] [Resolved] (FLINK-37675) Update elastic.yml for 3.1.0 release

[ https://issues.apache.org/jira/browse/FLINK-37675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37675. Resolution: Done v3.1 via a13cbac8dd6137ce54705591d9e898021e0db627. > Update elastic.yml for 3.1.

[jira] [Updated] (FLINK-37675) Update elastic.yml for 3.1.0 release

[ https://issues.apache.org/jira/browse/FLINK-37675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37675: --- Fix Version/s: elasticsearch-3.1.0 > Update elastic.yml for 3.1.0 release >

[jira] [Assigned] (FLINK-37636) Weekly CI failure

[ https://issues.apache.org/jira/browse/FLINK-37636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-37636: -- Assignee: Yanquan Lv > Weekly CI failure > -- > > Key: FLINK

[jira] [Resolved] (FLINK-37636) Weekly CI failure

[ https://issues.apache.org/jira/browse/FLINK-37636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37636. Fix Version/s: elasticsearch-4.1.0 Resolution: Done main(4.1) via dbcc2412e1d9ffaff0bdcaf39

[jira] [Created] (FLINK-37675) Update elastic.yml for 3.1.0 release

Weijie Guo created FLINK-37675: -- Summary: Update elastic.yml for 3.1.0 release Key: FLINK-37675 URL: https://issues.apache.org/jira/browse/FLINK-37675 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-37658) Improve the Datagen connector documentation

[ https://issues.apache.org/jira/browse/FLINK-37658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17944009#comment-17944009 ] Weijie Guo commented on FLINK-37658: Thanks [~davidradl], you are assigned. > Impro

[jira] [Resolved] (FLINK-37649) Datagen connector cannot set length for collection type

[ https://issues.apache.org/jira/browse/FLINK-37649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-37649. Fix Version/s: 2.1.0 Resolution: Fixed master(2.1) via 03bea48ad3beb1edb89b677e1fb69a1c5d86

[jira] [Assigned] (FLINK-37658) Improve the Datagen connector documentation

[ https://issues.apache.org/jira/browse/FLINK-37658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-37658: -- Assignee: david radley > Improve the Datagen connector documentation > --

[jira] [Created] (FLINK-37649) Datagen connector cannot set length for collection type

Weijie Guo created FLINK-37649: -- Summary: Datagen connector cannot set length for collection type Key: FLINK-37649 URL: https://issues.apache.org/jira/browse/FLINK-37649 Project: Flink Issue Typ

[jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type

[ https://issues.apache.org/jira/browse/FLINK-37649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37649: --- Description: I use the following DDL to generate collection type data: {code:java} CREATE TABLE Ord

[jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type

[ https://issues.apache.org/jira/browse/FLINK-37649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37649: --- Description: I use the following DDL to generate collection type data: {code:java} CREATE TABLE Ord

[jira] [Updated] (FLINK-37649) Datagen connector cannot set length for collection type

[ https://issues.apache.org/jira/browse/FLINK-37649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37649: --- Description: I use the following DDL to generate collection type data: {code:java} {code} {code

[jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider

[ https://issues.apache.org/jira/browse/FLINK-23900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-23900: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Migrate to ClusterActorRefProvider >

[jira] [Updated] (FLINK-32184) Use revision version property

[ https://issues.apache.org/jira/browse/FLINK-32184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32184: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Use revision version property > -

[jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module

[ https://issues.apache.org/jira/browse/FLINK-20572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20572: --- Affects Version/s: 2.1.0 > HiveCatalog should be a standalone module > -

[jira] [Updated] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase

[ https://issues.apache.org/jira/browse/FLINK-27455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-27455: --- Fix Version/s: 2.1.0 (was: 2.0.0) > [JUnit5 Migration] SnapshotMigrationTestB

[jira] [Updated] (FLINK-35326) Implement lineage interface for hive connector

[ https://issues.apache.org/jira/browse/FLINK-35326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35326: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Implement lineage interface for

[jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33558: --- Affects Version/s: 2.1.0 (was: 1.18.0) > Externalize Elasticsearch Python

[jira] [Updated] (FLINK-28830) new stack udtf doesn't support atomic type

[ https://issues.apache.org/jira/browse/FLINK-28830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28830: --- Affects Version/s: 2.1.0 (was: 1.16.0) > new stack udtf doesn't support a

[jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade

[ https://issues.apache.org/jira/browse/FLINK-36911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36911: --- Fix Version/s: 2.1.0 (was: 2.0.0) > add more calcite rules to improve flink p

[jira] [Updated] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32444: --- Affects Version/s: 2.1.0 > Enable object reuse for Flink SQL jobs by default > -

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-17784: --- Affects Version/s: (was: 2.1.0) > Better detection for parquet and orc in hive > ---

[jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective

[ https://issues.apache.org/jira/browse/FLINK-30467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30467: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Improve the accuracy of estimating the ro

[jira] [Updated] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally

[ https://issues.apache.org/jira/browse/FLINK-34665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34665: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Add streaming rule for union to

[jira] [Updated] (FLINK-34033) flink json supports raw type

[ https://issues.apache.org/jira/browse/FLINK-34033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34033: --- Fix Version/s: 2.1.0 (was: 2.0.0) > flink json supports raw type > -

[jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish

[ https://issues.apache.org/jira/browse/FLINK-19425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-19425: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Correct the usage of BulkWriter#flush and

[jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client

[ https://issues.apache.org/jira/browse/FLINK-32699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32699: --- Affects Version/s: 2.1.0 (was: 1.18.0) > select typeof(proctime()); throw

[jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-16774: --- Fix Version/s: 2.1.0 (was: 2.0.0) > expose HBaseUpsertSinkFunction hTableName

[jira] [Updated] (FLINK-34604) Migrate BatchPhysicalCalcRule

[ https://issues.apache.org/jira/browse/FLINK-34604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34604: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Migrate BatchPhysicalCalcRule >

[jira] [Updated] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown

[ https://issues.apache.org/jira/browse/FLINK-35737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35737: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Prevent Memory Leak by Closing MemoryExec

[jira] [Updated] (FLINK-30738) Disable verbose mode

[ https://issues.apache.org/jira/browse/FLINK-30738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30738: --- Affects Version/s: 2.1.0 > Disable verbose mode > > > Key: FLIN

[jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-16126: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Translate all connector related pages int

[jira] [Updated] (FLINK-26927) Improve FlinkContainers to better support JM restarting

[ https://issues.apache.org/jira/browse/FLINK-26927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26927: --- Affects Version/s: 2.1.0 (was: 1.16.0) > Improve FlinkContainers to bette

[jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15729: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Table planner dependency instructions for

[jira] [Updated] (FLINK-29551) Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions

[ https://issues.apache.org/jira/browse/FLINK-29551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29551: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Improving adaptive hash join by using sor

[jira] [Updated] (FLINK-12590) Replace http links in documentation

[ https://issues.apache.org/jira/browse/FLINK-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-12590: --- Affects Version/s: 2.1.0 (was: 1.8.0) (was: 1.9

[jira] [Updated] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule

[ https://issues.apache.org/jira/browse/FLINK-36988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36988: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Migrate LogicalCorrelateToJoinFromTempora

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-22607: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Examples use deprecated AscendingTimestam

[jira] [Updated] (FLINK-32537) Add compatibility annotation for REST API classes

[ https://issues.apache.org/jira/browse/FLINK-32537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32537: --- Affects Version/s: 2.1.0 (was: 1.16.2) (was: 1.

[jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected

[ https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30821: --- Affects Version/s: 2.1.0 (was: 1.16.0) (was: 1.

[jira] [Updated] (FLINK-35327) SQL Explain show push down condition

[ https://issues.apache.org/jira/browse/FLINK-35327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35327: --- Fix Version/s: 2.1.0 (was: 2.0.0) > SQL Explain show push down condition > -

[jira] [Updated] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule

[ https://issues.apache.org/jira/browse/FLINK-34609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34609: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Migrate BatchPhysicalScriptTrans

[jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34380: --- Affects Version/s: 1.19.0 (was: 2.1.0) > Strange RowKind and records abou

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20484: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Improve hive temporal table exception >

[jira] [Updated] (FLINK-37463) Make ForStMapState Serializer ThreadLocal

[ https://issues.apache.org/jira/browse/FLINK-37463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37463: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Make ForStMapState Serializer ThreadLocal

[jira] [Updated] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent.

[ https://issues.apache.org/jira/browse/FLINK-37103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37103: --- Affects Version/s: 2.1.0 (was: 2.0.0) > The argument lists of the method

[jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-25291: --- Affects Version/s: 2.1.0 > Add failure cases in DataStream source and sink suite of connector testin

[jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES

[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21126: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Reconsider FLINK_PROPERTIES > ---

[jira] [Updated] (FLINK-29003) sqlServerDialect should support limit clause

[ https://issues.apache.org/jira/browse/FLINK-29003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29003: --- Affects Version/s: 2.1.0 (was: 1.16.0) > sqlServerDialect should support

[jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26559: --- Affects Version/s: (was: 2.1.0) > Support Customized Kubernetes Schedulers for Flink Kubernetes

[jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system

[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33950: --- Affects Version/s: 2.1.0 (was: 1.19.0) > Update max aggregate functions t

[jira] [Updated] (FLINK-34605) Migrate BatchPhysicalDistributionRule

[ https://issues.apache.org/jira/browse/FLINK-34605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34605: --- Affects Version/s: 2.1.0 (was: 1.20.0) > Migrate BatchPhysicalDistributio

[jira] [Updated] (FLINK-32603) Avoid consuming twice when two pipelines have the same table source

[ https://issues.apache.org/jira/browse/FLINK-32603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32603: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Avoid consuming twice when two pipelines

[jira] [Updated] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34487: --- Affects Version/s: 2.1.0 (was: 1.19.0) (was: 1.

[jira] [Created] (FLINK-37500) CLONE - Publish the Dockerfiles for the new release

Weijie Guo created FLINK-37500: -- Summary: CLONE - Publish the Dockerfiles for the new release Key: FLINK-37500 URL: https://issues.apache.org/jira/browse/FLINK-37500 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-28109) Delete useful code in the row emitter.

[ https://issues.apache.org/jira/browse/FLINK-28109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28109: --- Affects Version/s: 1.15.0 (was: 2.1.0) > Delete useful code in the row em

[jira] [Updated] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators

[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24666: --- Affects Version/s: 2.1.0 (was: 1.14.0) (was: 1.

[jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs

[ https://issues.apache.org/jira/browse/FLINK-19263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-19263: --- Affects Version/s: 2.1.0 > Enforce alphabetical order in configuration option docs > ---

[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-17362: --- Affects Version/s: 2.1.0 > Improve table examples to reflect latest status > ---

[jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value

[ https://issues.apache.org/jira/browse/FLINK-29058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29058: --- Affects Version/s: 2.1.0 (was: 1.16.0) > Analyze table xxx For columns wi

[jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-25291: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Add failure cases in DataStream source an

[jira] [Updated] (FLINK-37576) Batch job failed when submit JobGraph contains broadcast edge

[ https://issues.apache.org/jira/browse/FLINK-37576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37576: --- Description: {code:java} public class TestJob { public static void main(String[] args) throws Ex

[jira] [Updated] (FLINK-29240) Unify the ClassLoader in StreamExecutionEnvironment and TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29240: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Unify the ClassLoader in StreamExecutionE

[jira] [Updated] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream`

[ https://issues.apache.org/jira/browse/FLINK-36488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36488: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Remove deprecated method `StreamTableEnvi

[jira] [Updated] (FLINK-24901) Some further improvements of the pluggable shuffle framework

[ https://issues.apache.org/jira/browse/FLINK-24901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24901: --- Affects Version/s: 2.1.0 > Some further improvements of the pluggable shuffle framework > --

[jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

[ https://issues.apache.org/jira/browse/FLINK-26003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26003: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Use Jackson serialization for persisting

[jira] [Updated] (FLINK-35206) Desc table syntax support materialized table

[ https://issues.apache.org/jira/browse/FLINK-35206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35206: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Desc table syntax support materialized ta

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15471: --- Affects Version/s: 2.1.0 (was: 1.9.0) > HA e2e check for empty .out files

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20457: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Fix the handling of timestamp in DataStre

[jira] [Updated] (FLINK-30284) Make datadog reporter url configurable

[ https://issues.apache.org/jira/browse/FLINK-30284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30284: --- Affects Version/s: 2.1.0 > Make datadog reporter url configurable >

[jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

[ https://issues.apache.org/jira/browse/FLINK-32535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32535: --- Fix Version/s: 2.1.0 (was: 2.0.0) > CheckpointingStatisticsHandler periodical

[jira] [Updated] (FLINK-30292) Better support for conversion between DataType and TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30292: --- Affects Version/s: 1.15.3 (was: 2.1.0) > Better support for conversion be

[jira] [Updated] (FLINK-37032) Prepare Flink 2.0 Release

[ https://issues.apache.org/jira/browse/FLINK-37032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-37032: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Prepare Flink 2.0 Release > -

[jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24757: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Yarn application is not terminated after

[jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected

[ https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30821: --- Fix Version/s: 2.1.0 (was: 2.0.0) > The optimized exec plan generated by > O

[jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-19362: --- Affects Version/s: 2.1.0 (was: 1.11.0) > Remove confusing comment for `DO

[jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-19038: --- Fix Version/s: 2.1.0 (was: 2.0.0) > It doesn't support to call Table.limit()

[jira] [Updated] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`

[ https://issues.apache.org/jira/browse/FLINK-36495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36495: --- Affects Version/s: 2.1.0 > Remove deprecated method `CatalogBaseTable#getSchema` > -

[jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image

[ https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24237: --- Fix Version/s: 2.1.0 (was: 2.0.0) > Consider disabling or lowering DNS cachin

[jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing

[ https://issues.apache.org/jira/browse/FLINK-15645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15645: --- Affects Version/s: 2.1.0 > enable COPY TO/FROM in Postgres JDBC source/sink for faster batch process

[jira] [Updated] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

[ https://issues.apache.org/jira/browse/FLINK-29775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29775: --- Affects Version/s: 2.1.0 > [JUnit5 Migration] Module: flink-statebackend-rocksdb > -

[jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes

[ https://issues.apache.org/jira/browse/FLINK-25350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-25350: --- Affects Version/s: 1.15.0 (was: 2.1.0) > Verify stability guarantees of a

  1   2   3   4   5   6   7   8   9   10   >