[GitHub] [flink] flinkbot commented on pull request #20749: [FLINK-28919][table] Add built-in generate_series function.

flinkbot commented on PR #20749: URL: https://github.com/apache/flink/pull/20749#issuecomment-1236610995 ## CI report: * a28f2f9f7732693e293438f112953663f651fce3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] HuangXingBo closed pull request #20685: [FLINK-28429][python] Optimize PyFlink tests

HuangXingBo closed pull request #20685: [FLINK-28429][python] Optimize PyFlink tests URL: https://github.com/apache/flink/pull/20685 -- 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 comm

[GitHub] [flink] MartijnVisser commented on pull request #20283: [FLINK-28122][docs-zh] Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page into Chinese

MartijnVisser commented on PR #20283: URL: https://github.com/apache/flink/pull/20283#issuecomment-1236609892 @flinkbot run azure -- 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 comm

[GitHub] [flink] yuzelin commented on a diff in pull request #20714: [FLINK-29118][sql-gateway] Remove 'default_catalog' in the HiveServer2 Endpoint

yuzelin commented on code in PR #20714: URL: https://github.com/apache/flink/pull/20714#discussion_r962545770 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/context/SessionContextTest.java: ## @@ -129,17 +132,20 @@ public void testSetAndRes

[jira] [Updated] (FLINK-28919) Add built-in generate_series function.

[ https://issues.apache.org/jira/browse/FLINK-28919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-28919: - Affects Version/s: 1.17.0 (was: 1.16.0) > Add built-in generate_series functi

[jira] [Comment Edited] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600229#comment-17600229 ] Weijie Guo edited comment on FLINK-29183 at 9/5/22 6:55 AM:

[jira] [Commented] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600229#comment-17600229 ] Weijie Guo commented on FLINK-29183: [~landlord] I think this is the semantic differ

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962542425 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot commented on pull request #20748: [hotfix][docs][release] Update the building branch in workflow

flinkbot commented on PR #20748: URL: https://github.com/apache/flink/pull/20748#issuecomment-1236607161 ## CI report: * 44ee6ba57dd3d4b630e35102bd808b107ca67dbf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuyongvs opened a new pull request, #20749: [FLINK-28919][table] Add built-in generate_series function.

liuyongvs opened a new pull request, #20749: URL: https://github.com/apache/flink/pull/20749 ## What is the purpose of the change *Add built-in generate_series function* ## Brief change log Syntax: generate_series ( start numeric, stop numeric [, step numeric ] ) →

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962542425 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962542425 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed to

[GitHub] [flink] liuyongvs closed pull request #20546: [FLINK-28919][table] Add built-in generate_series function.

liuyongvs closed pull request #20546: [FLINK-28919][table] Add built-in generate_series function. URL: https://github.com/apache/flink/pull/20546 -- 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

[GitHub] [flink] yuzelin commented on a diff in pull request #20714: [FLINK-29118][sql-gateway] Remove 'default_catalog' in the HiveServer2 Endpoint

yuzelin commented on code in PR #20714: URL: https://github.com/apache/flink/pull/20714#discussion_r962537416 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -235,40 +236,79 @@ public static SessionContext

[GitHub] [flink] yuzelin commented on a diff in pull request #20714: [FLINK-29118][sql-gateway] Remove 'default_catalog' in the HiveServer2 Endpoint

yuzelin commented on code in PR #20714: URL: https://github.com/apache/flink/pull/20714#discussion_r962528665 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -235,40 +236,79 @@ public static SessionContext

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #281: [FLINK-29154] Support LookupTableSource for table store

tsreaper commented on code in PR #281: URL: https://github.com/apache/flink-table-store/pull/281#discussion_r962514153 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/PrimaryKeyLookupTable.java: ## @@ -0,0 +1,86 @@ +/* + * Licensed to t

[jira] [Updated] (FLINK-29189) Pass KeyValue to MergeFunction

[ https://issues.apache.org/jira/browse/FLINK-29189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29189: --- Labels: pull-request-available (was: ) > Pass KeyValue to MergeFunction > -

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #286: [FLINK-29189] Pass KeyValue to MergeFunction

JingsongLi opened a new pull request, #286: URL: https://github.com/apache/flink-table-store/pull/286 We should pass KeyValue to MergeFunction, give MergeFunction more capabilities, such as throwing an exception when it sees an unreasonable RowKind. -- This is an automated message from t

[jira] [Created] (FLINK-29189) Pass KeyValue to MergeFunction

Jingsong Lee created FLINK-29189: Summary: Pass KeyValue to MergeFunction Key: FLINK-29189 URL: https://issues.apache.org/jira/browse/FLINK-29189 Project: Flink Issue Type: Improvement

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #281: [FLINK-29154] Support LookupTableSource for table store

tsreaper commented on code in PR #281: URL: https://github.com/apache/flink-table-store/pull/281#discussion_r962503790 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/PrimaryKeyLookupTable.java: ## @@ -0,0 +1,86 @@ +/* + * Licensed to t

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962485437 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed t

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962485437 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed t

[jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-28893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-28893: - Affects Version/s: 1.17.0 (was: 1.16.0) > Add conv function supported in SQL

[jira] [Updated] (FLINK-28929) Add built-in datediff function.

[ https://issues.apache.org/jira/browse/FLINK-28929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-28929: - Affects Version/s: 1.17.0 (was: 1.16.0) > Add built-in datediff function. > -

[GitHub] [flink] flinkbot commented on pull request #20747: [FLINK-28929][table] Add built-in datediff function.

flinkbot commented on PR #20747: URL: https://github.com/apache/flink/pull/20747#issuecomment-1236551595 ## CI report: * e23772a4053963047a7d82767134ab15fb5311c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuyongvs opened a new pull request, #20747: [FLINK-28929][table] Add built-in datediff function.

liuyongvs opened a new pull request, #20747: URL: https://github.com/apache/flink/pull/20747 ## What is the purpose of the change *Add built-in datediff function* ## Brief change log Syntax: - DATEDIFF(expr1,expr2) Returns: - returns expr1 − expr2 expressed as a

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962485437 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed t

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962485437 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,103 @@ +/* + * Licensed t

[GitHub] [flink] liuyongvs closed pull request #20554: [FLINK-28929][table] Add built-in datediff function.

liuyongvs closed pull request #20554: [FLINK-28929][table] Add built-in datediff function. URL: https://github.com/apache/flink/pull/20554 -- 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 specifi

[GitHub] [flink] flinkbot commented on pull request #20746: [FLINK-28893][table] Add built-in conv function.

flinkbot commented on PR #20746: URL: https://github.com/apache/flink/pull/20746#issuecomment-1236545321 ## CI report: * 5ebb26ec28393522aa25f643a3669509c32ddc8a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r962480826 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssigner.java: ## @@ -34,7 +33,7 @@ * readers

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r962480622 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/source/PulsarUnorderedSourceReader.java: ## @@ -80,6 +81,38 @@ pu

[GitHub] [flink] syhily commented on a diff in pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

syhily commented on code in PR #20725: URL: https://github.com/apache/flink/pull/20725#discussion_r962480505 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializer.java: ## @@ -54,57 +55,37 @@

[GitHub] [flink] liuyongvs opened a new pull request, #20746: [FLINK-28893][table] Add built-in conv function.

liuyongvs opened a new pull request, #20746: URL: https://github.com/apache/flink/pull/20746 ## What is the purpose of the change *Add built-in conv function* ## Brief change log - *Converts numbers between different number bases. Returns a string representation of the n

[GitHub] [flink] liuyongvs closed pull request #20544: [FLINK-28893][table] Add built-in conv function.

liuyongvs closed pull request #20544: [FLINK-28893][table] Add built-in conv function. URL: https://github.com/apache/flink/pull/20544 -- 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 co

[jira] [Commented] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600199#comment-17600199 ] Shuiqiang Chen commented on FLINK-28988: Hi, [~jark], could you please help eval

[GitHub] [flink] flinkbot commented on pull request #20745: [FLINK-28988] Don't push above filters down into the right table for temporal join

flinkbot commented on PR #20745: URL: https://github.com/apache/flink/pull/20745#issuecomment-1236539144 ## CI report: * c4f871d4cafe349453f438aa9635985b88d6ca35 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28988: --- Labels: pull-request-available (was: ) > Incorrect result for filter after temporal join >

[GitHub] [flink] shuiqiangchen opened a new pull request, #20745: [FLINK-28988] Don't push above filters down into the right table for t…

shuiqiangchen opened a new pull request, #20745: URL: https://github.com/apache/flink/pull/20745 …emporal join ## What is the purpose of the change *Do not push above filters down into the right table for temporal join.* ## Brief change log - *Not allow to

[GitHub] [flink] SwimSweet commented on pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

SwimSweet commented on PR #20671: URL: https://github.com/apache/flink/pull/20671#issuecomment-1236534734 > > sorry.I have to rebase the release-1.15 branch to solve the ci problem[1] .That will add work to cr . > > [1] https://issues.apache.org/jira/browse/FLINK-29161 > > I think

[jira] [Commented] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600195#comment-17600195 ] dalongliu commented on FLINK-28989: --- Currently, only jdbc and hbase connectors impleme

[jira] [Resolved] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-28989. --- Resolution: Fixed > Release Testing: Verify FLIP-221 lookup table cache > --

[jira] [Updated] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-28989: -- Attachment: image-2022-09-05-12-27-23-259.png > Release Testing: Verify FLIP-221 lookup table cache >

[jira] [Closed] (FLINK-27017) Fix divide by zero exception in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-27017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27017. --- Fix Version/s: 1.16.0 1.17.0 Resolution: Fixed Fixed in - master: df0bc117341a40

[jira] [Updated] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-28989: -- Attachment: image-2022-09-05-12-26-51-427.png > Release Testing: Verify FLIP-221 lookup table cache >

[jira] [Updated] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-28989: -- Attachment: image-2022-09-05-12-26-22-263.png > Release Testing: Verify FLIP-221 lookup table cache >

[GitHub] [flink] wuchong merged pull request #19216: [FLINK-27017][hive] Fix divide by zero exception in Hive dialect

wuchong merged PR #19216: URL: https://github.com/apache/flink/pull/19216 -- 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: issues-unsubscr...@flink.apach

[jira] [Closed] (FLINK-29182) SumAggFunction redundant computations

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

[GitHub] [flink] wuchong merged pull request #20738: [FLINK-29182][table] fix redundant computations in SumAggFunction.

wuchong merged PR #20738: URL: https://github.com/apache/flink/pull/20738 -- 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: issues-unsubscr...@flink.apach

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #151: [FLINK-29171] Add docs of MaxAbs, FeatureHasher, Interaction, VectorSlicer, ElementwiseProduct and Binarizer

zhipeng93 commented on code in PR #151: URL: https://github.com/apache/flink-ml/pull/151#discussion_r962460009 ## docs/content/docs/operators/feature/elementwiseproduct.md: ## @@ -0,0 +1,157 @@ +--- +title: "Elementwise Product" +weight: 1 +type: docs +aliases: +- /operators/fea

[GitHub] [flink] Aitozi commented on pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

Aitozi commented on PR #20671: URL: https://github.com/apache/flink/pull/20671#issuecomment-1236519162 > sorry.I have to rebase the release-1.15 branch to solve the ci problem[1] .That will add work to cr . > > [1] https://issues.apache.org/jira/browse/FLINK-29161 I think You s

[jira] [Comment Edited] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600135#comment-17600135 ] Shuiqiang Chen edited comment on FLINK-28988 at 9/5/22 3:51 AM: --

[GitHub] [flink] yuzelin commented on a diff in pull request #20714: [FLINK-29118][sql-gateway] Remove 'default_catalog' in the HiveServer2 Endpoint

yuzelin commented on code in PR #20714: URL: https://github.com/apache/flink/pull/20714#discussion_r962453909 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -235,40 +236,79 @@ public static SessionContext

[GitHub] [flink] lsyldliu commented on a diff in pull request #20713: [FLINK-28897][runtime] Fix bug of failing to generate Jobgraph when using scalar udf and enable checkpoint

lsyldliu commented on code in PR #20713: URL: https://github.com/apache/flink/pull/20713#discussion_r962452744 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java: ## @@ -293,7 +294,8 @@ public StreamExecutionEnvironme

[GitHub] [flink] yuzelin commented on a diff in pull request #20714: [FLINK-29118][sql-gateway] Remove 'default_catalog' in the HiveServer2 Endpoint

yuzelin commented on code in PR #20714: URL: https://github.com/apache/flink/pull/20714#discussion_r962452601 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -207,13 +208,13 @@ public void close() { pu

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962450829 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[jira] [Comment Edited] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600135#comment-17600135 ] Shuiqiang Chen edited comment on FLINK-28988 at 9/5/22 3:29 AM: --

[jira] [Comment Edited] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600135#comment-17600135 ] Shuiqiang Chen edited comment on FLINK-28988 at 9/5/22 3:28 AM: --

[GitHub] [flink] fsk119 commented on a diff in pull request #20714: [FLINK-29118][sql-gateway] Remove 'default_catalog' in the HiveServer2 Endpoint

fsk119 commented on code in PR #20714: URL: https://github.com/apache/flink/pull/20714#discussion_r962444932 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -235,40 +236,79 @@ public static SessionContext c

[jira] [Comment Edited] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600135#comment-17600135 ] Shuiqiang Chen edited comment on FLINK-28988 at 9/5/22 3:20 AM: --

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20713: [FLINK-28897][runtime] Fix bug of failing to generate Jobgraph when using scalar udf and enable checkpoint

zhuzhurk commented on code in PR #20713: URL: https://github.com/apache/flink/pull/20713#discussion_r962445460 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java: ## @@ -293,7 +294,8 @@ public StreamExecutionEnvironme

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962443389 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962443389 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot commented on pull request #20744: Update kubernetes.md

flinkbot commented on PR #20744: URL: https://github.com/apache/flink/pull/20744#issuecomment-1236500371 ## CI report: * 2c100e1c5fe15a975caa02f0c6f5eb9c669560c3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600135#comment-17600135 ] Shuiqiang Chen commented on FLINK-28988: TLTD: The filters in aboveFilter should

[GitHub] [flink] moqimoqidea opened a new pull request, #20744: Update kubernetes.md

moqimoqidea opened a new pull request, #20744: URL: https://github.com/apache/flink/pull/20744 `jobmanager-session-deployment.yaml` -> `jobmanager-session-deployment-non-ha.yaml`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Closed] (FLINK-29138) Project pushdown not work for lookup source

[ https://issues.apache.org/jira/browse/FLINK-29138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29138. Resolution: Fixed master: 2e2fb24bdbc69c9d85883081b0c29f9db254088e release-1.15: e7c7df4c9b0766734

[GitHub] [flink] JingsongLi merged pull request #20729: [BP-1.14][FLINK-29138][table-planner] fix project can not be pushed into lookup source

JingsongLi merged PR #20729: URL: https://github.com/apache/flink/pull/20729 -- 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: issues-unsubscr...@flink.ap

[jira] [Commented] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600131#comment-17600131 ] KurtDing commented on FLINK-29092: -- Let me try , [~hxb]  > HadoopPathBasedPartFileWrit

[jira] [Created] (FLINK-29188) The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried

Shengkai Fang created FLINK-29188: - Summary: The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried Key: FLINK-29188 URL: https://issues.apache.org/jira/browse/FLINK-29188

[jira] [Commented] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600129#comment-17600129 ] Shengkai Fang commented on FLINK-28952: --- I have tested the following cases: 1. CR

[jira] [Updated] (FLINK-29171) Add documents for MaxAbs, FeatureHasher, Interaction, VectorSlicer, ElementwiseProduct and Binarizer

[ https://issues.apache.org/jira/browse/FLINK-29171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29171: --- Labels: pull-request-available (was: ) > Add documents for MaxAbs, FeatureHasher, Interacti

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #151: [FLINK-29171] Add docs of MaxAbs, FeatureHasher, Interaction, VectorSlicer, ElementwiseProduct and Binarizer

zhipeng93 commented on code in PR #151: URL: https://github.com/apache/flink-ml/pull/151#discussion_r962427345 ## docs/content/docs/operators/feature/binarizer.md: ## @@ -0,0 +1,189 @@ +--- +title: "Binarizer" +weight: 1 +type: docs +aliases: +- /operators/feature/binarizer.html

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962426638 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] [flink] JingsongLi merged pull request #20727: [FLINK-29138][table-planner] fix project can not be pushed into lookup source

JingsongLi merged PR #20727: URL: https://github.com/apache/flink/pull/20727 -- 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: issues-unsubscr...@flink.ap

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600128#comment-17600128 ] Xingbo Huang commented on FLINK-28766: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink-table-store] liyubin117 commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

liyubin117 commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962421868 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] [flink] lincoln-lil commented on pull request #20743: [hotfix][tests][table-planner] Add two more cases to verify the conflict of multiple LOOKUP hints

lincoln-lil commented on PR #20743: URL: https://github.com/apache/flink/pull/20743#issuecomment-1236474485 I haven't find the reason why this can not trigger testing on flink ci pipeline.. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-28964) Release Testing: Verify FLIP-205 Cache in DataStream for Batch Processing

[ https://issues.apache.org/jira/browse/FLINK-28964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600127#comment-17600127 ] jiaxiong commented on FLINK-28964: -- yes, I'm sure that you can close the ticket. [~xuan

[GitHub] [flink-ml] lindong28 merged pull request #152: [FLINK-29175] Add documents for KBinsDiscretizer, RegexTokenizer, Tokenizer and VectorIndexer

lindong28 merged PR #152: URL: https://github.com/apache/flink-ml/pull/152 -- 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: issues-unsubscr...@flink.apac

[GitHub] [flink-ml] lindong28 commented on pull request #152: [FLINK-29175] Add documents for KBinsDiscretizer, RegexTokenizer, Tokenizer and VectorIndexer

lindong28 commented on PR #152: URL: https://github.com/apache/flink-ml/pull/152#issuecomment-1236451042 Thanks for the PR! 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 comm

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962384412 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #134: [FLINK-27207] Support built-in parquet format

SteNicholas commented on code in PR #134: URL: https://github.com/apache/flink-table-store/pull/134#discussion_r962384308 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/parquet/ParquetInputFormatFactory.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to

[GitHub] [flink] snuyanzin commented on a diff in pull request #20742: [FLINK-29156]Support LISTAGG in the Table API

snuyanzin commented on code in PR #20742: URL: https://github.com/apache/flink/pull/20742#discussion_r962354424 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/SqlAggFunctionVisitor.java: ## @@ -70,6 +70,8 @@ public class SqlAggFunctio

[GitHub] [flink] snuyanzin commented on a diff in pull request #20742: [FLINK-29156]Support LISTAGG in the Table API

snuyanzin commented on code in PR #20742: URL: https://github.com/apache/flink/pull/20742#discussion_r962354368 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/AggregateITCase.scala: ## @@ -259,6 +259,30 @@ class AggregateITC

[jira] [Commented] (FLINK-3033) Redis Source Connector

[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600089#comment-17600089 ] Pramod Immaneni commented on FLINK-3033: I have developed a Redis source connecto

[GitHub] [flink] SwimSweet commented on pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

SwimSweet commented on PR #20671: URL: https://github.com/apache/flink/pull/20671#issuecomment-1236370031 sorry.I have to rebase the release-1.15 branch to solve the ci problem[1] .That will add work to cr . [1] https://issues.apache.org/jira/browse/FLINK-29161 -- This is an a

[GitHub] [flink] lincoln-lil commented on pull request #20743: [hotfix][tests][table-planner] Add two more cases to verify the conflict of multiple LOOKUP hints

lincoln-lil commented on PR #20743: URL: https://github.com/apache/flink/pull/20743#issuecomment-1236355429 @flinkbot run azure -- 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 commen

[jira] [Closed] (FLINK-29091) Fix the determinism declaration of the rand function to be consistent with current behavior

[ https://issues.apache.org/jira/browse/FLINK-29091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29091. -- Resolution: Fixed Fixed in master: 4b15bc900eb60b1830bc406975ce974ad6050f98 > Fix the determinism dec

[jira] [Assigned] (FLINK-29091) Fix the determinism declaration of the rand function to be consistent with current behavior

[ https://issues.apache.org/jira/browse/FLINK-29091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29091: -- Assignee: lincoln lee > Fix the determinism declaration of the rand function to be consistent

[GitHub] [flink] godfreyhe closed pull request #20674: [FLINK-29091][table-planner] Fix the determinism declaration of the rand function to be consistent with current behavior

godfreyhe closed pull request #20674: [FLINK-29091][table-planner] Fix the determinism declaration of the rand function to be consistent with current behavior URL: https://github.com/apache/flink/pull/20674 -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Closed] (FLINK-28858) Add document to describe join hints for batch sql

[ https://issues.apache.org/jira/browse/FLINK-28858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-28858. -- Resolution: Fixed Fixed in master: 72f0cb6fc7cd635c872de6fcbac9aec4c5beaf69 > Add document to describ

[jira] [Updated] (FLINK-28858) Add document to describe join hints for batch sql

[ https://issues.apache.org/jira/browse/FLINK-28858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-28858: --- Fix Version/s: 1.16.0 > Add document to describe join hints for batch sql >

[jira] [Updated] (FLINK-28858) Add document to describe join hints for batch sql

[ https://issues.apache.org/jira/browse/FLINK-28858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-28858: --- Component/s: Documentation > Add document to describe join hints for batch sql > ---

[jira] [Assigned] (FLINK-28858) Add document to describe join hints for batch sql

[ https://issues.apache.org/jira/browse/FLINK-28858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-28858: -- Assignee: Yunhong Zheng > Add document to describe join hints for batch sql > ---

[GitHub] [flink] godfreyhe closed pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

godfreyhe closed pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql URL: https://github.com/apache/flink/pull/20513 -- 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