[
https://issues.apache.org/jira/browse/FLINK-29702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29702:
---
Labels: pull-request-available (was: )
> Add merge tree reader and writer micro benchmarks
zjureel opened a new pull request, #326:
URL: https://github.com/apache/flink-table-store/pull/326
In this PR we create `flink-table-store-micro-benchmarks` module in
`flink-table-store-benchmark`, and add merge tree reader/writer benchmarks:
1. In `MergeTreeReaderBenchmark` we
JingsongLi commented on PR #325:
URL:
https://github.com/apache/flink-table-store/pull/325#issuecomment-1286488493
Just cherry-pick from #315
--
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-29700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29700:
-
Fix Version/s: (was: table-store-0.3.0)
> Serializer to BinaryInMemorySortBuffer is wrong
>
[
https://issues.apache.org/jira/browse/FLINK-29700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29700:
---
Labels: pull-request-available (was: )
> Serializer to BinaryInMemorySortBuffer is wrong
>
JingsongLi opened a new pull request, #325:
URL: https://github.com/apache/flink-table-store/pull/325
In SortBufferMemTable, it will use
`BinaryInMemorySortBuffer.createBuffer(BinaryRowDataSerializer serializer)`,
the serializer is for full row, not just sort key fields.
Problems may
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
macdoor615 updated FLINK-29712:
---
Description:
All my batch jobs have failed with same error. All streaming jobs work fine.
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621486#comment-17621486
]
macdoor615 commented on FLINK-29712:
job parameters
{code:java}
SET table.dml-sync = true;
SET
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
macdoor615 updated FLINK-29712:
---
Description:
All my tasks have failed with same error
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
macdoor615 updated FLINK-29712:
---
Attachment: flink-conf.yaml
> The same batch task works fine in 1.15.2 and 1.16.0-rc1, but fails in
macdoor615 created FLINK-29712:
--
Summary: The same batch task works fine in 1.15.2 and 1.16.0-rc1,
but fails in 1.16.0-rc2
Key: FLINK-29712
URL: https://issues.apache.org/jira/browse/FLINK-29712
lindong28 commented on code in PR #20454:
URL: https://github.com/apache/flink/pull/20454#discussion_r1001273247
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -207,25 +241,43 @@ public void close() throws
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621475#comment-17621475
]
Aitozi commented on FLINK-29557:
ping [~gaoyunhaii]
> The SinkOperator's OutputFormat function is not
[
https://issues.apache.org/jira/browse/FLINK-29703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-29703.
--
Resolution: Fixed
> Fail to call unix_timestamp in runtime in Hive dialect
>
[
https://issues.apache.org/jira/browse/FLINK-29703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29703:
-
Description:
Can be reproduced by the following sql with Hive dialect:
{code:java}
select
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621470#comment-17621470
]
Xingbo Huang commented on FLINK-28766:
--
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621469#comment-17621469
]
Xingbo Huang edited comment on FLINK-24119 at 10/21/22 3:39 AM:
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-24119:
-
Fix Version/s: 1.16.1
(was: 1.16.0)
> KafkaITCase.testTimestamps fails
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621469#comment-17621469
]
Xingbo Huang commented on FLINK-24119:
--
[
https://issues.apache.org/jira/browse/FLINK-29684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junhan Yang closed FLINK-29684.
---
Resolution: Fixed
> [UI] Upgrade runtime web Angular framework and associated deps to v14
>
[
https://issues.apache.org/jira/browse/FLINK-29684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621467#comment-17621467
]
Junhan Yang commented on FLINK-29684:
-
master: 97bc331f84285117dc4c30bc583cc2df45196356
> [UI]
yangjunhan merged PR #21121:
URL: https://github.com/apache/flink/pull/21121
--
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-29687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29687.
Fix Version/s: table-store-0.2.2
Resolution: Fixed
master:
yangjunhan commented on PR #21121:
URL: https://github.com/apache/flink/pull/21121#issuecomment-1286408461
The CI failure does not relate to the PR's changes, so ready to merge.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
JingsongLi merged PR #323:
URL: https://github.com/apache/flink-table-store/pull/323
--
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-29703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621463#comment-17621463
]
luoyuxia commented on FLINK-29703:
--
The reason is the hive function unix_timestamp will call
HuangXingBo commented on code in PR #21110:
URL: https://github.com/apache/flink/pull/21110#discussion_r1001310191
##
docs/layouts/shortcodes/generated/python_configuration.html:
##
@@ -110,5 +110,11 @@
Integer
The maximum number of states cached in a
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621460#comment-17621460
]
Yun Gao commented on FLINK-29498:
-
[~eric.xiao] Thanks for the PR! I'll have a look
> Flink Async I/O
weibozhao commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r1001308391
##
docs/content/docs/operators/feature/splitter.md:
##
@@ -0,0 +1,143 @@
+---
+title: "Splitter"
+weight: 1
+type: docs
+aliases:
+- /operators/feature/splitter.html
[
https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621456#comment-17621456
]
Kai Chen commented on FLINK-23074:
--
[~luoyuxia] After this change, the version of
clarax commented on code in PR #406:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/406#discussion_r1000931100
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointStatus.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed
Durgesh Mishra created FLINK-29711:
--
Summary: Topic notification not present in metadata after 6 ms.
Key: FLINK-29711
URL: https://issues.apache.org/jira/browse/FLINK-29711
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29615.
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
- master (1.17):
xintongsong closed pull request #21051: [FLINK-29615] Retain active subtasks in
TaskMetricStore when fetching metrics to accommodate dynamic scaling
URL: https://github.com/apache/flink/pull/21051
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-29687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29687:
---
Labels: pull-request-available (was: )
> Do not throw exception when Lookup table is empty
LadyForest closed pull request #323: [FLINK-29687] Do not throw exception when
Lookup table is empty
URL: https://github.com/apache/flink-table-store/pull/323
--
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
LadyForest commented on PR #323:
URL:
https://github.com/apache/flink-table-store/pull/323#issuecomment-1286364083
`PreAggregationITCase#testMergeInMemory` is unstable
--
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-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621435#comment-17621435
]
Canope Nerda commented on FLINK-29692:
--
Thanks [~jark] for suggesting the legacy group window agg.
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621432#comment-17621432
]
hongcha edited comment on FLINK-29674 at 10/21/22 1:37 AM:
---
[~coderap] this is
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621432#comment-17621432
]
hongcha edited comment on FLINK-29674 at 10/21/22 1:15 AM:
---
[~coderap] this is
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621432#comment-17621432
]
hongcha commented on FLINK-29674:
-
[~coderap] this is my test source code:
{code:java}
package test;
[
https://issues.apache.org/jira/browse/FLINK-29701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29701.
Fix Version/s: table-store-0.3.0
Assignee: Shammon
Resolution: Fixed
master:
JingsongLi merged PR #324:
URL: https://github.com/apache/flink-table-store/pull/324
--
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-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621418#comment-17621418
]
Alexey Leonov-Vendrovskiy commented on FLINK-27344:
---
I think it is fine to proceed
clarax commented on PR #406:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1286272479
Local docker build and deployment to Minikube succeeded while image build
and deployment failed on the workflow. Anything else I should look?
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621406#comment-17621406
]
Jiale Tan commented on FLINK-29610:
---
Thanks [~gaoyunhaii] for the extra context. Will look into this
zentol commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1001199344
##
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendListTest.java:
##
@@ -28,21 +28,100 @@
import org.junit.jupiter.api.AfterAll;
import
zentol commented on PR #21126:
URL: https://github.com/apache/flink/pull/21126#issuecomment-1286242752
@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.
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1001103974
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,176 @@
+/*
+ *
flinkbot commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1286119990
## CI report:
* 655a9680f2a8861b3f43fd7475bf3e66e9264ca2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29710:
---
Labels: pull-request-available (was: )
> Upgrade the minimal supported hadoop version to
MartijnVisser opened a new pull request, #21128:
URL: https://github.com/apache/flink/pull/21128
## What is the purpose of the change
* Bump the minimum supported Hadoop version to 2.10.2
## Brief change log
* Changed all references from Hadoop 2.8.5 to 2.10.2
* Moved
Martijn Visser created FLINK-29710:
--
Summary: Upgrade the minimal supported hadoop version to 2.10.2
Key: FLINK-29710
URL: https://issues.apache.org/jira/browse/FLINK-29710
Project: Flink
Yufan Sheng created FLINK-29709:
---
Summary: Bump Pulsar to 2.10.2
Key: FLINK-29709
URL: https://issues.apache.org/jira/browse/FLINK-29709
Project: Flink
Issue Type: Technical Debt
MartijnVisser commented on PR #21127:
URL: https://github.com/apache/flink/pull/21127#issuecomment-1286072331
@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
ericxiao251 commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1286039619
@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-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621332#comment-17621332
]
Eric Xiao commented on FLINK-29498:
---
[~gaoyunhaii], I believe I have a
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621332#comment-17621332
]
Eric Xiao edited comment on FLINK-29498 at 10/20/22 7:30 PM:
-
Hi
ericxiao251 commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1286022609
@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-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621318#comment-17621318
]
Gyula Fora commented on FLINK-29708:
Looks good!
Maybe we could shorten operatorErrorType -> type
I
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29708:
--
Assignee: Daren Wong
> Enrich Flink Kubernetes Operator CRD error field
>
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621314#comment-17621314
]
Yordan Pavlov commented on FLINK-16419:
---
Thanks for your feedback [~martijnvisser]
> If you're
ericxiao251 commented on code in PR #21077:
URL: https://github.com/apache/flink/pull/21077#discussion_r1000959923
##
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncRetryStrategies.scala:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-29708:
---
Description:
h1. Problem Statement:
FlinkDeployment and FlinkSessionJob CRD has a CommonStatus
MartijnVisser commented on PR #17873:
URL: https://github.com/apache/flink/pull/17873#issuecomment-1285943401
Asking @godfreyhe to have a look at the PR
--
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-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-29708:
---
Description:
h1. Problem Statement:
FlinkDeployment and FlinkSessionJob CRD has a CommonStatus
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-29708:
---
Description:
h1. Problem Statement:
FlinkDeployment and FlinkSessionJob CRD has a CommonStatus
clarax commented on PR #406:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1285941481
"mvn clean verify" and local rerun of the failed test "testRollbackSession"
passed. The errors in the log seems transient errors.
--
This is an automated message from
Daren Wong created FLINK-29708:
--
Summary: Enrich Flink Kubernetes Operator CRD error field
Key: FLINK-29708
URL: https://issues.apache.org/jira/browse/FLINK-29708
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621298#comment-17621298
]
Martijn Visser edited comment on FLINK-16419 at 10/20/22 5:59 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621298#comment-17621298
]
Martijn Visser commented on FLINK-16419:
[~YordanPavlov] Let's see if we can resolve this. A
clarax commented on code in PR #406:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/406#discussion_r1000953174
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointStatus.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed
[ https://issues.apache.org/jira/browse/FLINK-16419 ]
Martijn Visser deleted comment on FLINK-16419:
was (Author: martijnvisser):
[~YordanPavlov] Just to verify, do you have unlimited retention for your Kafka
events?
> Avoid to recommit
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621293#comment-17621293
]
Martijn Visser commented on FLINK-16419:
[~YordanPavlov] Just to verify, do you have unlimited
ericxiao251 commented on code in PR #21077:
URL: https://github.com/apache/flink/pull/21077#discussion_r1000938133
##
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncRetryStrategies.scala:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache
clarax commented on code in PR #406:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/406#discussion_r1000931100
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/SavepointStatus.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-29582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29582.
Resolution: Fixed
master: d17ceaf2f8cb0a36c2b629b9f6f87e020ce79395
> SavepointWriter
zentol merged PR #21088:
URL: https://github.com/apache/flink/pull/21088
--
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-25841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621266#comment-17621266
]
Harry Li commented on FLINK-25841:
--
Right now the CompiledPlan feature works for INSERT statement. Is
ryanvanhuuksloot commented on code in PR #21077:
URL: https://github.com/apache/flink/pull/21077#discussion_r1000885089
##
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncRetryStrategies.scala:
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the
ferenc-csaky commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1000885230
##
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendListTest.java:
##
@@ -28,21 +28,100 @@
import org.junit.jupiter.api.AfterAll;
import
ferenc-csaky commented on PR #21127:
URL: https://github.com/apache/flink/pull/21127#issuecomment-1285847522
> I don't get how this can be JDK-specific. Probably related to overflows,
no?
>
> Is the test replicating the exact case you ran into?
TBH I'm not sure anymore :) I
ferenc-csaky commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1000864000
##
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendListTest.java:
##
@@ -28,21 +28,100 @@
import org.junit.jupiter.api.AfterAll;
import
zentol commented on PR #21088:
URL: https://github.com/apache/flink/pull/21088#issuecomment-1285836764
@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-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621220#comment-17621220
]
Yordan Pavlov commented on FLINK-16419:
---
[~martijnvisser] This issue has plagued our Flink setup
ferenc-csaky commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1000851448
##
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendListTest.java:
##
@@ -28,21 +28,100 @@
import org.junit.jupiter.api.AfterAll;
import
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000808803
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java:
##
@@ -0,0 +1,104 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000808138
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,144 @@
+/*
+ *
xinbinhuang commented on PR #17873:
URL: https://github.com/apache/flink/pull/17873#issuecomment-1285811478
@godfreyhe @KarmaGYZ @MartijnVisser can we merge this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ericxiao251 commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1285809373
@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-29707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-29707:
--
Assignee: Ferenc Csaky
> Fix possible comparator violation for "flink list"
>
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000815682
##
flink-connector-dynamodb/src/test/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilderTest.java:
##
@@ -0,0 +1,66 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000814379
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequest.java:
##
@@ -0,0 +1,63 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000813463
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java:
##
@@ -0,0 +1,104 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000808803
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java:
##
@@ -0,0 +1,104 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000808138
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,144 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1000803309
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSink.java:
##
@@ -0,0 +1,154 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-25595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621193#comment-17621193
]
Eric Xiao commented on FLINK-25595:
---
Hi [~godfreyhe] and [~jingzhang], I would like to get more
[
https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621187#comment-17621187
]
Krzysztof Chmielewski commented on FLINK-29459:
---
FYI ticets
29509
29512
29627
are fixing
[
https://issues.apache.org/jira/browse/FLINK-29707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621182#comment-17621182
]
Ferenc Csaky commented on FLINK-29707:
--
Just opened a PR with the proposed fix.
> Fix possible
1 - 100 of 304 matches
Mail list logo
