[
https://issues.apache.org/jira/browse/FLINK-29034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29034:
---
Labels: pull-request-available (was: )
> HYBRID_FULL result partition type is not yet
reswqa opened a new pull request, #20624:
URL: https://github.com/apache/flink/pull/20624
## What is the purpose of the change
*HYBRID_FULL partitions can be consumed repeatedly, but it does not support
concurrent consumption. So re-consumable is false, but double calculation can
be
flinkbot commented on PR #20623:
URL: https://github.com/apache/flink/pull/20623#issuecomment-1220245833
## CI report:
* 231cae1aa7eb8e1e265149f8ac991dc80f558245 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Myasuka commented on code in PR #16582:
URL: https://github.com/apache/flink/pull/16582#discussion_r949794919
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStore.java:
##
@@ -133,17 +134,23 @@ public void addCheckpoint(
HuangXingBo commented on code in PR #20619:
URL: https://github.com/apache/flink/pull/20619#discussion_r949794494
##
flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml:
##
@@ -212,6 +212,16 @@
test
+
+
liuzhuang2017 opened a new pull request, #20623:
URL: https://github.com/apache/flink/pull/20623
## What is the purpose of the change
- Fix the task class typo.
## Brief change log
- Fix the task class typo.
## Verifying this change
- This change is
[
https://issues.apache.org/jira/browse/FLINK-29007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-29007:
---
Assignee: dalongliu
> UsingRemoteJarITCase failed with NPE in hadoop3
>
lsyldliu commented on code in PR #20616:
URL: https://github.com/apache/flink/pull/20616#discussion_r949754180
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/columnar/vector/heap/HeapRowVector.java:
##
@@ -46,4 +46,12 @@ public ColumnarRowData
godfreyhe commented on code in PR #20506:
URL: https://github.com/apache/flink/pull/20506#discussion_r949785838
##
docs/content/docs/dev/table/sql/analyze.md:
##
@@ -0,0 +1,365 @@
+---
+title: "ANALYZE TABLE Statements"
+weight: 8
+type: docs
+aliases:
+ -
[
https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28956.
---
Assignee: luoyuxia
Resolution: Fixed
Fixed in master: 682ec6a5d73222d5c88a86e9b4caa29ee47e0bc7
> FIx
wuchong merged PR #20572:
URL: https://github.com/apache/flink/pull/20572
--
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-28917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28917.
---
Assignee: dalongliu
Resolution: Fixed
Fixed in master: d9516238cefb03324b0468bd23fd8962166ee565
>
wuchong merged PR #20602:
URL: https://github.com/apache/flink/pull/20602
--
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-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28965.
---
Resolution: Fixed
Fixed in master: e967a7b54da969c6d974a4ec6e3afcd1cc17a8be
> Shouldn't create empty
wuchong merged PR #20599:
URL: https://github.com/apache/flink/pull/20599
--
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:
godfreyhe commented on code in PR #20596:
URL: https://github.com/apache/flink/pull/20596#discussion_r949779080
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -171,7 +171,20 @@ private static void
swuferhong commented on code in PR #20596:
URL: https://github.com/apache/flink/pull/20596#discussion_r949015345
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/batch/DynamicPartitionPruningRuleTest.java:
##
@@ -479,10 +543,20
godfreyhe commented on code in PR #20596:
URL: https://github.com/apache/flink/pull/20596#discussion_r948927828
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/physical/batch/DynamicPartitionPruningRuleTest.java:
##
@@ -479,10 +543,20
[
https://issues.apache.org/jira/browse/FLINK-28990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-28990:
--
Assignee: Yunhong Zheng
> Fix BatchPhysicalDynamicFilteringDataCollector with empty output
[
https://issues.apache.org/jira/browse/FLINK-28990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28990.
--
Resolution: Fixed
Fixed in master: 06e8b7fb30fee04ed61cdf99763fc7cd17401c8e
> Fix
godfreyhe closed pull request #20594: [FLINK-28990][table-planner] Fix
BatchPhysicalDynamicFilteringDataCollector with empty output type
URL: https://github.com/apache/flink/pull/20594
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
HuangXingBo commented on PR #20618:
URL: https://github.com/apache/flink/pull/20618#issuecomment-1220201442
@dianfu @Sxnan I have resolved the comments in the latest commit.
--
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-29034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29034:
Assignee: Weijie Guo
> HYBRID_FULL result partition type is not yet reConsumable
>
HuangXingBo commented on code in PR #20618:
URL: https://github.com/apache/flink/pull/20618#discussion_r949761292
##
flink-python/pyflink/datastream/data_stream.py:
##
@@ -895,6 +895,20 @@ def get_side_output(self, output_tag: OutputTag) ->
'DataStream':
"""
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
[
https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marco A. Villalobos updated FLINK-29039:
Description:
RowData produced by LineBytesInputFormat is reused, but
Marco A. Villalobos created FLINK-29039:
---
Summary: RowData produced by LineBytesInputFormat is reused, but
DeserializationSchemaAdapter#Reader only shallow copies produced data, thus
result will always be the last row value
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-28915:
--
Affects Version/s: (was: 1.15.0)
(was: 1.15.1)
> Flink Native k8s mode
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581613#comment-17581613
]
Yang Wang commented on FLINK-28915:
---
I think we need to cover all the flink-supported
[
https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581610#comment-17581610
]
lincoln lee commented on FLINK-29038:
-
[~hxbks2ks] sure, I'll lookup into this.
>
wangyang0918 commented on code in PR #20590:
URL: https://github.com/apache/flink/pull/20590#discussion_r949150514
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java:
##
@@ -213,14 +214,26 @@ public
wangyang0918 commented on PR #20590:
URL: https://github.com/apache/flink/pull/20590#issuecomment-1220176355
Push a new fix which ignores the `AlreadyExistException` instead of throwing
`PossiblyInconsistentStateException`.
@XComp Would you like to have a look again?
--
This is an
flinkbot commented on PR #20622:
URL: https://github.com/apache/flink/pull/20622#issuecomment-1220176172
## CI report:
* ccddccaf9ade0464aa97f9fec0f955e10956b2cf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581604#comment-17581604
]
Huang Xingbo commented on FLINK-29018:
--
pltbkd commented on code in PR #20612:
URL: https://github.com/apache/flink/pull/20612#discussion_r949743163
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumerator.java:
##
@@ -159,6 +161,9 @@ RowData
[
https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581602#comment-17581602
]
Huang Xingbo commented on FLINK-29038:
--
[~lincoln.86xy] Could you help take a look? Thx.
>
[
https://issues.apache.org/jira/browse/FLINK-28974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28974:
---
Labels: pull-request-available (was: )
> Add doc for the API and Option of sql gateway
WencongLiu opened a new pull request, #20622:
URL: https://github.com/apache/flink/pull/20622
## What is the purpose of the change
*Add the document for the API and Option of sql gateway*
## Brief change log
- *Extend OpenApiSpecGenerator and
[
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581598#comment-17581598
]
Echo Lee commented on FLINK-25360:
--
[~liufangqi] Thank you very much for coming up with this idea. We
Sxnan commented on code in PR #20618:
URL: https://github.com/apache/flink/pull/20618#discussion_r949740721
##
flink-python/pyflink/datastream/data_stream.py:
##
@@ -895,6 +895,20 @@ def get_side_output(self, output_tag: OutputTag) ->
'DataStream':
"""
return
Huang Xingbo created FLINK-29038:
Summary:
AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed
with AssertionError
Key: FLINK-29038
URL:
dianfu commented on code in PR #20618:
URL: https://github.com/apache/flink/pull/20618#discussion_r949738102
##
flink-python/pyflink/datastream/data_stream.py:
##
@@ -895,6 +895,20 @@ def get_side_output(self, output_tag: OutputTag) ->
'DataStream':
"""
lincoln-lil commented on PR #20577:
URL: https://github.com/apache/flink/pull/20577#issuecomment-1220140905
@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
[
https://issues.apache.org/jira/browse/FLINK-28962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangdong7 updated FLINK-28962:
---
Priority: Blocker (was: Major)
> Constant memory usage increase
> --
>
Mrzyxing commented on PR #20510:
URL: https://github.com/apache/flink/pull/20510#issuecomment-1220122954
@ChengkaiYang2022 With your patience and help, all conversation resolved.
Thank you very much, expect the next collaborate :-)
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581581#comment-17581581
]
groot commented on FLINK-28747:
---
Thanks [~stepweiwu] for reporting this issues. Do you like to fix the
[
https://issues.apache.org/jira/browse/FLINK-28521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28521:
---
Labels: security stale-assigned (was: security)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-18631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18631:
---
Labels: auto-deprioritized-major auto-deprioritized-minor performance
[
https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28046:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
dependabot[bot] opened a new pull request, #41:
URL: https://github.com/apache/flink-statefun-playground/pull/41
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
2.2.16.Final to 2.2.19.Final.
Commits
dependabot[bot] closed pull request #36: Bump undertow-core from 1.4.18.Final
to 2.2.15.Final in /java/connected-components
URL: https://github.com/apache/flink-statefun-playground/pull/36
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
dependabot[bot] commented on PR #36:
URL:
https://github.com/apache/flink-statefun-playground/pull/36#issuecomment-1219847351
Superseded by #40.
--
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
dependabot[bot] opened a new pull request, #40:
URL: https://github.com/apache/flink-statefun-playground/pull/40
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.19.Final.
Commits
dependabot[bot] closed pull request #35: Bump undertow-core from 1.4.18.Final
to 2.2.15.Final in /java/showcase
URL: https://github.com/apache/flink-statefun-playground/pull/35
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dependabot[bot] commented on PR #35:
URL:
https://github.com/apache/flink-statefun-playground/pull/35#issuecomment-1219846417
Superseded by #39.
--
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
dependabot[bot] closed pull request #34: Bump undertow-core from 1.4.18.Final
to 2.2.15.Final in /java/greeter
URL: https://github.com/apache/flink-statefun-playground/pull/34
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dependabot[bot] opened a new pull request, #39:
URL: https://github.com/apache/flink-statefun-playground/pull/39
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.19.Final.
Commits
dependabot[bot] commented on PR #34:
URL:
https://github.com/apache/flink-statefun-playground/pull/34#issuecomment-1219846361
Superseded by #38.
--
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
dependabot[bot] opened a new pull request, #38:
URL: https://github.com/apache/flink-statefun-playground/pull/38
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.19.Final.
Commits
dependabot[bot] closed pull request #33: Bump undertow-core from 1.4.18.Final
to 2.2.15.Final in /java/shopping-cart
URL: https://github.com/apache/flink-statefun-playground/pull/33
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dependabot[bot] commented on PR #33:
URL:
https://github.com/apache/flink-statefun-playground/pull/33#issuecomment-1219846215
Superseded by #37.
--
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
dependabot[bot] opened a new pull request, #37:
URL: https://github.com/apache/flink-statefun-playground/pull/37
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.19.Final.
Commits
mbenenso commented on code in PR #20587:
URL: https://github.com/apache/flink/pull/20587#discussion_r949337527
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java:
##
@@ -246,7 +246,9 @@ public
ganlute commented on PR #20542:
URL: https://github.com/apache/flink/pull/20542#issuecomment-1219821186
hi @luoyuxia, could you please help me review the changes？Thank you.
--
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-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581433#comment-17581433
]
hjw commented on FLINK-28915:
-
[~wangyang0918] [~aitozi] Does the test case need to cover all Flink
Sarang Vadali created FLINK-29037:
-
Summary: Flink Histogram not emitting sum while using Metrics
Reporter
Key: FLINK-29037
URL: https://issues.apache.org/jira/browse/FLINK-29037
Project: Flink
mbenenso commented on code in PR #20587:
URL: https://github.com/apache/flink/pull/20587#discussion_r949337527
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java:
##
@@ -246,7 +246,9 @@ public
[
https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TE updated FLINK-28910:
---
Priority: Blocker (was: Minor)
> CDC From Mysql To Hbase Bugs
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TE updated FLINK-28910:
---
Priority: Minor (was: Blocker)
> CDC From Mysql To Hbase Bugs
>
>
>
xintongsong closed pull request #20553: [FLINK-28800][network]
HsFileDataManager should avoid busy-loop when fileReader has not data to read
URL: https://github.com/apache/flink/pull/20553
--
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-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581388#comment-17581388
]
Josh Mahonin commented on FLINK-19589:
--
{quote}Do you think your approach could be extended to
rkhachatryan commented on code in PR #16582:
URL: https://github.com/apache/flink/pull/16582#discussion_r949214456
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStore.java:
##
@@ -133,17 +134,23 @@ public void addCheckpoint(
ChengkaiYang2022 commented on PR #20510:
URL: https://github.com/apache/flink/pull/20510#issuecomment-1219553900
> @ChengkaiYang2022 There is one last unresovled conversation, looks like
you haven't catch this . Very expect your ideas.
[
https://issues.apache.org/jira/browse/FLINK-29036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-29036:
Assignee: Ryan Skraba
> Code examples on the Data Sources page have errors
>
[
https://issues.apache.org/jira/browse/FLINK-29036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581369#comment-17581369
]
Ryan Skraba commented on FLINK-29036:
-
I'm reading a bunch of the doc and picking up errors as i go
Ryan Skraba created FLINK-29036:
---
Summary: Code examples on the Data Sources page have errors
Key: FLINK-29036
URL: https://issues.apache.org/jira/browse/FLINK-29036
Project: Flink
Issue Type:
wangyang0918 commented on code in PR #20590:
URL: https://github.com/apache/flink/pull/20590#discussion_r949150514
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java:
##
@@ -213,14 +214,26 @@ public
[
https://issues.apache.org/jira/browse/FLINK-28218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28218:
---
Affects Version/s: (was: kubernetes-operator-1.1.0)
> Add readiness and liveness probe to k8s
[
https://issues.apache.org/jira/browse/FLINK-28218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-28218.
Resolution: Fixed
merged to main 199ed194f81502d3e146265c1694eddaf07e838e
> Add readiness and
[
https://issues.apache.org/jira/browse/FLINK-28218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28218:
---
Fix Version/s: kubernetes-operator-1.2.0
> Add readiness and liveness probe to k8s operator
>
gyfora merged PR #349:
URL: https://github.com/apache/flink-kubernetes-operator/pull/349
--
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-28963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28963.
Fix Version/s: 1.16.0
Resolution: Fixed
master:
zentol merged PR #20574:
URL: https://github.com/apache/flink/pull/20574
--
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-29035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581348#comment-17581348
]
Timo Walther commented on FLINK-29035:
--
CC [~lsy]
> ExpressionReducer does not work with jar
Timo Walther created FLINK-29035:
Summary: ExpressionReducer does not work with jar resources
Key: FLINK-29035
URL: https://issues.apache.org/jira/browse/FLINK-29035
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-29035:
-
Fix Version/s: 1.16.0
> ExpressionReducer does not work with jar resources
>
swuferhong commented on PR #20594:
URL: https://github.com/apache/flink/pull/20594#issuecomment-1219465845
@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
LinMingQiang commented on PR #20370:
URL: https://github.com/apache/flink/pull/20370#issuecomment-1219465061
I also encountered this exception. I read Kafka data in batches.Therefore,
we want to use latest when the timestamp is exceeded.
--
This is an automated message from
XComp commented on code in PR #20590:
URL: https://github.com/apache/flink/pull/20590#discussion_r949096186
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java:
##
@@ -213,14 +214,26 @@ public RetrievableStateHandle
flinkbot commented on PR #20621:
URL: https://github.com/apache/flink/pull/20621#issuecomment-1219453850
## CI report:
* 37d3b9cfbc949013dbcfc516e0935d44fd67 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17581330#comment-17581330
]
Jason Kania commented on FLINK-27611:
-
May I ask why this fix was not included in the 1.15.2
[
https://issues.apache.org/jira/browse/FLINK-29029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29029:
---
Labels: pull-request-available (was: )
> Fix the bug of CSV format doesn't work in Thread
wangyang0918 commented on code in PR #20590:
URL: https://github.com/apache/flink/pull/20590#discussion_r949071300
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java:
##
@@ -213,14 +214,26 @@ public
HuangXingBo opened a new pull request, #20621:
URL: https://github.com/apache/flink/pull/20621
## What is the purpose of the change
*This pull request will fix the bug of InternalTypeInfo mapping to
IdentityConverter in Thread Mode*
## Brief change log
- *Fix the
1 - 100 of 212 matches
Mail list logo
