WencongLiu commented on code in PR #20451:
URL: https://github.com/apache/flink/pull/20451#discussion_r939493280
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsRequestBody.java:
##
@@ -0,0 +1,47 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-28843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576147#comment-17576147
]
Yun Tang commented on FLINK-28843:
--
Thanks for reporting this bug!
The root cause is t
luoyuxia commented on PR #20413:
URL: https://github.com/apache/flink/pull/20413#issuecomment-1207158767
@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.
flinkbot commented on PR #20477:
URL: https://github.com/apache/flink/pull/20477#issuecomment-1207157515
## CI report:
* 4f20a0b31a5400c1f9dbf27db75b3f19caf45fbf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #20477:
URL: https://github.com/apache/flink/pull/20477
Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.3.3 to 42.4.1.
Release notes
Sourced from https://github.com/pgjdbc/pgjdbc/releases";>postgresql's
releases.
42.4.0
wsry commented on PR #20350:
URL: https://github.com/apache/flink/pull/20350#issuecomment-1207144254
@zhuzhurk I have updated the PR and add two fixup commits. Please take
another look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
xuyangzhong commented on PR #20359:
URL: https://github.com/apache/flink/pull/20359#issuecomment-1207143512
@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
wsry commented on code in PR #20350:
URL: https://github.com/apache/flink/pull/20350#discussion_r939480667
##
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java:
##
@@ -35,55 +35,48 @@
import org.apache.flink.runtime.testtas
flinkbot commented on PR #20476:
URL: https://github.com/apache/flink/pull/20476#issuecomment-1207138714
## CI report:
* 97a58a1e6a79658f433fbf9a4e8515af14767e8f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28094:
---
Labels: pull-request-available (was: )
> [aws][connectors][formats] Upgrade AWS SDK to supp
dannycranmer opened a new pull request, #20476:
URL: https://github.com/apache/flink/pull/20476
## What is the purpose of the change
Updating AWS SDK dependencies to latest versions to pull recent bug fixes
and add support for new AWS regions.
## Brief change log
Upgradi
[
https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576122#comment-17576122
]
zck commented on FLINK-28819:
-
For example: I want to empty all states in the early morning
[
https://issues.apache.org/jira/browse/FLINK-28843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lihe Ma updated FLINK-28843:
Description:
# When native checkpoint is enabled and incremental checkpointing is enabled in
rocksdb stat
Lihe Ma created FLINK-28843:
---
Summary: Failed to restore from changelog checkpoint in claim mode
Key: FLINK-28843
URL: https://issues.apache.org/jira/browse/FLINK-28843
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575148#comment-17575148
]
ConradJam edited comment on FLINK-27060 at 8/6/22 2:35 AM:
---
No
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575148#comment-17575148
]
ConradJam edited comment on FLINK-27060 at 8/6/22 2:21 AM:
---
No
JasonLeeCoding commented on PR #20466:
URL: https://github.com/apache/flink/pull/20466#issuecomment-1207127725
@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 com
sap1ens commented on PR #20475:
URL: https://github.com/apache/flink/pull/20475#issuecomment-1207126384
@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-28094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-28094:
-
Assignee: Danny Cranmer
> [aws][connectors][formats] Upgrade AWS SDK to support ap-sout
[
https://issues.apache.org/jira/browse/FLINK-27217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-27217.
---
Resolution: Fixed
Fixed in master: c54eaf51aad662dcfd187f370792edf15bb80b3c and
01d31f6ed30d2f1ed37eaaad705
luoyuxia commented on PR #20413:
URL: https://github.com/apache/flink/pull/20413#issuecomment-1207125131
> Please add an IT case just similar to
`HiveDialectITCase#testCreateFunctionUsingJar` which verifies functions in the
jar can be successfully discovered, registered, and executed.
I
wuchong merged PR #19450:
URL: https://github.com/apache/flink/pull/19450
--
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
luoyuxia commented on code in PR #20413:
URL: https://github.com/apache/flink/pull/20413#discussion_r939466542
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java:
##
@@ -1121,6 +1122,35 @@ public void testSetCommand() t
lsyldliu commented on PR #20365:
URL: https://github.com/apache/flink/pull/20365#issuecomment-1207124329
Thanks for all review, I've addressed comments.
--
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
lsyldliu commented on code in PR #20365:
URL: https://github.com/apache/flink/pull/20365#discussion_r939466103
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/HashJoinOperator.java:
##
@@ -214,16 +276,121 @@ void collect(RowData row
lsyldliu commented on code in PR #20365:
URL: https://github.com/apache/flink/pull/20365#discussion_r939466103
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/HashJoinOperator.java:
##
@@ -214,16 +276,121 @@ void collect(RowData row
lsyldliu commented on code in PR #20365:
URL: https://github.com/apache/flink/pull/20365#discussion_r939465887
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/util/JoinUtil.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache Software Foundati
leozhangsr commented on PR #20389:
URL: https://github.com/apache/flink/pull/20389#issuecomment-1207122536
@PatrickRen Do you have time to handle this rq? and the requests for
release-1.14 ,https://github.com/apache/flink/pull/20387
--
This is an automated message from the Apache Git Serv
1996fanrui commented on PR #19781:
URL: https://github.com/apache/flink/pull/19781#issuecomment-1207117749
@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
1996fanrui commented on PR #20137:
URL: https://github.com/apache/flink/pull/20137#issuecomment-1207117567
@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
1996fanrui commented on PR #20137:
URL: https://github.com/apache/flink/pull/20137#issuecomment-1207117441
@flinkbot run azur
--
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-20945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576101#comment-17576101
]
Robert Metzger commented on FLINK-20945:
I assume that this error happens when y
[
https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28394:
---
Labels: stale-assigned test-stability (was: test-stability)
I am the [Flink Jira Bot|https:
[
https://issues.apache.org/jira/browse/FLINK-28425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28425:
---
Labels: stale-assigned test-stability (was: test-stability)
I am the [Flink Jira Bot|https:
[
https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26692:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-25729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25729:
--
Fix Version/s: (was: 1.16.0)
> Replace the deprecated FlinkKinesisConsumer with a Kinesis
[
https://issues.apache.org/jira/browse/FLINK-26256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-26256:
--
Fix Version/s: (was: 1.16.0)
> AWS SDK Async Event Loop Group Classloader Issue
>
[
https://issues.apache.org/jira/browse/FLINK-25859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25859:
--
Fix Version/s: (was: 1.16.0)
> Add documentation for DynamoDB Async Sink
> ---
[
https://issues.apache.org/jira/browse/FLINK-28733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28733.
Resolution: Fixed
master: ff2f4cb624ab84c43f2fd0daea2daa8ba74b4169
> jobmanager.sh should
zentol merged PR #20474:
URL: https://github.com/apache/flink/pull/20474
--
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.apache
flinkbot commented on PR #20475:
URL: https://github.com/apache/flink/pull/20475#issuecomment-1206884228
## CI report:
* 4aaade4c77c9568324b50f37878f24e00f757807 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28842:
---
Labels: pull-request-available (was: )
> Add client.id.prefix for the KafkaSink
> -
sap1ens opened a new pull request, #20475:
URL: https://github.com/apache/flink/pull/20475
## What is the purpose of the change
Adding a way to configure `client.id.prefix` for the KafkaSink, which,
internally, configures `client.id` for the KafkaProducer. This implementation
essenti
[
https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576047#comment-17576047
]
Yaroslav Tkachenko commented on FLINK-28842:
I believe this will also fix ht
Yaroslav Tkachenko created FLINK-28842:
--
Summary: Add client.id.prefix for the KafkaSink
Key: FLINK-28842
URL: https://issues.apache.org/jira/browse/FLINK-28842
Project: Flink
Issue Type
qinjunjerry commented on PR #20464:
URL: https://github.com/apache/flink/pull/20464#issuecomment-1206853686
> Hi @qinjunjerry , the compile is failed, could you take a look?
It was due to a checkstyle error. I've fixed it and updated the PR. Now the
compilation is OK. But CI/CD piplel
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r939060670
##
flink-end-to-end-tests/flink-end-to-end-tests-aws-kinesis-firehose/src/test/resources/send-orders.sql:
##
@@ -29,7 +29,7 @@ CREATE TABLE orders (
'aws.credentials
alpinegizmo commented on PR #20473:
URL: https://github.com/apache/flink/pull/20473#issuecomment-1206723066
> > It seems unfortunate that the contract here has to be independently
implemented in several different places.
>
> Yes :( The are just used in too many different places in too
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r939059448
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RateLimitingStrategy.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licen
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r939059196
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RequestInfo.java:
##
@@ -0,0 +1,65 @@
+/*
+ * Licensed to th
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r939058926
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/RequestInfo.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to th
hlteoh37 commented on code in PR #20245:
URL: https://github.com/apache/flink/pull/20245#discussion_r939058598
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/AIMDScalingStrategy.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licens
zentol commented on PR #20473:
URL: https://github.com/apache/flink/pull/20473#issuecomment-1206713739
> It seems unfortunate that the contract here has to be independently
implemented in several different places.
Yes :( The are just used in too many different places in too many diffe
Chesnay Schepler created FLINK-28841:
Summary: Document dynamic property support for startup scripts
Key: FLINK-28841
URL: https://issues.apache.org/jira/browse/FLINK-28841
Project: Flink
zentol commented on PR #20474:
URL: https://github.com/apache/flink/pull/20474#issuecomment-1206685542
> should the same be done for taskmanager.sh?
That already works!
> what about documentation? I'll do that after the feature freeze.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-28713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28713.
Resolution: Fixed
master: 6335b573863af2b30a6541f910be96ddf61f9c84
> Remove unused curato
[
https://issues.apache.org/jira/browse/FLINK-25645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-25645.
---
Resolution: Fixed
Fixed in master: f806bb79950202256358988684964761ebe2a05b
> UnsupportedOperationException
wuchong merged PR #19709:
URL: https://github.com/apache/flink/pull/19709
--
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
wuchong commented on PR #19709:
URL: https://github.com/apache/flink/pull/19709#issuecomment-1206681944
The failed case is tracked by FLINK-26721
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575976#comment-17575976
]
Jark Wu commented on FLINK-26721:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
1996fanrui commented on PR #20137:
URL: https://github.com/apache/flink/pull/20137#issuecomment-1206678119
@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
alpinegizmo commented on code in PR #20473:
URL: https://github.com/apache/flink/pull/20473#discussion_r939011768
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testutils/formats/SchemaUtils.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-28808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28808.
Resolution: Fixed
master: e0f4a0ca9271f0e9e31011578dbdea4b5a8d30fe
> CsvFileFormatFactory
zentol merged PR #20381:
URL: https://github.com/apache/flink/pull/20381
--
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.apache
zentol merged PR #20452:
URL: https://github.com/apache/flink/pull/20452
--
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.apache
zentol commented on PR #20452:
URL: https://github.com/apache/flink/pull/20452#issuecomment-1206665474
> I am wondering though if we need to add a test somewhere to prevent this
improvement from regressing?
Once FLINK-28621 is in this will fail several tests.
--
This is an automate
[
https://issues.apache.org/jira/browse/FLINK-28733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28733:
---
Labels: pull-request-available (was: )
> jobmanager.sh should support dynamic properties
>
flinkbot commented on PR #20474:
URL: https://github.com/apache/flink/pull/20474#issuecomment-1206648520
## CI report:
* 04d87bb59b9cd83af0e455cf81febbe80eaf735c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20473:
URL: https://github.com/apache/flink/pull/20473#issuecomment-1206647558
## CI report:
* b5fdeedd74a2b5ad05cc86ed902b5334609f7d8b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol opened a new pull request, #20473:
URL: https://github.com/apache/flink/pull/20473
This PR resolves a large number of violations of the schema lifecycle; where
the schema was used without open() being called beforehand.
This is generally bad because certain schemas might rely on it
[
https://issues.apache.org/jira/browse/FLINK-28807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28807:
---
Labels: pull-request-available (was: )
> Various components don't respect schema lifecycle
[
https://issues.apache.org/jira/browse/FLINK-28554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575911#comment-17575911
]
Tim commented on FLINK-28554:
-
Sounds great, I will look into it as soon as I'm back from va
TanYuxin-tyx commented on PR #20457:
URL: https://github.com/apache/flink/pull/20457#issuecomment-1206596167
@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 comme
TanYuxin-tyx commented on PR #20461:
URL: https://github.com/apache/flink/pull/20461#issuecomment-1206595986
@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 comme
TanYuxin-tyx commented on PR #20459:
URL: https://github.com/apache/flink/pull/20459#issuecomment-1206595818
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28772:
Fix Version/s: 1.16.0
> Hive dialect supports add jar
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28772:
Component/s: Connectors / Hive
> Hive dialect supports add jar
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-28772:
---
Assignee: luoyuxia (was: Jark Wu)
> Hive dialect supports add jar
> -
[
https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-28772:
---
Assignee: Jark Wu
> Hive dialect supports add jar
> --
>
>
flinkbot commented on PR #20472:
URL: https://github.com/apache/flink/pull/20472#issuecomment-1206589357
## CI report:
* e27c525fb0c2a3265886a711280ef4f9eb3cad2a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28710:
---
Labels: pull-request-available (was: )
> Supports dynamic filtering execution
> ---
godfreyhe opened a new pull request, #20472:
URL: https://github.com/apache/flink/pull/20472
## What is the purpose of the change
*Supports dynamic filtering execution*
## Brief change log
- *The fact source of DPP must be FLIP-27 source*
- *Supports dy
[
https://issues.apache.org/jira/browse/FLINK-28710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-28710:
---
Summary: Supports dynamic filtering execution (was: Transform dpp ExecNode
to StreamGraph)
> Suppo
[
https://issues.apache.org/jira/browse/FLINK-28630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-28630.
-
Resolution: Implemented
Merged into master:
82417ab9a5ad6935a73f9b7d1bc6bd4f47ce4f61
> Allow to
fsk119 closed pull request #20401: [FLINK-28630][sql-gateway][hive] Allow to
getSchemas in the HiveServer2 Endpoint.
URL: https://github.com/apache/flink/pull/20401
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
lsyldliu commented on code in PR #20442:
URL: https://github.com/apache/flink/pull/20442#discussion_r938839276
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/ParquetDataColumnReader.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-27620.
---
Resolution: Fixed
Fixed in master: b4df097513be1ec0b82b5a110f93606388747765
> Support percent_rank
> --
wuchong merged PR #20347:
URL: https://github.com/apache/flink/pull/20347
--
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-28754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28754:
---
Labels: pull-request-available (was: )
> Document that Java 8 is required to build table st
SteNicholas opened a new pull request, #264:
URL: https://github.com/apache/flink-table-store/pull/264
Flink Table Store can not be built with Java 11, but the "[build from
source](https://nightlies.apache.org/flink/flink-table-store-docs-master/docs/engines/build)"
instructions don't menti
wuchong commented on code in PR #20413:
URL: https://github.com/apache/flink/pull/20413#discussion_r938805740
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java:
##
@@ -1121,6 +1122,35 @@ public void testSetCommand() th
[
https://issues.apache.org/jira/browse/FLINK-28754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicholas Jiang updated FLINK-28754:
---
Summary: Document that Java 8 is required to build table store (was:
document that Java 8 i
1996fanrui commented on PR #20137:
URL: https://github.com/apache/flink/pull/20137#issuecomment-1206453077
@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-28296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28296:
Component/s: Connectors / Hive
> Support Hive's UDAF which implement GenericUDAFResolver
> ---
[
https://issues.apache.org/jira/browse/FLINK-28296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28296.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: f9bd7d2f553174c2ae25da63e3d5be156649cf27
>
wuchong merged PR #20102:
URL: https://github.com/apache/flink/pull/20102
--
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-28840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28840:
---
Labels: pull-request-available (was: )
> Introduce roadmap document of Flink Table Store
>
SteNicholas opened a new pull request, #263:
URL: https://github.com/apache/flink-table-store/pull/263
The Flink Table Store subproject needs its own roadmap document to present
an overview of the general direction.
**The brief change log**
- Introduces roadmap document `roadmap.md
[
https://issues.apache.org/jira/browse/FLINK-28749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28749.
--
Resolution: Fixed
Merged to main c91ebbd1ae989749948dc6de69255be70c5b7557
> Add resource type to Kube
gyfora merged PR #339:
URL: https://github.com/apache/flink-kubernetes-operator/pull/339
--
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
1 - 100 of 233 matches
Mail list logo
