morhidi commented on PR #231:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/231#issuecomment-1132539384
cc @mbalassi @wangyang0918
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-27647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27647:
---
Labels: pull-request-available (was: )
> Improve Metrics documentation to include newly add
morhidi opened a new pull request, #231:
URL: https://github.com/apache/flink-kubernetes-operator/pull/231
Added Operator specific metrics description
--
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
KarmaGYZ commented on PR #17873:
URL: https://github.com/apache/flink/pull/17873#issuecomment-1132533635
> > @xinbinhuang Thanks for the update. Could you explain why you need to
derive the total task slots required from the JSON graph?
>
> Our team wants to derive the total slots req
Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r877785593
##
flink-python/pyflink/datastream/state.py:
##
@@ -281,6 +283,110 @@ def __iter__(self) -> Iterator[K]:
return iter(self.keys())
+class ReadOnlyBroadcastSt
wangyang0918 commented on code in PR #230:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/230#discussion_r877783426
##
.github/workflows/docs.yaml:
##
@@ -41,9 +42,11 @@ jobs:
echo "flink_branch=${currentBranch}"
echo "flink_branch=${current
Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r83328
##
flink-python/pyflink/datastream/__init__.py:
##
@@ -141,6 +141,11 @@
- :class:`state.AggregatingState`:
Interface for aggregating state, based on an :clas
wangyang0918 commented on code in PR #229:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/229#discussion_r89395
##
tools/releasing/update_branch_version.sh:
##
@@ -64,7 +64,11 @@ perl -pi -e "s#^ENV OPERATOR_VERSION=.*#ENV
OPERATOR_VERSION=${NEW_VERSION}#" D
[
https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-27504.
Resolution: Information Provided
> State compaction not happening with sliding window and incremental Rock
[
https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539944#comment-17539944
]
Yun Tang commented on FLINK-27504:
--
[~asardaes], one specific round of compaction is ju
[
https://issues.apache.org/jira/browse/FLINK-25950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-25950.
---
Resolution: Fixed
master: c57b84921447bb0ade5e1ff77a05ebd8bbbe71b7
> Delete retry mechanism
XComp merged PR #19666:
URL: https://github.com/apache/flink/pull/19666
--
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.
Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r83328
##
flink-python/pyflink/datastream/__init__.py:
##
@@ -141,6 +141,11 @@
- :class:`state.AggregatingState`:
Interface for aggregating state, based on an :clas
Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r82504
##
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/state/BeamStateHandler.java:
##
@@ -23,6 +23,35 @@
/** Interface for doing actual opera
Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r82151
##
flink-python/pyflink/datastream/functions.py:
##
@@ -119,6 +118,22 @@ def get_aggregating_state(
pass
+class OperatorStateStore(ABC):
Review Comment:
Vancior commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r80129
##
flink-python/pyflink/datastream/state.py:
##
@@ -281,6 +283,110 @@ def __iter__(self) -> Iterator[K]:
return iter(self.keys())
+class ReadOnlyBroadcastSt
[
https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539937#comment-17539937
]
ConradJam commented on FLINK-27060:
---
Hi [~martijnvisser] , I would like to move this w
[
https://issues.apache.org/jira/browse/FLINK-26895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26895.
--
Resolution: Won't Fix
Not relevant with 1.15 anymore
> Improve cancelWithSavepoint timeout error mess
[
https://issues.apache.org/jira/browse/FLINK-27686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27686.
--
Resolution: Fixed
merged to
main 0e537308975f29a6dc129d047f3db337122cc3ca
release-1.0 8f4cc547b8988048
gyfora merged PR #228:
URL: https://github.com/apache/flink-kubernetes-operator/pull/228
--
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
gyfora commented on PR #230:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/230#issuecomment-1132511577
cc @mbalassi @wangyang0918
--
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
deadwind4 commented on PR #19774:
URL: https://github.com/apache/flink/pull/19774#issuecomment-1132506576
I will update the doc in this ticket
https://issues.apache.org/jira/browse/FLINK-27690
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
flinkbot commented on PR #19774:
URL: https://github.com/apache/flink/pull/19774#issuecomment-1132505009
## CI report:
* 9071427ed48c3e005d42d64318945fa6a44f6eb0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora merged PR #229:
URL: https://github.com/apache/flink-kubernetes-operator/pull/229
--
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-27711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27711:
---
Labels: pull-request-available (was: )
> Align setTopicPattern for Pulsar Connector
> -
[
https://issues.apache.org/jira/browse/FLINK-27712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharon Xie updated FLINK-27712:
---
Description:
Happened intermittently. A restart made the issue go away.
Stack trace:
{code:java}
Ti
deadwind4 opened a new pull request, #19774:
URL: https://github.com/apache/flink/pull/19774
## What is the purpose of the change
set_topics_pattern is a typo, so I update set_topics_pattern to
set_topic_pattern in pulsar.py
## Brief change log
- *Add set_topic_pattern
Sharon Xie created FLINK-27712:
--
Summary: Job failed to start due to "Time should be non negative"
Key: FLINK-27712
URL: https://issues.apache.org/jira/browse/FLINK-27712
Project: Flink
Issue Ty
alpreu commented on PR #19655:
URL: https://github.com/apache/flink/pull/19655#issuecomment-1132500442
@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.
T
LuNng Wang created FLINK-27711:
--
Summary: Align setTopicPattern for Pulsar Connector
Key: FLINK-27711
URL: https://issues.apache.org/jira/browse/FLINK-27711
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-27646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539930#comment-17539930
]
Gyula Fora commented on FLINK-27646:
I think we have two alternatives here:
1. Incl
Sxnan commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r877747182
##
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java:
##
@@ -84,6 +86,33 @@ CompletableFuture registerPartitionWithProducer(
Par
gyfora commented on code in PR #229:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/229#discussion_r877749413
##
tools/releasing/update_branch_version.sh:
##
@@ -64,7 +64,11 @@ perl -pi -e "s#^ENV OPERATOR_VERSION=.*#ENV
OPERATOR_VERSION=${NEW_VERSION}#" Do
# c
gyfora commented on code in PR #229:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/229#discussion_r877748770
##
tools/releasing/update_branch_version.sh:
##
@@ -64,7 +64,11 @@ perl -pi -e "s#^ENV OPERATOR_VERSION=.*#ENV
OPERATOR_VERSION=${NEW_VERSION}#" Do
# c
gyfora commented on code in PR #228:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/228#discussion_r877733469
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/StatusHelper.java:
##
@@ -64,6 +67,14 @@ public > void
patchAndCac
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914
]
Zhu Zhu edited comment on FLINK-17295 at 5/20/22 4:31 AM:
--
I wa
flinkbot commented on PR #19773:
URL: https://github.com/apache/flink/pull/19773#issuecomment-1132447231
## CI report:
* 32a8b3baba8200dd3b3f5b91cf9c35288e7383fd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhuzhurk commented on code in PR #19747:
URL: https://github.com/apache/flink/pull/19747#discussion_r877719574
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java:
##
@@ -364,6 +373,8 @@ public DefaultExecutionGraph(
this.re
[
https://issues.apache.org/jira/browse/FLINK-24735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24735:
---
Labels: pull-request-available (was: )
> SQL client crashes with `Cannot add expression of
fsk119 opened a new pull request, #19773:
URL: https://github.com/apache/flink/pull/19773
…r than Exception
## What is the purpose of the change
*Catch throwable in the SQL Client to escape the crash.*
## Verifying this change
Please make sure both new and
zhuzhurk commented on code in PR #19747:
URL: https://github.com/apache/flink/pull/19747#discussion_r877718674
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java:
##
@@ -364,6 +373,8 @@ public DefaultExecutionGraph(
this.re
zhuzhurk commented on code in PR #19747:
URL: https://github.com/apache/flink/pull/19747#discussion_r877718479
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java:
##
@@ -44,7 +47,12 @@ public final class ResultPartitionID implemen
zhuzhurk commented on code in PR #19747:
URL: https://github.com/apache/flink/pull/19747#discussion_r877716691
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionAttemptID.java:
##
@@ -68,19 +117,32 @@ public boolean equals(Object obj) {
[
https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-27710:
---
Assignee: Zhu Zhu
> Improve logs to better display Execution
>
Zhu Zhu created FLINK-27710:
---
Summary: Improve logs to better display Execution
Key: FLINK-27710
URL: https://issues.apache.org/jira/browse/FLINK-27710
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539914#comment-17539914
]
Zhu Zhu commented on FLINK-17295:
-
I was not concerning about it because PartitionReques
tsreaper commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r877715408
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreImpl.java:
##
@@ -201,17 +204,28 @@ public static FileStoreImpl createWithPri
tsreaper commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r877715115
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/AggregateFunction.java:
##
@@ -0,0 +1,159 @@
+/*
+ * Licensed to the
wangyang0918 commented on PR #229:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/229#issuecomment-1132438195
cc @gyfora
--
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 speci
wangyang0918 opened a new pull request, #229:
URL: https://github.com/apache/flink-kubernetes-operator/pull/229
We also need to change version of documentation in
`update_branch_version.sh`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
luoyuxia commented on code in PR #19182:
URL: https://github.com/apache/flink/pull/19182#discussion_r877711250
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserSqlFunctionConverter.java:
##
@@ -415,24 +425,73 @@
[
https://issues.apache.org/jira/browse/FLINK-27709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27709:
-
Description: We can add comment to schema for table. See
`CatalogBaseTable.getComment`. (was: W
JingsongLi opened a new pull request, #130:
URL: https://github.com/apache/flink-table-store/pull/130
We can add comment to schema for table.
--
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 s
[
https://issues.apache.org/jira/browse/FLINK-27709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27709:
---
Labels: pull-request-available (was: )
> Add comment to schema
> -
>
>
Jingsong Lee created FLINK-27709:
Summary: Add comment to schema
Key: FLINK-27709
URL: https://issues.apache.org/jira/browse/FLINK-27709
Project: Flink
Issue Type: Sub-task
Componen
openinx commented on PR #99:
URL: https://github.com/apache/flink-table-store/pull/99#issuecomment-1132426379
Closing this PR now because we've merge most of the changes. Thanks all for
the reviewing & checking.
--
This is an automated message from the Apache Git Service.
To respond to th
openinx closed pull request #99: [FLINK-27307] Flink table store support
append-only ingestion without primary keys.
URL: https://github.com/apache/flink-table-store/pull/99
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
deadwind4 closed pull request #18454: [hotfix][connector/pulsar] Fix typo in
JavaDocs example.
URL: https://github.com/apache/flink/pull/18454
--
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 sp
luoyuxia commented on code in PR #19562:
URL: https://github.com/apache/flink/pull/19562#discussion_r877701927
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserTypeConverter.java:
##
@@ -289,6 +289,7 @@ private
[
https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27708:
-
Fix Version/s: table-store-0.2.0
> Add background compaction task for append-only table when ingesting.
Zheng Hu created FLINK-27708:
Summary: Add background compaction task for append-only table when
ingesting.
Key: FLINK-27708
URL: https://issues.apache.org/jira/browse/FLINK-27708
Project: Flink
ajian2002 commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r877701752
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/AggregateFunction.java:
##
@@ -0,0 +1,159 @@
+/*
+ * Licensed to th
ajian2002 commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r877701051
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreImpl.java:
##
@@ -201,17 +204,28 @@ public static FileStoreImpl createWithPr
lsyldliu commented on PR #19410:
URL: https://github.com/apache/flink/pull/19410#issuecomment-1132420587
>
ping @matriv Can you help to complete this work as soon as possible?
[FLIP-214](https://cwiki.apache.org/confluence/display/FLINK/FLIP-214+Support+Advanced+Function+DDL)
is blo
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-27638.
-
Resolution: Not A Problem
> failed to join with table function
> ---
[
https://issues.apache.org/jira/browse/FLINK-27638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539901#comment-17539901
]
Shengkai Fang commented on FLINK-27638:
---
The source in the graph is Values source
[
https://issues.apache.org/jira/browse/FLINK-27706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27706:
---
Labels: pull-request-available (was: )
> Refactor all subclasses of FileStoreTableITCase to
openinx opened a new pull request, #129:
URL: https://github.com/apache/flink-table-store/pull/129
A minor factor for the unit tests to reuse the `batchSql`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-27707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27707:
--
Description: Perform the latest scan and pick data files to compact. (was:
Perform scan and pick data
Jane Chan created FLINK-27707:
-
Summary: Implement TableStoreFactory#onCompactTable
Key: FLINK-27707
URL: https://issues.apache.org/jira/browse/FLINK-27707
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539899#comment-17539899
]
Shengkai Fang commented on FLINK-27639:
---
Hi. Could you also share the test data wi
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539352#comment-17539352
]
Jane Chan edited comment on FLINK-27557 at 5/20/22 3:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Description: Currently, FileStoreWrite will scan and plan files when
creating a non-empty writer. We s
[
https://issues.apache.org/jira/browse/FLINK-27706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27706:
-
Fix Version/s: table-store-0.2.0
> Refactor all subclasses of FileStoreTableITCase to use the batchSql.
Zheng Hu created FLINK-27706:
Summary: Refactor all subclasses of FileStoreTableITCase to use
the batchSql.
Key: FLINK-27706
URL: https://issues.apache.org/jira/browse/FLINK-27706
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Description: Currently, FileStoreWrite will scan and plan files when
creating a non-empty writer. We s
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Description: Currently, FileStoreWrite will scan and plan files when
creating a non-empty writer. For
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Description: Currently, FileStoreWrite will scan and plan files when
creating a non-empty writer. For
[
https://issues.apache.org/jira/browse/FLINK-27679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27679:
-
Fix Version/s: table-store-0.2.0
> Support append-only table for log store.
> --
[
https://issues.apache.org/jira/browse/FLINK-27683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539894#comment-17539894
]
Shengkai Fang commented on FLINK-27683:
---
Yes. I think we can fix this. Are you int
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539893#comment-17539893
]
Yang Wang commented on FLINK-27654:
---
I am making this ticket as a blocker now since we
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27654:
--
Priority: Blocker (was: Major)
> Older jackson-databind found in /flink-kubernetes-shaded-1.0-SNAPSHO
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539892#comment-17539892
]
Yang Wang commented on FLINK-27654:
---
Of cause, we could also bump the kubernetes-clien
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Let FileStoreWrite accept pre-planned manifest entries (was:
Create the empty writer for 'AL
[
https://issues.apache.org/jira/browse/FLINK-27683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539891#comment-17539891
]
Xin Yang commented on FLINK-27683:
--
[~fsk119] It's a bug, right?
> Insert into (column
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539352#comment-17539352
]
Jane Chan edited comment on FLINK-27557 at 5/20/22 2:59 AM:
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539886#comment-17539886
]
Yang Wang edited comment on FLINK-27654 at 5/20/22 2:54 AM:
KarmaGYZ commented on code in PR #17873:
URL: https://github.com/apache/flink/pull/17873#discussion_r877686196
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java:
##
@@ -184,6 +185,8 @@ private void decorateNode(Integer vertexID, Object
[
https://issues.apache.org/jira/browse/FLINK-27705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539887#comment-17539887
]
Jane Chan commented on FLINK-27705:
---
The reason is that the previous write job had tri
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539886#comment-17539886
]
Yang Wang commented on FLINK-27654:
---
[~jbusche] You are right. The kubernetes-client i
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27654:
--
Summary: Older jackson-databind found in
/flink-kubernetes-shaded-1.0-SNAPSHOT.jar (was: Older jackso
[
https://issues.apache.org/jira/browse/FLINK-27705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539885#comment-17539885
]
Jane Chan commented on FLINK-27705:
---
Stacktrace
{code:java}
java.util.concurrent.Execu
tsreaper commented on code in PR #121:
URL: https://github.com/apache/flink-table-store/pull/121#discussion_r876537585
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/FileStoreImpl.java:
##
@@ -201,17 +204,28 @@ public static FileStoreImpl createWithPri
Jane Chan created FLINK-27705:
-
Summary: num-sorted-run.compaction-trigger should not interfere
the num-levels
Key: FLINK-27705
URL: https://issues.apache.org/jira/browse/FLINK-27705
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27654:
--
Summary: Older jackson-databind found in
flink-kubernetes-operator-1.0-SNAPSHOT-shaded.jar (was: Olde
[
https://issues.apache.org/jira/browse/FLINK-27678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27678.
Fix Version/s: table-store-0.2.0
Assignee: Zheng Hu
Resolution: Fixed
master: 5928
JingsongLi merged PR #126:
URL: https://github.com/apache/flink-table-store/pull/126
--
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...@
HuangXingBo commented on code in PR #19743:
URL: https://github.com/apache/flink/pull/19743#discussion_r876562559
##
flink-python/pyflink/datastream/functions.py:
##
@@ -119,6 +118,22 @@ def get_aggregating_state(
pass
+class OperatorStateStore(ABC):
Review Comment
ajian2002 commented on PR #121:
URL:
https://github.com/apache/flink-table-store/pull/121#issuecomment-1132373009
So the problem is solved?
--
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 sp
[
https://issues.apache.org/jira/browse/FLINK-27646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539873#comment-17539873
]
ConradJam commented on FLINK-27646:
---
OK，I would like to ask is this page built on Flin
1 - 100 of 293 matches
Mail list logo
