[GitHub] [flink] flinkbot edited a comment on pull request #16534: [FLINK-23419][streaming] Fixed the condition in testNextFirstCheckpointBarrierOvertakesCancellationBarrier in order to make the test

flinkbot edited a comment on pull request #16534: URL: https://github.com/apache/flink/pull/16534#issuecomment-882522000 ## CI report: * 5af979019505831a2a9a2adb3710f91df7daa242 Azure:

[GitHub] [flink] curcur commented on pull request #16534: [FLINK-23419][streaming] Fixed the condition in testNextFirstCheckpointBarrierOvertakesCancellationBarrier in order to make the test more stab

curcur commented on pull request #16534: URL: https://github.com/apache/flink/pull/16534#issuecomment-883057169 Hey @akalash thanks for creating the PR 1. The azure failure does not seem to be related, could you please double-check to make sure it is not related 2. I know it is very

[GitHub] [flink] flinkbot edited a comment on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

flinkbot edited a comment on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-852816465 ## CI report: * a24d658a1dfac9f052a1d4aede0a0646ced2650c Azure:

[jira] [Created] (FLINK-23434) Inconsistent rowtypes occur in IncrementalAggregateRule

godfrey he created FLINK-23434: -- Summary: Inconsistent rowtypes occur in IncrementalAggregateRule Key: FLINK-23434 URL: https://issues.apache.org/jira/browse/FLINK-23434 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #16537: [FLINK-23432][docs] Solve the Markdown header failure issue

flinkbot edited a comment on pull request #16537: URL: https://github.com/apache/flink/pull/16537#issuecomment-883005791 ## CI report: * 2a432af4d6bc65d4391019168109783067c9e4d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16467: [FLINK-23309][python] Optimize the finish bundle logic in PyFlink

flinkbot edited a comment on pull request #16467: URL: https://github.com/apache/flink/pull/16467#issuecomment-878120698 ## CI report: * fd94525e8bccd478a175e531074a1356257e0dcf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

flinkbot edited a comment on pull request #16063: URL: https://github.com/apache/flink/pull/16063#issuecomment-853640847 ## CI report: * a5833f1f9f82960dcc3d860ed324e4f1fe53a3e9 UNKNOWN * df8a2187cf49025044ba00e5f672233d547f2d04 Azure:

[jira] [Created] (FLINK-23433) Metrics cannot be initialized in format

Fangliang Liu created FLINK-23433: - Summary: Metrics cannot be initialized in format Key: FLINK-23433 URL: https://issues.apache.org/jira/browse/FLINK-23433 Project: Flink Issue Type: Bug

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r672782651 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -110,69 +106,64

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

flinkbot edited a comment on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881388489 ## CI report: * 1eeef1fd87a930bafc95d564455b07640e3e22ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16467: [FLINK-23309][python] Optimize the finish bundle logic in PyFlink

flinkbot edited a comment on pull request #16467: URL: https://github.com/apache/flink/pull/16467#issuecomment-878120698 ## CI report: * fd94525e8bccd478a175e531074a1356257e0dcf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

flinkbot edited a comment on pull request #16063: URL: https://github.com/apache/flink/pull/16063#issuecomment-853640847 ## CI report: * a5833f1f9f82960dcc3d860ed324e4f1fe53a3e9 UNKNOWN * df8a2187cf49025044ba00e5f672233d547f2d04 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

flinkbot edited a comment on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-852816465 ## CI report: * c4831e9c1fa5b2fd77411a46e45c7927f0219b0e Azure:

[jira] [Commented] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383718#comment-17383718 ] Xintong Song commented on FLINK-23409: -- Logs added in b3eea9821aead6b8e11f592361384bed0a4fb016 >

[GitHub] [flink] xintongsong closed pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

xintongsong closed pull request #16530: URL: https://github.com/apache/flink/pull/16530 -- 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:

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383716#comment-17383716 ] Xintong Song commented on FLINK-22198: --

[GitHub] [flink] fsk119 commented on a change in pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

fsk119 commented on a change in pull request #15317: URL: https://github.com/apache/flink/pull/15317#discussion_r672768162 ## File path: flink-table/flink-sql-parser/src/main/resources/org.apache.flink.sql.parser.utils/ParserResource.properties ## @@ -19,3 +19,4 @@

[jira] [Closed] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion

[ https://issues.apache.org/jira/browse/FLINK-22677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-22677. --- Resolution: Done Done via 0d099b79fddc5e254884e44f2167c625744079a4 0b28fadccfb6b0d2a85592ced9e98b03a0c2d3bf

[GitHub] [flink] zhuzhurk closed pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

zhuzhurk closed pull request #16383: URL: https://github.com/apache/flink/pull/16383 -- 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:

[GitHub] [flink] leonardBang commented on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

leonardBang commented on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-883013639 Yes, rebasing master is recommended, and it doesn't matter. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #16537: [FLINK-23432][docs] Solve the Markdown header failure issue

flinkbot edited a comment on pull request #16537: URL: https://github.com/apache/flink/pull/16537#issuecomment-883005791 ## CI report: * 2a432af4d6bc65d4391019168109783067c9e4d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

flinkbot edited a comment on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881388489 ## CI report: * 1eeef1fd87a930bafc95d564455b07640e3e22ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

flinkbot edited a comment on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-852816465 ## CI report: * c4831e9c1fa5b2fd77411a46e45c7927f0219b0e Azure:

[GitHub] [flink] chaozwn commented on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

chaozwn commented on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-883009595 > @chaozwn Thanks for the update, but when we resolve reviewer's comment, we should append commit rather than squashing and force pushing which we cannot know the comment is

[GitHub] [flink] chaozwn commented on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

chaozwn commented on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-883009007 > @chaozwn Thanks for the update, but when we resolve reviewer's comment, we should append commit rather than squashing and force pushing which we cannot know the comment is

[jira] [Comment Edited] (FLINK-23426) Support changelog processing in batch mode

[ https://issues.apache.org/jira/browse/FLINK-23426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383706#comment-17383706 ] Jark Wu edited comment on FLINK-23426 at 7/20/21, 2:41 AM: --- This was planned

[jira] [Commented] (FLINK-23426) Support changelog processing in batch mode

[ https://issues.apache.org/jira/browse/FLINK-23426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383706#comment-17383706 ] Jark Wu commented on FLINK-23426: - This was planned in FLINK-18825. I prefer to have a materialize

[GitHub] [flink] leonardBang commented on pull request #16051: [FLINK-22844]Add doc to introduce ExplainDetails for EXPLAIN sytnax

leonardBang commented on pull request #16051: URL: https://github.com/apache/flink/pull/16051#issuecomment-883005804 @chaozwn Thanks for the update, but when we resolve reviewer's comment, we should append commit rather than squashing and force pushing which we cannot know the comment is

[GitHub] [flink] flinkbot commented on pull request #16537: [FLINK-23432][docs] Solve the Markdown header failure issue

flinkbot commented on pull request #16537: URL: https://github.com/apache/flink/pull/16537#issuecomment-883005791 ## CI report: * 2a432af4d6bc65d4391019168109783067c9e4d3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-23427) Translate the page of "Blocking Shuffle" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-23427: --- Assignee: Aiden Gong > Translate the page of "Blocking Shuffle" into Chinese >

[GitHub] [flink] guizmaii commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

guizmaii commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r672762449 ## File path: flink-core/src/main/java/org/apache/flink/core/classloading/SubmoduleClassLoader.java ## @@ -0,0 +1,45 @@ +/* + * Licensed to the Apache

[GitHub] [flink] guizmaii commented on a change in pull request #16345: [FLINK-18783] Load AkkaRpcSystem through separate classloader

guizmaii commented on a change in pull request #16345: URL: https://github.com/apache/flink/pull/16345#discussion_r672762449 ## File path: flink-core/src/main/java/org/apache/flink/core/classloading/SubmoduleClassLoader.java ## @@ -0,0 +1,45 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot commented on pull request #16537: [FLINK-23432][docs] Solve the Markdown header failure issue

flinkbot commented on pull request #16537: URL: https://github.com/apache/flink/pull/16537#issuecomment-882996664 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-23432) [DOCS] The 'docs/content.zh/docs/ops/state/checkpoints' page did not add a newline, which invalidated the Markdown header

[ https://issues.apache.org/jira/browse/FLINK-23432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wuguihu updated FLINK-23432: Description: The page url

[jira] [Updated] (FLINK-23432) [DOCS] The 'docs/content.zh/docs/ops/state/checkpoints' page did not add a newline, which invalidated the Markdown header

[ https://issues.apache.org/jira/browse/FLINK-23432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23432: --- Labels: pull-request-available (was: ) > [DOCS] The

[GitHub] [flink] hapihu opened a new pull request #16537: [FLINK-23432][docs] Solve the Markdown header failure issue

hapihu opened a new pull request #16537: URL: https://github.com/apache/flink/pull/16537 The page url ：https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/ops/state/checkpoints/ markdown： docs/content.zh/docs/ops/state/checkpoints.md - A blank line

[GitHub] [flink] KarmaGYZ commented on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

KarmaGYZ commented on pull request #16530: URL: https://github.com/apache/flink/pull/16530#issuecomment-882993707 cc @xintongsong -- 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

[jira] [Created] (FLINK-23432) [DOCS] The 'docs/content.zh/docs/ops/state/checkpoints' page did not add a newline, which invalidated the Markdown header

wuguihu created FLINK-23432: --- Summary: [DOCS] The 'docs/content.zh/docs/ops/state/checkpoints' page did not add a newline, which invalidated the Markdown header Key: FLINK-23432 URL:

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383691#comment-17383691 ] Xintong Song commented on FLINK-22702: --

[jira] [Commented] (FLINK-22382) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-22382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383690#comment-17383690 ] Xintong Song commented on FLINK-22382: --

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383689#comment-17383689 ] Xintong Song commented on FLINK-22869: --

[GitHub] [flink] paul8263 commented on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

paul8263 commented on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-882969525 Hi @NicoK , I successfully regenerated rest_v1_dispatcher.html and rest_api_v1.snapshot by running those commands. But I am still confused about the first point "Rebase onto

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * ae9a98b727dba02d7aa7e9ff8f58cde9d75f8598 Azure:

[jira] [Updated] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18634: --- Labels: auto-unassigned stale-blocker test-stability (was: auto-unassigned test-stability)

[jira] [Updated] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

[ https://issues.apache.org/jira/browse/FLINK-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16634: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Commented] (FLINK-22386) Introduce cache for docker images

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383580#comment-17383580 ] Dawid Wysakowicz commented on FLINK-22386: -- Hey, could you help me understand the logs from

[jira] [Updated] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22416: - Priority: Major (was: Blocker) > UpsertKafkaTableITCase hangs when collecting results

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383574#comment-17383574 ] Dawid Wysakowicz commented on FLINK-22416: -- I'll deprioritize the issue as it has not happened

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * c684094020717b1db64e414e645a3939d3aab838 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r672604163 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java ## @@ -57,4 +87,18 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * c684094020717b1db64e414e645a3939d3aab838 Azure:

[jira] [Created] (FLINK-23431) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The topic metadata failed to propagate to Kafka broker."

Dawid Wysakowicz created FLINK-23431: Summary: KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails with "The topic metadata failed to propagate to Kafka broker." Key: FLINK-23431 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #16536: [FLINK-23402][streaming-java] Refactor enums for shuffle modes

flinkbot edited a comment on pull request #16536: URL: https://github.com/apache/flink/pull/16536#issuecomment-882687204 ## CI report: * c8ecae2fd07bc9e2d36db1a2c2a49a8d0c59a924 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * cf7500f62e38121f5cccdeeb514b4ccd96394fad Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

rkhachatryan commented on a change in pull request #16523: URL: https://github.com/apache/flink/pull/16523#discussion_r672286565 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ## @@ -1435,8 +1437,18 @@ private boolean

[jira] [Closed] (FLINK-23428) Performance regression in state benchmarks on Jul 16 2021

[ https://issues.apache.org/jira/browse/FLINK-23428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-23428. - Resolution: Not A Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN * ddac8172a148210bf6539a0348d4bcb8b1983497 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

flinkbot edited a comment on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * 2f0927d4c92c3c807ee2e0d7dd8c8dd691ed8ae8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * da62d0dcd12e915507b783a94a177907d441c761 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

flinkbot edited a comment on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-881917566 ## CI report: * 6b5e7e5dba93d6baf725ee333c7c26c55d348e43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * c684094020717b1db64e414e645a3939d3aab838 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

flinkbot edited a comment on pull request #16478: URL: https://github.com/apache/flink/pull/16478#issuecomment-878958342 ## CI report: * dd0ac23c04fec173bfb90bf2ad500d15899b UNKNOWN * 3d90f93fe61d3d0516b4b1b0da99a14fd688c292 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

pnowojski commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670486540 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to the

[GitHub] [flink] pnowojski commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

pnowojski commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670486540 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to the

[jira] [Comment Edited] (FLINK-23388) Non-static Scala case classes cannot be serialised

[ https://issues.apache.org/jira/browse/FLINK-23388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383457#comment-17383457 ] Toby Miller edited comment on FLINK-23388 at 7/19/21, 4:59 PM: --- Thanks for

[jira] [Commented] (FLINK-23388) Non-static Scala case classes cannot be serialised

[ https://issues.apache.org/jira/browse/FLINK-23388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383457#comment-17383457 ] Toby Miller commented on FLINK-23388: - Thanks for your reply. I can check this, but I believe my

[GitHub] [flink] flinkbot edited a comment on pull request #16536: [FLINK-23402][streaming-java] Refactor enums for shuffle modes

flinkbot edited a comment on pull request #16536: URL: https://github.com/apache/flink/pull/16536#issuecomment-882687204 ## CI report: * c8ecae2fd07bc9e2d36db1a2c2a49a8d0c59a924 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16535: [FLINK-21979] Cleanup completed checkpoint store after dispatcher cleans up HA services

flinkbot edited a comment on pull request #16535: URL: https://github.com/apache/flink/pull/16535#issuecomment-882643278 ## CI report: * 803cadc1e55846e243ce2d952934fc3a29251a90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16534: [FLINK-23419][streaming] Fixed the condition in testNextFirstCheckpointBarrierOvertakesCancellationBarrier in order to make the test

flinkbot edited a comment on pull request #16534: URL: https://github.com/apache/flink/pull/16534#issuecomment-882522000 ## CI report: * 5af979019505831a2a9a2adb3710f91df7daa242 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

flinkbot edited a comment on pull request #16516: URL: https://github.com/apache/flink/pull/16516#issuecomment-881388489 ## CI report: * 1eeef1fd87a930bafc95d564455b07640e3e22ab Azure:

[GitHub] [flink] flinkbot commented on pull request #16536: [FLINK-23402][streaming-java] Refactor enums for shuffle modes

flinkbot commented on pull request #16536: URL: https://github.com/apache/flink/pull/16536#issuecomment-882687204 ## CI report: * c8ecae2fd07bc9e2d36db1a2c2a49a8d0c59a924 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

flinkbot edited a comment on pull request #16478: URL: https://github.com/apache/flink/pull/16478#issuecomment-878958342 ## CI report: * 306e5f7f279141ea3f0da8905457624f51039f9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * bd2ab46a5e8d4929110dc6360f53413b85e33b03 Azure:

[jira] [Updated] (FLINK-23402) Expose a consistent GlobalDataExchangeMode

[ https://issues.apache.org/jira/browse/FLINK-23402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23402: --- Labels: pull-request-available (was: ) > Expose a consistent GlobalDataExchangeMode >

[GitHub] [flink] flinkbot commented on pull request #16536: [FLINK-23402][streaming-java] Refactor enums for shuffle modes

flinkbot commented on pull request #16536: URL: https://github.com/apache/flink/pull/16536#issuecomment-882670472 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] twalthr opened a new pull request #16536: Flink 23402

twalthr opened a new pull request #16536: URL: https://github.com/apache/flink/pull/16536 ## What is the purpose of the change This refactors some enum classes that are used for more or less the same purpose but in different parts of the stack with different values. It should

[GitHub] [flink] flinkbot edited a comment on pull request #16535: [FLINK-21979] Cleanup completed checkpoint store after dispatcher cleans up HA services

flinkbot edited a comment on pull request #16535: URL: https://github.com/apache/flink/pull/16535#issuecomment-882643278 ## CI report: * 803cadc1e55846e243ce2d952934fc3a29251a90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

flinkbot edited a comment on pull request #16478: URL: https://github.com/apache/flink/pull/16478#issuecomment-878958342 ## CI report: * 306e5f7f279141ea3f0da8905457624f51039f9f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16416: [FLINK-22657][Connectors/Hive] HiveParserDDLSemanticAnalyzer return operations directly

flinkbot edited a comment on pull request #16416: URL: https://github.com/apache/flink/pull/16416#issuecomment-876055217 ## CI report: * 35ab962373500de173886d14610b871c3963272c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * bd2ab46a5e8d4929110dc6360f53413b85e33b03 Azure:

[jira] [Created] (FLINK-23430) Do not take snapshot for operator coordinators which all tasks finished

Dawid Wysakowicz created FLINK-23430: Summary: Do not take snapshot for operator coordinators which all tasks finished Key: FLINK-23430 URL: https://issues.apache.org/jira/browse/FLINK-23430

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN * 53b0f198de7397738c32c82a0bc6c3291c206707 Azure:

[GitHub] [flink] flinkbot commented on pull request #16535: [FLINK-21979] Cleanup completed checkpoint store after dispatcher cleans up HA services

flinkbot commented on pull request #16535: URL: https://github.com/apache/flink/pull/16535#issuecomment-882643278 ## CI report: * 803cadc1e55846e243ce2d952934fc3a29251a90 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

flinkbot edited a comment on pull request #16478: URL: https://github.com/apache/flink/pull/16478#issuecomment-878958342 ## CI report: * 306e5f7f279141ea3f0da8905457624f51039f9f Azure:

[jira] [Commented] (FLINK-23181) Add support for multi hop window

[ https://issues.apache.org/jira/browse/FLINK-23181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383404#comment-17383404 ] Aitozi commented on FLINK-23181: Thanks [~lzljs3620320] for your inputs. I think it's a good idea. I

[GitHub] [flink] flinkbot edited a comment on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

flinkbot edited a comment on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * ecaf98d03ade3e65b976afd102cc56073d38f30e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

flinkbot edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-872812232 ## CI report: * a702e37520cc8860e767ee7fe6119ef5dc60f2a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN * 53b0f198de7397738c32c82a0bc6c3291c206707 Azure:

[GitHub] [flink] RollsBean commented on a change in pull request #16490: [FLINK-23241][docs-zh] Translate the page of "Working with State " in…

RollsBean commented on a change in pull request #16490: URL: https://github.com/apache/flink/pull/16490#discussion_r672394466 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -27,18 +27,18 @@ under the License. # 带有状态的处理 -在本节中，你可以了解 Flink

[jira] [Commented] (FLINK-22594) Report oom killed pod in k8s resource manager

[ https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17383396#comment-17383396 ] Aitozi commented on FLINK-22594: I have create the pull request to implement this , could you help to

[GitHub] [flink] predatorray commented on pull request #16494: [FLINK-22452][Connectors/Kafka] Support specifying custom transactional.id prefix in FlinkKafkaProducer

predatorray commented on pull request #16494: URL: https://github.com/apache/flink/pull/16494#issuecomment-882632252 Thanks, @pnowojski! I will update the FLIP status accordingly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Assigned] (FLINK-23429) State Processor API failed with FileNotFoundException when working with state files on Cloud Storage

[ https://issues.apache.org/jira/browse/FLINK-23429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-23429: - Assignee: Jun Qin > State Processor API failed with FileNotFoundException when working

[jira] [Created] (FLINK-23429) State Processor API failed with FileNotFoundException when working with state files on Cloud Storage

Jun Qin created FLINK-23429: --- Summary: State Processor API failed with FileNotFoundException when working with state files on Cloud Storage Key: FLINK-23429 URL: https://issues.apache.org/jira/browse/FLINK-23429

[GitHub] [flink] RollsBean commented on pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

RollsBean commented on pull request #16478: URL: https://github.com/apache/flink/pull/16478#issuecomment-882617583 Hi @hackergin , @ranqiqiang , updated -- 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

[jira] [Updated] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state

[ https://issues.apache.org/jira/browse/FLINK-21979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21979: --- Labels: pull-request-available (was: ) > Job can be restarted from the beginning after it

[GitHub] [flink] flinkbot commented on pull request #16535: [FLINK-21979] Cleanup completed checkpoint store after dispatcher cleans up HA services

flinkbot commented on pull request #16535: URL: https://github.com/apache/flink/pull/16535#issuecomment-882615730 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] dmvk opened a new pull request #16535: Flink 21979

dmvk opened a new pull request #16535: URL: https://github.com/apache/flink/pull/16535 ## What is the purpose of the change * Cleaning up HA services before CompletedCheckpointStore ## Brief change log *(for example:)* - CompletedCheckpointStore is cleaned in

[GitHub] [flink] flinkbot edited a comment on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

flinkbot edited a comment on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * ecaf98d03ade3e65b976afd102cc56073d38f30e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * cf9c6bda554fa68a11c30f7bf8f66a80eafafd43 Azure:

[GitHub] [flink] zhuzhurk commented on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

zhuzhurk commented on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-882597202 Thanks for reviewing! @guoweiM @Thesharing Will rebase it onto latest master and merge it once CI gives green. -- This is an automated message from the Apache Git

  1   2   3   >