[jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

[ https://issues.apache.org/jira/browse/FLINK-36631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36631: -- Fix Version/s: cdc-3.4.0 > Supports reading incremental data from Oracle from a specified SCN > --

[jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields

[ https://issues.apache.org/jira/browse/FLINK-36813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36813: -- Description: *Background* In some scenarios, MySQL synchronization only expects to synchronize specified fiel

[jira] [Created] (FLINK-36813) MySQLCDC supports synchronization of specified fields

Di Wu created FLINK-36813: - Summary: MySQLCDC supports synchronization of specified fields Key: FLINK-36813 URL: https://issues.apache.org/jira/browse/FLINK-36813 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-36790) Flink CDC to Paimon: DeletionVectorsMaintainer CME problem

Rascal Wu created FLINK-36790: - Summary: Flink CDC to Paimon: DeletionVectorsMaintainer CME problem Key: FLINK-36790 URL: https://issues.apache.org/jira/browse/FLINK-36790 Project: Flink Issue Ty

[jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive

[ https://issues.apache.org/jira/browse/FLINK-36736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-36736: Priority: Critical (was: Major) > DynamicTableSink.Context#getTargetColumns should contains all the colum

[jira] [Commented] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive

[ https://issues.apache.org/jira/browse/FLINK-36736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898870#comment-17898870 ] Jark Wu commented on FLINK-36736: - cc [~lincoln.86xy] > DynamicTableSink.Context#getTar

[jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns

[ https://issues.apache.org/jira/browse/FLINK-36735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-36735: Priority: Critical (was: Major) > SupportsRowLevelUpdate gives sink only the values of required columns w

[jira] [Commented] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns

[ https://issues.apache.org/jira/browse/FLINK-36735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898869#comment-17898869 ] Jark Wu commented on FLINK-36735: - cc [~lincoln.86xy] > SupportsRowLevelUpdate gives si

[jira] [Created] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive

Jark Wu created FLINK-36736: --- Summary: DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive Key: FLINK-36736 URL: https://issues.apache.org/jira/browse/FLINK-36736

[jira] [Created] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns

Jark Wu created FLINK-36735: --- Summary: SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns Key: FLINK-36735 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-36709) Flink parquet will throw exception when reading nested row data with last column is array.

Wenchao Wu created FLINK-36709: -- Summary: Flink parquet will throw exception when reading nested row data with last column is array. Key: FLINK-36709 URL: https://issues.apache.org/jira/browse/FLINK-36709

[jira] [Commented] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897140#comment-17897140 ] Di Wu commented on FLINK-36687: --- This has been resolved here https://github.com/apache/fli

[jira] [Closed] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu closed FLINK-36687. - Resolution: Resolved > Improve Doris Pipeline Connector Version to 24.0.1 >

[jira] [Commented] (FLINK-36397) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

[ https://issues.apache.org/jira/browse/FLINK-36397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897115#comment-17897115 ] Di Wu commented on FLINK-36397: --- In snapshotreader, the data from lw to hw will be replaye

[jira] [Updated] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36687: -- Description: Improve Doris Pipeline Connector Version to 24.0.1, Related release note  [apache/doris-flink-con

[jira] [Updated] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36687: -- Description: Update Doris Pipeline Connector Version to 24.0.1 Improve Doris Pipeline Connector Version to 24

[jira] [Created] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

Di Wu created FLINK-36687: - Summary: Improve Doris Pipeline Connector Version to 24.0.1 Key: FLINK-36687 URL: https://issues.apache.org/jira/browse/FLINK-36687 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Description: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed.   {code

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Description: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed.     >

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Fix Version/s: 3.0.0 > Oracle When reading via OracleIncrementalSource, the connection is > occasionally clos

[jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

[ https://issues.apache.org/jira/browse/FLINK-36631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36631: -- Affects Version/s: cdc-3.1.1 cdc-3.2.0 cdc-3.1.0

[jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

Di Wu created FLINK-36649: - Summary: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed Key: FLINK-36649 URL: https://issues.apache.org/jira/browse/FLINK-36649 Project: Fli

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Affects Version/s: cdc-3.1.1 cdc-3.2.0 cdc-3.3.0 > Oracle When r

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Fix Version/s: (was: cdc-3.3.0) > Oracle When reading via OracleIncrementalSource, the connection is > oc

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Description: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed.   {code

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Fix Version/s: cdc-3.3.0 (was: 3.0.0) > Oracle When reading via OracleIncrementalSource

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Labels: CDC (was: ) > Oracle When reading via OracleIncrementalSource, the connection is > occasionally clos

[jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

Di Wu created FLINK-36631: - Summary: Supports reading incremental data from Oracle from a specified SCN Key: FLINK-36631 URL: https://issues.apache.org/jira/browse/FLINK-36631 Project: Flink Issue T

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884214#comment-17884214 ] Jark Wu commented on FLINK-29739: - +1 for the approach proposed by [~xuyangzhong]. Besid

[jira] [Commented] (FLINK-36004) Flink SQL returns wrong results for Paimon tables with complex schemas

[ https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872257#comment-17872257 ] Jark Wu commented on FLINK-36004: - [~xuyangzhong] could you help have a look at this iss

[jira] [Closed] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-35877. --- Resolution: Fixed This is fixed on master: 68d8174c996f05b2fbf9c50d0220a72f29e3a56b > Shade protobuf in fli

[jira] [Assigned] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-35877: --- Assignee: zhuanshenbsj1 > Shade protobuf in flink > --- > > Key

[jira] [Updated] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-35877: Fix Version/s: 2.0.0 (was: 1.19.2) > Shade protobuf in flink >

[jira] [Updated] (FLINK-35877) Shade protobuf in flink

[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-35877: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) (was: BuildSystem / Shad

[jira] [Created] (FLINK-35842) Change the FlinkCDC dependency to 3.1.x

Di Wu created FLINK-35842: - Summary: Change the FlinkCDC dependency to 3.1.x Key: FLINK-35842 URL: https://issues.apache.org/jira/browse/FLINK-35842 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-35841) Change package name to org.apache.flink

Di Wu created FLINK-35841: - Summary: Change package name to org.apache.flink Key: FLINK-35841 URL: https://issues.apache.org/jira/browse/FLINK-35841 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-35840) Add documentation for Doris

Di Wu created FLINK-35840: - Summary: Add documentation for Doris Key: FLINK-35840 URL: https://issues.apache.org/jira/browse/FLINK-35840 Project: Flink Issue Type: Sub-task Reporter: Di W

[jira] [Created] (FLINK-35839) Migrate repo from apache/doris to apache/flink

Di Wu created FLINK-35839: - Summary: Migrate repo from apache/doris to apache/flink Key: FLINK-35839 URL: https://issues.apache.org/jira/browse/FLINK-35839 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35838) FLIP-399: Flink Connector Doris

Di Wu created FLINK-35838: - Summary: FLIP-399: Flink Connector Doris Key: FLINK-35838 URL: https://issues.apache.org/jira/browse/FLINK-35838 Project: Flink Issue Type: New Feature Reporte

[jira] [Commented] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864228#comment-17864228 ] Wenchao Wu commented on FLINK-35753: Hello [~Weijie Guo],  I pull the newest master

[jira] [Commented] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864048#comment-17864048 ] Wenchao Wu commented on FLINK-35753: OK, I will check it > ParquetColumnarRowInputF

[jira] [Commented] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863754#comment-17863754 ] Wenchao Wu commented on FLINK-35753: Run test alone and install in my local, can not

[jira] [Created] (FLINK-35702) Support Parquet Nested Read

Wenchao Wu created FLINK-35702: -- Summary: Support Parquet Nested Read Key: FLINK-35702 URL: https://issues.apache.org/jira/browse/FLINK-35702 Project: Flink Issue Type: New Feature Com

[jira] [Updated] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

[ https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-35600: -- Description: Assume that the table has been split into 3 Chunks Timeline t1: chunk1 is read t2: a piece of da

[jira] [Created] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

Di Wu created FLINK-35600: - Summary: Data read duplication during the full-to-incremental conversion phase Key: FLINK-35600 URL: https://issues.apache.org/jira/browse/FLINK-35600 Project: Flink Issu

[jira] [Updated] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner via init Context

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-35384: --- Summary: Expose TaskIOMetricGroup to custom Partitioner via init Context (was: Expose TaskI

[jira] [Comment Edited] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847116#comment-17847116 ] Steven Zhen Wu edited comment on FLINK-35384 at 5/17/24 12:06 AM:

[jira] [Commented] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847116#comment-17847116 ] Steven Zhen Wu commented on FLINK-35384: one potential risk of this type of API

[jira] [Updated] (FLINK-35384) Expose TaskIOMetricGroup to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-35384: --- Summary: Expose TaskIOMetricGroup to custom Partitioner (was: Expose metrics group to custo

[jira] [Updated] (FLINK-35384) Expose metrics group to custom Partitioner

[ https://issues.apache.org/jira/browse/FLINK-35384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-35384: --- Description: I am trying to implement a custom range partitioner in the Flink Iceberg sink.

[jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner

Steven Zhen Wu created FLINK-35384: -- Summary: Expose metrics group to custom Partitioner Key: FLINK-35384 URL: https://issues.apache.org/jira/browse/FLINK-35384 Project: Flink Issue Type: Im

[jira] [Assigned] (FLINK-35353) Translate "Profiler" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-35353: --- Assignee: Juan Zifeng > Translate "Profiler" page into Chinese > -

[jira] [Assigned] (FLINK-20400) Migrate test_streaming_sql.sh

[ https://issues.apache.org/jira/browse/FLINK-20400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20400: --- Assignee: Muhammet Orazov > Migrate test_streaming_sql.sh > - > >

[jira] [Comment Edited] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834844#comment-17834844 ] Jark Wu edited comment on FLINK-33934 at 4/8/24 8:31 AM: - [~yunt

[jira] [Commented] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834844#comment-17834844 ] Jark Wu commented on FLINK-33934: - [~yunta] yes, I think the row format should avoid reu

[jira] [Created] (FLINK-34654) Add "Special Thanks" Page on the Flink Website

Jark Wu created FLINK-34654: --- Summary: Add "Special Thanks" Page on the Flink Website Key: FLINK-34654 URL: https://issues.apache.org/jira/browse/FLINK-34654 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-20399) Migrate test_sql_client.sh

[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20399. --- Assignee: (was: Lorenzo Affetti) Resolution: Fixed > Migrate test_sql_client.sh >

[jira] [Commented] (FLINK-20399) Migrate test_sql_client.sh

[ https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823859#comment-17823859 ] Jark Wu commented on FLINK-20399: - [~lorenzo.affetti] Yes, I think so. Thank you for the

[jira] [Commented] (FLINK-34214) FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811142#comment-17811142 ] Rascal Wu commented on FLINK-34214: --- Hi, may i consulting one question that if we disa

[jira] [Commented] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810723#comment-17810723 ] Jark Wu commented on FLINK-34147: - I agree it is ambiguous. Currently, {{TimestampData}}

[jira] [Assigned] (FLINK-27331) Support Avro microsecond precision for TIME

[ https://issues.apache.org/jira/browse/FLINK-27331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27331: --- Assignee: Peter Huang > Support Avro microsecond precision for TIME > -

[jira] [Assigned] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24939: --- Assignee: Yubin Li > Support 'SHOW CREATE CATALOG' syntax > >

[jira] [Assigned] (FLINK-20281) Window aggregation supports changelog stream input

[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20281: --- Assignee: xuyang > Window aggregation supports changelog stream input > ---

[jira] [Created] (FLINK-33600) Print cost time for batch queries in SQL Client

Jark Wu created FLINK-33600: --- Summary: Print cost time for batch queries in SQL Client Key: FLINK-33600 URL: https://issues.apache.org/jira/browse/FLINK-33600 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-20281) Window aggregation supports changelog stream input

[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20281: Priority: Major (was: Not a Priority) > Window aggregation supports changelog stream input >

[jira] [Commented] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763319#comment-17763319 ] Jark Wu commented on FLINK-33063: - Fixed in - master: 01cb6ef008273100718cd8a8cfd921c02

[jira] [Updated] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-33063: Fix Version/s: 1.19.0 > udaf with user defined pojo object throw error while generate record equaliser > -

[jira] [Commented] (FLINK-33015) TableAggregateFunction codegen does not eval emitUpdateWithRetract

[ https://issues.apache.org/jira/browse/FLINK-33015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761195#comment-17761195 ] Jark Wu commented on FLINK-33015: - Maybe duplicated with https://issues.apache.org/jira/

[jira] [Commented] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760471#comment-17760471 ] Jark Wu commented on FLINK-32952: - Fixed in - master: 103de5bf136816ce1e520f372e17b162e

[jira] [Updated] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32952: Fix Version/s: 1.19.0 > Scan reuse with readable metadata and watermark push down will get wrong > waterm

[jira] [Assigned] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-32952: --- Assignee: Yunhong Zheng > Scan reuse with readable metadata and watermark push down will get wrong

[jira] [Comment Edited] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758000#comment-17758000 ] Jark Wu edited comment on FLINK-32905 at 8/24/23 11:22 AM: --- Fi

[jira] [Closed] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32905. --- Resolution: Fixed > Fix the bug of broadcast hash join doesn't support spill to disk when enable > operator

[jira] [Commented] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758000#comment-17758000 ] Jark Wu commented on FLINK-32905: - Fixed in - master: 2cf32e82773254b79af4dad7ee317db4

[jira] [Updated] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32905: Fix Version/s: 1.19.0 > Fix the bug of broadcast hash join doesn't support spill to disk when enable > op

[jira] [Assigned] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

[ https://issues.apache.org/jira/browse/FLINK-32905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-32905: --- Assignee: dalongliu > Fix the bug of broadcast hash join doesn't support spill to disk when enable

[jira] [Commented] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF

[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757993#comment-17757993 ] Jark Wu commented on FLINK-32940: - [~337361...@qq.com] do you have time to help take a l

[jira] [Comment Edited] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF

[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757992#comment-17757992 ] Jark Wu edited comment on FLINK-32940 at 8/23/23 12:21 PM: --- Hi

[jira] [Commented] (FLINK-32940) Support projection pushdown to table source for column projections through UDTF

[ https://issues.apache.org/jira/browse/FLINK-32940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757992#comment-17757992 ] Jark Wu commented on FLINK-32940: - Hi [~vsowrirajan], thank you for reporting this probl

[jira] [Commented] (FLINK-32909) The jobmanager.sh pass arguments failed

[ https://issues.apache.org/jira/browse/FLINK-32909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757763#comment-17757763 ] Alex Wu commented on FLINK-32909: - Yes, I would be happy to. Emmm, I should prepare a PR

[jira] [Updated] (FLINK-32909) The jobmanager.sh pass arguments failed

[ https://issues.apache.org/jira/browse/FLINK-32909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Wu updated FLINK-32909: Description: I' m trying to use the jobmanager.sh script to create a jobmanager instance manually, and I

[jira] [Updated] (FLINK-32909) The jobmanager.sh pass arguments failed

[ https://issues.apache.org/jira/browse/FLINK-32909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Wu updated FLINK-32909: Description: I' m trying to use the jobmanager.sh script to create a jobmanager instance manually, and I

[jira] [Created] (FLINK-32909) The jobmanager.sh pass arguments failed

Alex Wu created FLINK-32909: --- Summary: The jobmanager.sh pass arguments failed Key: FLINK-32909 URL: https://issues.apache.org/jira/browse/FLINK-32909 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

[ https://issues.apache.org/jira/browse/FLINK-32776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754379#comment-17754379 ] Qiwei Wu commented on FLINK-32776: -- hi~[~martijnvisser] can you please assign this tick

[jira] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

[ https://issues.apache.org/jira/browse/FLINK-32776 ] Qiwei Wu deleted comment on FLINK-32776: -- was (Author: JIRAUSER301673): [~Weijie Guo]  can you please assign this ticket to [~stonewu] ? > Adding HTTP basic authentication support to Prometheus

[jira] [Commented] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

[ https://issues.apache.org/jira/browse/FLINK-32776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752722#comment-17752722 ] Qiwei Wu commented on FLINK-32776: -- [~Weijie Guo]  can you please assign this ticket to

[jira] [Updated] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

[ https://issues.apache.org/jira/browse/FLINK-32776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qiwei Wu updated FLINK-32776: - Remaining Estimate: (was: 1h) Original Estimate: (was: 1h) > Adding HTTP basic authenticati

[jira] [Created] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

Qiwei Wu created FLINK-32776: Summary: Adding HTTP basic authentication support to PrometheusPushGatewayReporter Key: FLINK-32776 URL: https://issues.apache.org/jira/browse/FLINK-32776 Project: Flink

[jira] [Closed] (FLINK-32279) Shuffle HashJoin support spill to disk when enable operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32279. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master: bff837622ddfd2c

[jira] [Closed] (FLINK-32280) HashAgg support operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32280. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master: f500b593911614

[jira] [Updated] (FLINK-32610) JSON format supports projection push down

[ https://issues.apache.org/jira/browse/FLINK-32610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-32610: Release Note: The JSON format introduced JsonParser as a new default way to deserialize JSON data. JsonPar

[jira] [Closed] (FLINK-32610) JSON format supports projection push down

[ https://issues.apache.org/jira/browse/FLINK-32610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32610. --- Fix Version/s: 1.18.0 Release Note: The JSON format introduced JsonParser as a new default way to deser

[jira] [Comment Edited] (FLINK-32632) Run Kubernetes test is unstable on AZP

[ https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745130#comment-17745130 ] Jark Wu edited comment on FLINK-32632 at 7/20/23 3:26 PM: -- Anot

[jira] [Commented] (FLINK-32632) Run Kubernetes test is unstable on AZP

[ https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745130#comment-17745130 ] Jark Wu commented on FLINK-32632: - Another instance: https://dev.azure.com/apache-flink

[jira] [Comment Edited] (FLINK-32632) Run Kubernetes test is unstable on AZP

[ https://issues.apache.org/jira/browse/FLINK-32632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745130#comment-17745130 ] Jark Wu edited comment on FLINK-32632 at 7/20/23 3:25 PM: -- Anot

[jira] [Updated] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30559: Fix Version/s: 1.18.0 1.16.3 1.17.2 > May get wrong result for `if`

[jira] [Resolved] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-30559. - Resolution: Duplicate > May get wrong result for `if` expression if it's string data type >

[jira] [Reopened] (FLINK-30559) May get wrong result for `if` expression if it's string data type

[ https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-30559: - > May get wrong result for `if` expression if it's string data type > --

[jira] [Closed] (FLINK-32277) Introduce operator fusion codegen basic framework

[ https://issues.apache.org/jira/browse/FLINK-32277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-32277. --- Fix Version/s: 1.18.0 Assignee: dalongliu Resolution: Fixed Fixed in master: 02be55ab780186a

[jira] [Comment Edited] (FLINK-32278) HashJoin support operator fusion codegen

[ https://issues.apache.org/jira/browse/FLINK-32278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742454#comment-17742454 ] Jark Wu edited comment on FLINK-32278 at 7/12/23 2:55 PM: -- Fixe

  1   2   3   4   5   6   7   8   9   10   >