[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620013#comment-17620013
]
Shengkai Fang commented on FLINK-29653:
---
Thanks for your report. I have assigned it to you.
>
[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29653:
-
Assignee: Jingqi Shi (was: Jing Ge)
> close DynamicResult but it was already closed
>
[
https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29653:
-
Assignee: Jing Ge
> close DynamicResult but it was already closed
>
zhoulii commented on PR #20168:
URL: https://github.com/apache/flink/pull/20168#issuecomment-1283459186
@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.
wangyang0918 commented on code in PR #20498:
URL: https://github.com/apache/flink/pull/20498#discussion_r998952751
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java:
##
@@ -630,4 +630,37 @@ private KubernetesConfigMap
zjureel closed pull request #321: [DRAFT] Micro benchmark module test
URL: https://github.com/apache/flink-table-store/pull/321
--
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.
dependabot[bot] closed pull request #48: Bump jackson-databind from 2.12.2 to
2.12.6.1 in /java/connected-components
URL: https://github.com/apache/flink-statefun-playground/pull/48
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dependabot[bot] commented on PR #48:
URL:
https://github.com/apache/flink-statefun-playground/pull/48#issuecomment-1283443216
Superseded by #52.
--
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
dependabot[bot] opened a new pull request, #52:
URL: https://github.com/apache/flink-statefun-playground/pull/52
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2
to 2.13.4.1.
Commits
See full diff in
dependabot[bot] closed pull request #47: Bump jackson-databind from 2.12.2 to
2.12.6.1 in /java/shopping-cart
URL: https://github.com/apache/flink-statefun-playground/pull/47
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dependabot[bot] commented on PR #47:
URL:
https://github.com/apache/flink-statefun-playground/pull/47#issuecomment-1283395840
Superseded by #51.
--
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
dependabot[bot] opened a new pull request, #51:
URL: https://github.com/apache/flink-statefun-playground/pull/51
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2
to 2.13.4.1.
Commits
See full diff in
dependabot[bot] commented on PR #46:
URL:
https://github.com/apache/flink-statefun-playground/pull/46#issuecomment-1283395381
Superseded by #50.
--
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
dependabot[bot] opened a new pull request, #50:
URL: https://github.com/apache/flink-statefun-playground/pull/50
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2
to 2.13.4.1.
Commits
See full diff in
dependabot[bot] closed pull request #46: Bump jackson-databind from 2.12.2 to
2.12.6.1 in /java/greeter
URL: https://github.com/apache/flink-statefun-playground/pull/46
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dependabot[bot] closed pull request #45: Bump jackson-databind from 2.12.2 to
2.12.6.1 in /java/showcase
URL: https://github.com/apache/flink-statefun-playground/pull/45
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
dependabot[bot] commented on PR #45:
URL:
https://github.com/apache/flink-statefun-playground/pull/45#issuecomment-1283395077
Superseded by #49.
--
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
dependabot[bot] opened a new pull request, #49:
URL: https://github.com/apache/flink-statefun-playground/pull/49
Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2
to 2.13.4.1.
Commits
See full diff in
[
https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-29613.
-
Resolution: Fixed
1.16 via f625a3244ca2c704eda04bdf3b009ffac1735978
> Wrong message size assertion in
tisonkun merged PR #21099:
URL: https://github.com/apache/flink/pull/21099
--
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:
LadyForest commented on PR #21097:
URL: https://github.com/apache/flink/pull/21097#issuecomment-1283370296
Hi @fsk119, do you have time to take a look?
--
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
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619963#comment-17619963
]
Xingbo Huang commented on FLINK-29419:
--
Temporarily disabled `HybridShuffleITCase` on master via
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29585:
-
Parent: FLINK-29072
Issue Type: Sub-task (was: Improvement)
> Migrate TableSchema to Schema
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619963#comment-17619963
]
Xingbo Huang edited comment on FLINK-29419 at 10/19/22 3:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-29072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619962#comment-17619962
]
luoyuxia commented on FLINK-29072:
--
Notice the deprecated TableSchema spreads in many modules , would
tsreaper commented on code in PR #315:
URL: https://github.com/apache/flink-table-store/pull/315#discussion_r998904675
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java:
##
@@ -122,48 +139,61 @@ public void write(KeyValue
HuangXingBo closed pull request #21105: [FLINK-29419] Disable
HybridShuffleITCase
URL: https://github.com/apache/flink/pull/21105
--
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
flinkbot commented on PR #21105:
URL: https://github.com/apache/flink/pull/21105#issuecomment-1283360079
## CI report:
* d4e7e4f45ad9d2cde475fbd093f0aa1ae4ff81d3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619952#comment-17619952
]
Weijie Guo edited comment on FLINK-29682 at 10/19/22 3:15 AM:
--
[~samrat007]
reswqa opened a new pull request, #21105:
URL: https://github.com/apache/flink/pull/21105
## What is the purpose of the change
*This test will cause the CI to get stuck. The specific reason needs to be
further investigated. In order not to block flink code merge pipeline,
flinkbot commented on PR #21104:
URL: https://github.com/apache/flink/pull/21104#issuecomment-1283352265
## CI report:
* 7e34a8e2791d397f5195e6e929ca1f7ea86fe517 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29681:
---
Labels: pull-request-available (was: )
> Python side-output operator not generated in some
Vancior opened a new pull request, #21104:
URL: https://github.com/apache/flink/pull/21104
## What is the purpose of the change
This PR fixes when SideOutputDataStream is used in `execute_and_collect`,
`from_data_stream` and `create_temporary_view`, the side-output setup is not
[
https://issues.apache.org/jira/browse/FLINK-29682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619952#comment-17619952
]
Weijie Guo commented on FLINK-29682:
We have tracked this issue in FLINK-29419
> Flaky test failure
JingsongLi commented on code in PR #315:
URL: https://github.com/apache/flink-table-store/pull/315#discussion_r998866949
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java:
##
@@ -122,48 +139,61 @@ public void write(KeyValue
[
https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619951#comment-17619951
]
Kai Chen commented on FLINK-23074:
--
I found that this commit(ce7481ae20cf6b4a32568df1d774467247acd08b)
[
https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619946#comment-17619946
]
luoyuxia edited comment on FLINK-29587 at 10/19/22 2:33 AM:
After a detail
[
https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-23074:
-
Attachment: screenshot-6.png
> There is a class conflict between flink-connector-hive and flink-parquet
[
https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619946#comment-17619946
]
luoyuxia edited comment on FLINK-29587 at 10/19/22 2:32 AM:
After a detail
[
https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kai Chen updated FLINK-23074:
-
Attachment: screenshot-5.png
> There is a class conflict between flink-connector-hive and flink-parquet
[
https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619946#comment-17619946
]
luoyuxia edited comment on FLINK-29587 at 10/19/22 2:29 AM:
After a detail
[
https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619946#comment-17619946
]
luoyuxia edited comment on FLINK-29587 at 10/19/22 2:29 AM:
After a detail
[
https://issues.apache.org/jira/browse/FLINK-29587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619946#comment-17619946
]
luoyuxia commented on FLINK-29587:
--
After a detain debug, I found the reason is that the reduced
[
https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619932#comment-17619932
]
Yubin Li edited comment on FLINK-29679 at 10/19/22 2:15 AM:
[~luoyuxia]
waywtdcc commented on PR #21078:
URL: https://github.com/apache/flink/pull/21078#issuecomment-1283291051
Hello, I hope you can review the code when you are free. Thank you very
much! @gyfora @mbalassi @JingsongLi
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-28643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619937#comment-17619937
]
LI Mingkun commented on FLINK-28643:
[~lsy] I'm making an improvement by add a lazy unzip of
[
https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619932#comment-17619932
]
Yubin Li commented on FLINK-29679:
--
[~luoyuxia] table's comment is a table level prop, we could use
JingsongLi commented on code in PR #315:
URL: https://github.com/apache/flink-table-store/pull/315#discussion_r998866949
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeWriter.java:
##
@@ -122,48 +139,61 @@ public void write(KeyValue
zhoulii commented on code in PR #20168:
URL: https://github.com/apache/flink/pull/20168#discussion_r998862192
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java:
##
@@ -269,15 +269,15 @@ public void
zhoulii commented on code in PR #20168:
URL: https://github.com/apache/flink/pull/20168#discussion_r998862068
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliResultViewTest.java:
##
@@ -58,35 +58,35 @@
import static
zhoulii commented on code in PR #20168:
URL: https://github.com/apache/flink/pull/20168#discussion_r998861965
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientITCase.java:
##
@@ -124,45 +136,52 @@ public static void setup() throws
zhoulii commented on code in PR #20168:
URL: https://github.com/apache/flink/pull/20168#discussion_r998861783
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientITCase.java:
##
@@ -76,8 +82,8 @@
import static
zhoulii commented on code in PR #20168:
URL: https://github.com/apache/flink/pull/20168#discussion_r998861628
##
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/SessionContextTest.java:
##
@@ -131,7 +132,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29679:
-
Summary: DESCRIBE statement shows column comment (was: DESCRIBE statement
shows comment)
>
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28985:
Assignee: waywtdcc
> support create table like view
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619921#comment-17619921
]
luoyuxia commented on FLINK-29679:
--
[~liyubin117] Is it for table's comment or column comment?
>
[
https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-29613:
--
Fix Version/s: 1.17.0
1.15.3
1.16.1
> Wrong message size
[
https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619919#comment-17619919
]
Zili Chen commented on FLINK-29613:
---
master via 8cb0297c2f092f42f989b4811aa438b6810aef8d
1.15 via
tisonkun commented on PR #21099:
URL: https://github.com/apache/flink/pull/21099#issuecomment-1283235447
@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.
tisonkun merged PR #21100:
URL: https://github.com/apache/flink/pull/21100
--
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-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Affects Version/s: 1.15.2
> Apache Kafka Connector‘s “ setBounded” not valid
>
[
https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sopan Phaltankar updated FLINK-29611:
-
Description:
The test
[
https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sopan Phaltankar updated FLINK-29611:
-
Description:
The test
[
https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619810#comment-17619810
]
Sopan Phaltankar commented on FLINK-29611:
--
[~martijnvisser]
This test depends on the order of
MartijnVisser commented on PR #21096:
URL: https://github.com/apache/flink/pull/21096#issuecomment-1282983010
@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
JingGe commented on code in PR #21065:
URL: https://github.com/apache/flink/pull/21065#discussion_r998676293
##
flink-connectors/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java:
##
@@ -96,11 +96,7 @@
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998664686
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/config/AWSDynamoDbConfigConstants.java:
##
@@ -0,0 +1,108 @@
+/*
+
Hong Liang Teoh created FLINK-29683:
---
Summary: Introduce config parser for AWS BackoffStrategy
Key: FLINK-29683
URL: https://issues.apache.org/jira/browse/FLINK-29683
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-7673.
--
Resolution: Fixed
> Flink Kinesis connector - remove dependency on the ASL code
>
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-7673:
Assignee: Danny Cranmer
> Flink Kinesis connector - remove dependency on the ASL code
>
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619762#comment-17619762
]
Danny Cranmer commented on FLINK-7673:
--
This has been done and is no longer an issue
> Flink
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998653397
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998651365
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998653397
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998651365
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998651365
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-26008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-26008:
--
Summary: Update Kinesalite docker container reference (was: [FLIP-171]
Update Kinesalite
[
https://issues.apache.org/jira/browse/FLINK-25733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25733:
--
Summary: Create A migration guide for Kinesis Table API connector (was:
[FLIP-171] Create A
[
https://issues.apache.org/jira/browse/FLINK-5783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-5783.
--
Assignee: Danny Cranmer
Resolution: Fixed
> flink-connector-kinesis
[
https://issues.apache.org/jira/browse/FLINK-5783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619759#comment-17619759
]
Danny Cranmer commented on FLINK-5783:
--
This is no longer an issue
> flink-connector-kinesis
[
https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619758#comment-17619758
]
Danny Cranmer commented on FLINK-5953:
--
This is fixed in latest docs
> Sample Kinesis Scala code
[
https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-5953.
--
Assignee: Danny Cranmer
Resolution: Fixed
> Sample Kinesis Scala code doesn't work
>
dannycranmer closed pull request #19589: [FLINK-27423][Connectors/Hive] Upgrade
Hive 3.1 connector from 3.1.2 to 3.1.3
URL: https://github.com/apache/flink/pull/19589
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dannycranmer commented on PR #19589:
URL: https://github.com/apache/flink/pull/19589#issuecomment-1282918466
Closing this since it is superseded by
https://github.com/apache/flink/pull/19589
--
This is an automated message from the Apache Git Service.
To respond to the message, please
dannycranmer commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1282917939
Seems like this was already started a while ago:
https://github.com/apache/flink/pull/19589
--
This is an automated message from the Apache Git Service.
To respond to the message,
Samrat Deb created FLINK-29682:
--
Summary: Flaky test failure in test_finegrained_resourcemanagement
Key: FLINK-29682
URL: https://issues.apache.org/jira/browse/FLINK-29682
Project: Flink
Issue
dannycranmer commented on code in PR #20937:
URL: https://github.com/apache/flink/pull/20937#discussion_r998630251
##
flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml:
##
@@ -164,11 +172,6 @@ under the License.
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998632189
##
flink-connector-aws-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/TableRequestsContainerTest.java:
##
@@ -0,0 +1,152 @@
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998629483
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
YuriGusev closed pull request #18518: [FLINK-24229][connectors/dynamodb] Added
DynamoDB connector
URL: https://github.com/apache/flink/pull/18518
--
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
YuriGusev commented on PR #18518:
URL: https://github.com/apache/flink/pull/18518#issuecomment-1282899969
Closing this pull request as it was moved to a separate
flink-connector-dynamodb repository:
https://github.com/apache/flink-connector-dynamodb/pull/1
--
This is an automated
dannycranmer commented on PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#issuecomment-1282890400
> Question for general discussion: Do we have any thoughts on using
conditional expressions? I note that the `BatchWriteItem` API we are using
doesn't support this.
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998595643
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/config/AWSDynamoDbConfigConstants.java:
##
@@ -0,0 +1,108 @@
[
https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619733#comment-17619733
]
Samrat Deb commented on FLINK-20350:
got it !
I will try to go with the first approach that you
snuyanzin commented on PR #20922:
URL: https://github.com/apache/flink/pull/20922#issuecomment-1282805645
@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
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998512587
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998512587
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r998512587
##
flink-connector-aws-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,134 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-29654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619701#comment-17619701
]
nagasudhakar commented on FLINK-29654:
--
[~martijnvisser] Thanks for the quick answer, appreciate
Juntao Hu created FLINK-29681:
-
Summary: Python side-output operator not generated in some cases
Key: FLINK-29681
URL: https://issues.apache.org/jira/browse/FLINK-29681
Project: Flink
Issue
1 - 100 of 306 matches
Mail list logo
