zentol commented on PR #3:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/3#issuecomment-1347897497
> Correct. I'm assuming that we want to want to ignore these errors for this
PR?
No. But you just need to run the architecture test locally and
set...`-Dfreeze.refreeze=true
PatrickRen commented on PR #21365:
URL: https://github.com/apache/flink/pull/21365#issuecomment-1347902713
@SmirAlex Sorry for my late response. Is this PR ready to be reviewed? I see
the LookupJoinITCase still failed in the CI of this PR 🤔
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646491#comment-17646491
]
Dawid Wysakowicz commented on FLINK-30386:
--
Thanks for the explanation [~qingyu
LadyForest commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1347908262
Update 9545b73 to 03a65c64
--
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
MartijnVisser commented on PR #21365:
URL: https://github.com/apache/flink/pull/21365#issuecomment-1347914135
@SmirAlex The build for this PR is failing with exactly the same issue as
the PR is supposed to fix 😅 can you have a look if this really fixes the issue?
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646500#comment-17646500
]
Qingsheng Ren commented on FLINK-29427:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646501#comment-17646501
]
Qingsheng Ren commented on FLINK-29859:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-13400:
--
Assignee: Sergey Nuyanzin (was: frank wang)
> Remove Hive and Hadoop dependencies fr
tsreaper commented on code in PR #433:
URL: https://github.com/apache/flink-table-store/pull/433#discussion_r1046796807
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriteImpl.java:
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
snuyanzin commented on PR #21495:
URL: https://github.com/apache/flink/pull/21495#issuecomment-1347930810
@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.
Jianhui Dong created FLINK-30396:
Summary: sql hint 'LOOKUP' which is defined in outer query block
may take effect in inner query block
Key: FLINK-30396
URL: https://issues.apache.org/jira/browse/FLINK-30396
mbalassi commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1347935947
@gaborgsomogyi with the externalization of the [HBase
connector](https://github.com/apache/flink-connector-hbase) will the
`HBaseDelegationTokenProvider` continue to live in `flink-runti
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianhui Dong updated FLINK-30396:
-
Description:
As [flink
doc|https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/
gaborgsomogyi commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1347937882
@mbalassi I've mentioned the move possibility to @ferenc-csaky but seems
like not yet done. From my point of view we could move it now :)
--
This is an automated message from the
mbalassi commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1347939789
@gaborgsomogyi please take a look at the
[CI](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43921&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=24c3384f-1bcb
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianhui Dong updated FLINK-30396:
-
Description:
As [flink
doc|https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianhui Dong updated FLINK-30396:
-
Description:
As [flink
doc|https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianhui Dong updated FLINK-30396:
-
Description:
As [flink
doc|https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianhui Dong updated FLINK-30396:
-
Description:
As [flink
doc|https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/
MartijnVisser commented on PR #20937:
URL: https://github.com/apache/flink/pull/20937#issuecomment-1347953611
@KarlManong No, we don't do these type of changes in patch releases.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
gaborgsomogyi commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1347957923
Just fixed it.
--
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.
gaborgsomogyi commented on code in PR #21499:
URL: https://github.com/apache/flink/pull/21499#discussion_r1046830220
##
flink-runtime/src/test/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManagerITCase.java:
##
@@ -175,21 +162,21 @@ void startTokensUpdate(
[
https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646515#comment-17646515
]
luoyuxia commented on FLINK-26603:
--
[~Sergey Nuyanzin] Of course not. Thanks.
> [Umbre
tsreaper merged PR #433:
URL: https://github.com/apache/flink-table-store/pull/433
--
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...@fl
tsreaper merged PR #434:
URL: https://github.com/apache/flink-table-store/pull/434
--
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...@fl
[
https://issues.apache.org/jira/browse/FLINK-30210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-30210.
---
Resolution: Fixed
master: 2073bd66a4e41ac47a98b0c0370b0ccdeb516c62,
333bb8dad697d65e70a4d672748bc1e
[
https://issues.apache.org/jira/browse/FLINK-30395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-30395.
---
Resolution: Fixed
master: 0620350d292600b11ba97779bfdb8869b87597db
> Refactor module name and docum
[
https://issues.apache.org/jira/browse/FLINK-30353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-30353:
Assignee: Chesnay Schepler (was: Martijn Visser)
> Limit concurrency for externa
swathic95 commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1046852187
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -171,11 +170,6 @@ protecte
zentol commented on PR #3:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/3#issuecomment-1348026466
Please remember to address
https://github.com/apache/flink-connector-rabbitmq/pull/3#discussion_r1045606463
--
This is an automated message from the Apache Git Service.
To re
tsreaper opened a new pull request, #435:
URL: https://github.com/apache/flink-table-store/pull/435
This ticket introduces the `CompactorStoreSink` for compact jobs in Table
Store.
The behavior of `CompactorStoreSink` is sketched as follows: This sink
accepts records containing parti
[
https://issues.apache.org/jira/browse/FLINK-30211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30211:
---
Labels: pull-request-available (was: )
> Introduce CompactStoreSink for compact jobs in Tab
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646524#comment-17646524
]
Godfrey He commented on FLINK-18356:
[~zhengyunhong97] will help to address this iss
MartijnVisser merged PR #3:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/3
--
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-unsubs
ferenc-csaky commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1348069130
> @gaborgsomogyi with the externalization of the [HBase
connector](https://github.com/apache/flink-connector-hbase) will the
`HBaseDelegationTokenProvider` continue to live in `flink
[
https://issues.apache.org/jira/browse/FLINK-30279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30279.
--
Resolution: Fixed
Fixed in main: a80c0f47afd49b1cda8f1135f63a179766efb58d
> Move existing Rab
dannycranmer commented on code in PR #21458:
URL: https://github.com/apache/flink/pull/21458#discussion_r1046891518
##
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java:
##
@@ -126,7 +126,9 @@ public long g
Martijn Visser created FLINK-30397:
--
Summary: Remove Pulsar connector from master branch
Key: FLINK-30397
URL: https://issues.apache.org/jira/browse/FLINK-30397
Project: Flink
Issue Type: Su
LadyForest commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1348079390
Update fb4e41c to 6470f1cc
--
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-30353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30353.
Resolution: Fixed
> Limit concurrency for external connector repositories
> --
snuyanzin opened a new pull request, #21500:
URL: https://github.com/apache/flink/pull/21500
## What is the purpose of the change
This is a draft version of Janino's upgrade
In https://github.com/apache/flink/pull/21203 Calcite was updated to 1.28.0
However Janino was still 3.0.1
[
https://issues.apache.org/jira/browse/FLINK-27995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27995:
---
Labels: pull-request-available (was: )
> Upgrade Janino version
> ---
[
https://issues.apache.org/jira/browse/FLINK-22317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-22317:
-
Assignee: Jane Chan (was: Aiden Gong)
> Support DROP column/constraint/watermark for A
[
https://issues.apache.org/jira/browse/FLINK-22316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-22316:
-
Assignee: Jane Chan
> Support MODIFY column/constraint/watermark for ALTER TABLE statem
[ https://issues.apache.org/jira/browse/FLINK-22316 ]
Jane Chan deleted comment on FLINK-22316:
---
was (Author: qingyue):
Sorry for being late, but [https://github.com/apache/flink/pull/20652] already
covers this.
> Support MODIFY column/constrain
flinkbot commented on PR #21500:
URL: https://github.com/apache/flink/pull/21500#issuecomment-1348089154
## CI report:
* cec7edbce8b10f2f543e70a14cdfeca322682a21 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LadyForest commented on PR #17155:
URL: https://github.com/apache/flink/pull/17155#issuecomment-1348089256
> > Thanks for your contribution @SteNicholas, Can you continue to finish
this work?
>
> @lsyldliu, thanks for the reminder. I will update this pull request this
week. Sorry for
lindong28 commented on PR #187:
URL: https://github.com/apache/flink-ml/pull/187#issuecomment-1348091384
Thanks for the update! 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
lindong28 merged PR #187:
URL: https://github.com/apache/flink-ml/pull/187
--
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.apac
LadyForest commented on PR #20652:
URL: https://github.com/apache/flink/pull/20652#issuecomment-1348095651
Hi @fsk119, I've addressed the comments. Would you have time to revisit it?
By the way, `ALTER TABLE MODIFY` will be tracked by FLINK-22316
--
This is an automated message from th
[
https://issues.apache.org/jira/browse/FLINK-30397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30397:
---
Labels: pull-request-available (was: )
> Remove Pulsar connector from master branch
> -
MartijnVisser opened a new pull request, #21501:
URL: https://github.com/apache/flink/pull/21501
## What is the purpose of the change
The Pulsar connector code has been moved to
https://github.com/apache/flink-connector-pulsar.
* The `3.0` branch contains the 1.16 code. There's cu
flinkbot commented on PR #21501:
URL: https://github.com/apache/flink/pull/21501#issuecomment-1348108783
## CI report:
* 8ebea561f871d186dfa3e5b816e768bf91747d1e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #483:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/483#issuecomment-1348130360
Added.
--
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
Jingsong Lee created FLINK-30398:
Summary: Introduce S3 support for table store
Key: FLINK-30398
URL: https://issues.apache.org/jira/browse/FLINK-30398
Project: Flink
Issue Type: Sub-task
gaborgsomogyi commented on PR #21499:
URL: https://github.com/apache/flink/pull/21499#issuecomment-1348132361
@ferenc-csaky ok, then we can come back to this in 1.17. At that timepoint
we're going to have a relatively stable API.
--
This is an automated message from the Apache Git Service
zentol opened a new pull request, #38:
URL: https://github.com/apache/flink-connector-aws/pull/38
Migrates this repo to the common CI setup and newly reusable workflow.
AFAICT the main change is not having 2 separate steps for normal/e2e tests.
Please let me know if that's a significant p
[
https://issues.apache.org/jira/browse/FLINK-30128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan updated FLINK-30128:
---
Attachment: (was: Flink_ABFS_support_1.pdf)
> Introduce Azure Data Lake
[
https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646543#comment-17646543
]
JasonLee commented on FLINK-30219:
--
hi [~Aiden Gong] Can you provide your query stateme
yuzelin opened a new pull request, #21502:
URL: https://github.com/apache/flink/pull/21502
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
flinkbot commented on PR #21502:
URL: https://github.com/apache/flink/pull/21502#issuecomment-1348153671
## CI report:
* 19cb7f57ebcbfb579de9689cbad44d0bd3564e27 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liming30 opened a new pull request, #21503:
URL: https://github.com/apache/flink/pull/21503
## What is the purpose of the change
At present, the external IO during abort checkpoint is in the mailbox
thread. When the external system fails, it will block the Task for a long time
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30251:
---
Labels: pull-request-available (was: )
> Move the IO with DFS during abort checkpoint to an
zentol commented on PR #38:
URL:
https://github.com/apache/flink-connector-aws/pull/38#issuecomment-1348162714
The test failure is likely caused by an actual packaging problem, that was
previously masked because you were using Maven 3.8.5 which has known issues
w.r.t. dependency propagatio
flinkbot commented on PR #21503:
URL: https://github.com/apache/flink/pull/21503#issuecomment-1348167988
## CI report:
* 08e7e73d32ec04d720c9c4d2d96e064a00be14c9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingsongLi opened a new pull request, #436:
URL: https://github.com/apache/flink-table-store/pull/436
S3 contains a large number of dependencies, which can easily lead to class
conflicts. We need a plugin mechanism to load the corresponding jars through
the classloader.
--
This is an aut
[
https://issues.apache.org/jira/browse/FLINK-30398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30398:
---
Labels: pull-request-available (was: )
> Introduce S3 support for table store
> ---
zentol commented on code in PR #21501:
URL: https://github.com/apache/flink/pull/21501#discussion_r1046979593
##
flink-docs/src/main/java/org/apache/flink/docs/util/ConfigurationOptionLocator.java:
##
@@ -73,15 +73,6 @@ public class ConfigurationOptionLocator {
zentol commented on code in PR #21501:
URL: https://github.com/apache/flink/pull/21501#discussion_r1046980377
##
mvnw:
##
@@ -1,316 +0,0 @@
-#!/bin/sh
-#
-# Licensed to the Apache Software Foundation (A
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646576#comment-17646576
]
Yun Tang commented on FLINK-29427:
--
Another instance:
https://dev.azure.com/apache-fli
LadyForest opened a new pull request, #21504:
URL: https://github.com/apache/flink/pull/21504
## What is the purpose of the change
This pull request is a subtask of FLINK-21634 and is based on FLINK-22316 to
support
```sql
ALTER TABLE table_name MODIFY { | (
[, ...]) }
``
[
https://issues.apache.org/jira/browse/FLINK-22316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22316:
---
Labels: pull-request-available (was: )
> Support MODIFY column/constraint/watermark for ALT
flinkbot commented on PR #21504:
URL: https://github.com/apache/flink/pull/21504#issuecomment-1348280379
## CI report:
* 16907ffbc7562839ce31c33ff9798f4306b44649 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047034839
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -171,11 +170,6 @@ protected v
gyfora commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047041760
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -171,11 +170,6 @@ protected v
[
https://issues.apache.org/jira/browse/FLINK-30215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30215:
-
Summary: Deprecate Cassandra explicit Scala support (was: Deprecated
Cassandra explicit
Chesnay Schepler created FLINK-30399:
Summary: Enable connectors to use config docs generator
Key: FLINK-30399
URL: https://issues.apache.org/jira/browse/FLINK-30399
Project: Flink
Issue
Chesnay Schepler created FLINK-30400:
Summary: Stop bundling connector-base in externalized connectors
Key: FLINK-30400
URL: https://issues.apache.org/jira/browse/FLINK-30400
Project: Flink
JingsongLi commented on code in PR #435:
URL: https://github.com/apache/flink-table-store/pull/435#discussion_r1047065211
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/AtMostOnceCommitterOperator.java:
##
@@ -69,34 +69,24 @@ public clas
[
https://issues.apache.org/jira/browse/FLINK-25913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-25913.
Resolution: Won't Fix
Might as well keep it to keep people on their toes.
> Disable japic
[
https://issues.apache.org/jira/browse/FLINK-24078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-24078:
-
Fix Version/s: 2.0.0
(was: 1.17.0)
> Remove brackets around varia
JingsongLi commented on code in PR #435:
URL: https://github.com/apache/flink-table-store/pull/435#discussion_r1047070272
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/CompactorStreamPartitioner.java:
##
@@ -0,0 +1,81 @@
+/*
+ * License
swathic95 commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047078026
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -171,11 +170,6 @@ protecte
JingsongLi commented on code in PR #435:
URL: https://github.com/apache/flink-table-store/pull/435#discussion_r1047076834
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/AbstractFlinkSink.java:
##
@@ -158,4 +125,10 @@ private void
assert
JingsongLi commented on code in PR #435:
URL: https://github.com/apache/flink-table-store/pull/435#discussion_r1047065211
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/AtMostOnceCommitterOperator.java:
##
@@ -69,34 +69,24 @@ public clas
MartijnVisser commented on code in PR #21501:
URL: https://github.com/apache/flink/pull/21501#discussion_r1047097193
##
mvnw:
##
@@ -1,316 +0,0 @@
-#!/bin/sh
-#
-# Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-30340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646617#comment-17646617
]
Martijn Visser commented on FLINK-30340:
https://github.com/apache/flink-connect
[
https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28352:
---
Fix Version/s: pulsar-3.0.1
pulsar-4.0.0
> [Umbrella] Make Pulsar connect
[
https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646619#comment-17646619
]
lincoln lee commented on FLINK-30386:
-
[~qingyue] this is indeed a bug of current im
gyfora commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047125068
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkServiceTest.java:
##
@@ -177,11 +177,123 @@ publi
gyfora commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047128422
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkServiceTest.java:
##
@@ -177,11 +177,123 @@ publi
gyfora commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047129173
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -316,6
Fan Hong created FLINK-30401:
Summary: Add Estimator and Transformer for MinHashLSH
Key: FLINK-30401
URL: https://issues.apache.org/jira/browse/FLINK-30401
Project: Flink
Issue Type: New Feature
Gabor Somogyi created FLINK-30402:
-
Summary: Separate token framework generic and hadoop specific parts
Key: FLINK-30402
URL: https://issues.apache.org/jira/browse/FLINK-30402
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-30402:
-
Assignee: Gabor Somogyi
> Separate token framework generic and hadoop specific parts
>
swathic95 commented on code in PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#discussion_r1047169872
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java:
##
@@ -171,11 +170,6 @@ protecte
Zdenek Tison created FLINK-30403:
Summary: The reported latest completed checkpoint is discarded
Key: FLINK-30403
URL: https://issues.apache.org/jira/browse/FLINK-30403
Project: Flink
Issue T
MartijnVisser closed pull request #21377: [FLINK-30175][Build] Bump snakeyaml
from 1.31 to 1.33
URL: https://github.com/apache/flink/pull/21377
--
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 sp
[
https://issues.apache.org/jira/browse/FLINK-30175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30175:
--
Assignee: Martijn Visser
> Bump snakeyaml from 1.31 to 1.33
> ---
[
https://issues.apache.org/jira/browse/FLINK-30175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30175.
--
Fix Version/s: 1.17.0
Resolution: Fixed
Fixed in master: 2c89283b87746398ac2be425f13cd5
1 - 100 of 206 matches
Mail list logo
