[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-29492:
-
Assignee: Hang Ruan
> Kafka exactly-once sink causes OutOfMemoryError
>
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616199#comment-17616199
]
waywtdcc commented on FLINK-3033:
-
[~pramod] Hello, where is the Redis connector you wrote? Recently, we
[
https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616198#comment-17616198
]
Tigran Manasyan commented on FLINK-28229:
-
Hello, [~martijnvisser] ! I have implemented FLIP-27
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616187#comment-17616187
]
Sergey Troshkov edited comment on FLINK-28049 at 10/12/22 5:13 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616187#comment-17616187
]
Sergey Troshkov commented on FLINK-28049:
-
Thank you!
> Introduce FLIP-208 functionality to
hehuiyuan commented on PR #21011:
URL: https://github.com/apache/flink/pull/21011#issuecomment-1275590651
@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-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-25409.
-
Resolution: Fixed
> Add cache metric to LookupFunction
> --
>
>
JingsongLi commented on PR #313:
URL:
https://github.com/apache/flink-table-store/pull/313#issuecomment-1275570471
Hi @zjureel can you do some benchmark to verify the improvement?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
JingsongLi commented on PR #313:
URL:
https://github.com/apache/flink-table-store/pull/313#issuecomment-1275570123
CC: @tsreaper
--
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
JingsongLi commented on PR #305:
URL:
https://github.com/apache/flink-table-store/pull/305#issuecomment-1275569659
Thanks for the update, just left one minor comment.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-28618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-28618.
--
Resolution: Fixed
Close it since I haven't reproduced this problem using master branch. Feel
free
JingsongLi commented on code in PR #305:
URL: https://github.com/apache/flink-table-store/pull/305#discussion_r992981418
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/WriteFunction.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache
flinkbot commented on PR #21026:
URL: https://github.com/apache/flink/pull/21026#issuecomment-1275560087
## CI report:
* b35021c3135509cbcb1a33f30180ffc2626f19b2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29590:
---
Labels: pull-request-available (was: )
> Fix literal issue in HiveDialect
>
luoyuxia opened a new pull request, #21026:
URL: https://github.com/apache/flink/pull/21026
## What is the purpose of the change
To fix the thrown excpetion with literal in Hive dialect.
1: some folded constant like `Double.NAN` and no-primitive type can't be
convert into
[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616169#comment-17616169
]
Hang Ruan commented on FLINK-29492:
---
I am interested in this bug. Maybe I could help to take a look at
zoltar9264 commented on PR #20965:
URL: https://github.com/apache/flink/pull/20965#issuecomment-1275551163
@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
zoltar9264 commented on PR #20975:
URL: https://github.com/apache/flink/pull/20975#issuecomment-1275550883
@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-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616165#comment-17616165
]
Ran Tao commented on FLINK-28786:
-
[~grimsby] Yes, you are right. when i change to conda, it works well.
luoyuxia commented on PR #20855:
URL: https://github.com/apache/flink/pull/20855#issuecomment-1275532530
@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-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616152#comment-17616152
]
Xingbo Huang commented on FLINK-25343:
--
HuangXingBo commented on PR #20920:
URL: https://github.com/apache/flink/pull/20920#issuecomment-1275520470
cc @PatrickRen
--
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-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616151#comment-17616151
]
Xingbo Huang commented on FLINK-29405:
--
HuangXingBo commented on PR #20919:
URL: https://github.com/apache/flink/pull/20919#issuecomment-1275520363
cc @PatrickRen
--
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.
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992921852
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given
JingsongLi commented on PR #314:
URL:
https://github.com/apache/flink-table-store/pull/314#issuecomment-1275519030
Thanks @zjureel , I just left one minor comment.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
JingsongLi commented on code in PR #314:
URL: https://github.com/apache/flink-table-store/pull/314#discussion_r992939690
##
flink-table-store-e2e-tests/src/test/java/org/apache/flink/table/store/tests/SparkE2eTest.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Description:
in FLINK-26474, we try to fold constant, but it brings a issue that the folded
constant
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616142#comment-17616142
]
Xintong Song commented on FLINK-29572:
--
After looking into this a bit more, I think this might not
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992921852
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Description:
in FLINK-26474, we try to fold constant, but it may bring a issue that the
folded
libenchao commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1275500147
@qingwei91 Thanks for the updating, I'll review this PR in a few days.
> I didn't implement additional operators like IN and BETWEEN because I am
quite busy of late. Given they
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992921852
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616135#comment-17616135
]
Aitozi commented on FLINK-29557:
Anyone can help confirm this issue ?
> The SinkOperator's
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Summary: Fix literal issue for HiveDialect (was: Fix constant fold issue
for HiveDialect)
> Fix
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Description: in FLINK-26474, we try to fold constant, but it may bring a
issue that the folded constant
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Summary: Fix literal issue in HiveDialect (was: Fix literal issue for
HiveDialect)
> Fix literal
luoyuxia created FLINK-29590:
Summary: Fix constant fold issue for HiveDialect
Key: FLINK-29590
URL: https://issues.apache.org/jira/browse/FLINK-29590
Project: Flink
Issue Type: Bug
czy006 commented on PR #21012:
URL: https://github.com/apache/flink/pull/21012#issuecomment-1275495467
@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.
zoucao commented on PR #19250:
URL: https://github.com/apache/flink/pull/19250#issuecomment-1275491596
> @zoucao Thanks for updating. Could you please open the same pr to
release-1.16/1.15/1.14? @wuchong Could you please help merge?
Yes, I will do the bp soon.
--
This is an
RocMarshal commented on code in PR #20989:
URL: https://github.com/apache/flink/pull/20989#discussion_r992912891
##
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConversions.scala:
##
@@ -496,16 +496,16 @@ trait
RocMarshal commented on code in PR #20989:
URL: https://github.com/apache/flink/pull/20989#discussion_r992911391
##
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConversions.scala:
##
@@ -496,16 +496,16 @@ trait
yunfengzhou-hub commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992901815
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssemblerParams.java:
##
@@ -21,11 +21,29 @@
import
[
https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26726:
-
Issue Type: Bug (was: Improvement)
> Remove the unregistered task from readersAwaitingSplit
>
luoyuxia commented on PR #20855:
URL: https://github.com/apache/flink/pull/20855#issuecomment-1275467486
@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.
luoyuxia closed pull request #20883: [WIP] validate for
https://github.com/apache/flink/pull/20882
URL: https://github.com/apache/flink/pull/20883
--
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
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616111#comment-17616111
]
luoyuxia commented on FLINK-29585:
--
Sure. [~jark] Could you please assign this ticket to [~aitozi] ?
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-29495.
-
Fix Version/s: 1.16.0
1.17.0
1.15.3
Assignee: Martijn
Cyberness commented on PR #20257:
URL: https://github.com/apache/flink/pull/20257#issuecomment-1275379856
> The code changes look good. Recognise that we specify a KryoSerializer
instead of making the SequenceNumber a POJO to maintain backwards
compatibility. Given that we are changing the
hlteoh37 commented on PR #20257:
URL: https://github.com/apache/flink/pull/20257#issuecomment-1275342620
The code changes look good. Recognise that we specify a KryoSerializer
instead of making the SequenceNumber a POJO to maintain backwards
compatibility. Given that we are changing the
snuyanzin commented on PR #20410:
URL: https://github.com/apache/flink/pull/20410#issuecomment-1275339899
@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
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992793159
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -193,6 +204,10 @@ under the License.
org.apiguardian
Review Comment:
I've
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992793159
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -193,6 +204,10 @@ under the License.
org.apiguardian
Review Comment:
I've
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992790858
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616076#comment-17616076
]
Martijn Visser commented on FLINK-29589:
If there's indeed a reproducible case with data loss I
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29589:
---
Priority: Blocker (was: Major)
> Data Loss in Sink GlobalCommitter during Task Manager
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be
Krzysztof Chmielewski created FLINK-29589:
-
Summary: Data Loss in Sink GlobalCommitter during Task Manager
recovery
Key: FLINK-29589
URL: https://issues.apache.org/jira/browse/FLINK-29589
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink's architecture with global committer seems to be
hlteoh37 commented on PR #14737:
URL: https://github.com/apache/flink/pull/14737#issuecomment-1275238559
@MartijnVisser @dannycranmer Have picked it up here:
https://issues.apache.org/jira/browse/FLINK-29574
--
This is an automated message from the Apache Git Service.
To respond to the
kristoffSC commented on PR #21025:
URL: https://github.com/apache/flink/pull/21025#issuecomment-1275215995
wrong target branch
--
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
kristoffSC closed pull request #21025: [DRAFT] Flink 1.14 data loss sink global
committer
URL: https://github.com/apache/flink/pull/21025
--
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
kristoffSC opened a new pull request, #21025:
URL: https://github.com/apache/flink/pull/21025
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1275195142
Hi @libenchao I finally got around and implemented your suggestion. Do you
mind to take a look again?
I didn't implement additional operators like IN and BETWEEN because I am
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616044#comment-17616044
]
Gyula Fora commented on FLINK-29588:
We don't really have a concept of application version for
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616041#comment-17616041
]
Clara Xiong commented on FLINK-29588:
-
appVersion is the application version of the FlinkDeployment.
XComp commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r992679151
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -841,6 +842,12 @@ private StreamConfig
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29588:
---
Affects Version/s: (was: kubernetes-operator-1.2.0)
> Add Flink Version and Application Version
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616020#comment-17616020
]
Gyula Fora commented on FLINK-29588:
Since savepoints are compatible across version upgrades I think
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616018#comment-17616018
]
Gyula Fora commented on FLINK-29588:
What do you mean by appVersion here?
> Add Flink Version and
flinkbot commented on PR #21024:
URL: https://github.com/apache/flink/pull/21024#issuecomment-1275081315
## CI report:
* 2196926d20b5bd63f416355928bc4c76d0bfa205 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616011#comment-17616011
]
Martijn Visser commented on FLINK-29495:
Tests alsof disabled for/via:
release-1.16:
MartijnVisser merged PR #21017:
URL: https://github.com/apache/flink/pull/21017
--
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:
MartijnVisser merged PR #21018:
URL: https://github.com/apache/flink/pull/21018
--
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:
kosigz opened a new pull request, #21024:
URL: https://github.com/apache/flink/pull/21024
The current version of cloudpickle has a bug in that locally / interactively
defined classes with `@property` cannot be serialized.
This makes it more difficult for MLP team to demo E2E flows.
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1275067537
@zentol I see I have a lot of style issues and thanks for pointing them out.
I am wondering if you have a doc / pointer for those style rules so I won't
make those mistakes in the
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r992626495
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointTriggerHandlersTest.java:
##
@@ -0,0 +1,349 @@
+/*
+ * Licensed to the
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r992624496
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerStatusHeaders.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the
Clara Xiong created FLINK-29588:
---
Summary: Add Flink Version and Application Version to Savepoint
properties
Key: FLINK-29588
URL: https://issues.apache.org/jira/browse/FLINK-29588
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613317#comment-17613317
]
Dawid Wysakowicz edited comment on FLINK-22243 at 10/11/22 5:19 PM:
dawidwys merged PR #21021:
URL: https://github.com/apache/flink/pull/21021
--
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:
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992562130
##
flink-table/flink-table-planner/pom.xml:
##
@@ -127,22 +127,22 @@ under the License.
${calcite.version}
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992562130
##
flink-table/flink-table-planner/pom.xml:
##
@@ -127,22 +127,22 @@ under the License.
${calcite.version}
Samrat002 commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1274984521
- made changes in commit message as per contributing guide
- squashed all commits to one commit
- removed boiler plate example in description of pr
- updated "Does this pull
Samrat002 commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1274946338
@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-26890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-26890:
--
Fix Version/s: 1.17.0
1.15.3
1.16.1
> DynamoDB consumer
[
https://issues.apache.org/jira/browse/FLINK-26890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-26890:
--
Affects Version/s: 1.15.2
1.16.0
(was:
[
https://issues.apache.org/jira/browse/FLINK-26890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615888#comment-17615888
]
Danny Cranmer commented on FLINK-26890:
---
Thanks [~elphastori] , I have assigned to you
> DynamoDB
[
https://issues.apache.org/jira/browse/FLINK-26890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-26890:
-
Assignee: Elphas Toringepi
> DynamoDB consumer error consuming partitions close to
[
https://issues.apache.org/jira/browse/FLINK-26890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615886#comment-17615886
]
Elphas Toringepi commented on FLINK-26890:
--
I would like to take this.
> DynamoDB consumer
dannycranmer commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1274827001
@Samrat002 can you please rebase and squash your commits. Please also change
the commit message as per the [contribution
[
https://issues.apache.org/jira/browse/FLINK-29563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615878#comment-17615878
]
Etienne Chauchot commented on FLINK-29563:
--
Ok let's forget about automatically disabling the
XComp commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r992414646
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -841,6 +842,12 @@ private StreamConfig
[
https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-29577:
Description:
For now, RocksDBFullRestoreOperation and RocksDBHeapTimersFullRestoreOperation
zentol commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r992402913
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -841,6 +842,12 @@ private StreamConfig
1 - 100 of 320 matches
Mail list logo
