[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out

2023-02-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690217#comment-17690217 ] Piotr Nowojski commented on FLINK-31036: {quote} So should we use the

[GitHub] [flink] reswqa commented on pull request #21953: [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid.

2023-02-16 Thread via GitHub
reswqa commented on PR #21953: URL: https://github.com/apache/flink/pull/21953#issuecomment-1434261335 The current change is to think of them as `cluster-level` configurations. The reason is that from the key of `Option`, they are prefixed with `taskmanager`. I'm not sure whether

[jira] [Commented] (FLINK-31105) SqlClient: Make HELP, EXIT and QUIT also work without a semicolon

2023-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690212#comment-17690212 ] Matthias Pohl commented on FLINK-31105: --- [~jingge] out of curiosity, where do you see the flaws in

[GitHub] [flink] reswqa commented on pull request #21953: [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid.

2023-02-16 Thread via GitHub
reswqa commented on PR #21953: URL: https://github.com/apache/flink/pull/21953#issuecomment-1434257521 @pnowojski Would you mind taking a look at this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-31116: - Component/s: Runtime / Task > Support taskmanager related parameters in session mode Support job >

[jira] [Created] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

2023-02-16 Thread waywtdcc (Jira)
waywtdcc created FLINK-31116: Summary: Support taskmanager related parameters in session mode Support job granularity setting Key: FLINK-31116 URL: https://issues.apache.org/jira/browse/FLINK-31116

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-31116: - Affects Version/s: 1.16.1 > Support taskmanager related parameters in session mode Support job >

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-31116: - Fix Version/s: 1.18.0 > Support taskmanager related parameters in session mode Support job >

[GitHub] [flink] flinkbot commented on pull request #21957: [FLINK-23810][TABLE]Show original sql when parse failed

2023-02-16 Thread via GitHub
flinkbot commented on PR #21957: URL: https://github.com/apache/flink/pull/21957#issuecomment-1434253035 ## CI report: * f6a09158141fa4fd92c10e6b6cc449be056fe1ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

2023-02-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690209#comment-17690209 ] Weijie Guo commented on FLINK-30989: After offline discuss, the configuration does not take effect

[jira] [Updated] (FLINK-30069) Expected prune behavior for matches with same priority

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-30069: -- Affects Version/s: 1.16.1 1.15.3 > Expected prune behavior for matches with

[jira] [Updated] (FLINK-29681) Python side-output operator not generated in some cases

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-29681: -- Affects Version/s: (was: 1.17.0) > Python side-output operator not generated in some cases >

[jira] [Updated] (FLINK-30864) Optional pattern at the start of a group pattern not working

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-30864: -- Affects Version/s: 1.15.3 > Optional pattern at the start of a group pattern not working >

[jira] [Updated] (FLINK-30839) Relaxed looping group pattern make the following strict contiguity relaxed too

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-30839: -- Affects Version/s: 1.15.3 > Relaxed looping group pattern make the following strict contiguity

[jira] [Updated] (FLINK-30961) Remove deprecated tests_require in setup.py

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-30961: -- Fix Version/s: 1.17.0 (was: 1.18.0) > Remove deprecated tests_require in

[jira] [Assigned] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

2023-02-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-30989: -- Assignee: dalongliu (was: Weijie Guo) > Configuration

[jira] [Updated] (FLINK-30885) Optional group pattern starts with non-optional looping pattern get wrong result on followed-by

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-30885: -- Affects Version/s: 1.16.1 1.15.3 > Optional group pattern starts with

[jira] [Updated] (FLINK-31017) Early-started partial match timeout not yield completed matches

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-31017: -- Affects Version/s: (was: 1.17.0) > Early-started partial match timeout not yield completed

[jira] [Updated] (FLINK-31042) AfterMatchSkipStrategy not working on notFollowedBy ended pattern

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-31042: -- Fix Version/s: 1.17.0 1.15.4 1.16.2 Affects

[jira] [Updated] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

2023-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23810: --- Labels: pull-request-available (was: ) > Print sql when parse failed , which is

[GitHub] [flink] hehuiyuan opened a new pull request, #21957: [FLINK-23810]Show original sql when parse failed

2023-02-16 Thread via GitHub
hehuiyuan opened a new pull request, #21957: URL: https://github.com/apache/flink/pull/21957 ## What is the purpose of the change show the original SQL and highlight the error in place at the line and position. -- This is an automated message from the Apache

[jira] [Commented] (FLINK-31017) Early-started partial match timeout not yield completed matches

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690204#comment-17690204 ] Juntao Hu commented on FLINK-31017: --- [~martijnvisser] I've changed the tags, thx for reminding >

[jira] [Updated] (FLINK-31017) Early-started partial match timeout not yield completed matches

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-31017: -- Fix Version/s: 1.17.0 1.15.4 1.16.2 (was:

[jira] [Updated] (FLINK-31040) Looping pattern notFollowedBy at end missing an element

2023-02-16 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-31040: -- Fix Version/s: (was: 1.17.0) (was: 1.15.4) (was:

[jira] [Resolved] (FLINK-30109) Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar

2023-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30109. --- Fix Version/s: pulsar-4.0.0 Resolution: Fixed You can resolve this issue if you're

[jira] [Closed] (FLINK-30971) Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

2023-02-16 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30971. -- Resolution: Fixed Fixed in master: 55b927b0e6eb2d5d71487b9bb2c4dab80017a7e5 > Modify the default

[jira] [Updated] (FLINK-30971) Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

2023-02-16 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-30971: --- Component/s: Table SQL / Planner (was: Table SQL / Runtime) > Modify the

[jira] [Updated] (FLINK-30109) Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar

2023-02-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30109: -- Affects Version/s: pulsar-3.0.0 (was: 1.17.0) > Checked exceptions

[GitHub] [flink] snuyanzin commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

2023-02-16 Thread via GitHub
snuyanzin commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1109377574 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -178,6 +178,35 @@ ANY,

[GitHub] [flink] godfreyhe merged pull request #21900: [FLINK-30971][table-runtime] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

2023-02-16 Thread via GitHub
godfreyhe merged PR #21900: URL: https://github.com/apache/flink/pull/21900 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Comment Edited] (FLINK-31112) How to Change the default mode of the volume attached to flink-config-volume in a pod on Flink native Kubernetes

2023-02-16 Thread hob007 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690189#comment-17690189 ] hob007 edited comment on FLINK-31112 at 2/17/23 7:08 AM: - Hi Hu, Because

[jira] [Commented] (FLINK-31112) How to Change the default mode of the volume attached to flink-config-volume in a pod on Flink native Kubernetes

2023-02-16 Thread hob007 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690189#comment-17690189 ] hob007 commented on FLINK-31112: Security requires minimum permissions. 600 could be more secure. > How

[jira] [Commented] (FLINK-31115) Support a task to specify multiple slots

2023-02-16 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690187#comment-17690187 ] Lijie Wang commented on FLINK-31115:  Do you mean to specifiy different resources for different type

[jira] [Closed] (FLINK-31103) Public Table Reader API for table store

2023-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31103. Resolution: Fixed master: 726af803d233e2752cc5532b59ed977eecc8c5aa > Public Table Reader API for

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #540: [FLINK-31087] Introduce insert-changes action

2023-02-16 Thread via GitHub
JingsongLi commented on code in PR #540: URL: https://github.com/apache/flink-table-store/pull/540#discussion_r1109369372 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/ActionBase.java: ## @@ -61,4 +93,48 @@ public abstract class

[GitHub] [flink-table-store] JingsongLi merged pull request #544: [FLINK-31103] Public Table Reader API

2023-02-16 Thread via GitHub
JingsongLi merged PR #544: URL: https://github.com/apache/flink-table-store/pull/544 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-31115) Support a task to specify multiple slots

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-31115: - Component/s: Runtime / Task > Support a task to specify multiple slots >

[jira] [Updated] (FLINK-31115) Support a task to specify multiple slots

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-31115: - Issue Type: Improvement (was: Bug) > Support a task to specify multiple slots >

[jira] [Created] (FLINK-31115) Support a task to specify multiple slots

2023-02-16 Thread waywtdcc (Jira)
waywtdcc created FLINK-31115: Summary: Support a task to specify multiple slots Key: FLINK-31115 URL: https://issues.apache.org/jira/browse/FLINK-31115 Project: Flink Issue Type: Bug Affects

[jira] [Commented] (FLINK-31013) Session window aggregation cannot trigger window using event time

2023-02-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690177#comment-17690177 ] Jane Chan commented on FLINK-31013: --- [~xzw0223] What's your point? According to the table schema

[jira] [Updated] (FLINK-31103) Public Table Reader API for table store

2023-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31103: --- Labels: pull-request-available (was: ) > Public Table Reader API for table store >

[GitHub] [flink-table-store] yuzelin commented on pull request #544: [FLINK-31103] Public Table Reader API

2023-02-16 Thread via GitHub
yuzelin commented on PR #544: URL: https://github.com/apache/flink-table-store/pull/544#issuecomment-1434165736 LGTM! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Closed] (FLINK-31028) Provide different compression methods for per level

2023-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31028. Assignee: Jun Zhang Resolution: Fixed master: f5850b6f9ce71818e3391436697c07c4c433871b >

[GitHub] [flink-table-store] JingsongLi merged pull request #536: [FLINK-31028]Provide different compression for per level

2023-02-16 Thread via GitHub
JingsongLi merged PR #536: URL: https://github.com/apache/flink-table-store/pull/536 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

2023-02-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690161#comment-17690161 ] dalongliu commented on FLINK-30989: --- Thanks for repport it. For the table module, I will take a look.

[jira] [Commented] (FLINK-31112) How to Change the default mode of the volume attached to flink-config-volume in a pod on Flink native Kubernetes

2023-02-16 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690158#comment-17690158 ] Weihua Hu commented on FLINK-31112: --- Can i ask why do you need change the mode? > How to Change the

[GitHub] [flink] saLeox commented on pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

2023-02-16 Thread via GitHub
saLeox commented on PR #21149: URL: https://github.com/apache/flink/pull/21149#issuecomment-1434133679 Hi @XComp, thanks for your comment! and it is quite useful and make the code more lean and robust. I modify code accordingly and please help take a look again. For the size of

[jira] [Created] (FLINK-31114) Batch job fails with IllegalStateException when using adaptive batch scheduler

2023-02-16 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-31114: -- Summary: Batch job fails with IllegalStateException when using adaptive batch scheduler Key: FLINK-31114 URL: https://issues.apache.org/jira/browse/FLINK-31114 Project:

[jira] [Assigned] (FLINK-31113) Support AND filter for flink-orc

2023-02-16 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31113: Assignee: Shammon > Support AND filter for flink-orc >

[jira] (FLINK-28985) support create table like view

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985 ] waywtdcc deleted comment on FLINK-28985: -- was (Author: waywtdcc): hi [~jark]  [~martijnvisser]    > support create table like view > -- > > Key:

[GitHub] [flink] waywtdcc commented on pull request #21159: [FLINK-28985][table]Create table statement supports create table like view

2023-02-16 Thread via GitHub
waywtdcc commented on PR #21159: URL: https://github.com/apache/flink/pull/21159#issuecomment-1434115585 @JingsongLi hi,WDYT? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Closed] (FLINK-31100) Support the short topic pattern subscriber on default tenant and namespace

2023-02-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31100. -- Resolution: Fixed main(4.0) via 47b588f62bd8b9630303d62d0f3b36469f81d5fb > Support the short topic

[GitHub] [flink-connector-pulsar] reswqa merged pull request #33: [FLINK-31100][Stream] Support the short topic pattern subscriber on default tenant and namespace.

2023-02-16 Thread via GitHub
reswqa merged PR #33: URL: https://github.com/apache/flink-connector-pulsar/pull/33 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #33: [FLINK-31100][Stream] Support the short topic pattern subscriber on default tenant and namespace.

2023-02-16 Thread via GitHub
reswqa commented on code in PR #33: URL: https://github.com/apache/flink-connector-pulsar/pull/33#discussion_r1109311741 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/remote/PulsarRemoteRuntime.java: ## @@ -28,8 +28,12 @@ public

[GitHub] [flink] liuyongvs commented on pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

2023-02-16 Thread via GitHub
liuyongvs commented on PR #21947: URL: https://github.com/apache/flink/pull/21947#issuecomment-1434099828 hi @snuyanzin please review it again, i fix all your review infos -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] liuyongvs commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

2023-02-16 Thread via GitHub
liuyongvs commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1109302970 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java: ## @@ -160,6 +160,142 @@ Stream

[GitHub] [flink] flinkbot commented on pull request #21956: [FLINK-31113] Support AND filter push down in orc

2023-02-16 Thread via GitHub
flinkbot commented on PR #21956: URL: https://github.com/apache/flink/pull/21956#issuecomment-1434092510 ## CI report: * 01adcd4daf3aa40e4b14da457c67d172ecabcf08 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31113) Support AND filter for flink-orc

2023-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31113: --- Labels: pull-request-available (was: ) > Support AND filter for flink-orc >

[GitHub] [flink] FangYongs opened a new pull request, #21956: [FLINK-31113] Support AND filter push down in orc

2023-02-16 Thread via GitHub
FangYongs opened a new pull request, #21956: URL: https://github.com/apache/flink/pull/21956 ## What is the purpose of the change This PR aims to support AND filter push down in orc. ## Brief change log - Added AND predicate in `OrcFilters` ## Verifying this

[jira] [Commented] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

2023-02-16 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690135#comment-17690135 ] Weijie Guo commented on FLINK-30989: cc [~lsy]  > Configuration

[jira] [Created] (FLINK-31113) Support AND filter for flink-orc

2023-02-16 Thread Shammon (Jira)
Shammon created FLINK-31113: --- Summary: Support AND filter for flink-orc Key: FLINK-31113 URL: https://issues.apache.org/jira/browse/FLINK-31113 Project: Flink Issue Type: Improvement

[GitHub] [flink] liuyongvs commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

2023-02-16 Thread via GitHub
liuyongvs commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1109289338 ## docs/data/sql_functions.yml: ## @@ -617,6 +617,12 @@ collection: - sql: ARRAY_DISTINCT(haystack) table: haystack.arrayDistinct() description: Returns

[jira] [Commented] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

2023-02-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690131#comment-17690131 ] Zhu Zhu commented on FLINK-31041: - I think yes, or even a wider scope in

[jira] [Assigned] (FLINK-30983) the security.ssl.algorithms configuration does not take effect in rest ssl

2023-02-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-30983: Assignee: Yuxin Tan > the security.ssl.algorithms configuration does not take effect in

[jira] [Created] (FLINK-31112) How to Change the default mode of the volume attached to flink-config-volume in a pod on Flink native Kubernetes

2023-02-16 Thread hob007 (Jira)
hob007 created FLINK-31112: -- Summary: How to Change the default mode of the volume attached to flink-config-volume in a pod on Flink native Kubernetes Key: FLINK-31112 URL:

[GitHub] [flink-connector-pulsar] syhily commented on a diff in pull request #33: [FLINK-31100][Stream] Support the short topic pattern subscriber on default tenant and namespace.

2023-02-16 Thread via GitHub
syhily commented on code in PR #33: URL: https://github.com/apache/flink-connector-pulsar/pull/33#discussion_r1109280705 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/remote/PulsarRemoteRuntime.java: ## @@ -28,8 +28,12 @@ public

[GitHub] [flink] flinkbot commented on pull request #21955: [FLINK-23314][CEP] Eagerly clear keyed state footprints

2023-02-16 Thread via GitHub
flinkbot commented on PR #21955: URL: https://github.com/apache/flink/pull/21955#issuecomment-1434063393 ## CI report: * bb0671c2287607ab2bc30f40dd2c3b1c80fc8506 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Vancior opened a new pull request, #21955: [FLINK-23314][CEP] Eagerly clear keyed state footprints

2023-02-16 Thread via GitHub
Vancior opened a new pull request, #21955: URL: https://github.com/apache/flink/pull/21955 ## What is the purpose of the change This PR fixes in CEP, state belongs to a key is not cleaned by pattern timeout or state ttl, even if data of this key will never appear, which makes

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out

2023-02-16 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690125#comment-17690125 ] Rui Fan commented on FLINK-31036: - Hi [~pnowojski] , thanks a lot for the analysis, sounds makes sense

[jira] [Commented] (FLINK-31111) Introduce CatalogTestBase

2023-02-16 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690123#comment-17690123 ] Jun Zhang commented on FLINK-3: --- I think we should add a test class for parameterized test for

[GitHub] [flink] godfreyhe merged pull request #21950: [FLINK-31082][table-planner] Fixups for setting maven property 'flinkresueForks' to false in table planner module in right way

2023-02-16 Thread via GitHub
godfreyhe merged PR #21950: URL: https://github.com/apache/flink/pull/21950 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-connector-pulsar] reswqa commented on a diff in pull request #33: [FLINK-31100][Stream] Support the short topic pattern subscriber on default tenant and namespace.

2023-02-16 Thread via GitHub
reswqa commented on code in PR #33: URL: https://github.com/apache/flink-connector-pulsar/pull/33#discussion_r1109271209 ## flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/remote/PulsarRemoteRuntime.java: ## @@ -28,8 +28,12 @@ public

[jira] [Created] (FLINK-31111) Introduce CatalogTestBase

2023-02-16 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-3: Summary: Introduce CatalogTestBase Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690115#comment-17690115 ] waywtdcc commented on FLINK-29699: -- I have already edited it > Json format parsing supports converting

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Affects Version/s: 1.16.1 > Json format parsing supports converting strings at the end with Z and >

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: When I use flink cdc to read oracle, the time type data returned by cdc is a long type

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Fix Version/s: 1.18.0 > Json format parsing supports converting strings at the end with Z and >

[GitHub] [flink] waywtdcc commented on pull request #21124: [FLINK-29699]Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread via GitHub
waywtdcc commented on PR #21124: URL: https://github.com/apache/flink/pull/21124#issuecomment-1434043455 > If this is a Debezium specific thing, why are you modifying the generic JSON format implementation? > > The PR also doesn't contain any test, nor is clear what you're trying to

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: 1. JSON parsing supports converting long timestamps into flink timestamp types, for

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: 1. JSON parsing supports converting long timestamps into flink timestamp types, for

[jira] [Commented] (FLINK-28375) Whether to consider adding other data type to support for last_value function

2023-02-16 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690108#comment-17690108 ] hehuiyuan commented on FLINK-28375: --- Hi [~martijnvisser]  , both CHAR and TIMESTAMP are supported data

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Summary: Json format parsing supports converting strings at the end with Z and numbers to timestamp

[GitHub] [flink-connector-aws] Samrat002 commented on pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-02-16 Thread via GitHub
Samrat002 commented on PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#issuecomment-1434018720 @dannycranmer please review changes in free time -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] ruanhang1993 commented on a diff in pull request #21952: [FLINK-21000][runtime] Add an internal split enumerator metric group

2023-02-16 Thread via GitHub
ruanhang1993 commented on code in PR #21952: URL: https://github.com/apache/flink/pull/21952#discussion_r1109219195 ## flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/InternalSplitEnumeratorGroupTest.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed to the Apache

[GitHub] [flink] liuyongvs commented on a diff in pull request #21947: [FLINK-31098][table] Add ARRAY_SIZE function.

2023-02-16 Thread via GitHub
liuyongvs commented on code in PR #21947: URL: https://github.com/apache/flink/pull/21947#discussion_r1109218217 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -178,6 +178,35 @@ ANY,

[jira] [Closed] (FLINK-30792) clean up not uploaded state changes after materialization complete

2023-02-16 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang closed FLINK-30792. --- Fix Version/s: 1.17.0 1.16.2 Resolution: Duplicate > clean up not

[jira] [Commented] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

2023-02-16 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690091#comment-17690091 ] jackylau commented on FLINK-31098: -- [~Sergey Nuyanzin] thanks for your detailedly explain. but supports

[jira] [Commented] (FLINK-31095) FileSink doesn't work with s3a on EKS

2023-02-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690089#comment-17690089 ] Tzu-Li (Gordon) Tai commented on FLINK-31095: - Hi [~linqyd218], I think your latest

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Issue Type: Improvement (was: New Feature) > Debezium format parsing supports converting strings at

[jira] [Commented] (FLINK-28985) support create table like view

2023-02-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690076#comment-17690076 ] waywtdcc commented on FLINK-28985: -- hi [~jark]  [~martijnvisser]    > support create table like view

[jira] [Commented] (FLINK-31109) Fails with proxy user not supported even when security.kerberos.fetch.delegation-token is set to false

2023-02-16 Thread Venkata krishnan Sowrirajan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690067#comment-17690067 ] Venkata krishnan Sowrirajan commented on FLINK-31109: - [~gaborgsomogyi] I will take

[GitHub] [flink-connector-opensearch] lilyevsky commented on pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-02-16 Thread via GitHub
lilyevsky commented on PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#issuecomment-1433883642 @reta I installed docker, the daemon is running, the hello world test worked. However, the 'mvn verify' still fails with "OpensearchSinkITCase » IllegalState Could

[jira] [Commented] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces

2023-02-16 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690044#comment-17690044 ] Mingliang Liu commented on FLINK-31110: --- CC: [~markcho] > Web UI shows "User Configuration"

[jira] [Updated] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces

2023-02-16 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-31110: -- Priority: Minor (was: Major) > Web UI shows "User Configuration" preserving lines and

[jira] [Updated] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces

2023-02-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31110: --- Labels: pull-request-available (was: ) > Web UI shows "User Configuration" preserving

[GitHub] [flink] flinkbot commented on pull request #21954: [FLINK-31110][web] Show "User Configuration" preserving lines and whitespaces

2023-02-16 Thread via GitHub
flinkbot commented on PR #21954: URL: https://github.com/apache/flink/pull/21954#issuecomment-1433849816 ## CI report: * 2d6d5216ce2771ac0b41bc8d701c45ffe957f75e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuml07 commented on pull request #21954: [FLINK-31110][web] Show "User Configuration" preserving lines and whitespaces

2023-02-16 Thread via GitHub
liuml07 commented on PR #21954: URL: https://github.com/apache/flink/pull/21954#issuecomment-1433849680 CC: @vthinkxie @yangjunhan -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Created] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces

2023-02-16 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-31110: - Summary: Web UI shows "User Configuration" preserving lines and whitespaces Key: FLINK-31110 URL: https://issues.apache.org/jira/browse/FLINK-31110 Project: Flink

[jira] [Commented] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-02-16 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690038#comment-17690038 ] Danny Cranmer commented on FLINK-30777: --- Merged commit

[jira] [Updated] (FLINK-30777) Allow Kinesis Table API Connector to specify shard assigner

2023-02-16 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30777: -- Fix Version/s: aws-connector-4.1.0 > Allow Kinesis Table API Connector to specify shard

  1   2   3   4   >