echauchot commented on PR #8:
URL:
https://github.com/apache/flink-connector-cassandra/pull/8#issuecomment-1507085334
> I assume we only merge this to `main` (Since the CTestEnvironment is only
there)?
>
Yes
> Will we do anything about v3.0 / release-1.16 on the Flink
[
https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711921#comment-17711921
]
Yufan Sheng commented on FLINK-28352:
-
Thanks. The FLINK-24302 will be closed in Pulsar itself 3.0.0
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-31757:
---
Component/s: Runtime / Coordination
(was: Runtime / Task)
> Optimize
pnowojski commented on code in PR #22392:
URL: https://github.com/apache/flink/pull/22392#discussion_r1165593019
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java:
##
@@ -381,7 +383,7 @@ private void
dmvk commented on code in PR #22350:
URL: https://github.com/apache/flink/pull/22350#discussion_r1165606301
##
flink-runtime-web/web-dashboard/src/app/app.interceptor.ts:
##
@@ -62,10 +65,8 @@ export class AppInterceptor implements HttpInterceptor {
[
https://issues.apache.org/jira/browse/FLINK-31796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergio Sainz updated FLINK-31796:
-
Description:
Currently Flink Native Kubernetes does not support istio + TLS cleanly : Flink
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711914#comment-17711914
]
Martijn Visser commented on FLINK-25509:
[~syhily] I defer to [~lindong] for his input on that
[
https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711913#comment-17711913
]
Martijn Visser commented on FLINK-31761:
[~fanrui] No worries, I would have closed it for you
[
https://issues.apache.org/jira/browse/FLINK-31797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31797:
-
Assignee: Matthias Pohl
> Move LeaderElectionService out of LeaderContender
>
Matthias Pohl created FLINK-31797:
-
Summary: Move LeaderElectionService out of LeaderContender
Key: FLINK-31797
URL: https://issues.apache.org/jira/browse/FLINK-31797
Project: Flink
Issue
flinkbot commented on PR #22393:
URL: https://github.com/apache/flink/pull/22393#issuecomment-1507043111
## CI report:
* f9d940ab5bb355f5174a6377948d4e1f7a7d00c2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31785:
--
Summary: Move LeaderElectionService.stop() into LeaderElection.close()
(was: Move
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711909#comment-17711909
]
Piotr Nowojski commented on FLINK-31655:
I think there are ways to address problems with
wanglijie95 commented on PR #22367:
URL: https://github.com/apache/flink/pull/22367#issuecomment-1507041121
Squash commits. Merged % CI green.
--
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-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711907#comment-17711907
]
Rui Fan commented on FLINK-31761:
-
Hi [~martijnvisser] , sorry for the late update.
Merged master
Sergio Sainz created FLINK-31796:
Summary: Support service mesh istio with Flink kubernetes (both
native and operator) for secure communications
Key: FLINK-31796
URL:
[
https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-31761.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> Fix Some Typo And Improve lambda expressions.
>
flinkbot commented on PR #22392:
URL: https://github.com/apache/flink/pull/22392#issuecomment-1507031958
## CI report:
* c8d6b945ad2c8ff9e2d0c3328dba3d7f8cd59767 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
GilShmaya commented on PR #379:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/379#issuecomment-1507030410
Hi,
I notice that this bug you fixed in version 1.2.0 seems to have resurfaced
in version 1.4.0.
@avocadomaster @gyfora Would you mind taking a look at this
sigalite opened a new pull request, #22393:
URL: https://github.com/apache/flink/pull/22393
## What is the purpose of the change
enable the job manager and task manager communicate in a Kubernetes cluster
with Istio and mTLS enabled.
*(For example: This pull request makes task
[
https://issues.apache.org/jira/browse/FLINK-31795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31795:
---
Labels: pull-request-available (was: )
> Add Config to enable/disable savepoint cleanup
>
darenwkt opened a new pull request, #565:
URL: https://github.com/apache/flink-kubernetes-operator/pull/565
## What is the purpose of the change
Add new operator config "savepoint.cleaner.enabled" to allow user to
configure whether to enable SavepointObserver to clean up
[
https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31588:
---
Labels: pull-request-available (was: )
> The unaligned checkpoint type is wrong at subtask
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711902#comment-17711902
]
Yufan Sheng commented on FLINK-25509:
-
[~martijnvisser] I think this breaking change should be
1996fanrui opened a new pull request, #22392:
URL: https://github.com/apache/flink/pull/22392
## What is the purpose of the change
Correct the unaligned checkpoint type after aligned barrier timeout to
unaligned barrier on PipelinedSubpartition.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711897#comment-17711897
]
RocMarshal commented on FLINK-31757:
Thanks for your [~Weijie Guo] sorted concise and precise
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711895#comment-17711895
]
RocMarshal commented on FLINK-31757:
Thank you [~fanrui] & [~huwh] very much.
I'll prepare a design
[
https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-31699.
---
Resolution: Fixed
> JDBC nightly CI failure
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711894#comment-17711894
]
Danny Cranmer commented on FLINK-31699:
---
main branch is good
Daren Wong created FLINK-31795:
--
Summary: Add Config to enable/disable savepoint cleanup
Key: FLINK-31795
URL: https://issues.apache.org/jira/browse/FLINK-31795
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711892#comment-17711892
]
Weijie Guo commented on FLINK-31757:
[~RocMarshal] I have updated the description of this ticket
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711886#comment-17711886
]
Rui Fan commented on FLINK-31757:
-
Thanks [~RocMarshal] 's reporting and [~huwh] 's feedback.
{quote}If
Aitozi commented on code in PR #22386:
URL: https://github.com/apache/flink/pull/22386#discussion_r1165532653
##
docs/data/sql_functions.yml:
##
@@ -933,11 +933,13 @@ valueconstruction:
- sql: |
-- implicit constructor with parenthesis
(value1 [, value2]*)
+
flinkbot commented on PR #22391:
URL: https://github.com/apache/flink/pull/22391#issuecomment-1506974825
## CI report:
* 156e8ecc00c8ff9b86519b4b3139845e67274fda UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31757:
---
Description:
Supposed we have a Job with 21 {{JobVertex}}. The parallelism of vertex A is
100, and
LadyForest opened a new pull request, #22391:
URL: https://github.com/apache/flink/pull/22391
## What is the purpose of the change
This is a trivial fix for the `FlinkVersion` enum, which should start with
lowercase.
## Brief change log
Change `V1_18` to `v1_18`.
[
https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30371:
--
Fix Version/s: jdbc-3.2.0
(was: jdbc-3.1.0)
> JdbcOutputFormat is at
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711880#comment-17711880
]
Weihua Hu commented on FLINK-31757:
---
[~RocMarshal] sure, I would like to. Will you prepare a design
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-31757:
---
Assignee: RocMarshal
> Optimize Flink un-balanced tasks scheduling
>
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711875#comment-17711875
]
RocMarshal commented on FLINK-31757:
Based on this problem, we has achieved balanced task
flinkbot commented on PR #22390:
URL: https://github.com/apache/flink/pull/22390#issuecomment-1506940038
## CI report:
* 152e71f5cffd7626fed20f57387a256c2c078a53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31794:
---
Labels: pull-request-available (was: )
> Ignore unknown CRD fields
>
darenwkt opened a new pull request, #564:
URL: https://github.com/apache/flink-kubernetes-operator/pull/564
## What is the purpose of the change
Ignore unknown CRD fields to prevent failure in creating CR.
## Brief change log
Added class-level annotation
[
https://issues.apache.org/jira/browse/FLINK-31750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31750:
--
Assignee: ZhengYi Weng
> Hash Keys are duplicate when join reorder happens in stream mode
>
Daren Wong created FLINK-31794:
--
Summary: Ignore unknown CRD fields
Key: FLINK-31794
URL: https://issues.apache.org/jira/browse/FLINK-31794
Project: Flink
Issue Type: Improvement
eskabetxe commented on PR #31:
URL:
https://github.com/apache/flink-connector-jdbc/pull/31#issuecomment-1506928813
Renamed, and rebased
--
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-31785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31785:
---
Labels: pull-request-available (was: )
> Move LeaderElectionService out of LeaderContender
XComp opened a new pull request, #22390:
URL: https://github.com/apache/flink/pull/22390
* [FLINK-30765](https://issues.apache.org/jira/browse/FLINK-30765) (PR
https://github.com/apache/flink/pull/21742)
* [FLINK-31768](https://issues.apache.org/jira/browse/FLINK-31768) (PR
snuyanzin commented on code in PR #22063:
URL: https://github.com/apache/flink/pull/22063#discussion_r1165481084
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/SqlClientOptions.java:
##
@@ -68,4 +69,12 @@ private SqlClientOptions() {}
snuyanzin commented on code in PR #22063:
URL: https://github.com/apache/flink/pull/22063#discussion_r1165478544
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/SqlClientSyntaxHighlighter.java:
##
@@ -0,0 +1,256 @@
+/*
+ * Licensed to the
snuyanzin commented on code in PR #22063:
URL: https://github.com/apache/flink/pull/22063#discussion_r1165477945
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/SqlClientSyntaxHighlighter.java:
##
@@ -0,0 +1,256 @@
+/*
+ * Licensed to the
libenchao commented on code in PR #22386:
URL: https://github.com/apache/flink/pull/22386#discussion_r1165466847
##
docs/data/sql_functions.yml:
##
@@ -933,11 +933,13 @@ valueconstruction:
- sql: |
-- implicit constructor with parenthesis
(value1 [, value2]*)
+
[
https://issues.apache.org/jira/browse/FLINK-31750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengYi Weng updated FLINK-31750:
-
Description:
When I run `JoinReorderTestBase#testAllInnerJoin` in the case that
[
https://issues.apache.org/jira/browse/FLINK-31750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengYi Weng updated FLINK-31750:
-
Affects Version/s: 1.16.1
1.17.0
> Hash Keys are duplicate when join
qingwei91 commented on PR #14084:
URL: https://github.com/apache/flink/pull/14084#issuecomment-1506843409
Hi, I am keen to have this feature, how can we make progress on this? Happy
to help :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711854#comment-17711854
]
Feng Jin commented on FLINK-31788:
--
[~jark] This question is from a user mail.
The origin discuss
jiangxin369 commented on code in PR #229:
URL: https://github.com/apache/flink-ml/pull/229#discussion_r1165403137
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java:
##
@@ -104,6 +107,33 @@ public static StreamConfig
jiangxin369 commented on code in PR #229:
URL: https://github.com/apache/flink-ml/pull/229#discussion_r1165403137
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java:
##
@@ -104,6 +107,33 @@ public static StreamConfig
XComp commented on PR #22257:
URL: https://github.com/apache/flink/pull/22257#issuecomment-1506819296
@PatrickRen may you have a final pass over this PR. I fixed the issue now
with the help of FLINK-31765
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-31788:
-
Description:
This feature was originally implemented in the old planner:
XComp commented on PR #22257:
URL: https://github.com/apache/flink/pull/22257#issuecomment-1506818191
@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-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711852#comment-17711852
]
Jark Wu commented on FLINK-31788:
-
Thanks for pointing out this [~hackergin]. If it's true, I think it
Aitozi commented on PR #22386:
URL: https://github.com/apache/flink/pull/22386#issuecomment-1506815970
CC @libenchao
--
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
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711848#comment-17711848
]
Weihua Hu commented on FLINK-31757:
---
Hi [~RocMarshal] , thanks for reporting this.
For now, you could
MartijnVisser opened a new pull request, #10:
URL: https://github.com/apache/flink-connector-cassandra/pull/10
Same as https://github.com/apache/flink-connector-cassandra/pull/9
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
zhipeng93 commented on PR #229:
URL: https://github.com/apache/flink-ml/pull/229#issuecomment-1506787052
The update LGTM except the unresolved one. @lindong28 Would you like to take
a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711841#comment-17711841
]
Martijn Visser commented on FLINK-31793:
[~Wencong Liu] Done!
> Remove dependency on
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-31793:
--
Assignee: Wencong Liu
> Remove dependency on flink-shaded for flink-connector-jdbc
>
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711840#comment-17711840
]
Feng Jin commented on FLINK-31788:
--
[~jark] I'm sorry, I wrote the wrong name. It should be
tisonkun commented on code in PR #43:
URL:
https://github.com/apache/flink-connector-pulsar/pull/43#discussion_r1165364566
##
.github/workflows/daily.yml:
##
@@ -18,6 +18,7 @@
name: Nightly
on:
+ pull_request:
Review Comment:
```suggestion
```
Verified.
[
https://issues.apache.org/jira/browse/FLINK-31785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31785:
-
Assignee: Matthias Pohl
> Move LeaderElectionService out of LeaderContender
>
[
https://issues.apache.org/jira/browse/FLINK-31610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711825#comment-17711825
]
Yingjie Cao commented on FLINK-31610:
-
Sorry for the delayed reply.
Totally agree that we should
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal reopened FLINK-31757:
> Optimize Flink un-balanced tasks scheduling
> ---
>
>
wanglijie95 commented on PR #31:
URL:
https://github.com/apache/flink-connector-jdbc/pull/31#issuecomment-1506730457
> org.apache.flink.connector.jdbc.internal.options.JdbcConnectorOptions
This is also `@Internal`, which is only used by `JdbcDynamicTableSink`(users
are not expected
[
https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711820#comment-17711820
]
Jark Wu commented on FLINK-31777:
-
Hi [~ge.bugman], "upsert-kafka" doesn't support JSON or AVRO in
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711816#comment-17711816
]
Wencong Liu commented on FLINK-31793:
-
Hello [~dannycranmer] , I think this could follow the same
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31793:
--
Component/s: Connectors / JDBC
(was: Connectors / Cassandra)
> Remove
dannycranmer commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-jdbc/pull/39#discussion_r1165324674
##
pom.xml:
##
@@ -48,7 +48,7 @@ under the License.
1.16.0
-15.0
+16.1
Review Comment:
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31793:
--
Fix Version/s: (was: cassandra-4.0.0)
(was: cassandra-3.0.1)
>
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31793:
--
Labels: (was: pull-request-available)
> Remove dependency on flink-shaded for
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-31793:
-
Assignee: (was: Etienne Chauchot)
> Remove dependency on flink-shaded for
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31793:
--
Reporter: Danny Cranmer (was: Martijn Visser)
> Remove dependency on flink-shaded for
[
https://issues.apache.org/jira/browse/FLINK-31793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31793:
--
Description: The JDBC connector relies on flink-shaded and uses Flinks'
shaded Guava. With
Danny Cranmer created FLINK-31793:
-
Summary: Remove dependency on flink-shaded for flink-connector-jdbc
Key: FLINK-31793
URL: https://issues.apache.org/jira/browse/FLINK-31793
Project: Flink
dannycranmer merged PR #39:
URL: https://github.com/apache/flink-connector-jdbc/pull/39
--
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:
tisonkun commented on code in PR #43:
URL:
https://github.com/apache/flink-connector-pulsar/pull/43#discussion_r1165322478
##
.github/workflows/daily.yml:
##
@@ -18,6 +18,7 @@
name: Nightly
on:
+ pull_request:
Review Comment:
To be reverted after verified.
--
This
tisonkun opened a new pull request, #43:
URL: https://github.com/apache/flink-connector-pulsar/pull/43
TRIVIAL
--
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
[
https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31748:
---
Labels: pull-request-available (was: )
> Adapt SplitFetcherManager#removeSplit for
[
https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-31777:
Component/s: Connectors / Kafka
(was: kafka)
> Upsert Kafka use Avro Confluent, key
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711809#comment-17711809
]
Jark Wu commented on FLINK-31778:
-
Hi [~soin08], nice catch! However, constructing BinaryRowWriter and
tisonkun closed pull request #35: [FLINK-31427][Table] Initial Catalog
implementation with a new config model and schema conversion.
URL: https://github.com/apache/flink-connector-pulsar/pull/35
--
This is an automated message from the Apache Git Service.
To respond to the message, please
tisonkun commented on PR #35:
URL:
https://github.com/apache/flink-connector-pulsar/pull/35#issuecomment-1506709597
> Hi all, my account was revoked from streamnative. I have to start a new PR
for this feature.
OK. Then let's close the PR as it's stale...
--
This is an automated
tisonkun commented on PR #16:
URL:
https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1506708663
I see the respond. Feel free to cc me to verify the release. I'll send a
patch to suppress the compile issue but still wait a bit for @syhily to
implement FLINK-31748.
--
eskabetxe commented on code in PR #31:
URL:
https://github.com/apache/flink-connector-jdbc/pull/31#discussion_r1165316211
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkFunctionState.java:
##
@@ -28,6 +30,7 @@
/** Thread-safe (assuming
MartijnVisser merged PR #9:
URL: https://github.com/apache/flink-connector-cassandra/pull/9
--
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-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711805#comment-17711805
]
Jark Wu commented on FLINK-16868:
-
Hi [~charles-tan], yes, the configuraitons just work on the legacy
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711802#comment-17711802
]
Jark Wu commented on FLINK-31788:
-
Hi [~hackergin], it seems the {{emitValueWithRetract}} was never
wanglijie95 commented on code in PR #31:
URL:
https://github.com/apache/flink-connector-jdbc/pull/31#discussion_r1165295846
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkFunctionState.java:
##
@@ -28,6 +30,7 @@
/** Thread-safe (assuming
MartijnVisser commented on code in PR #39:
URL:
https://github.com/apache/flink-connector-jdbc/pull/39#discussion_r1165293180
##
pom.xml:
##
@@ -48,7 +48,7 @@ under the License.
1.16.0
-15.0
+16.1
Review Comment:
We actually should create a
[
https://issues.apache.org/jira/browse/FLINK-31700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711798#comment-17711798
]
Jiabao Sun commented on FLINK-31700:
Hey [~dannycranmer].
Could you help close this issue?
>
101 - 200 of 285 matches
Mail list logo
