flinkbot commented on PR #20625:
URL: https://github.com/apache/flink/pull/20625#issuecomment-1220313901
## CI report:
* fc43dd7d4e1ce99cc8129ba58be67cb5266fe0c4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29040:
---
Labels: pull-request-available (was: )
> When using the JDBC Catalog, the custom cannot be
gaaraG opened a new pull request, #20625:
URL: https://github.com/apache/flink/pull/20625
…d because it is fixed in the code
https://issues.apache.org/jira/browse/FLINK-29040
## What is the purpose of the change
*(For example: This pull request makes task deployment go th
Zhimin Geng created FLINK-29040:
---
Summary: When using the JDBC Catalog, the custom cannot be applied
because it is fixed in the code
Key: FLINK-29040
URL: https://issues.apache.org/jira/browse/FLINK-29040
[
https://issues.apache.org/jira/browse/FLINK-28974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-28974:
Assignee: Wencong Liu
> Add doc for the API and Option of sql gateway rest endpoint
> ---
flinkbot commented on PR #20624:
URL: https://github.com/apache/flink/pull/20624#issuecomment-1220283475
## CI report:
* bd4e57e4c8100a5633f7483229fb91c1e414355d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
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 reCon
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(
c
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 getRow
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:
+ - /dev/table/sql/analyz
[
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: issues-unsubscr...@flink.apach
[
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
> Add
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: issues-unsubscr...@flink.apach
[
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 partit
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: issues-unsubscr...@flink.apach
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 vi
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 ty
[
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 BatchPhysicalDynami
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 Git
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':
"""
r
[
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
Deserializat
[
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
Deserializat
[
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
Deserializat
[
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
Deserializat
[
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
Deserializat
[
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
Deserializat
[
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
Deserializat
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&focusedCommentId=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&focusedCommentId=17581610#comment-17581610
]
lincoln lee commented on FLINK-29038:
-
[~hxbks2ks] sure, I'll lookup into this.
> A
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 RetrievableStateHand
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 auto
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&focusedCommentId=17581604#comment-17581604
]
Huang Xingbo commented on FLINK-29018:
--
https://dev.azure.com/apache-flink/apache-f
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 createRowData
[
https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581602#comment-17581602
]
Huang Xingbo commented on FLINK-29038:
--
[~lincoln.86xy] Could you help take a look?
[
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 rest
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 RestAPIDocG
[
https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581598#comment-17581598
]
Echo Lee commented on FLINK-25360:
--
[~liufangqi] Thank you very much for coming up with
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: https://issues.apache.org/jira/browse/FLINK-290
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':
"""
return
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 commen
[
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 Servi
[
https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581581#comment-17581581
]
groot commented on FLINK-28747:
---
Thanks [~stepweiwu] for reporting this issues. Do you lik
[
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 Bot|https://github.com
[
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
pull-request-availab
[
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 [Flink
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
https://github.com/undertow-io/undertow/commit/2ec4d952b6c3
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 to
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 t
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
https://github.com/undertow-io/undertow/commit/2ec4d952b6c3
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 t
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 u
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
https://github.com/undertow-io/undertow/commit/2ec4d952b6c3
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 t
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
https://github.com/undertow-io/undertow/commit/2ec4d952b6c3
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 GitHub
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 t
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
https://github.com/undertow-io/undertow/commit/2ec4d952b6c3
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 voi
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 u
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581433#comment-17581433
]
hjw commented on FLINK-28915:
-
[~wangyang0918] [~aitozi] Does the test case need to cover al
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 voi
[
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
>
>
> Ke
[
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
>
>
> Ke
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 to
[
https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581388#comment-17581388
]
Josh Mahonin commented on FLINK-19589:
--
{quote}Do you think your approach could be
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.
![image](https://user-images.githubusercontent.com/1586
[
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&focusedCommentId=17581369#comment-17581369
]
Ryan Skraba commented on FLINK-29036:
-
I'm reading a bunch of the doc and picking up
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 RetrievableStateHand
[
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 op
[
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 liv
[
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: issues-unsubscr
[
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: b550e3f59d0e9cf06339bcf717050531aac
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-29035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581348#comment-17581348
]
Timo Walther commented on FLINK-29035:
--
CC [~lsy]
> ExpressionReducer does not wo
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 Type
[
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 comment
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 th
1 - 100 of 197 matches
Mail list logo