[jira] [Created] (FLINK-35341) Retraction stop working with Clock dependent function in Filter

2024-05-13 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-35341: Summary: Retraction stop working with Clock dependent function in Filter Key: FLINK-35341 URL: https://issues.apache.org/jira/browse/FLINK-35341 Project: Flink

[jira] [Commented] (FLINK-34246) Allow only archive failed job to history server

2024-01-27 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811480#comment-17811480 ] Lim Qing Wei commented on FLINK-34246: -- Hi [~Wencong Liu] , thanks for replying. S

[jira] [Created] (FLINK-34246) Allow only archive failed job to history server

2024-01-26 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-34246: Summary: Allow only archive failed job to history server Key: FLINK-34246 URL: https://issues.apache.org/jira/browse/FLINK-34246 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-14 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785826#comment-17785826 ] Lim Qing Wei commented on FLINK-33365: -- I am not familiar with Calcite, not able to

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-13 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785672#comment-17785672 ] Lim Qing Wei commented on FLINK-33365: -- Hi [~davidradl] ,  if you can work on this

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-13 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785470#comment-17785470 ] Lim Qing Wei commented on FLINK-33365: -- [~Sergey Nuyanzin] , I will look into this

[jira] [Comment Edited] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-17 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743720#comment-17743720 ] Lim Qing Wei edited comment on FLINK-32296 at 7/17/23 10:23 AM: --

[jira] [Commented] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-17 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743720#comment-17743720 ] Lim Qing Wei commented on FLINK-32296: -- Hi [~Sergey Nuyanzin] , sorry for the long

[jira] [Comment Edited] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-08 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741252#comment-17741252 ] Lim Qing Wei edited comment on FLINK-32296 at 7/8/23 8:38 AM:

[jira] [Commented] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-08 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741252#comment-17741252 ] Lim Qing Wei commented on FLINK-32296: -- Hi [~Sergey Nuyanzin] , I am not able to bu

[jira] [Commented] (FLINK-32323) Flink Testing doc missing key information about dependency

2023-06-13 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732028#comment-17732028 ] Lim Qing Wei commented on FLINK-32323: -- Hi [~martijnvisser] , but without the `test

[jira] [Commented] (FLINK-32323) Flink Testing doc missing key information about dependency

2023-06-13 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731997#comment-17731997 ] Lim Qing Wei commented on FLINK-32323: -- Hi [~martijnvisser] , I believe we need the

[jira] [Created] (FLINK-32323) Flink Testing doc missing key information about dependency

2023-06-13 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-32323: Summary: Flink Testing doc missing key information about dependency Key: FLINK-32323 URL: https://issues.apache.org/jira/browse/FLINK-32323 Project: Flink Is

[jira] [Updated] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-06-12 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lim Qing Wei updated FLINK-32296: - Description: FlinkSQL produce incorrect result when involving data with type of ARRAY, here's a

[jira] [Updated] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-06-12 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lim Qing Wei updated FLINK-32296: - Affects Version/s: 1.17.1 > Flink SQL handle array of row incorrectly >

[jira] [Created] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-06-09 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-32296: Summary: Flink SQL handle array of row incorrectly Key: FLINK-32296 URL: https://issues.apache.org/jira/browse/FLINK-32296 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-17 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635257#comment-17635257 ] Lim Qing Wei commented on FLINK-29984: -- Hi [~xtsong] , thanks for the assignment.

[jira] [Commented] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631800#comment-17631800 ] Lim Qing Wei commented on FLINK-29984: -- I am happy to work on this if we agree this

[jira] [Updated] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lim Qing Wei updated FLINK-29984: - Affects Version/s: 1.15.2 1.16.0 (was: 1.13.6)

[jira] [Updated] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lim Qing Wei updated FLINK-29984: - Description: Flink Histogram when using the Prometheus Metrics Reporter only produces * quantil

[jira] [Created] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-29984: Summary: Flink Histogram not emitting min and max when using Prometheus Reporter Key: FLINK-29984 URL: https://issues.apache.org/jira/browse/FLINK-29984 Project: Flin

[jira] [Commented] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631793#comment-17631793 ] Lim Qing Wei commented on FLINK-29037: -- I had a closer look, and I think sum is not

[jira] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037 ] Lim Qing Wei deleted comment on FLINK-29037: -- was (Author: JIRAUSER289353): [~martijnvisser] , I am happy to take a look at this, can you assign this to me? > Flink Histogram not emitting s

[jira] [Comment Edited] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631773#comment-17631773 ] Lim Qing Wei edited comment on FLINK-29037 at 11/10/22 4:56 PM: --

[jira] [Commented] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631773#comment-17631773 ] Lim Qing Wei commented on FLINK-29037: -- [~martijnvisser] , I am happy to take a loo

[jira] [Commented] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-10 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631772#comment-17631772 ] Lim Qing Wei commented on FLINK-29037: -- I believe this is still not supported in Fl

[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

2022-09-09 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602192#comment-17602192 ] Wei-Che Wei commented on FLINK-25932: - Hi [~twalthr], got it. I was not aware of thi

[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

2022-09-09 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602168#comment-17602168 ] Wei-Che Wei commented on FLINK-25932: - Hi [~slinkydeveloper], [~twalthr], I found t

[jira] [Comment Edited] (FLINK-14101) Introduce SqlServerDialect

2022-07-28 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572590#comment-17572590 ] Lim Qing Wei edited comment on FLINK-14101 at 7/28/22 5:59 PM: ---

[jira] [Commented] (FLINK-14101) Introduce SqlServerDialect

2022-07-28 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572590#comment-17572590 ] Lim Qing Wei commented on FLINK-14101: -- Hi [~maver1ck] I've opened a PR, it has 1 a

[jira] [Resolved] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

2022-07-04 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lim Qing Wei resolved FLINK-28365. -- Resolution: Not A Problem > TO_TIMESTAMP lose precision beyond seconds > -

[jira] [Commented] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

2022-07-04 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562284#comment-17562284 ] Lim Qing Wei commented on FLINK-28365: -- Hi, I am not able to reproduce this easily

[jira] [Comment Edited] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

2022-07-04 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562177#comment-17562177 ] Lim Qing Wei edited comment on FLINK-28365 at 7/4/22 1:25 PM:

[jira] [Commented] (FLINK-14101) Introduce SqlServerDialect

2022-07-04 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562178#comment-17562178 ] Lim Qing Wei commented on FLINK-14101: -- Hi [~martijnvisser] , yes I would like to w

[jira] [Commented] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

2022-07-04 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562177#comment-17562177 ] Lim Qing Wei commented on FLINK-28365: -- Hi, sorry for creating PR for it.   It re

[jira] [Commented] (FLINK-28337) java.lang.IllegalArgumentException: Table identifier not set

2022-07-03 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561962#comment-17561962 ] wei commented on FLINK-28337: - Ok, thanks~ > java.lang.IllegalArgumentException: Table iden

[jira] [Comment Edited] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561943#comment-17561943 ] Lim Qing Wei edited comment on FLINK-28367 at 7/3/22 9:30 PM:

[jira] [Commented] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561943#comment-17561943 ] Lim Qing Wei commented on FLINK-28367: -- I had a look, I think part of it is that we

[jira] [Commented] (FLINK-16024) support filter pushdown in jdbc connector

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561826#comment-17561826 ] Lim Qing Wei commented on FLINK-16024: -- Thanks [~martijnvisser]    I've opened a

[jira] [Updated] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lim Qing Wei updated FLINK-28365: - Description: The TO_TIMESTAMP function in Flink SQL seems to have a regression.   It loses the

[jira] [Created] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

2022-07-03 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-28365: Summary: TO_TIMESTAMP lose precision beyond seconds Key: FLINK-28365 URL: https://issues.apache.org/jira/browse/FLINK-28365 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28359) Support Microsoft SQL Server JDBC Dialect

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561818#comment-17561818 ] Lim Qing Wei commented on FLINK-28359: -- I am willing to work on this if project mai

[jira] [Created] (FLINK-28359) Support Microsoft SQL Server JDBC Dialect

2022-07-02 Thread Lim Qing Wei (Jira)
Lim Qing Wei created FLINK-28359: Summary: Support Microsoft SQL Server JDBC Dialect Key: FLINK-28359 URL: https://issues.apache.org/jira/browse/FLINK-28359 Project: Flink Issue Type: New Fea

[jira] [Commented] (FLINK-28337) java.lang.IllegalArgumentException: Table identifier not set

2022-07-01 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561340#comment-17561340 ] wei commented on FLINK-28337: - You mean I can't use Flink Table API to select an Iceberg tab

[jira] [Created] (FLINK-28337) java.lang.IllegalArgumentException: Table identifier not set

2022-06-30 Thread wei (Jira)
wei created FLINK-28337: --- Summary: java.lang.IllegalArgumentException: Table identifier not set Key: FLINK-28337 URL: https://issues.apache.org/jira/browse/FLINK-28337 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-30 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wei resolved FLINK-28276. - Resolution: Fixed > org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate > the hadoop inp

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-30 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561241#comment-17561241 ] wei commented on FLINK-28276: - I add  `table.updateProperties().set("engine.hive.enabled", "

[jira] [Updated] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-30 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wei updated FLINK-28276: Attachment: image-2022-07-01-11-05-01-238.png > org.apache.flink.connectors.hive.FlinkHiveException: Unable to ins

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560806#comment-17560806 ] wei edited comment on FLINK-28276 at 6/30/22 3:47 AM: -- Thanks! I th

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560806#comment-17560806 ] wei commented on FLINK-28276: - Thanks! I think this is the cause of the problem. I create ta

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560792#comment-17560792 ] wei commented on FLINK-28276: - I didn't specify the input format when creating the table, so

[jira] [Updated] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wei updated FLINK-28276: Attachment: image-2022-06-30-10-36-17-075.png > org.apache.flink.connectors.hive.FlinkHiveException: Unable to ins

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560781#comment-17560781 ] wei edited comment on FLINK-28276 at 6/30/22 1:52 AM: -- The table in

[jira] [Comment Edited] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560781#comment-17560781 ] wei edited comment on FLINK-28276 at 6/30/22 1:47 AM: -- The table in

[jira] [Commented] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560781#comment-17560781 ] wei commented on FLINK-28276: - The table input format displayed by `describe extended xxx` i

[jira] [Updated] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-29 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wei updated FLINK-28276: Attachment: image-2022-06-30-09-37-44-705.png > org.apache.flink.connectors.hive.FlinkHiveException: Unable to ins

[jira] [Created] (FLINK-28276) org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate the hadoop input format

2022-06-28 Thread wei (Jira)
Title: Message Title wei created an issue

[jira] [Commented] (FLINK-16024) support filter pushdown in jdbc connector

2022-06-23 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558015#comment-17558015 ] Lim Qing Wei commented on FLINK-16024: -- Hi, I wish to pick this up, but I am not ab

[jira] [Created] (FLINK-27890) bug of SideOutputExample.java

2022-06-03 Thread XiaoWen Wei (Jira)
XiaoWen Wei created FLINK-27890: --- Summary: bug of SideOutputExample.java Key: FLINK-27890 URL: https://issues.apache.org/jira/browse/FLINK-27890 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink

2022-03-01 Thread wang da wei (Jira)
wang da wei created FLINK-26425: --- Summary: Yarn aggregate log files in a rolling fashion for flink Key: FLINK-26425 URL: https://issues.apache.org/jira/browse/FLINK-26425 Project: Flink Issue T

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904 ] Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:41 AM: --

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904 ] Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:37 AM: --

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904 ] Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:35 AM: --

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904 ] Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:32 AM: --

[jira] [Commented] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904 ] Wei-Che Wei commented on FLINK-25048: - [~liangxinli] try this > 在某个option后设置waterma

[jira] [Updated] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

2021-08-30 Thread li wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li wei updated FLINK-23918: --- Priority: Blocker (was: Major) > FileNotFoundException when open auto-compact in filesystem > -

[jira] [Updated] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

2021-08-23 Thread li wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li wei updated FLINK-23918: --- Environment: Flink 1.12.2 HDFS 3.2.1 config: flink parallelism is 8 task manager slot is 4 task manager

[jira] [Created] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

2021-08-23 Thread li wei (Jira)
li wei created FLINK-23918: -- Summary: FileNotFoundException when open auto-compact in filesystem Key: FLINK-23918 URL: https://issues.apache.org/jira/browse/FLINK-23918 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-17 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22970: Affects Version/s: 1.14.0 > The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[jira] [Commented] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-16 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364645#comment-17364645 ] Wei-Che Wei commented on FLINK-22970: - Hi [~Leonard Xu] Could you assign this jira t

[jira] [Comment Edited] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-16 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364644#comment-17364644 ] Wei-Che Wei edited comment on FLINK-23012 at 6/17/21, 2:46 AM: ---

[jira] [Commented] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-16 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364644#comment-17364644 ] Wei-Che Wei commented on FLINK-23012: - Hi [~jark] > Add v1.13 docs link in "Pick Do

[jira] [Updated] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-10 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22970: Description: According to this ML discussion [http://apache-flink-user-mailing-list-archive.23360

[jira] [Created] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-10 Thread Wei-Che Wei (Jira)
Wei-Che Wei created FLINK-22970: --- Summary: The documentation for `TO_TIMESTAMP` UDF has an incorrect description Key: FLINK-22970 URL: https://issues.apache.org/jira/browse/FLINK-22970 Project: Flink

[jira] [Commented] (FLINK-22796) Update mem_setup_tm documentation

2021-05-28 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353014#comment-17353014 ] Wei-Che Wei commented on FLINK-22796: - Hi [~jark] could you assign this issue to me?

[jira] [Created] (FLINK-22796) Update mem_setup_tm documentation

2021-05-28 Thread Wei-Che Wei (Jira)
Wei-Che Wei created FLINK-22796: --- Summary: Update mem_setup_tm documentation Key: FLINK-22796 URL: https://issues.apache.org/jira/browse/FLINK-22796 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

2021-05-14 Thread Wang Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344568#comment-17344568 ] Wang Wei commented on FLINK-15390: -- Yes, I will work on this feature. > List/Map/Struc

[jira] [Commented] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

2021-05-11 Thread Wang Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342971#comment-17342971 ] Wang Wei commented on FLINK-15390: -- Hello [~lzljs3620320]  , I can implement this featu

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22476: Affects Version/s: 1.13.0 > Extend the description of the config option `execution.target` > -

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22476: Description: the current description for `execution.target` only lists `remote`, `local`, `yarn-p

[jira] [Created] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
Wei-Che Wei created FLINK-22476: --- Summary: Extend the description of the config option `execution.target` Key: FLINK-22476 URL: https://issues.apache.org/jira/browse/FLINK-22476 Project: Flink

[jira] [Commented] (FLINK-17783) Add array,map,row types support for orc row writer

2021-04-25 Thread Wang Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331709#comment-17331709 ] Wang Wei commented on FLINK-17783: -- In this PR, I implements array,map,row types suppor

[jira] [Commented] (FLINK-17783) Add array,map,row types support for orc row writer

2021-04-25 Thread Wang Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331680#comment-17331680 ] Wang Wei commented on FLINK-17783: -- hello [~lzljs3620320] , could you please help me re

[jira] [Commented] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2021-04-20 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325611#comment-17325611 ] Wei-Che Wei commented on FLINK-19358: - Hi [~trohrmann], [~kkl0u] I think this issue

[jira] [Commented] (FLINK-17783) Add array,map,row types support for orc row writer

2021-04-13 Thread Wang Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319973#comment-17319973 ] Wang Wei commented on FLINK-17783: -- Hi [~lzljs3620320], I'm interested in this issue, c

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-19 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Fix Version/s: (was: 1.12.2) 1.11.4 > flink-connector-es add onSuccess handler

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-19 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: (was: 1.12.0) > flink-connector-es add onSuccess handler after bulk process for

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: 1.12.0 > flink-connector-es add onSuccess handler after bulk process for sync succe

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Description: flink-connector-es add onSuccess handler after successful bulk process, in order to sync

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Fix Version/s: 1.12.3 1.13.0 > flink-connector-es add onSuccess handler after bulk

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: (was: 1.10.2) > flink-connector-es add onSuccess handler after bulk process for

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

2021-01-18 Thread Zheng WEI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng WEI updated FLINK-21022: -- Affects Version/s: 1.10.2 > flink-connector-es add onSuccess handler after bulk process for sync succe

[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

2021-01-18 Thread Zheng WEI (Jira)
Zheng WEI created FLINK-21022: - Summary: flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking Key: FLINK-21022 URL: https://issue

[jira] [Updated] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-08-12 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wei updated FLINK-18915: Summary: FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM (was: FIXED_PATH(dummy Hadoop Pat

[jira] [Created] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl cause ORC

2020-08-12 Thread wei (Jira)
wei created FLINK-18915: --- Summary: FIXED_PATH(dummy Hadoop Path) with WriterImpl cause ORC Key: FLINK-18915 URL: https://issues.apache.org/jira/browse/FLINK-18915 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl cause ORC OOM

2020-08-12 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wei updated FLINK-18915: Summary: FIXED_PATH(dummy Hadoop Path) with WriterImpl cause ORC OOM (was: FIXED_PATH(dummy Hadoop Path) with Wri

[jira] [Commented] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode

2020-03-03 Thread David Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050433#comment-17050433 ] David Wei commented on FLINK-10030: --- [~trohrmann] Thanks for the response. We are stil

[jira] [Comment Edited] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-08 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947309#comment-16947309 ] Wei-Che Wei edited comment on FLINK-14302 at 10/9/19 1:52 AM:

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-08 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947309#comment-16947309 ] Wei-Che Wei commented on FLINK-14302: - Hi [~becket_qin] I think the error was from

[jira] [Comment Edited] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-07 Thread Wei-Che Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941640#comment-16941640 ] Wei-Che Wei edited comment on FLINK-14302 at 10/7/19 6:59 AM:

  1   2   3   >