gaborgsomogyi commented on PR #364:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/364#issuecomment-1238987557
@mbalassi @morhidi I've considered the doc in-depth and I think better to do
it in separate jira since there is no doc for the webhook in general.
--
This is an a
SteNicholas commented on code in PR #364:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/364#discussion_r964458293
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/fs/FileSystemWatchService.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licensed
gaoyunhaii commented on code in PR #20534:
URL: https://github.com/apache/flink/pull/20534#discussion_r964342154
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTracker.java:
##
@@ -57,15 +59,32 @@ void stopTrackingAndReleasePartiti
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964462819
##
docs/content/docs/dev/table/hiveCompatibility/hiveDialect/overview.md:
##
@@ -0,0 +1,97 @@
+---
+title: "Overview"
+weight: 1
+type: docs
+aliases:
+- /dev/table/hiv
[
https://issues.apache.org/jira/browse/FLINK-29216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601167#comment-17601167
]
Spongebob commented on FLINK-29216:
---
Thanks [~lincoln.86xy] , it apparents normal when
[
https://issues.apache.org/jira/browse/FLINK-28461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601169#comment-17601169
]
Xingbo Huang commented on FLINK-28461:
--
Thanks [~bzhaoop] . I have assigned it to y
[
https://issues.apache.org/jira/browse/FLINK-28461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-28461:
Assignee: bo zhao
> PyFlink Table should add get_resolved_schema method
> ---
[
https://issues.apache.org/jira/browse/FLINK-27929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601170#comment-17601170
]
Xingbo Huang commented on FLINK-27929:
--
Thanks [~bzhaoop] . I have assigned it to y
[
https://issues.apache.org/jira/browse/FLINK-27929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-27929:
Assignee: bo zhao
> Drop support for python 3.6
> ---
>
>
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964480454
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/overview.md:
##
@@ -0,0 +1,163 @@
+---
+title: "Overview"
+weight: 1
+type: docs
+aliases:
+- /d
JingGe commented on PR #20235:
URL: https://github.com/apache/flink/pull/20235#issuecomment-1239017424
@PatrickRen Would you like to merge this PR? Thanks!
--
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
swuferhong opened a new pull request, #20777:
URL: https://github.com/apache/flink/pull/20777
## What is the purpose of the change
For sql statement `select * from c1 = 1 and c2 = true; `, if `c2` is varchar
type, filter condition `c2 = true` will be incorrectly simpl
[
https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27402:
---
Labels: pull-request-available (was: )
> Unexpected boolean expression simplification for
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964489186
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/overview.md:
##
@@ -0,0 +1,163 @@
+---
+title: "Overview"
+weight: 1
+type: docs
+aliases:
+- /d
SubNader commented on PR #15491:
URL: https://github.com/apache/flink/pull/15491#issuecomment-1239021381
@xinbinhuang this would be very nice to have. Let me know if I can help.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot commented on PR #20777:
URL: https://github.com/apache/flink/pull/20777#issuecomment-1239025583
## CI report:
* 265511cf0c7401eb608ef3f619399c886b2f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601175#comment-17601175
]
Qingsheng Ren commented on FLINK-29069:
---
# Used CTAS syntax to create a Kafka sink
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964494659
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/sort-cluster-distribute-by.md:
##
@@ -0,0 +1,94 @@
+---
+title: "Sort/Cluster/Distributed By"
+w
gaoyunhaii commented on code in PR #20235:
URL: https://github.com/apache/flink/pull/20235#discussion_r939799891
##
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/dialect/sqlserver/SqlServerTableSinkITCase.java:
##
@@ -0,0 +1,492 @@
+/*
+ * L
gaoyunhaii commented on PR #20235:
URL: https://github.com/apache/flink/pull/20235#issuecomment-1239030600
Thanks @qingwei91 for the PR and everyone for the reviewing and tracking! I
could help merging the PR~
--
This is an automated message from the Apache Git Service.
To respond to the
Qingsheng Ren created FLINK-29218:
-
Summary: ADD JAR syntax could not work with Hive catalog in SQL
client
Key: FLINK-29218
URL: https://issues.apache.org/jira/browse/FLINK-29218
Project: Flink
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964505352
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/group-by.md:
##
@@ -0,0 +1,129 @@
+---
+title: "Group By"
+weight: 3
+type: docs
+---
+
+
+# Gro
Qingsheng Ren created FLINK-29219:
-
Summary: CREATE TABLE AS statement blocks SQL client's execution
Key: FLINK-29219
URL: https://issues.apache.org/jira/browse/FLINK-29219
Project: Flink
Iss
gaoyunhaii closed pull request #20235: [Flink-14101][Connectors][Jdbc] SQL
Server dialect
URL: https://github.com/apache/flink/pull/20235
--
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
gaoyunhaii commented on PR #20235:
URL: https://github.com/apache/flink/pull/20235#issuecomment-1239055514
Merge on master.
--
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.
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964524728
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/join.md:
##
@@ -0,0 +1,105 @@
+---
+title: "Join"
+weight: 4
+type: docs
+---
+
+
+# Join
+
+##
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601192#comment-17601192
]
Yun Gao commented on FLINK-14101:
-
Merge on master via a8ca381c57788cd1a1527e4ebdc19bdbc
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-14101.
---
Fix Version/s: 1.17.0
Resolution: Fixed
> Introduce SqlServerDialect
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reopened FLINK-14101:
-
> Introduce SqlServerDialect
> --
>
> Key: FLINK-14101
>
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-14101.
---
Release Note: This issue introduce the support of Microsoft SQLSever
dialect in the jdbc connector.
R
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-14101:
Release Note: This issue introduces the support of Microsoft SQLSever
dialect in the jdbc connector. (wa
[
https://issues.apache.org/jira/browse/FLINK-29069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-29069.
-
Resolution: Resolved
> Release Testing: Verify FLIP-218 Create table as select syntax
>
MartijnVisser commented on PR #20640:
URL: https://github.com/apache/flink/pull/20640#issuecomment-1239069610
@liuzhuang2017 Can you please fetch all upstream commits, rebase and push
again? Right now all tests fail which make it not possible to merge.
Something like:
- `git fetch
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964572857
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/sub-queries.md:
##
@@ -0,0 +1,69 @@
+---
+title: "Sub-Queries"
+weight: 8
+type: docs
+---
+
+
+
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964579483
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/Queries/transform.md:
##
@@ -0,0 +1,129 @@
+---
+title: "Transform Clause"
+weight: 10
+type: docs
+---
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964584086
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/create.md:
##
@@ -0,0 +1,247 @@
+---
+title: "CREATE Statements"
+weight: 2
+type: docs
+aliases:
+- /de
Xingbo Huang created FLINK-29220:
Summary: Skip ci tests on docs-only-PRs
Key: FLINK-29220
URL: https://issues.apache.org/jira/browse/FLINK-29220
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29220:
Assignee: Xingbo Huang
> Skip ci tests on docs-only-PRs
> --
xuyang created FLINK-29221:
--
Summary: Adding join hint in sql may cause imcompatible state
Key: FLINK-29221
URL: https://issues.apache.org/jira/browse/FLINK-29221
Project: Flink
Issue Type: Improvem
snuyanzin commented on PR #19782:
URL: https://github.com/apache/flink/pull/19782#issuecomment-1239155381
Probably also makes sense to add this to
`docs/content/docs/flinkDev/ide_setup.md`
```
7. Set up maven home path to maven-wrapper.
Go to "File" → "Settings" → "Build,Executi
snuyanzin commented on PR #20753:
URL: https://github.com/apache/flink/pull/20753#issuecomment-1239156355
closed in favor of https://github.com/apache/flink/pull/19782
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
snuyanzin closed pull request #20753: [FLINK-29201][docs] Add setting up of
maven-wrapper
URL: https://github.com/apache/flink/pull/20753
--
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-29201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29201:
---
Labels: pull-request-available (was: )
> Some tests from flink-sql-client, flink-connector-
[
https://issues.apache.org/jira/browse/FLINK-29197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-29197.
---
Release Note: closed in favor of
https://issues.apache.org/jira/browse/FLINK-27640
Res
[
https://issues.apache.org/jira/browse/FLINK-29201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601222#comment-17601222
]
Sergey Nuyanzin commented on FLINK-29201:
-
Thanks for the feedback
modified .m2
[
https://issues.apache.org/jira/browse/FLINK-29201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-29201.
---
Resolution: Duplicate
> Some tests from flink-sql-client, flink-connector-hive are not compi
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reopened FLINK-27917:
--
> PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetTo
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601243#comment-17601243
]
Xingbo Huang commented on FLINK-27917:
--
[~syhily] Thanks a lot for the investigatio
[
https://issues.apache.org/jira/browse/FLINK-29195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-29195:
Assignee: chenyuzhi
> Expose lastCheckpointId metric
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601254#comment-17601254
]
Yun Tang commented on FLINK-29195:
--
I think this idea is okay, [~stupid_pig] please go
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964719930
##
docs/content/docs/dev/table/hiveCompatibility/hiveDialect/load-data.md:
##
@@ -0,0 +1,86 @@
+---
+title: "Load Data Statements"
+weight: 4
+type: docs
+aliases:
+- /
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964721241
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/set.md:
##
@@ -0,0 +1,72 @@
+---
+title: "SET Statements"
+weight: 8
+type: docs
+aliases:
+- /dev/table
bzhaoopenstack commented on code in PR #20642:
URL: https://github.com/apache/flink/pull/20642#discussion_r964728414
##
flink-dist/pom.xml:
##
@@ -715,6 +715,8 @@ under the License.
*
luoyuxia commented on code in PR #20696:
URL: https://github.com/apache/flink/pull/20696#discussion_r964733789
##
docs/content.zh/docs/dev/table/hiveCompatibility/hiveDialect/show.md:
##
@@ -0,0 +1,119 @@
+---
+title: "Show Statements"
+weight: 5
+type: docs
+aliases:
+- /dev/ta
luoyuxia commented on PR #20774:
URL: https://github.com/apache/flink/pull/20774#issuecomment-1239277822
@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.
rkhachatryan commented on PR #20723:
URL: https://github.com/apache/flink/pull/20723#issuecomment-1239281202
@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
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964741596
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
XComp commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r964749404
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSinkTest.java:
##
@@ -122,15 +123,15 @@ protected void verifyResultsWhe
luoyuxia created FLINK-29222:
Summary: Wrong behavior for Hive's load data inpath
Key: FLINK-29222
URL: https://issues.apache.org/jira/browse/FLINK-29222
Project: Flink
Issue Type: Bug
liuyongvs commented on PR #20746:
URL: https://github.com/apache/flink/pull/20746#issuecomment-1239309060
hi @twalthr do you have time to review it, thanks?
--
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
[
https://issues.apache.org/jira/browse/FLINK-29222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29222:
-
Description:
When using the following sql with Hive dialect:
{code:java}
load data local inpath 'test
luoyuxia opened a new pull request, #20778:
URL: https://github.com/apache/flink/pull/20778
## What is the purpose of the change
To fix the wrong behavior for Hive's load data inpath
## Brief change log
- Call method `HiveCatalog#loadTable(..., isOverWrite, isSource
[
https://issues.apache.org/jira/browse/FLINK-29222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29222:
---
Labels: pull-request-available (was: )
> Wrong behavior for Hive's load data inpath
> -
[
https://issues.apache.org/jira/browse/FLINK-29222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29222:
-
Description:
In hive, `load data inpath` will remove src file, and `load data local inpath`
won't remov
[
https://issues.apache.org/jira/browse/FLINK-29222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29222:
-
Description:
In hive, `load data inpath` will remove src file, and `load data local inpath`
won't remov
flinkbot commented on PR #20778:
URL: https://github.com/apache/flink/pull/20778#issuecomment-1239331228
## CI report:
* 4f66e9233c9414b6bb9e6cf4db1a7e0fa667eddb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601289#comment-17601289
]
John Ervine commented on FLINK-28171:
-
Is there tested workaround for this?
> Adjus
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964807950
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/SourceReaderFactory.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964810222
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GeneratingIteratorSourceReader.java:
##
@@ -0,0 +1,90 @@
+/*
+ * Licensed to the Apache Softw
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r964820287
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -559,14 +577,67 @@ private void createOutputForSplits(List
newSpli
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r964825458
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -559,14 +577,67 @@ private void createOutputForSplits(List
newSpli
[
https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601303#comment-17601303
]
Moshe Elisha commented on FLINK-28171:
--
[~johnboy74]
You can configure Istio to a
[
https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601316#comment-17601316
]
Weijie Guo commented on FLINK-29183:
[~landlord] First of all, the phenomenon you ob
bzhaoopenstack commented on code in PR #20642:
URL: https://github.com/apache/flink/pull/20642#discussion_r964871297
##
flink-dist/pom.xml:
##
@@ -715,6 +715,8 @@ under the License.
*
[
https://issues.apache.org/jira/browse/FLINK-28411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong closed FLINK-28411.
--
Resolution: Won't Fix
> OperatorCoordinator exception may fail Session Cluster
> -
darenwkt closed pull request #20186: [FLINK-28411] - Error Handling for
OperatorCoordinatorHolder which may fail Session Cluster
URL: https://github.com/apache/flink/pull/20186
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-26256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-26256:
-
Assignee: (was: Zichen Liu)
> AWS SDK Async Event Loop Group Classloader Issue
> --
[
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
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-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
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
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
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_r964964213
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -559,14 +577,67 @@ private void createOutputForSplits(List
newSpli
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
[
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
[
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:
--
Description:
We have the case where we don't see (in the logs) a job being registered in the
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() {
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
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
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_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_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_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_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
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
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
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
1 - 100 of 177 matches
Mail list logo
