yuzelin commented on code in PR #20719:
URL: https://github.com/apache/flink/pull/20719#discussion_r966597307
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -0,0 +1,226 @@
+---
+title: Overview
+weight: 1
+type: docs
+aliases:
+- /dev/table/sql-gateway.html
yuzelin commented on code in PR #20719:
URL: https://github.com/apache/flink/pull/20719#discussion_r966597933
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -0,0 +1,226 @@
+---
+title: Overview
+weight: 1
+type: docs
+aliases:
+- /dev/table/sql-gateway.html
[
https://issues.apache.org/jira/browse/FLINK-28833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-28833:
-
Assignee: bo zhao
> [5] Support customized scheduler options as a hashmap for each scheduler.
[
https://issues.apache.org/jira/browse/FLINK-29055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-29055:
-
Assignee: bo zhao
> [3.4] Provide a way to exclude the build-in stepDecorator
>
[
https://issues.apache.org/jira/browse/FLINK-28831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-28831:
-
Assignee: bo zhao
> [3] Support pluginable decorators mechanism
>
[
https://issues.apache.org/jira/browse/FLINK-28829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-28829:
-
Assignee: bo zhao
> [2] Need the ability of preparing K8S resource before JobManager creation
[
https://issues.apache.org/jira/browse/FLINK-28825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-28825:
-
Assignee: bo zhao
> [1] Support specify K8S pod scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-29047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-29047:
-
Assignee: bo zhao
> [3.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with
>
[
https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-26559:
-
Assignee: bo zhao
> Support Customized Kubernetes Schedulers for Flink Kubernetes
>
[
https://issues.apache.org/jira/browse/FLINK-28832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-28832:
-
Assignee: (was: bo zhao)
> [4] Upgrade Fabric8 to the latest version
>
[
https://issues.apache.org/jira/browse/FLINK-29047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-29047.
-
Resolution: Fixed
Fixed via:
master(1.17): 17d7c39bb2a9fcbaac1ead42073c099a52171d7d
> [3.1] Shade the
[
https://issues.apache.org/jira/browse/FLINK-29047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-29047:
--
Fix Version/s: 1.17.0
> [3.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with
>
[
https://issues.apache.org/jira/browse/FLINK-28832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-28832:
-
Assignee: bo zhao
> [4] Upgrade Fabric8 to the latest version
>
[
https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-26559:
--
Fix Version/s: 1.17.0
> Support Customized Kubernetes Schedulers for Flink Kubernetes
>
wangyang0918 merged PR #20642:
URL: https://github.com/apache/flink/pull/20642
--
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-26980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602103#comment-17602103
]
Yufan Sheng commented on FLINK-26980:
-
This bug would be fixed in 2.11.0 release. See the related
[
https://issues.apache.org/jira/browse/FLINK-27736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-27736.
-
Assignee: Yufan Sheng
Resolution: Duplicate
> Pulsar sink catch watermark error
>
tisonkun merged PR #20765:
URL: https://github.com/apache/flink/pull/20765
--
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:
tisonkun commented on PR #20765:
URL: https://github.com/apache/flink/pull/20765#issuecomment-1241474048
Thanks for your contribution! Merging...
@wenbingshen please ping me on the related backport PR. After all PRs
merged, I'll close the JIRA ticket.
--
This is an automated
[ https://issues.apache.org/jira/browse/FLINK-27736 ]
Yufan Sheng deleted comment on FLINK-27736:
-
was (Author: syhily):
Tks for your report. This is a known bug and gets fixed in FLINK-28083. The
source shouldn't set the timestamp to zero.
>
[
https://issues.apache.org/jira/browse/FLINK-27736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602101#comment-17602101
]
Yufan Sheng commented on FLINK-27736:
-
[~tison] Since this is a duplicated issue. Can you help me
wenbingshen commented on PR #20765:
URL: https://github.com/apache/flink/pull/20765#issuecomment-1241471194
> @wenbingshen Can you backport this PR to `release-1.15` and `release-1.16`
branch?
Of course. I will submit other PRs later. Thanks.
--
This is an automated message from
JingsongLi commented on code in PR #288:
URL: https://github.com/apache/flink-table-store/pull/288#discussion_r966600291
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/TableStoreSink.java:
##
@@ -159,6 +163,10 @@ public void
syhily commented on PR #20765:
URL: https://github.com/apache/flink/pull/20765#issuecomment-1241469176
@wenbingshen Can you backport this PR to `release-1.15` and `release-1.16`
branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
yuzelin commented on code in PR #20719:
URL: https://github.com/apache/flink/pull/20719#discussion_r966597933
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -0,0 +1,226 @@
+---
+title: Overview
+weight: 1
+type: docs
+aliases:
+- /dev/table/sql-gateway.html
syhily commented on PR #20765:
URL: https://github.com/apache/flink/pull/20765#issuecomment-1241466493
@tisonkun Since this is a minor hotfix. Can you merge it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-28506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng closed FLINK-28506.
---
Resolution: Duplicate
> Pulsar sink don't support zero timestamp which may be provided by flink
>
syhily commented on PR #20765:
URL: https://github.com/apache/flink/pull/20765#issuecomment-1241466240
Thanks, this PR LGTM.
--
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.
yuzelin commented on code in PR #20719:
URL: https://github.com/apache/flink/pull/20719#discussion_r966597307
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -0,0 +1,226 @@
+---
+title: Overview
+weight: 1
+type: docs
+aliases:
+- /dev/table/sql-gateway.html
masteryhx commented on code in PR #20782:
URL: https://github.com/apache/flink/pull/20782#discussion_r966587453
##
docs/content/docs/ops/metrics.md:
##
@@ -1292,6 +1292,11 @@ Note that for failed checkpoints, metrics are updated on
a best efforts basis an
The
[
https://issues.apache.org/jira/browse/FLINK-29226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29226:
---
Labels: pull-request-available (was: )
> Throw exception for streaming insert overwrite
>
SteNicholas opened a new pull request, #288:
URL: https://github.com/apache/flink-table-store/pull/288
Currently, table store dose not support streaming insert overwrite, we
should throw exception for this.
**The brief change log**
- `TableStoreSink#applyOverwrite` throws the
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602087#comment-17602087
]
Qingsheng Ren commented on FLINK-29153:
---
[~hxb] Yes I'm waiting for the CI on release-1.16. Will
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602086#comment-17602086
]
Xingbo Huang commented on FLINK-29153:
--
[~renqs] Should we need to cp this fix to release-1.16
>
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29153:
-
Attachment: image-2022-09-09-11-15-42-735.png
> KafkaConsumerThread should catch
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29153:
-
Attachment: (was: image-2022-09-09-11-15-42-735.png)
> KafkaConsumerThread should catch
godfreyhe commented on PR #20705:
URL: https://github.com/apache/flink/pull/20705#issuecomment-1241438437
@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-28787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28787.
--
Resolution: Fixed
Fixed in master: 347316ea6394b24c4471aa8616f2632e126f733d
in 1.16:
godfreyhe closed pull request #20763: [FLINK-28787][table-planner] rename
getUniqueKeys to getUpsertKeys in CommonPhysicalJoin
URL: https://github.com/apache/flink/pull/20763
--
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-29238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29238:
---
Description: Hybrid shuffle relies on the index to read the disk data.
Since the spilled data may
Weijie Guo created FLINK-29238:
--
Summary: Wrong index information will be obtained after the
downstream failover in hybrid full mode
Key: FLINK-29238
URL: https://issues.apache.org/jira/browse/FLINK-29238
godfreyhe closed pull request #20743: [hotfix][tests][table-planner] Add two
more cases to verify the conflict of multiple LOOKUP hints
URL: https://github.com/apache/flink/pull/20743
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on PR #20794:
URL: https://github.com/apache/flink/pull/20794#issuecomment-1241429203
## CI report:
* 7ba7f3ee1dd988aeef17dd71d679b8eb9d768227 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
PatrickRen opened a new pull request, #20794:
URL: https://github.com/apache/flink/pull/20794
Unchanged backport of #20764 on release-1.16
--
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
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602076#comment-17602076
]
Qingsheng Ren commented on FLINK-29153:
---
Fixed on master: 3e883e687d2bdb80ad2f160b08184fca11f4f554
PatrickRen merged PR #20764:
URL: https://github.com/apache/flink/pull/20764
--
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-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau closed FLINK-29227.
Resolution: Won't Fix
> shoud package disruptor(com.lmax) to flink lib for aync logger when
>
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602064#comment-17602064
]
jackylau commented on FLINK-29227:
--
i close this issue [~jark] [~chesnay]
> shoud package
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602061#comment-17602061
]
jackylau commented on FLINK-29227:
--
[~jark] thanks for your careful explanation
> shoud package
bzhaoopenstack commented on PR #20642:
URL: https://github.com/apache/flink/pull/20642#issuecomment-1241408388
@wangyang0918 Thanks
--
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-29226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29226:
Assignee: Nicholas Jiang
> Throw exception for streaming insert overwrite
>
[
https://issues.apache.org/jira/browse/FLINK-29226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602059#comment-17602059
]
Nicholas Jiang commented on FLINK-29226:
[~lzljs3620320], could you please assign this ticket to
flinkbot commented on PR #20793:
URL: https://github.com/apache/flink/pull/20793#issuecomment-1241381224
## CI report:
* 192e1cb919e07a75b2ec3f90237f2c52b142a9be UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20792:
URL: https://github.com/apache/flink/pull/20792#issuecomment-1241378212
## CI report:
* e228ea02f9c01740c1268f2b7f0357b777a7401b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily opened a new pull request, #20793:
URL: https://github.com/apache/flink/pull/20793
This is a backport PR for https://github.com/apache/flink/pull/20725.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
syhily opened a new pull request, #20792:
URL: https://github.com/apache/flink/pull/20792
This is a backport PR for https://github.com/apache/flink/pull/20725.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-29203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602032#comment-17602032
]
Sergey Nuyanzin commented on FLINK-29203:
-
Probably was solve by
Sergey Nuyanzin created FLINK-29237:
---
Summary: CalcITCase.testOrWithIsNullPredicate fails after update
to calcite 1.27
Key: FLINK-29237
URL: https://issues.apache.org/jira/browse/FLINK-29237
[
https://issues.apache.org/jira/browse/FLINK-29236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krishnaiah Narukulla updated FLINK-29236:
-
Description:
SQL API:
{code:java}
CREATE TEMPORARY TABLE `playevents`
Krishnaiah Narukulla created FLINK-29236:
Summary: TableFactory wildcard options are not supported
Key: FLINK-29236
URL: https://issues.apache.org/jira/browse/FLINK-29236
Project: Flink
snuyanzin commented on PR #20663:
URL: https://github.com/apache/flink/pull/20663#issuecomment-1241305429
@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
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r966428003
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkElementConverter.java:
##
@@ -0,0 +1,73
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r965983155
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkElementConverter.java:
##
@@ -0,0 +1,73
pnowojski commented on PR #20485:
URL: https://github.com/apache/flink/pull/20485#issuecomment-1241135990
> @mxm Thanks a lot also from my side for you contributions. However,
@pnowojski this PR was not orphaned! (I wrote to you that I'm on vacations.)
Yes, sorry for the mental
mxm commented on PR #20485:
URL: https://github.com/apache/flink/pull/20485#issuecomment-1241039980
Thank you @pnowojski for your thoughtful comments and guidance. And of
course thanks to the original authors @AHeise @dawidwys @smattheis.
Whoops @smattheis I had assumed you wouldn't
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r966251899
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java:
##
@@ -179,6 +180,21 @@
zentol merged PR #570:
URL: https://github.com/apache/flink-web/pull/570
--
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:
Sergio Sainz created FLINK-29235:
Summary: CVE-2022-25857 on flink-shaded
Key: FLINK-29235
URL: https://issues.apache.org/jira/browse/FLINK-29235
Project: Flink
Issue Type: Bug
gaborgsomogyi commented on PR #18118:
URL: https://github.com/apache/flink/pull/18118#issuecomment-1240943704
@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
smattheis commented on PR #20485:
URL: https://github.com/apache/flink/pull/20485#issuecomment-1240941359
@mxm Thanks a lot also from my side for you contributions. However,
@pnowojski this PR was not orphaned! (I wrote to you that I'm on vacations.)
--
This is an automated message from
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r966164935
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software
zentol commented on PR #20187:
URL: https://github.com/apache/flink/pull/20187#issuecomment-1240930119
I made a pass over the PR and prepared a significant set of changes here:
https://github.com/atris/flink/pull/1
I know that this isn't the ideal approach; but otherwise we would've
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r966129384
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkElementConverter.java:
##
@@ -0,0 +1,73 @@
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r966129384
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkElementConverter.java:
##
@@ -0,0 +1,73 @@
[
https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated FLINK-29234:
Description:
Jobmanager stop working because the deadlock in DefaultLeaderElectionService.
The log
[
https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated FLINK-29234:
Description:
Jobmanager stop working because the deadlock in DefaultLeaderElectionService.
Which may
[
https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated FLINK-29234:
Priority: Critical (was: Major)
> Dead lock in DefaultLeaderElectionService
>
Yu Wang created FLINK-29234:
---
Summary: Dead lock in DefaultLeaderElectionService
Key: FLINK-29234
URL: https://issues.apache.org/jira/browse/FLINK-29234
Project: Flink
Issue Type: Bug
mxm commented on PR #20485:
URL: https://github.com/apache/flink/pull/20485#issuecomment-1240828114
@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.
To
syhily commented on code in PR #20725:
URL: https://github.com/apache/flink/pull/20725#discussion_r966051977
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarUnorderedPartitionSplitReader.java:
##
@@ -147,7
tisonkun commented on code in PR #20725:
URL: https://github.com/apache/flink/pull/20725#discussion_r965996490
##
flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/UnorderedCollectIteratorAssert.java:
##
@@ -0,0 +1,140
flinkbot commented on PR #20791:
URL: https://github.com/apache/flink/pull/20791#issuecomment-1240760497
## CI report:
* add298232cfe66ffc5129b153fbc4c929ebd40b3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Fix Version/s: 1.16.0
> SinkUpsertMaterializer should be aware of the input upsertKey if it is
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Affects Version/s: 1.15.2
1.14.5
> SinkUpsertMaterializer should be aware
dannycranmer commented on PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#issuecomment-1240753383
Apologies for the delay, I have left some comments. As commented in the main
pom I will open a PR to contribute the general repo files so we can decouple
from this
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28569:
---
Labels: pull-request-available (was: )
> SinkUpsertMaterializer should be aware of the
lincoln-lil opened a new pull request, #20791:
URL: https://github.com/apache/flink/pull/20791
## What is the purpose of the change
Currently SinkUpsertMaterializer only update row by comparing the complete
row in anycase, but this may cause wrong result if input has upsertKey and also
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r965965165
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbAttributeValueUtils.java:
##
@@ -0,0 +1,127
[
https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601826#comment-17601826
]
dalongliu edited comment on FLINK-29090 at 9/8/22 1:48 PM:
---
I didn't reproduce
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Description:
Currently SinkUpsertMaterializer only update row by comparing the complete row
in
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Description:
Currently SinkUpsertMaterializer only update row by comparing the complete row
in
mxm commented on PR #20485:
URL: https://github.com/apache/flink/pull/20485#issuecomment-1240740217
> I wouldn't squash all commits into one. The original commits authored by
Sebastian, Dawid and Arvid I think are nicely separated. But sure, squashing
your fixups to those commits and
[
https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601826#comment-17601826
]
dalongliu commented on FLINK-29090:
---
I didn't reproduce the exception through the following sql case:
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Description:
Currently
{code}
@Test
public void
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Description:
Currently
{code:java}
@Test
public void
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Summary: SinkUpsertMaterializer should be aware of the input upsertKey if
it is not empty
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Parent: (was: FLINK-27849)
Issue Type: Bug (was: Sub-task)
> Optimization:
[
https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-28569:
Priority: Major (was: Minor)
> Optimization: SinkUpsertMaterializer should be aware of the input
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r965983501
##
flink-core/src/main/java/org/apache/flink/api/common/eventtime/CombinedWatermarkStatus.java:
##
@@ -95,10 +97,12 @@ public boolean updateCombinedWatermark() {
XComp commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r965971077
##
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java:
##
@@ -46,15 +47,15 @@
import
1 - 100 of 213 matches
Mail list logo
