[
https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601678#comment-17601678
]
dalongliu commented on FLINK-29090:
---
Thanks for report, I will take a look.
> Fix the
[
https://issues.apache.org/jira/browse/FLINK-29045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29045:
-
Summary: Optimize error message in Flink SQL Client and Gateway when try to
use Hive Dialect (was: Opti
[
https://issues.apache.org/jira/browse/FLINK-29218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601677#comment-17601677
]
dalongliu commented on FLINK-29218:
---
Thanks for report it, I will take a look.
> ADD
SwimSweet commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1240296559
I create a new pr based on master.
Please help take a look when you are free @wangyang0918 @Aitozi . thx.
--
This is an automated message from the Apache Git Service.
To respond to
flinkbot commented on PR #20785:
URL: https://github.com/apache/flink/pull/20785#issuecomment-1240289387
## CI report:
* a11851b92b0a2f9d9cdfbc326a8b9878d3bcbe0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu commented on PR #20630:
URL: https://github.com/apache/flink/pull/20630#issuecomment-1240288252
@wuchong Thanks for review, I've updated 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
fsk119 opened a new pull request, #20785:
URL: https://github.com/apache/flink/pull/20785
Cherry pick the fix #20714 to the release-1.16
--
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 specif
[
https://issues.apache.org/jira/browse/FLINK-29118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29118:
-
Assignee: yuzelin
> Remove default_catalog in the HiveServer2 Endpoint
> --
[
https://issues.apache.org/jira/browse/FLINK-29118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29118.
-
Resolution: Fixed
Merged into master: 833e7ffbb5f075d2014dfaec547b6987d59bc89f
> Remove default
[
https://issues.apache.org/jira/browse/FLINK-29184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29184:
-
Assignee: Shengkai Fang
> SQL Gateway should remove the downloaded resources
>
[
https://issues.apache.org/jira/browse/FLINK-29184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29184.
-
Resolution: Fixed
Merged into master: bd1d97391be408885dc8df35c8a83770fe7e0c38
> SQL Gateway sh
fsk119 closed pull request #20714: [FLINK-29118][sql-gateway] Remove
'default_catalog' in the HiveServer2 Endpoint
URL: https://github.com/apache/flink/pull/20714
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601658#comment-17601658
]
tartarus edited comment on FLINK-29219 at 9/8/22 6:21 AM:
--
[~re
[
https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601658#comment-17601658
]
tartarus commented on FLINK-29219:
--
[~renqs] Thank you very much for your feedback on
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601631#comment-17601631
]
jackylau edited comment on FLINK-29227 at 9/8/22 6:12 AM:
--
hi [
[
https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601648#comment-17601648
]
Xingbo Huang commented on FLINK-29217:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601650#comment-17601650
]
Xingbo Huang commented on FLINK-29153:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601649#comment-17601649
]
Xingbo Huang commented on FLINK-29153:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601645#comment-17601645
]
Xingbo Huang commented on FLINK-29153:
--
https://dev.azure.com/apache-flink/apache-f
flinkbot commented on PR #20784:
URL: https://github.com/apache/flink/pull/20784#issuecomment-1240250987
## CI report:
* 31668c696fe0c57a33e070681f7b582546c7b31d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29227:
---
Labels: pull-request-available (was: )
> shoud package disruptor(com.lmax) to flink lib for
liuyongvs opened a new pull request, #20784:
URL: https://github.com/apache/flink/pull/20784
## What is the purpose of the change
*package disruptor for log4j async logger*
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-29227:
-
Description:
when i develop xxConnector which dependecncy like this
xxconnector -> log4j2 -> Asyn
[
https://issues.apache.org/jira/browse/FLINK-29227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601631#comment-17601631
]
jackylau commented on FLINK-29227:
--
hi [~tiwalter] so i I propose to add disruptor t
jackylau created FLINK-29227:
Summary: shoud package disruptor(com.lmax) to flink lib for aync
logger when xxconnector using it.
Key: FLINK-29227
URL: https://issues.apache.org/jira/browse/FLINK-29227
Pro
[
https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601628#comment-17601628
]
Yu Li edited comment on FLINK-28910 at 9/8/22 4:47 AM:
---
>From my p
[
https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601628#comment-17601628
]
Yu Li commented on FLINK-28910:
---
>From my point of view, a better solution is to facilitat
[
https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601623#comment-17601623
]
dalongliu commented on FLINK-29219:
---
cc [~tartarus]
> CREATE TABLE AS statement bloc
[
https://issues.apache.org/jira/browse/FLINK-29200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601618#comment-17601618
]
Yang Wang commented on FLINK-29200:
---
I hesitate to do this in the production code. By
[
https://issues.apache.org/jira/browse/FLINK-29045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29045:
-
Summary: Optimize error message in Flink SQL Client/HiveServer2 Endpoint
when try to switch Hive Dialect
flinkbot commented on PR #20783:
URL: https://github.com/apache/flink/pull/20783#issuecomment-1240175425
## CI report:
* 597f4b58bff5f151a9dd5fabf6feba1019a07f7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wsad4782568 opened a new pull request, #20783:
URL: https://github.com/apache/flink/pull/20783
## 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 the
[
https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-28860.
---
Resolution: Fixed
> CacheITCase.testBatchProduceCacheStreamConsume failed
>
[
https://issues.apache.org/jira/browse/FLINK-28860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601606#comment-17601606
]
Yun Gao commented on FLINK-28860:
-
Merged on master via
208f08b406a7fd48890cda16d317a30
gaoyunhaii closed pull request #20534: [FLINK-28860] Fix CacheITCase
URL: https://github.com/apache/flink/pull/20534
--
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 unsubscr
gaoyunhaii commented on PR #20534:
URL: https://github.com/apache/flink/pull/20534#issuecomment-1240171126
Merged on master and 1.16, closed.
--
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
Jingsong Lee created FLINK-29226:
Summary: Throw exception for streaming insert overwrite
Key: FLINK-29226
URL: https://issues.apache.org/jira/browse/FLINK-29226
Project: Flink
Issue Type: Im
flinkbot commented on PR #20782:
URL: https://github.com/apache/flink/pull/20782#issuecomment-1240156705
## CI report:
* f72009b5a81d947d2403d3f67b32cff1cda36868 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29195:
---
Labels: pull-request-available (was: )
> Expose lastCheckpointId metric
>
chenyuzhi459 opened a new pull request, #20782:
URL: https://github.com/apache/flink/pull/20782
## What is the purpose of the change
*Expose the lastCheckpointId metric.*
## Brief change log
- *Register `LatestCompletedCheckpointIdGauge` named "lastCheckpoi
pltbkd commented on PR #20733:
URL: https://github.com/apache/flink/pull/20733#issuecomment-1240153997
@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.
T
lsyldliu commented on code in PR #20630:
URL: https://github.com/apache/flink/pull/20630#discussion_r965450158
##
docs/content/docs/dev/table/sql/jar.md:
##
@@ -68,22 +70,24 @@ Flink SQL> REMOVE JAR '/path/hello.jar';
ADD JAR '.jar'
```
-Currently it only supports to add the
lsyldliu commented on code in PR #20630:
URL: https://github.com/apache/flink/pull/20630#discussion_r965450158
##
docs/content/docs/dev/table/sql/jar.md:
##
@@ -68,22 +70,24 @@ Flink SQL> REMOVE JAR '/path/hello.jar';
ADD JAR '.jar'
```
-Currently it only supports to add the
flinkbot commented on PR #20781:
URL: https://github.com/apache/flink/pull/20781#issuecomment-1240147430
## CI report:
* 186d378879995bdb53e715fe2aa4aaa570df8824 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20780:
URL: https://github.com/apache/flink/pull/20780#issuecomment-1240147370
## CI report:
* 31d6a24336e03e7716f456af9b7af255d2597d6a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yunfengzhou-hub opened a new pull request, #20781:
URL: https://github.com/apache/flink/pull/20781
## What is the purpose of the change
#20752 and #20754 have added test cases to verify that the operator
coordinator can work correctly in case of concurrent checkpoints. However, when
[
https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29217:
---
Labels: pull-request-available test-stability (was: test-stability)
> CoordinatorEventsToSt
yunfengzhou-hub opened a new pull request, #20780:
URL: https://github.com/apache/flink/pull/20780
## What is the purpose of the change
#20752 and #20754 have added test cases to verify that the operator
coordinator can work correctly in case of concurrent checkpoints. However, when
lsyldliu commented on code in PR #20630:
URL: https://github.com/apache/flink/pull/20630#discussion_r965426745
##
docs/content/docs/dev/table/sql/jar.md:
##
@@ -51,10 +48,15 @@ The following examples show how to run `JAR` statements in
[SQL CLI]({{< ref "do
{{< tab "SQL CLI" >
[
https://issues.apache.org/jira/browse/FLINK-29225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29225:
Description:
Currently if the interval between the arrival of the delete message and the
insert/u
[
https://issues.apache.org/jira/browse/FLINK-29225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29225:
Description:
Currently if the interval between the arrival of the delete message and the
insert/u
[
https://issues.apache.org/jira/browse/FLINK-29191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29191:
-
Description:
When using Hive dialect, we can use
{code:java}
set k1=v1;
{code}
to set variable to Flink
[
https://issues.apache.org/jira/browse/FLINK-29225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29225:
Fix Version/s: (was: 1.16.0)
(was: 1.14.6)
(was:
[
https://issues.apache.org/jira/browse/FLINK-28896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang resolved FLINK-28896.
--
Resolution: Fixed
> [Umbrella] Test Flink Release 1.16
> --
>
[
https://issues.apache.org/jira/browse/FLINK-29225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29225:
Description:
Currently if the interval between the arrival of the delete message and the
insert/u
lincoln lee created FLINK-29225:
---
Summary: Delete message incorrectly ignored in
SinkUpsertMaterializer
Key: FLINK-29225
URL: https://issues.apache.org/jira/browse/FLINK-29225
Project: Flink
I
lsyldliu commented on code in PR #20630:
URL: https://github.com/apache/flink/pull/20630#discussion_r965426745
##
docs/content/docs/dev/table/sql/jar.md:
##
@@ -51,10 +48,15 @@ The following examples show how to run `JAR` statements in
[SQL CLI]({{< ref "do
{{< tab "SQL CLI" >
[
https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601576#comment-17601576
]
Lu commented on FLINK-29183:
[~Weijie Guo] I know what do u mean. But let's look at the ori
luoyuxia commented on PR #20696:
URL: https://github.com/apache/flink/pull/20696#issuecomment-1240113219
@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.
wenbingshen commented on PR #20765:
URL: https://github.com/apache/flink/pull/20765#issuecomment-1240090035
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-29224.
-
Fix Version/s: 1.16.0
Resolution: Fixed
> flink-mirror does not pick up the new release branch 1.
[
https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601539#comment-17601539
]
Jing Ge commented on FLINK-29224:
-
Fixed. It seems there was some issues with git fetch.
Jing Ge created FLINK-29224:
---
Summary: flink-mirror does not pick up the new release branch 1.16
Key: FLINK-29224
URL: https://issues.apache.org/jira/browse/FLINK-29224
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-29224:
---
Assignee: Jing Ge
> flink-mirror does not pick up the new release branch 1.16
> ---
SwimSweet commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1239918732
@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-29194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-29194:
--
Assignee: Matyas Orhidi
> Add Logging for ResourceListener
>
[
https://issues.apache.org/jira/browse/FLINK-29194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-29194.
--
Resolution: Fixed
[{{b7fc9b7}}|https://github.com/apache/flink-kubernetes-operator/commit/b7fc
mbalassi merged PR #363:
URL: https://github.com/apache/flink-kubernetes-operator/pull/363
--
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
[
https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peleg Tsadok resolved FLINK-28653.
--
Resolution: Feedback Received
> State Schema Evolution does not work - Flink defaults to Kryo
[
https://issues.apache.org/jira/browse/FLINK-29223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29223:
--
Summary: Missing info output for when filtering JobGraphs based on their
persisted JobResult
[
https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601454#comment-17601454
]
Peleg Tsadok commented on FLINK-28653:
--
[~chesnay] Thanks you so much!
It finally
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965123891
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965121095
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/SourceReaderFactory.java:
##
@@ -27,9 +27,17 @@
/**
* A factory for creating source reader inst
flinkbot commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1239675137
## CI report:
* a239844f4e21385374b370e28587fc2d51f8f8c9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SwimSweet commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1239672190
@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.
SwimSweet opened a new pull request, #20779:
URL: https://github.com/apache/flink/pull/20779
## What is the purpose of the change
Flink On Kerbernetes Native K8s Application Mode supports fetching jar from
DFS schema(S3, OSS, HDFS, etc.).
## Brief change log
- Fetch jar fr
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r965066688
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherPauseResumeSplitReaderTest.java:
##
@@ -0,0 +1,311 @
gaoyunhaii commented on PR #20733:
URL: https://github.com/apache/flink/pull/20733#issuecomment-1239624491
@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
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965058470
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965053647
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReaderBase.java:
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software F
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965053647
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/IteratorSourceReaderBase.java:
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software F
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965008089
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation (A
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965003553
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation (A
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r963654710
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation (A
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964999081
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/SourceReaderFactory.java:
##
@@ -27,9 +27,17 @@
/**
* A factory for creating source reader instan
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r963472820
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GeneratingIteratorSourceReader.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Softwar
zentol commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964996882
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReader.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Software Found
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r964978381
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -562,11 +580,62 @@ private void
updateMaxDesiredWatermark(Watermar
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r952493768
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcher.java:
##
@@ -171,17 +230,54 @@ void runOnce() {
[
https://issues.apache.org/jira/browse/FLINK-29223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29223:
--
Description:
We have the case where we don't see (in the logs) a job being registered in the
[
https://issues.apache.org/jira/browse/FLINK-29223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29223:
--
Affects Version/s: 1.15.2
1.16.0
1.17.0
> Missin
[
https://issues.apache.org/jira/browse/FLINK-29223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29223:
--
Labels: starter (was: )
> Missing debug output for when filtering JobGraphs based on their pe
Matthias Pohl created FLINK-29223:
-
Summary: Missing debug output for when filtering JobGraphs based
on their persisted JobResult
Key: FLINK-29223
URL: https://issues.apache.org/jira/browse/FLINK-29223
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r964964213
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -559,14 +577,67 @@ private void createOutputForSplits(List
newSpli
gaborgsomogyi commented on code in PR #364:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/364#discussion_r964963833
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/fs/FileSystemWatchService.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licens
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r964907964
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -562,11 +580,62 @@ private void
updateMaxDesiredWatermark(Watermar
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964946446
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-29210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29210.
--
Fix Version/s: 1.17.0
Resolution: Fixed
Fixed in master: 442ab0ce6cbba4e276659db765846f
MartijnVisser merged PR #20766:
URL: https://github.com/apache/flink/pull/20766
--
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
[
https://issues.apache.org/jira/browse/FLINK-28411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-28411:
--
Fix Version/s: (was: 1.16.0)
(was: 1.15.3)
> OperatorCoordinator ex
1 - 100 of 177 matches
Mail list logo
