gaoyunhaii commented on PR #20351:
URL: https://github.com/apache/flink/pull/20351#issuecomment-1200354111
Thanks @wsry for the PR! LGTM, let's have a final check after the commit
merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-28625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573340#comment-17573340
]
Aitozi commented on FLINK-28625:
Make sense, I will push a PR for this.
> Guard against
[
https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28751:
---
Description:
When I use the JSON_VALUE function, I found the performance is very poor. It's
mainly affected
luoyuxia commented on code in PR #2:
URL: https://github.com/apache/flink/pull/2#discussion_r933919454
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java:
##
@@ -918,6 +918,72 @@ public void testMacro() throws E
[
https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28751:
---
Description:
When I use the JSON_VALUE function, I found the performance is very poor. It's
mainly affected
[
https://issues.apache.org/jira/browse/FLINK-26937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573335#comment-17573335
]
xingyuan cheng commented on FLINK-26937:
I would like to try to tease out the ba
[
https://issues.apache.org/jira/browse/FLINK-28552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573336#comment-17573336
]
xingyuan cheng commented on FLINK-28552:
I would like to try to tease out the ba
swuferhong commented on PR #20084:
URL: https://github.com/apache/flink/pull/20084#issuecomment-1200334904
@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 comment
wuchong commented on code in PR #2:
URL: https://github.com/apache/flink/pull/2#discussion_r933836257
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java:
##
@@ -918,6 +918,72 @@ public void testMacro() throws Ex
lindong28 commented on code in PR #20275:
URL: https://github.com/apache/flink/pull/20275#discussion_r932818606
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -121,7 +118,15 @@
private final OperatorID op
David Anderson created FLINK-28754:
--
Summary: document that Java 8 is required to build table store
Key: FLINK-28754
URL: https://issues.apache.org/jira/browse/FLINK-28754
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-27387.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: bed7993aaf9838efdd254c8140c36d4ae1f80a56
>
wuchong merged PR #19647:
URL: https://github.com/apache/flink/pull/19647
--
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
[
https://issues.apache.org/jira/browse/FLINK-25142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-25142.
---
Fix Version/s: 1.16.0
Assignee: xiangqiao
Resolution: Fixed
Fixed in master: 541c66b7b71b396
wuchong merged PR #19400:
URL: https://github.com/apache/flink/pull/19400
--
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
[
https://issues.apache.org/jira/browse/FLINK-28111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573268#comment-17573268
]
DavidLiu edited comment on FLINK-28111 at 7/30/22 1:58 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-28111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573268#comment-17573268
]
DavidLiu commented on FLINK-28111:
--
This is not an issue, but rather, by design.
The t
leozhangsr commented on PR #20387:
URL: https://github.com/apache/flink/pull/20387#issuecomment-1200156751
@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 comment
[
https://issues.apache.org/jira/browse/FLINK-27019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573263#comment-17573263
]
DavidLiu commented on FLINK-27019:
--
The source codes have supported hive-dialect.
This
simplejason commented on code in PR #20380:
URL: https://github.com/apache/flink/pull/20380#discussion_r933797678
##
flink-runtime-web/web-dashboard/src/app/pages/overview/statistic/overview-statistic.component.less:
##
@@ -17,50 +17,56 @@
*/
@import "theme";
-nz-card {
-
simplejason commented on code in PR #20380:
URL: https://github.com/apache/flink/pull/20380#discussion_r933797173
##
flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpressure.component.html:
##
@@ -63,9 +63,18 @@
-
[
https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573247#comment-17573247
]
Peleg Tsadok commented on FLINK-28653:
--
Okay I fixed the AvroMissingFieldException
flinkbot commented on PR #20398:
URL: https://github.com/apache/flink/pull/20398#issuecomment-1200139640
## CI report:
* e4136d7989e9a1876aa7c37424b6a4d135b000d5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28752:
---
Labels: pull-request-available (was: )
> Add the json plan support in Python UDFs
> ---
HuangXingBo opened a new pull request, #20398:
URL: https://github.com/apache/flink/pull/20398
## What is the purpose of the change
*This pull request will add the json plan support in Python UDFs*
## Brief change log
- *Add the json plan support in Python UDFs*
[
https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573242#comment-17573242
]
Peleg Tsadok commented on FLINK-28653:
--
[~chesnay] Great comments!
I fixed the ign
godfrey he created FLINK-28753:
--
Summary: Improve FilterIntoJoinRule which could push some
predicate to another side
Key: FLINK-28753
URL: https://issues.apache.org/jira/browse/FLINK-28753
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28707.
--
Resolution: Fixed
Fixed in master: c9d34ed773e311bcb0e1c54ed1b3ca31973e8853
> Introduce interface Sup
[
https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573238#comment-17573238
]
Aitozi commented on FLINK-28751:
I opened a PR for this. cc [~jark] [~libenchao]
> Poo
flinkbot commented on PR #20397:
URL: https://github.com/apache/flink/pull/20397#issuecomment-1200123756
## CI report:
* 91f7fef85fc48bbeaf4737e3a55b48fd422a1849 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28751:
---
Labels: pull-request-available (was: )
> Poor performance of the built in json_value functi
Aitozi opened a new pull request, #20397:
URL: https://github.com/apache/flink/pull/20397
… functions
## What is the purpose of the change
This PR is meant to improve the performance of the built in json functions.
The default `LRUCache` used in the JsonPath CacheProvider heavi
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Attachment: image-2022-07-30-16-36-37-032.png
> Whether to add field comment for hive table
>
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Description:
Currently, I have a hive ddl,as follows
{code:java}
"set table.sql-dialect=hive;\n" +
"C
Huang Xingbo created FLINK-28752:
Summary: Add the json plan support in Python UDFs
Key: FLINK-28752
URL: https://issues.apache.org/jira/browse/FLINK-28752
Project: Flink
Issue Type: New Feat
flinkbot commented on PR #20396:
URL: https://github.com/apache/flink/pull/20396#issuecomment-1200115276
## CI report:
* 650e7b2a693a8f6989f6ad20e17ceca5ef6a8359 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Summary: Whether to add field comment for hive table (was: Whether to add
comment for hive table)
>
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Priority: Minor (was: Major)
> Whether to add comment for hive table
> --
[
https://issues.apache.org/jira/browse/FLINK-28745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28745:
---
Labels: pull-request-available (was: )
> Support DataStream PythonCoProcessOperator and Pyt
HuangXingBo opened a new pull request, #20396:
URL: https://github.com/apache/flink/pull/20396
## What is the purpose of the change
*This pull request will support DataStream PythonCoProcessOperator and
PythonKeyedCoProcessOperator in Thread Mode*
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Description:
Currently, I have a hive ddl,as follows
{code:java}
"set table.sql-dialect=hive;\n" +
"C
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Description:
Currently, I have a hive ddl,as follows
{code:java}
"set table.sql-dialect=hive;\n" +
"C
swuferhong commented on PR #20084:
URL: https://github.com/apache/flink/pull/20084#issuecomment-1200113237
@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 comment
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Attachment: image-2022-07-30-15-53-03-754.png
> Whether to add comment for hive table
> --
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Description:
Currently, I have a hive ddl,as follows
{code:java}
"set table.sql-dialect=hive;\n" +
"C
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Description:
Currently, I have a hive ddl,as follows
{code:java}
"set table.sql-dialect=hive;\n" +
"C
[
https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28751:
---
Description:
When I use the JSON_VALUE function, I found the performance is very poor. It's
mainly affected
WencongLiu commented on PR #20236:
URL: https://github.com/apache/flink/pull/20236#issuecomment-1200111512
@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 comment
[
https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28751:
---
Description:
When I use the JSON_VALUE function, I found the performance is very poor. It's
mainly affected
Aitozi created FLINK-28751:
--
Summary: Poor performance of the built in json_value function
Key: FLINK-28751
URL: https://issues.apache.org/jira/browse/FLINK-28751
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-28750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-28750:
--
Description:
Currently, I have a hive ddl,as follows
{code:java}
"set table.sql-dialect=hive;\n" +
"C
hehuiyuan created FLINK-28750:
-
Summary: Whether to add comment for hive table
Key: FLINK-28750
URL: https://issues.apache.org/jira/browse/FLINK-28750
Project: Flink
Issue Type: Improvement
SmirAlex commented on code in PR #20196:
URL: https://github.com/apache/flink/pull/20196#discussion_r933765687
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/DefaultLookupCache.java:
##
@@ -0,0 +1,270 @@
+/*
+ * Licensed to t
53 matches
Mail list logo