[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621521#comment-17621521
]
luoyuxia commented on FLINK-29712:
--
[~macdoor615] Which mode do you run Flink? Applicat
[
https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621520#comment-17621520
]
Yun Tang commented on FLINK-29328:
--
First of all, the problem would only occur during s
fredia commented on PR #20965:
URL: https://github.com/apache/flink/pull/20965#issuecomment-1286536164
Hi @zoltar9264, I think it's a little confusing to mix `successed` and
`failed` together. In fact, the failed materialization duration is meaningless,
I prefer to keep `lastDurationOfMater
[
https://issues.apache.org/jira/browse/FLINK-29700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29700.
Resolution: Fixed
release-0.2: aa6846089afc61e6715a7d50ae40e6bb9d8efc0f
> Serializer to BinaryInM
JingsongLi merged PR #325:
URL: https://github.com/apache/flink-table-store/pull/325
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621510#comment-17621510
]
Yun Tang commented on FLINK-29577:
--
[~cailiuyang] I'm not sure whether the fast disk pe
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621506#comment-17621506
]
Weijie Guo commented on FLINK-29712:
cc [~luoyuxia]
> The same batch task works fin
[
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 first
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 occ
[
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.
{code:java
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621486#comment-17621486
]
macdoor615 commented on FLINK-29712:
job parameters
{code:java}
SET table.dml-sy
[
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}
org.apache.flink.runtime.JobExcep
[
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
Project:
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 Exc
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621475#comment-17621475
]
Aitozi commented on FLINK-29557:
ping [~gaoyunhaii]
> The SinkOperator's OutputFormat
[
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 unix_timestamp
[
https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621470#comment-17621470
]
Xingbo Huang commented on FLINK-28766:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 du
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621469#comment-17621469
]
Xingbo Huang commented on FLINK-24119:
--
https://dev.azure.com/apache-flink/apache-f
[
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&focusedCommentId=17621467#comment-17621467
]
Junhan Yang commented on FLINK-29684:
-
master: 97bc331f84285117dc4c30bc583cc2df45196
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: issues-unsubscr...@flink.ap
[
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: b54c474e2596271fedfffaec5eddc895
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 Git
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: issues-unsubscr...@
[
https://issues.apache.org/jira/browse/FLINK-29703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621463#comment-17621463
]
luoyuxia commented on FLINK-29703:
--
The reason is the hive function unix_timestamp will
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 P
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621460#comment-17621460
]
Yun Gao commented on FLINK-29498:
-
[~eric.xiao] Thanks for the PR! I'll have a look
> F
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&focusedCommentId=17621456#comment-17621456
]
Kai Chen commented on FLINK-23074:
--
[~luoyuxia] After this change, the version of
org
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 to
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): f11c3224
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 l
[
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 t
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621435#comment-17621435
]
Canope Nerda commented on FLINK-29692:
--
Thanks [~jark] for suggesting the legacy gr
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621432#comment-17621432
]
hongcha edited comment on FLINK-29674 at 10/21/22 1:37 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621432#comment-17621432
]
hongcha edited comment on FLINK-29674 at 10/21/22 1:15 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621432#comment-17621432
]
hongcha commented on FLINK-29674:
-
[~coderap] this is my test source code:
{code:java
[
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: cc6d2
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: issues-unsubscr...@
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621418#comment-17621418
]
Alexey Leonov-Vendrovskiy commented on FLINK-27344:
---
I think it is fin
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 mes
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621406#comment-17621406
]
Jiale Tan commented on FLINK-29610:
---
Thanks [~gaoyunhaii] for the extra context. Will
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 org.junit.ju
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.
T
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 @@
+/*
+ * Lic
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 2.
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
Is
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
Comp
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 comm
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 commen
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621332#comment-17621332
]
Eric Xiao commented on FLINK-29498:
---
[~gaoyunhaii], I believe I have a
[PR|https://gi
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621332#comment-17621332
]
Eric Xiao edited comment on FLINK-29498 at 10/20/22 7:30 PM:
-
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 commen
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621318#comment-17621318
]
Gyula Fora commented on FLINK-29708:
Looks good!
Maybe we could shorten operatorErro
[
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&focusedCommentId=17621314#comment-17621314
]
Yordan Pavlov commented on FLINK-16419:
---
Thanks for your feedback [~martijnvisser]
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 S
[
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 erro
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 erro
[
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 erro
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 t
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: Impr
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=17621298#comment-17621298
]
Martijn Visser commented on FLINK-16419:
[~YordanPavlov] Let's see if we can res
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 to
[ 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 t
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621293#comment-17621293
]
Martijn Visser commented on FLINK-16419:
[~YordanPavlov] Just to verify, do you
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 S
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 to
[
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 shou
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-25841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621266#comment-17621266
]
Harry Li commented on FLINK-25841:
--
Right now the CompiledPlan feature works for INSERT
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 Apa
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 org.ju
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 did
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 org.ju
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.
T
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621220#comment-17621220
]
Yordan Pavlov commented on FLINK-16419:
---
[~martijnvisser] This issue has plagued o
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 org.ju
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 @@
+/*
+ * License
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 @@
+/*
+ * Licen
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 t
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 commen
[
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 @@
+/*
+ * Li
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 @@
+/*
+ * Licen
1 - 100 of 303 matches
Mail list logo