[
https://issues.apache.org/jira/browse/FLINK-29241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29241:
---
Labels: pull-request-available (was: )
> Can not overwrite from empty input
> -
[
https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602156#comment-17602156
]
dalongliu commented on FLINK-29240:
---
cc [~zhuzh], [~jark]
> Unify the ClassLoader in
JingsongLi opened a new pull request, #289:
URL: https://github.com/apache/flink-table-store/pull/289
There is currently no data, which will not trigger an overwrite, which
causes the semantics of the sql to not be correct
--
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-29240:
--
Description: Since [FLINK-15635|
https://issues.apache.org/jira/browse/FLINK-15635], we have introduce
Jingsong Lee created FLINK-29241:
Summary: Can not overwrite from empty input
Key: FLINK-29241
URL: https://issues.apache.org/jira/browse/FLINK-29241
Project: Flink
Issue Type: Bug
dalongliu created FLINK-29240:
-
Summary: Unify the ClassLoader in StreamExecutionEnvironment and
TableEnvironment
Key: FLINK-29240
URL: https://issues.apache.org/jira/browse/FLINK-29240
Project: Flink
Bill G created FLINK-29239:
--
Summary: KafkaSerializerWrapper.config should be Map
for full configurability.
Key: FLINK-29239
URL: https://issues.apache.org/jira/browse/FLINK-29239
Project: Flink
Is
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
> org.
[
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
> org.apa
[
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: issues-unsubscr...@flink.
[
https://issues.apache.org/jira/browse/FLINK-26980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602103#comment-17602103
]
Yufan Sheng commented on FLINK-26980:
-
This bug would be fixed in 2.11.0 release. Se
[
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: issues-unsubscr...@flink.apac
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 messag
[ 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&focusedCommentId=17602101#comment-17602101
]
Yufan Sheng commented on FLINK-27736:
-
[~tison] Since this is a duplicated issue. Ca
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 th
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 applyStaticP
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 t
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 a
[
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 checkpointe
[
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 `Unsu
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602087#comment-17602087
]
Qingsheng Ren commented on FLINK-29153:
---
[~hxb] Yes I'm waiting for the CI on rele
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602086#comment-17602086
]
Xingbo Huang commented on FLINK-29153:
--
[~renqs] Should we need to cp this fix to r
[
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 WakeupException
[
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 Wake
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 comment.
[
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: 77574b7e1ee5f514c
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 us
[
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 be
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 GitH
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 spec
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602076#comment-17602076
]
Qingsheng Ren commented on FLINK-29153:
---
Fixed on master: 3e883e687d2bdb80ad2f160b
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: issues-unsubscr...@flink.ap
[
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
> xxconnector
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602064#comment-17602064
]
jackylau commented on FLINK-29227:
--
i close this issue [~jark] [~chesnay]
> shoud pac
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602061#comment-17602061
]
jackylau commented on FLINK-29227:
--
[~jark] thanks for your careful explanation
> sho
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 c
[
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&focusedCommentId=17602059#comment-17602059
]
Nicholas Jiang commented on FLINK-29226:
[~lzljs3620320], could you please assig
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 ab
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 ab
[
https://issues.apache.org/jira/browse/FLINK-29203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602032#comment-17602032
]
Sergey Nuyanzin commented on FLINK-29203:
-
Probably was solve by
https://github
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
Project
[
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` (upload_t
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 speci
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 shortc
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 c
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 @@ p
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: issues-unsubscr...@flink.apache
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
Comp
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 comm
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 t
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 Foundation
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 h
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 stoppe
[
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 simi
[
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
Com
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 u
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 +136
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 not
[
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 o
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 contri
[
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 inpu
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
n
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&focusedCommentId=17601826#comment-17601826
]
dalongliu edited comment on FLINK-29090 at 9/8/22 1:48 PM:
---
I
[
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 an
[
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 an
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 co-aut
[
https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601826#comment-17601826
]
dalongliu commented on FLINK-29090:
---
I didn't reproduce the exception through the foll
1 - 100 of 201 matches
Mail list logo
