syhily commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-pulsar/pull/10#discussion_r1060346224
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -177,9 +171,11 @@ public PulsarSourceBuilder
tisonkun commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-pulsar/pull/10#discussion_r1060346981
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -177,9 +171,11 @@ public PulsarSourceBuild
syhily commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-pulsar/pull/10#discussion_r1060347329
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java:
##
@@ -236,6 +230,8 @@ private PulsarSourceOptions
syhily commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-pulsar/pull/10#discussion_r1060346224
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -177,9 +171,11 @@ public PulsarSourceBuilder
tisonkun commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-pulsar/pull/10#discussion_r1060350503
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java:
##
@@ -236,6 +230,8 @@ private PulsarSourceOptio
syhily commented on code in PR #10:
URL:
https://github.com/apache/flink-connector-pulsar/pull/10#discussion_r1060351426
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java:
##
@@ -236,6 +230,8 @@ private PulsarSourceOptions
JingsongLi merged PR #449:
URL: https://github.com/apache/flink-table-store/pull/449
--
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-30545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30545:
---
Labels: pull-request-available (was: )
> The SchemaManager doesn't check 'NOT NULL' specifi
[
https://issues.apache.org/jira/browse/FLINK-30544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-30544:
---
Description:
Currently, every time a task receives a watermark, it tries to update the
minimum wate
wanglijie95 opened a new pull request, #21588:
URL: https://github.com/apache/flink/pull/21588
## What is the purpose of the change
Currently, every time a task receives a watermark, it tries to update the
minimum watermark. In current implementation, we use the traversal algorithm to
[
https://issues.apache.org/jira/browse/FLINK-30544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30544:
---
Labels: pull-request-available (was: )
> Speed up finding minimum watermark across all chan
[
https://issues.apache.org/jira/browse/FLINK-30545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30545.
Assignee: yuzelin
Resolution: Fixed
master:
a47dc2b483692df2a61d2a567f1c58323e6a4fdb
3b9ce35
JingsongLi commented on PR #447:
URL:
https://github.com/apache/flink-table-store/pull/447#issuecomment-1369495707
> In addition, I would like to add a recommendation on the [Build from
source
page](https://nightlies.apache.org/flink/flink-table-store-docs-master/docs/engines/build/)
to u
JingsongLi merged PR #447:
URL: https://github.com/apache/flink-table-store/pull/447
--
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...@
dependabot[bot] opened a new pull request, #450:
URL: https://github.com/apache/flink-table-store/pull/450
Bumps [json-smart](https://github.com/netplex/json-smart-v2) from 2.3 to
2.3.1.
Commits
See full diff in https://github.com/netplex/json-smart-v2/commits";>compare view
flinkbot commented on PR #21588:
URL: https://github.com/apache/flink/pull/21588#issuecomment-1369498047
## CI report:
* 11eeb48f8fe801f1be41baca07e82d8f9360583e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
kevinshin created FLINK-30546:
-
Summary: WindowDeduplicate didn't write result to sink timely
Key: FLINK-30546
URL: https://issues.apache.org/jira/browse/FLINK-30546
Project: Flink
Issue Type: Bu
ramkrish86 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1369511575
@xintongsong - We have almost completed the testing part also. I will
update the PR in a day or two time frame. Am checking with other comments that
Anoop had added over here.
--
ramkrish86 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1369515475
> except for the one about deduplicating
HadoopRecoverableFsDataOutputStream and AzureBlobFsRecoverableDataOutputStream
What specifically you are talking about here? I went through
[
https://issues.apache.org/jira/browse/FLINK-30497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-30497:
-
Assignee: Shengkai Fang
> Introduce TableChange to represent DROP change
>
tisonkun merged PR #10:
URL: https://github.com/apache/flink-connector-pulsar/pull/10
--
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-30540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30540:
--
Priority: Critical (was: Major)
> DataSinkTaskTest failed with a 143 exit code
>
[
https://issues.apache.org/jira/browse/FLINK-29594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29594:
--
Affects Version/s: rabbitmq-3.0.1
> RMQSourceITCase.testMessageDelivery timed out
> --
zhuzhurk commented on code in PR #21570:
URL: https://github.com/apache/flink/pull/21570#discussion_r1060266079
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertexInputInfo.java:
##
@@ -68,4 +68,9 @@ public boolean equals(Object obj) {
[
https://issues.apache.org/jira/browse/FLINK-29594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653883#comment-17653883
]
Matthias Pohl commented on FLINK-29594:
---
This issue will be resolved on {{master}}
[
https://issues.apache.org/jira/browse/FLINK-30485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653885#comment-17653885
]
Matthias Pohl commented on FLINK-30485:
---
[~martijnvisser] may you remove 1.17 as a
lindong28 commented on PR #21558:
URL: https://github.com/apache/flink/pull/21558#issuecomment-1369537264
Thanks for the 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 com
lindong28 merged PR #21558:
URL: https://github.com/apache/flink/pull/21558
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-29217.
Resolution: Fixed
> CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint
>
lindong28 commented on code in PR #21576:
URL: https://github.com/apache/flink/pull/21576#discussion_r1060393161
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -990,6 +991,10 @@ public MailboxExecutorFactory getMailboxExecut
[
https://issues.apache.org/jira/browse/FLINK-30512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang closed FLINK-30512.
Release Note: add param : set table.exec.source.idle-timeout=120s; the
issue fixed.
Resolution: Fixe
[
https://issues.apache.org/jira/browse/FLINK-30512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653889#comment-17653889
]
wangkang commented on FLINK-30512:
--
add param : set table.exec.source.idle-timeout=120s
[
https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653890#comment-17653890
]
Matthias Pohl commented on FLINK-27518:
---
Awesome, thanks~
> Refactor migration te
[
https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29835:
--
Affects Version/s: pulsar-3.0.0
pulsar-4.0.0
[
https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653894#comment-17653894
]
Matthias Pohl edited comment on FLINK-29835 at 1/3/23 9:26 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653894#comment-17653894
]
Matthias Pohl commented on FLINK-29835:
---
I updated the affected versions. FLINK-30
[
https://issues.apache.org/jira/browse/FLINK-30340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653895#comment-17653895
]
Matthias Pohl commented on FLINK-30340:
---
I updated the affected versions. FLINK-30
[
https://issues.apache.org/jira/browse/FLINK-30340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30340:
--
Affects Version/s: pulsar-4.0.0
(was: 1.17.0)
> PulsarUnorderedSour
Jingsong Lee created FLINK-30547:
Summary: Flink-table-runtime free for flink-table-store-common
Key: FLINK-30547
URL: https://issues.apache.org/jira/browse/FLINK-30547
Project: Flink
Issue T
JingsongLi commented on code in PR #451:
URL: https://github.com/apache/flink-table-store/pull/451#discussion_r1060403458
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java:
##
@@ -405,6 +405,10 @@ public CoreOptions(Configuration options) {
[
https://issues.apache.org/jira/browse/FLINK-30522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30522:
---
Labels: pull-request-available (was: )
> `SHOW TBLPROPERTIES` can't read properties of tabl
xintongsong commented on code in PR #21508:
URL: https://github.com/apache/flink/pull/21508#discussion_r1060404322
##
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureBlobFsRecoverableDataOutputStream.java:
##
@@ -0,0 +1,299 @@
+/*
+ * Licen
JingsongLi merged PR #450:
URL: https://github.com/apache/flink-table-store/pull/450
--
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...@
yuzelin commented on code in PR #451:
URL: https://github.com/apache/flink-table-store/pull/451#discussion_r1060405512
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java:
##
@@ -405,6 +405,10 @@ public CoreOptions(Configuration options) {
gaborgsomogyi commented on PR #21583:
URL: https://github.com/apache/flink/pull/21583#issuecomment-1369559291
Seems like `LookupJoinITCase` is super super stable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
gaborgsomogyi commented on PR #21583:
URL: https://github.com/apache/flink/pull/21583#issuecomment-1369559417
@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
gaborgsomogyi commented on PR #21584:
URL: https://github.com/apache/flink/pull/21584#issuecomment-1369560946
@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
[
https://issues.apache.org/jira/browse/FLINK-30539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653900#comment-17653900
]
Gabor Somogyi commented on FLINK-30539:
---
I think it's not going to cause any big c
heyu dou created FLINK-30548:
Summary: In some cases AvroDeserializationSchema buffer is not
reset
Key: FLINK-30548
URL: https://issues.apache.org/jira/browse/FLINK-30548
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Description:
When the avro schema changes, if the downstream uses the old schema to read the
data gener
ruanhang1993 opened a new pull request, #21589:
URL: https://github.com/apache/flink/pull/21589
## What is the purpose of the change
This pull request add RecordEvaluator to dynamically stop source based on
de-serialized records.
## Brief change log
The changes could be
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25509:
---
Labels: pull-request-available (was: )
> FLIP-208: Add RecordEvaluator to dynamically stop
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> In some cases AvroDeserializationSchema
flinkbot commented on PR #21589:
URL: https://github.com/apache/flink/pull/21589#issuecomment-1369567350
## CI report:
* d423b3536c0ad2899a29c4d2f478477db6ad37d6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Description:
When the avro schema changes, if the downstream uses the old schema to read the
data gener
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Description:
When the avro schema changes, if the downstream uses the old schema to read the
data gener
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Description:
When the avro schema changes, if the downstream uses the old schema to read the
data gener
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
heyu dou updated FLINK-30548:
-
Attachment: AvroNew.java
AvroOld.java
> In some cases AvroDeserializationSchema buffer i
reswqa commented on code in PR #21560:
URL: https://github.com/apache/flink/pull/21560#discussion_r1060429247
##
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputGateDeploymentDescriptor.java:
##
@@ -75,7 +77,7 @@ public class InputGateDeploymentDescriptor im
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653909#comment-17653909
]
Yunhong Zheng commented on FLINK-18356:
---
[~godfrey] and [~martijnvisser] . I will
JingsongLi commented on PR #447:
URL:
https://github.com/apache/flink-table-store/pull/447#issuecomment-1369589430
Revert this in
https://github.com/apache/flink-table-store/commit/6489d299aa87666f6f26b88c691850ea9fd63428
maven 3.2.5 is widely used by us, this change will make maven 3.2.
[
https://issues.apache.org/jira/browse/FLINK-30548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653916#comment-17653916
]
heyu dou commented on FLINK-30548:
--
If you agree, can you let me modify it?
> In some
gyfora commented on PR #493:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/493#issuecomment-1369591561
After some offline discussions, we have agreed with @mxm to keep the
original version of this PR and not introduce an extra config for minimum
metric window now to keep th
[
https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29755:
--
Affects Version/s: pulsar-3.0.0
pulsar-4.0.0
[
https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653927#comment-17653927
]
Matthias Pohl commented on FLINK-29755:
---
I updated the affected versions. FLINK-30
XComp commented on PR #21583:
URL: https://github.com/apache/flink/pull/21583#issuecomment-1369599382
Yeah, we're planning to pick up on FLINK-29427.
--
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
XComp merged PR #21583:
URL: https://github.com/apache/flink/pull/21583
--
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.
XComp merged PR #21584:
URL: https://github.com/apache/flink/pull/21584
--
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.
XComp commented on PR #21584:
URL: https://github.com/apache/flink/pull/21584#issuecomment-1369602071
Sorry, I missed that the build is still pending for that one. But,
`YARNSessionCapacitySchedulerITCase` is packaged in `misc` which succeeded
already. So, we should be fine.
--
This is a
XComp merged PR #21585:
URL: https://github.com/apache/flink/pull/21585
--
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-30539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653930#comment-17653930
]
Matthias Pohl commented on FLINK-30539:
---
Removed timeouts:
master: 2ffe7e01919682b
Danny Cranmer created FLINK-30549:
-
Summary: Remove flink-connector-firehose from Flink master branch
Key: FLINK-30549
URL: https://issues.apache.org/jira/browse/FLINK-30549
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-30385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30385:
--
Summary: Remove AWS connectors from master branch (was: Remove KDS/KDF/AWS
Base connectors fr
[
https://issues.apache.org/jira/browse/FLINK-30549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30549:
--
Description:
Remove:
* {{flink-connector-fir
> Remove flink-connector-firehose from Flink ma
[
https://issues.apache.org/jira/browse/FLINK-30549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30549:
-
Assignee: Danny Cranmer
> Remove flink-connector-firehose from Flink master branch
> --
[
https://issues.apache.org/jira/browse/FLINK-30549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30549:
--
Summary: Remove flink-connector-aws-kinesis-firehose from Flink master
branch (was: Remove fl
[
https://issues.apache.org/jira/browse/FLINK-30549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30549:
--
Description:
Remove:
* {{flink-connector-aws-kinesis-firehose}}
* {{flink-sql-connector-aws-
Danny Cranmer created FLINK-30550:
-
Summary: Flink master to integrate KDS/KDF docs from
flink-connector-aws
Key: FLINK-30550
URL: https://issues.apache.org/jira/browse/FLINK-30550
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30550:
--
Fix Version/s: 1.17.0
(was: 1.16.1)
> Flink master to integrate KDS/KDF
[
https://issues.apache.org/jira/browse/FLINK-30550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30550:
--
Affects Version/s: (was: 1.16.0)
> Flink master to integrate KDS/KDF docs from flink-conne
[
https://issues.apache.org/jira/browse/FLINK-30550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30550:
--
Component/s: Connectors / Firehose
Connectors / Kinesis
> Flink master to int
zhipeng93 commented on code in PR #188:
URL: https://github.com/apache/flink-ml/pull/188#discussion_r1060470625
##
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/TableUtilsTest.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
zjureel commented on PR #423:
URL:
https://github.com/apache/flink-table-store/pull/423#issuecomment-1369631457
Hi @JingsongLi I have updated this PR according to the cast executor, please
help to review it again, thanks
--
This is an automated message from the Apache Git Service.
To res
dannycranmer opened a new pull request, #21590:
URL: https://github.com/apache/flink/pull/21590
…ctor-aws
## What is the purpose of the change
Integrate AWS connectors v4.0.0 docs with Flink master
## Brief change log
- Pull Kinesis/Firehose docs from flink-connect
zhipeng93 commented on code in PR #188:
URL: https://github.com/apache/flink-ml/pull/188#discussion_r1060480557
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/binarizer/Binarizer.java:
##
@@ -70,11 +71,12 @@ public Table[] transform(Table... inputs) {
for (
flinkbot commented on PR #21590:
URL: https://github.com/apache/flink/pull/21590#issuecomment-1369641260
## CI report:
* d52af1f6d8046367a1617146b054fd484a645f25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hlteoh37 commented on code in PR #21590:
URL: https://github.com/apache/flink/pull/21590#discussion_r1060482687
##
docs/data/sql_connectors.yml:
##
@@ -169,22 +169,26 @@ upsert-kafka:
kinesis:
name: Amazon Kinesis Data Streams
category: connector
-maven: flink-con
hlteoh37 commented on code in PR #21590:
URL: https://github.com/apache/flink/pull/21590#discussion_r1060484427
##
docs/data/sql_connectors.yml:
##
@@ -169,22 +169,26 @@ upsert-kafka:
kinesis:
name: Amazon Kinesis Data Streams
category: connector
-maven: flink-con
dannycranmer commented on code in PR #21590:
URL: https://github.com/apache/flink/pull/21590#discussion_r1060488627
##
docs/data/sql_connectors.yml:
##
@@ -169,22 +169,26 @@ upsert-kafka:
kinesis:
name: Amazon Kinesis Data Streams
category: connector
-maven: flink
dannycranmer commented on code in PR #21590:
URL: https://github.com/apache/flink/pull/21590#discussion_r1060489104
##
docs/data/sql_connectors.yml:
##
@@ -169,22 +169,26 @@ upsert-kafka:
kinesis:
name: Amazon Kinesis Data Streams
category: connector
-maven: flink
dannycranmer commented on code in PR #21590:
URL: https://github.com/apache/flink/pull/21590#discussion_r1060489589
##
docs/setup_docs.sh:
##
@@ -63,7 +63,7 @@ mkdir tmp
cd tmp
integrate_connector_docs elasticsearch v3.0.0
-integrate_connector_docs aws v3.0.0
+integrate_conn
dannycranmer commented on code in PR #21590:
URL: https://github.com/apache/flink/pull/21590#discussion_r1060489589
##
docs/setup_docs.sh:
##
@@ -63,7 +63,7 @@ mkdir tmp
cd tmp
integrate_connector_docs elasticsearch v3.0.0
-integrate_connector_docs aws v3.0.0
+integrate_conn
[
https://issues.apache.org/jira/browse/FLINK-16006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653945#comment-17653945
]
qiunan commented on FLINK-16006:
[~ZhenqiuHuang] Hi, Why didn't you support it？
> Add h
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653944#comment-17653944
]
Xingbo Huang commented on FLINK-26974:
--
[~mapohl] Sure. I will take a look.
> Pyth
XComp commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1060497575
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatMonitorImpl.java:
##
@@ -39,6 +39,8 @@
private static final Logger LOG =
LoggerFactory.
JingsongLi commented on code in PR #423:
URL: https://github.com/apache/flink-table-store/pull/423#discussion_r1060497684
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/casting/CastExecutors.java:
##
@@ -176,7 +176,7 @@ public class CastExecutors {
XComp commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1060497575
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatMonitorImpl.java:
##
@@ -39,6 +39,8 @@
private static final Logger LOG =
LoggerFactory.
XComp commented on code in PR #21467:
URL: https://github.com/apache/flink/pull/21467#discussion_r1060497575
##
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatMonitorImpl.java:
##
@@ -39,6 +39,8 @@
private static final Logger LOG =
LoggerFactory.
JingsongLi commented on code in PR #423:
URL: https://github.com/apache/flink-table-store/pull/423#discussion_r1060500678
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaEvolutionUtil.java:
##
@@ -304,4 +307,56 @@ private static int indexOf
JingsongLi commented on code in PR #423:
URL: https://github.com/apache/flink-table-store/pull/423#discussion_r1060501943
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaEvolutionUtil.java:
##
@@ -304,4 +307,56 @@ private static int indexOf
1 - 100 of 232 matches
Mail list logo
