[
https://issues.apache.org/jira/browse/FLINK-29713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622561#comment-17622561
]
Peter Vary commented on FLINK-29713:
The main goal is to have a possibility to add a
Myasuka commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r1002375735
##
_config.yml:
##
@@ -244,6 +260,10 @@ component_releases:
release_archive:
flink:
+ -
+version_short: "1.16"
+version_long: 1.16.0
+
Angelo Kastroulis created FLINK-29728:
-
Summary: TablePlanner prevents Flink from starting is working
directory is a symbolic link
Key: FLINK-29728
URL: https://issues.apache.org/jira/browse/FLINK-29728
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622444#comment-17622444
]
Jeremy DeGroot commented on FLINK-29398:
Here's the FLIP page I made for this
h
[
https://issues.apache.org/jira/browse/FLINK-29713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622391#comment-17622391
]
Danny Cranmer commented on FLINK-29713:
---
Did you try using the job restart strateg
snuyanzin commented on PR #20772:
URL: https://github.com/apache/flink/pull/20772#issuecomment-1287268456
@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-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622382#comment-17622382
]
Jeremy DeGroot commented on FLINK-29398:
[~martijnvisser] If I'm reading KIP-392
snuyanzin commented on PR #20773:
URL: https://github.com/apache/flink/pull/20773#issuecomment-1287219472
@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.
RyanSkraba commented on code in PR #20258:
URL: https://github.com/apache/flink/pull/20258#discussion_r1001994132
##
flink-formats/flink-sequence-file/src/test/java/org/apache/flink/formats/sequencefile/SerializableHadoopConfigurationTest.java:
##
@@ -19,70 +19,51 @@
package or
ferenc-csaky commented on PR #21127:
URL: https://github.com/apache/flink/pull/21127#issuecomment-1287199318
@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 comme
RyanSkraba commented on PR #19897:
URL: https://github.com/apache/flink/pull/19897#issuecomment-1287185674
Thanks for the review -- I've addressed the comments, except for
`org.apache.flink.formats.csv.CsvFilesystemBatchITCase` which is based on a
hierarchy of tests across modules that need
[
https://issues.apache.org/jira/browse/FLINK-25993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622344#comment-17622344
]
Galen Warren commented on FLINK-25993:
--
[~chesnay] [~diagonalbishop]
I found your
[
https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29496:
--
Summary: Add Configuration for STS endpoint when using ASSUME_ROLE
credential provider (was:
[
https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29496:
--
Fix Version/s: (was: 1.15.3)
(was: 1.16.1)
> Unable to configure ST
RyanSkraba commented on PR #20805:
URL: https://github.com/apache/flink/pull/20805#issuecomment-1287136423
Rebased again and moved some modifications to their own separate commit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-29696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-29696.
--
Resolution: Not A Problem
This is intentional. One references the released helm chart, the oth
RyanSkraba commented on code in PR #20805:
URL: https://github.com/apache/flink/pull/20805#discussion_r1001917794
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnFailureTest.java:
##
@@ -18,17 +18,16 @@
package org.apach
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1001914891
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbWriteRequestType.java:
##
@@ -0,0 +1,35 @@
+/*
+
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1001870394
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkBuilder.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622318#comment-17622318
]
Matthias Pohl commented on FLINK-24119:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622315#comment-17622315
]
Yordan Pavlov commented on FLINK-16419:
---
Again, thanks for you input [~martijnviss
XComp commented on code in PR #20805:
URL: https://github.com/apache/flink/pull/20805#discussion_r1001878855
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnFailureTest.java:
##
@@ -18,17 +18,16 @@
package org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-29716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622313#comment-17622313
]
Chesnay Schepler commented on FLINK-29716:
--
The log4j jars are bundled separate
[
https://issues.apache.org/jira/browse/FLINK-29694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29694.
--
Fix Version/s: kubernetes-operator-1.3.0
Resolution: Fixed
merged to main f2c34abc466c9e33745a9
gyfora merged PR #405:
URL: https://github.com/apache/flink-kubernetes-operator/pull/405
--
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-29715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29715.
--
Resolution: Won't Fix
Turns out this is already part of the JobDetailsInfo
> Expose max_parallelism i
[
https://issues.apache.org/jira/browse/FLINK-29727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-29727:
--
Description:
Currently {{docker-enterypoint.sh}} always overrides {{jobmanager.rpc.add
[
https://issues.apache.org/jira/browse/FLINK-29727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-29727:
--
Description:
Currently {{docker-enterypoint.sh}} always overrides {{jobmanager.rpc.add
[
https://issues.apache.org/jira/browse/FLINK-29727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-29727:
--
Description:
Currently {{docker-enterypoint.sh}} always overrides {{jobmanager.rpc.add
Alexander Fedulov created FLINK-29727:
-
Summary: Fall back to flink-conf.yaml if no
JOB_MANAGER_RPC_ADDRESS is specified
Key: FLINK-29727
URL: https://issues.apache.org/jira/browse/FLINK-29727
Pro
Myasuka commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r1001703393
##
_posts/2022-10-15-1.16-announcement.md:
##
@@ -0,0 +1,402 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date: 2022-10-1
dannycranmer commented on code in PR #21129:
URL: https://github.com/apache/flink/pull/21129#discussion_r1001784454
##
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java:
##
@@ -209,6 +200,28 @@ public void refr
zentol commented on PR #20757:
URL: https://github.com/apache/flink/pull/20757#issuecomment-1286949316
```
Oct 18 11:05:28 [ERROR] Tests run: 4, Failures: 0, Errors: 1, Skipped: 0,
Time elapsed: 42.188 s <<< FAILURE! - in
org.apache.flink.architecture.rules.ApiAnnotationRules
Oct 18 1
zentol commented on PR #20757:
URL: https://github.com/apache/flink/pull/20757#issuecomment-1286942416
FYI: my fix has been merged; we're just waiting for the next japicmp release.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
flinkbot commented on PR #21129:
URL: https://github.com/apache/flink/pull/21129#issuecomment-1286907632
## CI report:
* 4395f880b56dbc67078c7c222d1f661e50ac8f02 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29713:
---
Fix Version/s: kubernetes-operator-1.3.0
> Kubernetes operator should restart failed jobs
>
[
https://issues.apache.org/jira/browse/FLINK-29713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29713:
--
Assignee: Peter Vary
> Kubernetes operator should restart failed jobs
> -
[
https://issues.apache.org/jira/browse/FLINK-29496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29496:
---
Labels: pull-request-available (was: )
> Unable to configure STS endpoint when using ASSUME
z3d1k opened a new pull request, #21129:
URL: https://github.com/apache/flink/pull/21129
## What is the purpose of the change
When using `ASSUME_ROLE` credentials provider option for AWS connectors, STS
endpoint is chosen by AWS SDK. In some use cases default endpoint may be
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1764#comment-1764
]
Jakub Partyka commented on FLINK-29692:
---
It would be really nice if Windowing TVF'
ferenc-csaky commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1001724180
##
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
dalongliu created FLINK-29726:
-
Summary: Supports hive stddev_samp function by native
implementation
Key: FLINK-29726
URL: https://issues.apache.org/jira/browse/FLINK-29726
Project: Flink
Issue
dalongliu created FLINK-29725:
-
Summary: Supports hive std function by native implementation
Key: FLINK-29725
URL: https://issues.apache.org/jira/browse/FLINK-29725
Project: Flink
Issue Type: Sub
dalongliu created FLINK-29724:
-
Summary: Supports hive last_value function by native implementation
Key: FLINK-29724
URL: https://issues.apache.org/jira/browse/FLINK-29724
Project: Flink
Issue Ty
pnowojski commented on PR #20033:
URL: https://github.com/apache/flink/pull/20033#issuecomment-1286876812
@zhougit86 , could you rebase the PR on the latest master?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1760#comment-1760
]
Martijn Visser commented on FLINK-16419:
I've synced offline with [~pnowojski] o
[
https://issues.apache.org/jira/browse/FLINK-29722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-29722:
--
Parent: FLINK-29717
Issue Type: Sub-task (was: Improvement)
> Supports hive max function by n
dalongliu created FLINK-29723:
-
Summary: Supports hive first_value function by native
implementation
Key: FLINK-29723
URL: https://issues.apache.org/jira/browse/FLINK-29723
Project: Flink
Issue
dalongliu created FLINK-29722:
-
Summary: Supports hive max function by native implementation
Key: FLINK-29722
URL: https://issues.apache.org/jira/browse/FLINK-29722
Project: Flink
Issue Type: Imp
dalongliu created FLINK-29721:
-
Summary: Supports hive min function by native implementation
Key: FLINK-29721
URL: https://issues.apache.org/jira/browse/FLINK-29721
Project: Flink
Issue Type: Sub
dalongliu created FLINK-29720:
-
Summary: Supports hive average function by native implemetatoin
Key: FLINK-29720
URL: https://issues.apache.org/jira/browse/FLINK-29720
Project: Flink
Issue Type:
dalongliu created FLINK-29719:
-
Summary: Supports hive count function by native implementation
Key: FLINK-29719
URL: https://issues.apache.org/jira/browse/FLINK-29719
Project: Flink
Issue Type: S
dalongliu created FLINK-29718:
-
Summary: Supports hive sum function by native implementation
Key: FLINK-29718
URL: https://issues.apache.org/jira/browse/FLINK-29718
Project: Flink
Issue Type: Sub
MartijnVisser commented on code in PR #21128:
URL: https://github.com/apache/flink/pull/21128#discussion_r1001704804
##
flink-connectors/flink-connector-hive/pom.xml:
##
@@ -39,6 +39,11 @@ under the License.
0.9.8
10.10.2.0
1.8.2
+
Myasuka commented on code in PR #20860:
URL: https://github.com/apache/flink/pull/20860#discussion_r1001688491
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandle.java:
##
@@ -148,7 +148,7 @@ public int read(byte[] b, int off, int len) thro
zentol commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1001671017
##
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 code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1001669758
##
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
ferenc-csaky commented on code in PR #21127:
URL: https://github.com/apache/flink/pull/21127#discussion_r1001664100
##
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
snuyanzin commented on PR #19870:
URL: https://github.com/apache/flink/pull/19870#issuecomment-1286796533
@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-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622190#comment-17622190
]
Durgesh Mishra commented on FLINK-29711:
[~martijnvisser] I am using the KafkaDi
[
https://issues.apache.org/jira/browse/FLINK-29717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-29717:
--
Description: The current Flink side of the Hive UDAF has a unified
encapsulation HiveGenericUDAF, and
gaborgsomogyi commented on PR #20206:
URL: https://github.com/apache/flink/pull/20206#issuecomment-1286762134
@JackWangCS
[This](https://github.com/apache/flink/pull/20206#discussion_r928147951) is the
last questionable part to be merged. Are you actively working on this?
--
This is an a
dalongliu created FLINK-29717:
-
Summary: Supports hive udaf such as sum/count by native
implementation
Key: FLINK-29717
URL: https://issues.apache.org/jira/browse/FLINK-29717
Project: Flink
Is
MOBIN-F closed pull request #290: [FLINK-29252]Support create table-store table
with 'connector'='table-store'
URL: https://github.com/apache/flink-table-store/pull/290
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-28157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28157:
---
Labels: pull-request-available (was: )
> Table Store Hive Reader supports Hive3
> -
JingsongLi commented on code in PR #329:
URL: https://github.com/apache/flink-table-store/pull/329#discussion_r1001612616
##
flink-table-store-hive/flink-table-store-hive-connector/src/test/java/org/apache/flink/table/store/hive/TableStoreHiveStorageHandlerITCase.java:
##
@@ -89
[
https://issues.apache.org/jira/browse/FLINK-28157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28157:
Assignee: Jingsong Lee
> Table Store Hive Reader supports Hive3
> ---
liyubin117 commented on PR #21116:
URL: https://github.com/apache/flink/pull/21116#issuecomment-1286729949
@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
mbalassi merged PR #20265:
URL: https://github.com/apache/flink/pull/20265
--
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
[
https://issues.apache.org/jira/browse/FLINK-29472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622145#comment-17622145
]
Chesnay Schepler commented on FLINK-29472:
--
I've created a
[repository|https:/
zentol commented on code in PR #21128:
URL: https://github.com/apache/flink/pull/21128#discussion_r1001551554
##
docs/content.zh/docs/deployment/filesystems/gcs.md:
##
@@ -68,7 +68,7 @@ You must include the following jars in Flink's `lib`
directory to connect Flink
```
-We
[
https://issues.apache.org/jira/browse/FLINK-29695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29695.
--
Fix Version/s: kubernetes-operator-1.3.0
Resolution: Fixed
merged to main 67d4cef5aadf05bb043c4
gyfora merged PR #406:
URL: https://github.com/apache/flink-kubernetes-operator/pull/406
--
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-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622133#comment-17622133
]
Martijn Visser commented on FLINK-29711:
Which Kafka sink are you using, FlinkKa
[
https://issues.apache.org/jira/browse/FLINK-29706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29706.
Resolution: Fixed
master: b8672a230a3d34e09fddc7f506e090910e2d202e
> Remove japicmp depen
zentol merged PR #21126:
URL: https://github.com/apache/flink/pull/21126
--
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
pnowojski commented on PR #20151:
URL: https://github.com/apache/flink/pull/20151#issuecomment-1286649770
> As I understand, you mean that multiple ChannelStateWriterImpl share the
same
> ChannelStateWriteRequestExecutorImpl. When
channel-state.number-of-tasks-share-file=5, each thread i
xintongsong commented on code in PR #21122:
URL: https://github.com/apache/flink/pull/21122#discussion_r1001497856
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##
@@ -72,8 +73,8 @@ public class HsMemoryDataManager
Alexis Sarda-Espinosa created FLINK-29716:
-
Summary: Separate slf4j jar in the lib folder from the distribution
Key: FLINK-29716
URL: https://issues.apache.org/jira/browse/FLINK-29716
Project:
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622124#comment-17622124
]
Durgesh Mishra edited comment on FLINK-29711 at 10/21/22 8:36 AM:
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622124#comment-17622124
]
Durgesh Mishra edited comment on FLINK-29711 at 10/21/22 8:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622124#comment-17622124
]
Durgesh Mishra commented on FLINK-29711:
Hello [~martijnvisser] We created one
[
https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622120#comment-17622120
]
Sergey Nuyanzin commented on FLINK-21239:
-
Thanks for assignment
yes i would tak
Gyula Fora created FLINK-29715:
--
Summary: Expose max_parallelism in JSON plan
Key: FLINK-29715
URL: https://issues.apache.org/jira/browse/FLINK-29715
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622115#comment-17622115
]
Yun Tang commented on FLINK-24932:
--
[~martijnvisser] We have built and released a packa
wanglijie95 commented on PR #20097:
URL: https://github.com/apache/flink/pull/20097#issuecomment-1286625764
I will review this in the next few weeks :)
--
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 g
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622105#comment-17622105
]
Martijn Visser commented on FLINK-29711:
Please add more information to the tick
echauchot commented on PR #21073:
URL: https://github.com/apache/flink/pull/21073#issuecomment-1286623220
> > I don't know Flink specifics on reviews but can a non-committer give
LGTM and then a committer simply merge ?
>
> > It could [...]
>
> Correction: No. The committer _mu
[
https://issues.apache.org/jira/browse/FLINK-29714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29714:
---
Labels: pull-request-available (was: )
> Merge TableWrite and TableCompact into one interfa
[
https://issues.apache.org/jira/browse/FLINK-29714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29714:
---
Assignee: Caizhi Weng
> Merge TableWrite and TableCompact into one interface
>
tsreaper opened a new pull request, #328:
URL: https://github.com/apache/flink-table-store/pull/328
To make sure that full compaction is triggered constantly for every written
bucket regardless of failure, we need to add `compact` interface to
`TableWrite` so that Flink sink operators can t
Caizhi Weng created FLINK-29714:
---
Summary: Merge TableWrite and TableCompact into one interface
Key: FLINK-29714
URL: https://issues.apache.org/jira/browse/FLINK-29714
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-29612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29612.
---
Resolution: Fixed
> Extract changelog files out of DataFileMeta#extraFiles
> ---
[
https://issues.apache.org/jira/browse/FLINK-29612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29612:
---
Assignee: Caizhi Weng
> Extract changelog files out of DataFileMeta#extraFiles
> --
Peter Vary created FLINK-29713:
--
Summary: Kubernetes operator should restart failed jobs
Key: FLINK-29713
URL: https://issues.apache.org/jira/browse/FLINK-29713
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
macdoor615 closed FLINK-29712.
--
Resolution: Fixed
upgraded client to Flink 1.16.0-rc2 from 1.16.0-rc1. Problem solved
> The same batc
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29711:
---
Component/s: Connectors / Kafka
(was: API / Core)
> Topic notification
[
https://issues.apache.org/jira/browse/FLINK-29712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622095#comment-17622095
]
macdoor615 commented on FLINK-29712:
@luoyuxia I upgraded client to Flink 1.16.0-rc2
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622093#comment-17622093
]
Martijn Visser commented on FLINK-24119:
[~renqs] There's still something wrong,
[
https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-29540:
-
Parent Issue: FLINK-21239 (was: FLINK-20873)
> SubQueryAntiJoinTest started to fail after Calci
1 - 100 of 118 matches
Mail list logo
