Matthias Pohl created FLINK-36292:
-
Summary:
SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out
Key: FLINK-36292
URL: https://issues.apache.org/jira/browse/FLINK-36292
Project:
1996fanrui opened a new pull request, #25344:
URL: https://github.com/apache/flink/pull/25344
## What is the purpose of the change
The link has 2 `https://` prefixes.
## Brief change log
[hotfix][doc] Fix the wrong link of materialized table
--
This is an autom
[
https://issues.apache.org/jira/browse/FLINK-36292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882276#comment-17882276
]
Matthias Pohl commented on FLINK-36292:
---
[~becket_qin] can you have a look at this
[
https://issues.apache.org/jira/browse/FLINK-35499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882277#comment-17882277
]
Matthias Pohl commented on FLINK-35499:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882278#comment-17882278
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
flinkbot commented on PR #25344:
URL: https://github.com/apache/flink/pull/25344#issuecomment-2354728877
## CI report:
* 8239f405e28f45a0143c4ae3df5b22ec84b5bb50 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Matthias Pohl created FLINK-36293:
-
Summary: RocksDBWriteBatchWrapperTest.testAsyncCancellation
Key: FLINK-36293
URL: https://issues.apache.org/jira/browse/FLINK-36293
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-36293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882283#comment-17882283
]
Matthias Pohl commented on FLINK-36293:
---
[~srichter] may you have a look at this?
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882285#comment-17882285
]
Matthias Pohl commented on FLINK-35810:
---
https://dev.azure.com/apache-flink/apache
Matthias Pohl created FLINK-36294:
-
Summary: table stage failed with general junit5 TestEngine failure
Key: FLINK-36294
URL: https://issues.apache.org/jira/browse/FLINK-36294
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882287#comment-17882287
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36290:
--
Priority: Blocker (was: Critical)
> OutOfMemoryError in connect test run
> --
[
https://issues.apache.org/jira/browse/FLINK-36291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882288#comment-17882288
]
Matthias Pohl commented on FLINK-36291:
---
https://dev.azure.com/apache-flink/apache
Matthias Pohl created FLINK-36295:
-
Summary: AdaptiveSchedulerClusterITCase.
testCheckpointStatsPersistedAcrossRescale failed with
Key: FLINK-36295
URL: https://issues.apache.org/jira/browse/FLINK-36295
[
https://issues.apache.org/jira/browse/FLINK-36295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882290#comment-17882290
]
Matthias Pohl commented on FLINK-36295:
---
This might be related to the issue FLINK-
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882291#comment-17882291
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
Abhi Gupta created FLINK-36296:
--
Summary: Add incremental shard discovery for DDB Streams source
Key: FLINK-36296
URL: https://issues.apache.org/jira/browse/FLINK-36296
Project: Flink
Issue Type
gguptp opened a new pull request, #166:
URL: https://github.com/apache/flink-connector-aws/pull/166
## Purpose of the change
Adds incremental shard discovery for DDB Streams source. Since full
describestream discovery can take a longer time, having incremental shard
d
[
https://issues.apache.org/jira/browse/FLINK-36296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36296:
---
Labels: pull-request-available (was: )
> Add incremental shard discovery for DDB Streams so
hlteoh37 closed pull request #150: [FLINK-31922][Connectors/AWS] Port over
Kinesis Client configurations for retry and backoff
URL: https://github.com/apache/flink-connector-aws/pull/150
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
hlteoh37 commented on PR #150:
URL:
https://github.com/apache/flink-connector-aws/pull/150#issuecomment-2354810490
Closed as replaced by this PR
https://github.com/apache/flink-connector-aws/pull/165
--
This is an automated message from the Apache Git Service.
To respond to the message,
hlteoh37 commented on code in PR #165:
URL:
https://github.com/apache/flink-connector-aws/pull/165#discussion_r1762587467
##
flink-connector-aws-base/pom.xml:
##
@@ -87,6 +87,12 @@ under the License.
test
+
+software.amazon.awssdk
+
hlteoh37 commented on code in PR #165:
URL:
https://github.com/apache/flink-connector-aws/pull/165#discussion_r1762587971
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache S
hlteoh37 commented on code in PR #165:
URL:
https://github.com/apache/flink-connector-aws/pull/165#discussion_r1762592327
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java:
#
[
https://issues.apache.org/jira/browse/FLINK-36296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-36296:
---
Assignee: Abhi Gupta
> Add incremental shard discovery for DDB Streams source
> ---
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762594562
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java:
##
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762602286
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java:
##
@
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762608231
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -185,7
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762610714
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -185,7 +1
vahmed-hamdy commented on code in PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#discussion_r1762615947
##
flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762616322
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762617573
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762621737
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6 +2
vahmed-hamdy commented on code in PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#discussion_r1762620710
##
flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Lice
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762623393
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6 +2
hackergin commented on PR #25344:
URL: https://github.com/apache/flink/pull/25344#issuecomment-2354868964
@1996fanrui There is similar pr https://github.com/apache/flink/pull/25315
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
1996fanrui closed pull request #25344: [hotfix][doc] Fix the wrong link of
materialized table
URL: https://github.com/apache/flink/pull/25344
--
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 spec
1996fanrui commented on PR #25344:
URL: https://github.com/apache/flink/pull/25344#issuecomment-2354875613
Thanks @hackergin for pointing it out. Let me close this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
vahmed-hamdy commented on PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#issuecomment-2354877068
@hlteoh37 Thanks for the review, Addressed now!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-36077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882313#comment-17882313
]
Ahmed Hamdy commented on FLINK-36077:
-
[~snuyanzin] Would you be able to review this
[
https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882312#comment-17882312
]
Matthias Pohl commented on FLINK-36279:
---
older CI runs whichdidn't include the fix
[
https://issues.apache.org/jira/browse/FLINK-36297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36297:
--
Labels: test-stability (was: )
> SIGSEGV caused CI failure
> -
>
>
Matthias Pohl created FLINK-36297:
-
Summary: SIGSEGV caused CI failure
Key: FLINK-36297
URL: https://issues.apache.org/jira/browse/FLINK-36297
Project: Flink
Issue Type: Bug
Compone
[
https://issues.apache.org/jira/browse/FLINK-36297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882315#comment-17882315
]
Matthias Pohl commented on FLINK-36297:
---
[~roman] [~srichter] can you have look at
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882316#comment-17882316
]
Matthias Pohl commented on FLINK-18476:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36166:
--
Priority: Critical (was: Major)
> testJoinDisorderChangeLog failed on AZP
> -
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36166:
--
Affects Version/s: 2.0-preview
(was: 2.0.0)
> testJoinDisorderChang
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882317#comment-17882317
]
Matthias Pohl commented on FLINK-36166:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36166:
--
Component/s: Table SQL / Planner
> testJoinDisorderChangeLog failed on AZP
> -
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36166:
--
Labels: test-stability (was: )
> testJoinDisorderChangeLog failed on AZP
> --
Matthias Pohl created FLINK-36298:
-
Summary: NullPointerException in Calcite causes a PyFlink test
failure
Key: FLINK-36298
URL: https://issues.apache.org/jira/browse/FLINK-36298
Project: Flink
Matthias Pohl created FLINK-36299:
-
Summary: AdaptiveSchedulerTest.testStatusMetrics times out
Key: FLINK-36299
URL: https://issues.apache.org/jira/browse/FLINK-36299
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-36299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882321#comment-17882321
]
Matthias Pohl commented on FLINK-36299:
---
Might be related to FLINK-36279
> Adapti
Matthias Pohl created FLINK-36300:
-
Summary:
TableEnvHiveConnectorITCase.testDateTimestampPartitionColumns times out
Key: FLINK-36300
URL: https://issues.apache.org/jira/browse/FLINK-36300
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882328#comment-17882328
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882329#comment-17882329
]
Matthias Pohl commented on FLINK-35810:
---
https://dev.azure.com/apache-flink/apache
Matthias Pohl created FLINK-36301:
-
Summary: TPC-H end-to-end test fails due to TimeoutException
Key: FLINK-36301
URL: https://issues.apache.org/jira/browse/FLINK-36301
Project: Flink
Issue T
AHeise commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1762809895
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java:
##
@@ -369,6 +370,38 @@ public void testConsumingTopi
AHeise commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2355026088
Changes all LGTM. I'm running CI and merge when it's green.
Thank you very much for this much needed fix!
--
This is an automated message from the Apache Git Service.
To
davidradl commented on code in PR #25343:
URL: https://github.com/apache/flink/pull/25343#discussion_r1762819715
##
docs/content/docs/connectors/table/hive/overview.md:
##
@@ -237,7 +237,7 @@ hive_catalog = HiveCatalog(catalog_name, default_database,
hive_conf_dir)
t_env.regis
davidradl commented on code in PR #25336:
URL: https://github.com/apache/flink/pull/25336#discussion_r1762908443
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1971,7 +1967,7 @@ private TypeInformation
privateGetForClass(
}
davidradl commented on code in PR #25275:
URL: https://github.com/apache/flink/pull/25275#discussion_r1762912702
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/ArrayAggr.java:
##
@@ -0,0 +1,81 @@
+package org.apache.flink.table.utils;
+
+import org.
[
https://issues.apache.org/jira/browse/FLINK-36272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-36272.
-
Resolution: Duplicate
> YarnFileStageTestS3ITCase fails on master
>
[
https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882312#comment-17882312
]
Matthias Pohl edited comment on FLINK-36279 at 9/17/24 11:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882375#comment-17882375
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882376#comment-17882376
]
Matthias Pohl commented on FLINK-36166:
---
https://dev.azure.com/apache-flink/apache
fapaul commented on code in PR #25292:
URL: https://github.com/apache/flink/pull/25292#discussion_r1763062367
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/AbstractStreamingWriter.java:
##
@@ -123,6 +142,27 @@ public void bu
TomiFG commented on code in PR #25343:
URL: https://github.com/apache/flink/pull/25343#discussion_r1763163971
##
docs/content/docs/connectors/table/hive/overview.md:
##
@@ -237,7 +237,7 @@ hive_catalog = HiveCatalog(catalog_name, default_database,
hive_conf_dir)
t_env.register
[
https://issues.apache.org/jira/browse/FLINK-36291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882389#comment-17882389
]
Matthias Pohl commented on FLINK-36291:
---
Another Hive-related OOM:
https://dev.azu
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882393#comment-17882393
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-35004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882394#comment-17882394
]
Matthias Pohl commented on FLINK-35004:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882312#comment-17882312
]
Matthias Pohl edited comment on FLINK-36279 at 9/17/24 1:09 PM:
--
AHeise commented on code in PR #25292:
URL: https://github.com/apache/flink/pull/25292#discussion_r1763232011
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/AbstractStreamingWriter.java:
##
@@ -123,6 +142,27 @@ public void bu
AHeise commented on code in PR #25292:
URL: https://github.com/apache/flink/pull/25292#discussion_r1763233550
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/AbstractStreamingWriter.java:
##
@@ -149,15 +190,20 @@ public void p
[
https://issues.apache.org/jira/browse/FLINK-36301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882404#comment-17882404
]
Matthias Pohl commented on FLINK-36301:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882406#comment-17882406
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882407#comment-17882407
]
Matthias Pohl commented on FLINK-36297:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882408#comment-17882408
]
Matthias Pohl commented on FLINK-36291:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882312#comment-17882312
]
Matthias Pohl edited comment on FLINK-36279 at 9/17/24 1:28 PM:
--
mbalassi commented on code in PR #25342:
URL: https://github.com/apache/flink/pull/25342#discussion_r1763256681
##
docs/content/docs/deployment/java_compatibility.md:
##
@@ -50,7 +50,8 @@ The following Flink features have not been tested with Java
11:
## Java 17
-Experimen
Matthias Pohl created FLINK-36302:
-
Summary: FileSourceTextLinesITCase timed out
Key: FLINK-36302
URL: https://issues.apache.org/jira/browse/FLINK-36302
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-36302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36302:
--
Description:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=62064&view
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36167:
--
Affects Version/s: 2.0-preview
(was: 2.0.0)
> testSinkDisorderChang
AHeise merged PR #100:
URL: https://github.com/apache/flink-connector-kafka/pull/100
--
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...@
boring-cyborg[bot] commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2355822850
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882409#comment-17882409
]
Matthias Pohl commented on FLINK-36167:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36167:
--
Priority: Critical (was: Major)
> testSinkDisorderChangeLog failed on AZP
> -
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-34470.
-
Fix Version/s: kafka-3.3.0
Release Note: Merged as 122a743
Resolution: Fixed
> Trans
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882410#comment-17882410
]
Matthias Pohl commented on FLINK-35810:
---
https://dev.azure.com/apache-flink/apache
mbalassi commented on PR #25342:
URL: https://github.com/apache/flink/pull/25342#issuecomment-2355827442
> Thanks. Overall, I think the tone is a bit too much like a blog post, and
a not enough like a documentation that you use as a reference.
Thanks, updated accordingly.
--
This i
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Description:
||Module||Contributor||IsDone||
|flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]|fal
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Fix Version/s: 2.0-preview
> Remove deprecated API for 2.0-preview
> ---
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Affects Version/s: 2.0-preview
> Remove deprecated API for 2.0-preview
> ---
Weijie Guo created FLINK-36306:
--
Summary: Remove deprecated API for 2.0-preview
Key: FLINK-36306
URL: https://issues.apache.org/jira/browse/FLINK-36306
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Description:
||Module||Contributor||IsDone||
|Col A1|Col A2|false|
|Col A1|Col A2|false|
|Col A1|Col
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Description:
|Module||Contributor||IsDone||
|Col A1|Col A2|false|
> Remove deprecated API for 2.0
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Description:
||Module||Contributor||IsDone||
|flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]|fal
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Description:
||Module||Contributor||IsDone||
|flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong]|fal
1996fanrui commented on code in PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1764419949
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -383,23 +403,68 @@ protected static int scale(
//
[
https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36306:
---
Priority: Blocker (was: Major)
> Remove deprecated API for 2.0-preview
> --
1 - 100 of 211 matches
Mail list logo
