godfreyhe closed pull request #20462: [FLINK-28821][table-planner] Adjust join
cost for dpp query pattern which could help more plans use dpp
URL: https://github.com/apache/flink/pull/20462
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-28706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28706.
--
Resolution: Fixed
Fixed in master
> FLIP-248: Introduce dynamic partition pruning
>
[ https://issues.apache.org/jira/browse/FLINK-24332 ]
Yang Wang deleted comment on FLINK-24332:
---
was (Author: fly_in_gis):
Thanks for the volunteer. You have got assigned and I will get to the PR in
this week.
> Support to mount a
lincoln-lil commented on PR #20482:
URL: https://github.com/apache/flink/pull/20482#issuecomment-1210169749
local verify ok for table modules(the ci pipeline was too slow)
wuchong commented on PR #20419:
URL: https://github.com/apache/flink/pull/20419#issuecomment-1210176326
CI is passed:
https://dev.azure.com/imjark/Flink/_build/results?buildId=576=results
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
wuchong merged PR #20419:
URL: https://github.com/apache/flink/pull/20419
--
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:
[
https://issues.apache.org/jira/browse/FLINK-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-27338.
--
Resolution: Fixed
Fixed in master: dd16b0801305c98b3e2876d7cb9e4631a7c5621a
> Improve spliting file
SteNicholas commented on code in PR #20390:
URL: https://github.com/apache/flink/pull/20390#discussion_r941943372
##
flink-kubernetes/src/main/resources/META-INF/NOTICE:
##
@@ -14,27 +14,27 @@ This project bundles the following dependencies under the
Apache Software Licens
-
godfreyhe closed pull request #20377: [FLINK-27338][hive] Improve splitting
file for Hive table with orc format
URL: https://github.com/apache/flink/pull/20377
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
SteNicholas commented on code in PR #20390:
URL: https://github.com/apache/flink/pull/20390#discussion_r941943372
##
flink-kubernetes/src/main/resources/META-INF/NOTICE:
##
@@ -14,27 +14,27 @@ This project bundles the following dependencies under the
Apache Software Licens
-
[
https://issues.apache.org/jira/browse/FLINK-28481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-28481.
-
Resolution: Fixed
Fixed via:
master: f2ec01241c5e5bcb860180dae5c0a660bc816926
> Bump the fabric8
Myasuka commented on code in PR #20421:
URL: https://github.com/apache/flink/pull/20421#discussion_r941969248
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -474,9 +474,10 @@ ttl_config = StateTtlConfig \
For more fine-grained control over some special
Huang Xingbo created FLINK-28896:
Summary: Test Flink Release 1.16
Key: FLINK-28896
URL: https://issues.apache.org/jira/browse/FLINK-28896
Project: Flink
Issue Type: Improvement
lincoln-lil commented on PR #20482:
URL: https://github.com/apache/flink/pull/20482#issuecomment-1210159092
there're several merge conflicts for the latest master, so need to verify
the merged pr completely, the local verify are running
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-28876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28876:
Affects Version/s: (was: 1.15.1)
> Support writing RowData to Orc files in PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-28876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28876.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via cf3beff586a088c20833d8a8fc72bbc37d87a2b1
[
https://issues.apache.org/jira/browse/FLINK-28701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-28701.
Resolution: Fixed
master (1.16): 56e91700ca56f5535f677314167b94b476eb6c3f
> Minimize the
lincoln-lil commented on PR #20482:
URL: https://github.com/apache/flink/pull/20482#issuecomment-1210064098
@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
Juntao Hu created FLINK-28895:
-
Summary: Eliminate the map to convert RowData to Row before
RowData FileSink
Key: FLINK-28895
URL: https://issues.apache.org/jira/browse/FLINK-28895
Project: Flink
SteNicholas commented on PR #20390:
URL: https://github.com/apache/flink/pull/20390#issuecomment-1210068123
@bzhaoopenstack, thanks for your contribution. There are a few
inconsistencies for NOTICE file. You could refer to
godfreyhe commented on PR #20462:
URL: https://github.com/apache/flink/pull/20462#issuecomment-1210068656
The private CI is green:
https://dev.azure.com/leonardBang/Azure_CI/_build/results?buildId=715=results.
I will merge it
--
This is an automated message from the Apache Git Service.
wuchong merged PR #20365:
URL: https://github.com/apache/flink/pull/20365
--
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:
fredia commented on code in PR #20421:
URL: https://github.com/apache/flink/pull/20421#discussion_r941966732
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -474,9 +474,10 @@ ttl_config = StateTtlConfig \
For more fine-grained control over some special
Liu created FLINK-28897:
---
Summary: Fail to use udf in added jar when enabling checkpoint
Key: FLINK-28897
URL: https://issues.apache.org/jira/browse/FLINK-28897
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577750#comment-17577750
]
dalongliu commented on FLINK-28897:
---
[~Jiangang] Thanks for report it, I will take a look.
> Fail to
[
https://issues.apache.org/jira/browse/FLINK-28767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577765#comment-17577765
]
luoyuxia commented on FLINK-28767:
--
[
https://issues.apache.org/jira/browse/FLINK-28632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-28632:
-
Assignee: yuzelin (was: Shengkai Fang)
> Allow to
[
https://issues.apache.org/jira/browse/FLINK-28895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28895:
---
Labels: pull-request-available (was: )
> Eliminate RowRowConverter between RowData source
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu updated FLINK-28897:
Description:
The problem can be reproduced when enabling checkpoint for that
Vancior opened a new pull request, #20525:
URL: https://github.com/apache/flink/pull/20525
## What is the purpose of the change
This PR eliminates using a `RowRowConverter` between RowData sources and
sinks, which frees users from creating a identity map to convert records type.
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577747#comment-17577747
]
Xingbo Huang commented on FLINK-28898:
--
[~Yanfei Lei] Could you help take a look?
>
Xingbo Huang created FLINK-28898:
Summary:
ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut
failed
Key: FLINK-28898
URL:
[
https://issues.apache.org/jira/browse/FLINK-28855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577748#comment-17577748
]
Xingbo Huang commented on FLINK-28855:
--
flinkbot commented on PR #20525:
URL: https://github.com/apache/flink/pull/20525#issuecomment-1210130236
## CI report:
* 542a70de56e96f8e1be2d5166df42c7b678b1766 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-28896:
---
Summary: [Umbrella] Test Flink Release 1.16 (was: Test Flink Release 1.16)
> [Umbrella] Test Flink
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28897:
Priority: Critical (was: Major)
> Fail to use udf in added jar when enabling checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-28774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28774.
---
Fix Version/s: 1.16.0
Assignee: luoyuxia
Resolution: Fixed
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-28774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28774:
Component/s: Connectors / Hive
> Allow user to configure whether to enable sort or not when it's for
[
https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-28060:
Assignee: Chesnay Schepler
> Kafka Commit on checkpointing fails repeatedly
[
https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-28060:
-
Fix Version/s: 1.16.0
> Kafka Commit on checkpointing fails repeatedly after a broker
luoyuxia commented on PR #20419:
URL: https://github.com/apache/flink/pull/20419#issuecomment-1210069019
@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-26929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-26929.
---
Resolution: Fixed
Fixed in master: 10acb641a036ae9d171452695b660c46d97c865a
> Introduce adaptive hash join
[
https://issues.apache.org/jira/browse/FLINK-26929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577710#comment-17577710
]
Jark Wu commented on FLINK-26929:
-
[~Runking], yes, you are right.
> Introduce adaptive hash join for
[
https://issues.apache.org/jira/browse/FLINK-28821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28821.
--
Resolution: Fixed
Fixed in master: 320f4cd5e5f3e851ad14f9d1e504959e58106157
> Adjust join cost for
wangyang0918 commented on PR #20390:
URL: https://github.com/apache/flink/pull/20390#issuecomment-1210089927
Using the following command to get the bundled dependencies and verified.
```
cd flink-kubernetes
mvn clean install -DskipTests | grep Including | grep -v
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-28898:
--
Assignee: Hangxiang Yu
>
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577741#comment-17577741
]
Huang Xingbo commented on FLINK-28766:
--
xintongsong closed pull request #20429: [FLINK-28701][runtime] Minimize the
explosion range during failover for hybrid shuffle
URL: https://github.com/apache/flink/pull/20429
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-28895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-28895:
--
Summary: Eliminate RowRowConverter between RowData source and sink (was:
Eliminate the map to
Myracle commented on PR #20269:
URL: https://github.com/apache/flink/pull/20269#issuecomment-1210072884
@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.
dependabot[bot] commented on PR #20279:
URL: https://github.com/apache/flink/pull/20279#issuecomment-1210093057
Looks like io.fabric8:kubernetes-client is up-to-date now, so this is no
longer needed.
--
This is an automated message from the Apache Git Service.
To respond to the message,
wangyang0918 merged PR #20390:
URL: https://github.com/apache/flink/pull/20390
--
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:
[
https://issues.apache.org/jira/browse/FLINK-28481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-28481:
--
Fix Version/s: 1.16.0
> Bump the fabric8 kubernetes-client to 5.12.3
>
dependabot[bot] closed pull request #20279: Bump kubernetes-client from 5.5.0
to 5.7.4 in /flink-kubernetes
URL: https://github.com/apache/flink/pull/20279
--
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
fsk119 closed pull request #20493: [FLINK-28632][sql-gateway][hive] Allow to
GetColumns/GetPrimaryKeys/GetTableTypes in the HiveServer2 Endpoint.
URL: https://github.com/apache/flink/pull/20493
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
lincoln-lil commented on PR #20482:
URL: https://github.com/apache/flink/pull/20482#issuecomment-1210095530
@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
dianfu closed pull request #20505: [FLINK-28876][python][format/orc] Support
writing RowData into Orc files
URL: https://github.com/apache/flink/pull/20505
--
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
[
https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577742#comment-17577742
]
Huang Xingbo commented on FLINK-26721:
--
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28897:
Component/s: Table SQL / Client
> Fail to use udf in added jar when enabling checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28897:
Fix Version/s: 1.16.0
> Fail to use udf in added jar when enabling checkpoint
>
leonardBang merged PR #18469:
URL: https://github.com/apache/flink/pull/18469
--
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:
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577255#comment-17577255
]
Yunfeng Zhou commented on FLINK-27691:
--
[
https://issues.apache.org/jira/browse/FLINK-28815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28815:
---
Labels: pull-request-available (was: )
> Translate the "Real Time Reporting with the Table
zhuzhurk commented on code in PR #20507:
URL: https://github.com/apache/flink/pull/20507#discussion_r941037269
##
docs/content/docs/deployment/speculative_execution.md:
##
@@ -0,0 +1,100 @@
+---
+title: Speculative Execution
+weight: 5
+type: docs
+
+---
+
+
+# Speculative
flinkbot commented on PR #20511:
URL: https://github.com/apache/flink/pull/20511#issuecomment-1209085049
## CI report:
* e0654a81c17f975f5f9729d0eb2c015cca6c3bde UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28811.
Resolution: Fixed
master: 5fb135e23e3251bcacf19d8db8cf358ddda76d6e
> Enable Java 11
zentol merged PR #20453:
URL: https://github.com/apache/flink/pull/20453
--
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:
swuferhong opened a new pull request, #20513:
URL: https://github.com/apache/flink/pull/20513
## What is the purpose of the change
This pr is aims to add document for introduce join hints for batch sql.
## Brief change log
- Adding join hints contents in
Myasuka commented on code in PR #20421:
URL: https://github.com/apache/flink/pull/20421#discussion_r941081228
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -474,9 +474,10 @@ ttl_config = StateTtlConfig \
For more fine-grained control over some special
gaoyunhaii closed pull request #20512: [FLINK-28860][tests] Disable CacheITCase
URL: https://github.com/apache/flink/pull/20512
--
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-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28883:
---
Description: like file number, total line number and total size
> HiveTableSink support to report
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28883:
---
Summary: HiveTableSink support to report metrics to metastore (was: Report
hive tasks' file
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-28883:
Description: Currently, HiveTableSink is failed to report metrics to
metastores, like file number, total
flinkbot commented on PR #20514:
URL: https://github.com/apache/flink/pull/20514#issuecomment-1209133788
## CI report:
* ce5b5703c44161b675cb5004d267f33c96ac1fe6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yunfengzhou-hub commented on PR #20454:
URL: https://github.com/apache/flink/pull/20454#issuecomment-1209157911
@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
Weijie Guo created FLINK-28889:
--
Summary: Hybrid shuffle writes multiple copies of broadcast data
Key: FLINK-28889
URL: https://issues.apache.org/jira/browse/FLINK-28889
Project: Flink
Issue
flinkbot commented on PR #20515:
URL: https://github.com/apache/flink/pull/20515#issuecomment-1209172445
## CI report:
* 879ff1c6f3f4301df8c675092d8dd451c7670203 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rmetzger commented on code in PR #19972:
URL: https://github.com/apache/flink/pull/19972#discussion_r941153631
##
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java:
##
@@ -33,8 +33,10 @@
import
Grypse commented on PR #20516:
URL: https://github.com/apache/flink/pull/20516#issuecomment-1209190506
@wangyang0918 Please help me review this PR.
--
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
rkhachatryan commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1209195638
Previously, I had a class-loading issue in this test. Byut trying to debug
your test, I see that the custom `CheckpointStorage` doesn't override
`configure()`;
rkhachatryan commented on PR #20217:
URL: https://github.com/apache/flink/pull/20217#issuecomment-1209205537
Merged manually as
1f9632a07199854c0225bd7f416c038fbf59abe0..52eb7e76b5d66ff5c4d9d4af8a213b5b8f9f8322
(build
rkhachatryan closed pull request #20217: [FLINK-27693][state] Support local
recovery for non-materialized part
URL: https://github.com/apache/flink/pull/20217
--
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
Gyula Fora created FLINK-28892:
--
Summary: Update NOTICE for flink-kubernetes-operator 1.1.1
Key: FLINK-28892
URL: https://issues.apache.org/jira/browse/FLINK-28892
Project: Flink
Issue Type:
gyfora commented on PR #344:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/344#issuecomment-1209241084
This is based on the command:
```
mvn clean install -DskipTests -pl flink-kubernetes-operator | grep Including
| grep -v org.apache.flink | cut -d' ' -f3 | sort
luoyuxia commented on PR #20377:
URL: https://github.com/apache/flink/pull/20377#issuecomment-1209247982
@godfreyhe Thanks for reviewing. I have addressed your comments. Could you
please help review again?
--
This is an automated message from the Apache Git Service.
To respond to the
dannycranmer commented on PR #20245:
URL: https://github.com/apache/flink/pull/20245#issuecomment-1209258678
@pnowojski any final 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 go to the
Vancior commented on code in PR #20505:
URL: https://github.com/apache/flink/pull/20505#discussion_r941223474
##
docs/content/docs/connectors/datastream/filesystem.md:
##
@@ -792,6 +792,36 @@ class PersonVectorizer(schema: String) extends
Vectorizer[Person](schema) {
{{< /tab
[
https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577368#comment-17577368
]
Chesnay Schepler commented on FLINK-28060:
--
I ran CI with Kafka 3.2.1 and it passed without
rkhachatryan commented on PR #20103:
URL: https://github.com/apache/flink/pull/20103#issuecomment-1209275667
The build
[succeeded](https://dev.azure.com/khachatryanroman/flink/_build/results?buildId=1601=results)
in a private branch, merging.
--
This is an automated message from the
Myasuka commented on code in PR #20421:
URL: https://github.com/apache/flink/pull/20421#discussion_r941272331
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -474,9 +474,10 @@ ttl_config = StateTtlConfig \
For more fine-grained control over some special
[
https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-25485.
Fix Version/s: 1.16.0
Resolution: Resolved
Resolved in master(1.16):
[
https://issues.apache.org/jira/browse/FLINK-28884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-28884:
---
Description:
Downstream task may never be notified of data available in hybrid shuffle when
number
Myasuka commented on code in PR #20405:
URL: https://github.com/apache/flink/pull/20405#discussion_r941079853
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java:
##
@@ -223,4 +223,27 @@ public
libenchao commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1209118740
> I believe IN is supported out of the box, because Flink compile IN into
multiple X=Y condition chained together by OR
Not exactly, we have a threshold (default 4):
Qingsheng Ren created FLINK-28885:
-
Summary: Improve LookupFunction to support different kinds of
RowData as key row
Key: FLINK-28885
URL: https://issues.apache.org/jira/browse/FLINK-28885
Project:
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28883:
---
Description: HiveTableSink support to report metrics to metastores, like
file number, total line
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28883:
---
Fix Version/s: (was: 1.16.0)
> HiveTableSink supports to report metrics to hive metastore
>
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28883:
---
Fix Version/s: 1.16.0
> HiveTableSink supports to report metrics to hive metastore
>
Vancior commented on code in PR #20499:
URL: https://github.com/apache/flink/pull/20499#discussion_r941102426
##
flink-python/pyflink/fn_execution/coders.py:
##
@@ -725,13 +725,17 @@ def from_type_info_proto(type_info):
return RowCoder(
luoyuxia commented on code in PR #20377:
URL: https://github.com/apache/flink/pull/20377#discussion_r941114418
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/PartitionMonitorTest.java:
##
@@ -99,6 +99,10 @@ private void
1 - 100 of 391 matches
Mail list logo
