[jira] [Issue Comment Deleted] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-22268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22268: - Comment: was deleted (was: Hey [~trohrmann] I've seen your comment ;) Yes you are

[jira] [Commented] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-22268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322115#comment-17322115 ] Dawid Wysakowicz commented on FLINK-22268: -- Hey [~trohrmann] I've seen your comment ;) Yes you

[GitHub] [flink-web] StephanEwen commented on pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

StephanEwen commented on pull request #433: URL: https://github.com/apache/flink-web/pull/433#issuecomment-820356948 What do you think about this as the introductory paragraph? The Apache Flink community is happy to announce the release of Stateful Functions (StateFun)

[jira] [Commented] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322112#comment-17322112 ] Jin Xing commented on FLINK-22276: -- Thanks a lot [~mapohl] > ExceptionHistoryEntryExtractor throws

[jira] [Created] (FLINK-22294) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

Junfan Zhang created FLINK-22294: Summary: Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices Key: FLINK-22294 URL: https://issues.apache.org/jira/browse/FLINK-22294

[jira] [Created] (FLINK-22293) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

Junfan Zhang created FLINK-22293: Summary: Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices Key: FLINK-22293 URL: https://issues.apache.org/jira/browse/FLINK-22293

[jira] [Closed] (FLINK-22154) PushFilterIntoTableSourceScanRule fails to deal with IN expressions

[ https://issues.apache.org/jira/browse/FLINK-22154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22154. -- Resolution: Fixed Fixed in 1.13.0: 067f237d73635f98a454c7f23c1faf4d4c7add1a >

[GitHub] [flink] godfreyhe closed pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

godfreyhe closed pull request #15525: URL: https://github.com/apache/flink/pull/15525 -- 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. For queries about this service,

[jira] [Commented] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

[ https://issues.apache.org/jira/browse/FLINK-22287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322108#comment-17322108 ] Dawid Wysakowicz commented on FLINK-22287: -- No problem! Thanks for being active in the

[GitHub] [flink-web] StephanEwen commented on a change in pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

StephanEwen commented on a change in pull request #433: URL: https://github.com/apache/flink-web/pull/433#discussion_r613987523 ## File path: _posts/2021-04-14-release-statefun-3.0.0.md ## @@ -0,0 +1,166 @@ +--- +layout: post +title: "Stateful Functions 3.0.0 Release

[GitHub] [flink] flinkbot commented on pull request #15623: [FLINK-22292][python][docs] Add documentation for state acess in Python DataStream API

flinkbot commented on pull request #15623: URL: https://github.com/apache/flink/pull/15623#issuecomment-820350101 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-22292) Add documentation about state access in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22292: --- Labels: pull-request-available (was: ) > Add documentation about state access in Python

[GitHub] [flink] dianfu opened a new pull request #15623: [FLINK-22292][python][docs] Add documentation for state acess in Python DataStream API

dianfu opened a new pull request #15623: URL: https://github.com/apache/flink/pull/15623 ## What is the purpose of the change *This pull request adds documentation for state acess in Python DataStream API.* ## Verifying this change This change is a

[GitHub] [flink-web] knaufk commented on a change in pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

knaufk commented on a change in pull request #433: URL: https://github.com/apache/flink-web/pull/433#discussion_r613977197 ## File path: _posts/2021-04-14-release-statefun-3.0.0.md ## @@ -0,0 +1,166 @@ +--- +layout: post +title: "Stateful Functions 3.0.0 Release Announcement"

[GitHub] [flink] Airblader commented on a change in pull request #15588: [FLINK-20613][table] Update TableResult.collect() to the new type system

Airblader commented on a change in pull request #15588: URL: https://github.com/apache/flink/pull/15588#discussion_r612239343 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/connectors/CollectDynamicSink.java ## @@ -0,0 +1,122

[jira] [Created] (FLINK-22292) Add documentation about state access in Python DataStream API

Dian Fu created FLINK-22292: --- Summary: Add documentation about state access in Python DataStream API Key: FLINK-22292 URL: https://issues.apache.org/jira/browse/FLINK-22292 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

flinkbot edited a comment on pull request #15618: URL: https://github.com/apache/flink/pull/15618#issuecomment-820024114 ## CI report: * a5030e29742e58a6df2dbca7d7e1ce27a90e8722 Azure:

[jira] [Commented] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

[ https://issues.apache.org/jira/browse/FLINK-22287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322086#comment-17322086 ] Svend Vanderveken commented on FLINK-22287: --- Thanks for the feed-back Dawid. I see my mistake

[GitHub] [flink] flinkbot edited a comment on pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

flinkbot edited a comment on pull request #15618: URL: https://github.com/apache/flink/pull/15618#issuecomment-820024114 ## CI report: * a5030e29742e58a6df2dbca7d7e1ce27a90e8722 Azure:

[jira] [Created] (FLINK-22291) Fix split switching in HiveInputFormatPartitionReader

Miklos Gergely created FLINK-22291: -- Summary: Fix split switching in HiveInputFormatPartitionReader Key: FLINK-22291 URL: https://issues.apache.org/jira/browse/FLINK-22291 Project: Flink

[jira] [Issue Comment Deleted] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed.

[ https://issues.apache.org/jira/browse/FLINK-22269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22269: -- Comment: was deleted (was: This test has probably the same problem as FLINK-22268.) >

[jira] [Closed] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed.

[ https://issues.apache.org/jira/browse/FLINK-22269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22269. - Resolution: Duplicate The test has probably the same problem as FLINK-22266. >

[jira] [Issue Comment Deleted] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-22268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22268: -- Comment: was deleted (was: I think the problem of this test is that the test only waits on

[jira] [Commented] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithNoRestartsShouldFailTheTerminate fail

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322074#comment-17322074 ] Till Rohrmann commented on FLINK-22266: --- I think the problem of this test is that the test only

[jira] [Reopened] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed.

[ https://issues.apache.org/jira/browse/FLINK-22269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-22269: --- >

[jira] [Closed] (FLINK-22269) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInSuspend failed.

[ https://issues.apache.org/jira/browse/FLINK-22269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22269. - Resolution: Duplicate This test has probably the same problem as FLINK-22268. >

[jira] [Commented] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-22268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322065#comment-17322065 ] Till Rohrmann commented on FLINK-22268: --- I think the problem of this test is that the test only

[jira] [Commented] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

[ https://issues.apache.org/jira/browse/FLINK-21329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322061#comment-17322061 ] Roman Khachatryan commented on FLINK-21329: --- >From what I see in the logs: 1. Test times out

[GitHub] [flink] flinkbot edited a comment on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

flinkbot edited a comment on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820206631 ## CI report: * Unknown: [CANCELED](TBD) * 2e986775d3770ea31bef2c5c649dc39cb2da458b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15615: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

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

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * 0344f2d9a7d7f5e995dbd9c193d2c3dbd3fdddb8 Azure:

[GitHub] [flink-web] StephanEwen commented on a change in pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

StephanEwen commented on a change in pull request #433: URL: https://github.com/apache/flink-web/pull/433#discussion_r613949691 ## File path: _posts/2021-04-14-release-statefun-3.0.0.md ## @@ -0,0 +1,166 @@ +--- +layout: post +title: "Stateful Functions 3.0.0 Release

[GitHub] [flink] LadyForest commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

LadyForest commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r613949192 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala ## @@ -985,6

[GitHub] [flink] KurtYoung merged pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

KurtYoung merged pull request #15549: URL: https://github.com/apache/flink/pull/15549 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

flinkbot edited a comment on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820206631 ## CI report: * Unknown: [CANCELED](TBD) * 2e986775d3770ea31bef2c5c649dc39cb2da458b UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

flinkbot edited a comment on pull request #15622: URL: https://github.com/apache/flink/pull/15622#issuecomment-820290426 ## CI report: * af4135b758aa97ee2690a18bb244c95e82d33df5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * d3ddcf5ae33856edf855a55a43fdfe0782e9530e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

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

[jira] [Updated] (FLINK-22286) Fix picklebytescoder doesn't support custom python class

[ https://issues.apache.org/jira/browse/FLINK-22286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-22286: - Description: Currently picklebytescoder use pickle to serialize data, which won't work when the

[GitHub] [flink] zoltar9264 commented on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

zoltar9264 commented on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820304150 @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

[jira] [Updated] (FLINK-22286) Fix picklebytescoder doesn't support custom python class

[ https://issues.apache.org/jira/browse/FLINK-22286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-22286: - Summary: Fix picklebytescoder doesn't support custom python class (was: Fix the state doesn't

[GitHub] [flink] zoltar9264 edited a comment on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

zoltar9264 edited a comment on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820298464 @flinkbot run travis -- 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

[GitHub] [flink] zoltar9264 commented on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

zoltar9264 commented on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820298464 @flinkbot run travis @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

[jira] [Commented] (FLINK-22229) Noise stacktraces if checkpoints fails because sources are not ready

[ https://issues.apache.org/jira/browse/FLINK-9?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322048#comment-17322048 ] Yun Gao commented on FLINK-9: - Very sorry for the inconvenient brought, I'm currently working on

[jira] [Comment Edited] (FLINK-22140) Test the unified binary savepoint

[ https://issues.apache.org/jira/browse/FLINK-22140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322046#comment-17322046 ] Yun Gao edited comment on FLINK-22140 at 4/15/21, 9:56 AM: --- Hi [~dwysakowicz],

[jira] [Updated] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22290: Affects Version/s: 1.13.0 > Add new unaligned checkpiont options to Python API. >

[jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API.

Arvid Heise created FLINK-22290: --- Summary: Add new unaligned checkpiont options to Python API. Key: FLINK-22290 URL: https://issues.apache.org/jira/browse/FLINK-22290 Project: Flink Issue

[jira] [Commented] (FLINK-22229) Noise stacktraces if checkpoints fails because sources are not ready

[ https://issues.apache.org/jira/browse/FLINK-9?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322047#comment-17322047 ] Roman Khachatryan commented on FLINK-9: --- We discussed this previously offline and decided

[jira] [Commented] (FLINK-22140) Test the unified binary savepoint

[ https://issues.apache.org/jira/browse/FLINK-22140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322046#comment-17322046 ] Yun Gao commented on FLINK-22140: - !1.png!       !2.png! > Test the unified binary savepoint >

[jira] [Updated] (FLINK-22140) Test the unified binary savepoint

[ https://issues.apache.org/jira/browse/FLINK-22140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22140: Attachment: 2.png 1.png > Test the unified binary savepoint >

[GitHub] [flink] flinkbot commented on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

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

[GitHub] [flink] flinkbot edited a comment on pull request #15621: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

flinkbot edited a comment on pull request #15621: URL: https://github.com/apache/flink/pull/15621#issuecomment-820267169 ## CI report: * 77e1b15a83e1e073054aa2254e528f6d3093ec3d Azure:

[jira] [Commented] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

[ https://issues.apache.org/jira/browse/FLINK-22287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322043#comment-17322043 ] Dawid Wysakowicz commented on FLINK-22287: -- You could also annotate it with {{@Rule}} if you

[GitHub] [flink] dawidwys closed pull request #15620: [FLINK-22287][docs] Java documentation of mini cluster should mention usage of before() a…

dawidwys closed pull request #15620: URL: https://github.com/apache/flink/pull/15620 -- 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. For queries about this service,

[GitHub] [flink] dawidwys commented on pull request #15620: [FLINK-22287][docs] Java documentation of mini cluster should mention usage of before() a…

dawidwys commented on pull request #15620: URL: https://github.com/apache/flink/pull/15620#issuecomment-820284509 The documentation is correct. Please see corresponding JIRA ticket for explanation. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

[ https://issues.apache.org/jira/browse/FLINK-22287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322040#comment-17322040 ] Dawid Wysakowicz commented on FLINK-22287: -- The usage is correct. Please see that the field is

[jira] [Closed] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

[ https://issues.apache.org/jira/browse/FLINK-22287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22287. Resolution: Invalid > Java documentation of mini cluster should mention usage of before()

[jira] [Resolved] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22173. - Assignee: Arvid Heise Resolution: Cannot Reproduce > UnalignedCheckpointRescaleITCase

[jira] [Commented] (FLINK-22229) Noise stacktraces if checkpoints fails because sources are not ready

[ https://issues.apache.org/jira/browse/FLINK-9?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322037#comment-17322037 ] Till Rohrmann commented on FLINK-9: --- cc [~pnowojski], [~roman_khachatryan] [~gaoyunhaii] >

[jira] [Commented] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322038#comment-17322038 ] Arvid Heise commented on FLINK-22173: - Given the frequency and the lack of logs, I'm closing it.

[jira] [Commented] (FLINK-21067) Modify the logic of computing tasks to trigger/wait/commit to consider finished tasks

[ https://issues.apache.org/jira/browse/FLINK-21067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322035#comment-17322035 ] Till Rohrmann commented on FLINK-21067: --- Due to this change, the logs became super noisy when we

[GitHub] [flink] flinkbot commented on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

flinkbot commented on pull request #15622: URL: https://github.com/apache/flink/pull/15622#issuecomment-820276451 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] [Comment Edited] (FLINK-22141) Manually test exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322032#comment-17322032 ] Yuan Mei edited comment on FLINK-22141 at 4/15/21, 9:26 AM:

[jira] [Commented] (FLINK-22141) Manually test exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322032#comment-17322032 ] Yuan Mei commented on FLINK-22141: -- Cool, after testing, I can pick up some of them! > Manually test

[jira] [Closed] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22259. --- Resolution: Duplicate > UnalignedCheckpointITCase fails with "Value too large for header, this >

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322030#comment-17322030 ] Arvid Heise commented on FLINK-22259: - I'd close this issue in hopes that the upcoming fixes for

[GitHub] [flink] spoon-lz opened a new pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

spoon-lz opened a new pull request #15622: URL: https://github.com/apache/flink/pull/15622 ## What is the purpose of the change Fixed a bug where when our table parameters are limited to a range, if the set range is exceeded, the exception message is thrown incorrectly

[GitHub] [flink] flinkbot commented on pull request #15621: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

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

[GitHub] [flink] flinkbot commented on pull request #15620: [FLINK-22287][docs] Java documentation of mini cluster should mention usage of before() a…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

flinkbot edited a comment on pull request #15613: URL: https://github.com/apache/flink/pull/15613#issuecomment-819470379 ## CI report: * e1ecc11ab51b9eb422e99497c8853dedfad74e54 Azure:

[jira] [Updated] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-12141: Labels: pull-request-available starter usability (was: pull-request-available stale-minor

[GitHub] [flink] flinkbot commented on pull request #15621: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

flinkbot commented on pull request #15621: URL: https://github.com/apache/flink/pull/15621#issuecomment-820251373 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] [Closed] (FLINK-20813) SQL Client should create modules with user class loader

[ https://issues.apache.org/jira/browse/FLINK-20813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-20813. - Resolution: Fixed Fixed. > SQL Client should create modules with user class loader >

[GitHub] [flink] tillrohrmann opened a new pull request #15621: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

tillrohrmann opened a new pull request #15621: URL: https://github.com/apache/flink/pull/15621 Wait for the registration response before measuring the passed time for the assumption criterion. This is my third and last attempt to stabilize this test. If the test is still unstable,

[jira] [Closed] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-20549. - Resolution: Fixed !image-2021-04-15-16-52-38-799.png! Verified in my local env. > New

[GitHub] [flink] flinkbot commented on pull request #15620: [FLINK-22287][docs] Java documentation of mini cluster should mention usage of before() a…

flinkbot commented on pull request #15620: URL: https://github.com/apache/flink/pull/15620#issuecomment-820246311 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] flinkbot edited a comment on pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

flinkbot edited a comment on pull request #15613: URL: https://github.com/apache/flink/pull/15613#issuecomment-819470379 ## CI report: * e1ecc11ab51b9eb422e99497c8853dedfad74e54 Azure:

[jira] [Commented] (FLINK-22141) Manually test exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322014#comment-17322014 ] Roman Khachatryan commented on FLINK-22141: --- Thanks a lot [~ym], I agree with all the points

[jira] [Updated] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20549: -- Attachment: image-2021-04-15-16-51-16-765.png > New ExecutionContext doesn't inherit

[GitHub] [flink] flinkbot edited a comment on pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

flinkbot edited a comment on pull request #15559: URL: https://github.com/apache/flink/pull/15559#issuecomment-817479787 ## CI report: * 32b7789699122e7e4e495de4d3f7df282ba8d2b5 UNKNOWN * 89b4f4f520a31451901f92fe873239ffa545b63d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15549: [FLINK-20761][hive] Escape the location path when creating input splits

flinkbot edited a comment on pull request #15549: URL: https://github.com/apache/flink/pull/15549#issuecomment-816597084 ## CI report: * 387e94130b66c6fb2dd5ac36133b2c317d83060e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

flinkbot edited a comment on pull request #15496: URL: https://github.com/apache/flink/pull/15496#issuecomment-814224240 ## CI report: * bb793910ece02e290d4397eff1a26ce621cf618e Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

dawidwys commented on a change in pull request #15589: URL: https://github.com/apache/flink/pull/15589#discussion_r613878226 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -242,6 +258,27 @@ public void

[jira] [Created] (FLINK-22289) Update JDBC XA sink docs

Roman Khachatryan created FLINK-22289: - Summary: Update JDBC XA sink docs Key: FLINK-22289 URL: https://issues.apache.org/jira/browse/FLINK-22289 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22288) Remove unnecesary argument from JdbcSink.exactlyOnceSink

Roman Khachatryan created FLINK-22288: - Summary: Remove unnecesary argument from JdbcSink.exactlyOnceSink Key: FLINK-22288 URL: https://issues.apache.org/jira/browse/FLINK-22288 Project: Flink

[jira] [Updated] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

[ https://issues.apache.org/jira/browse/FLINK-22287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22287: --- Labels: pull-request-available (was: ) > Java documentation of mini cluster should mention

[GitHub] [flink] sv3ndk opened a new pull request #15620: [FLINK-22287][docs] Java documentation of mini cluster should mention usage of before() a…

sv3ndk opened a new pull request #15620: URL: https://github.com/apache/flink/pull/15620 …nd after() ## What is the purpose of the change Improve documentation of usage of Mini Cluster in java unit tests ## Brief change log - *added mention of

[GitHub] [flink] AHeise commented on a change in pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

AHeise commented on a change in pull request #15589: URL: https://github.com/apache/flink/pull/15589#discussion_r613873168 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointITCase.java ## @@ -97,6 +100,19 @@ private

[jira] [Created] (FLINK-22287) Java documentation of mini cluster should mention usage of before() and after()

Svend Vanderveken created FLINK-22287: - Summary: Java documentation of mini cluster should mention usage of before() and after() Key: FLINK-22287 URL: https://issues.apache.org/jira/browse/FLINK-22287

[jira] [Comment Edited] (FLINK-22141) Manually test exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321934#comment-17321934 ] Yuan Mei edited comment on FLINK-22141 at 4/15/21, 8:37 AM: Couple of things

[GitHub] [flink] kezhuw commented on a change in pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

kezhuw commented on a change in pull request #15605: URL: https://github.com/apache/flink/pull/15605#discussion_r613867235 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java ## @@ -64,6 +69,17 @@

[jira] [Commented] (FLINK-22141) Manually test exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322006#comment-17322006 ] Yuan Mei commented on FLINK-22141: -- [~roman_khachatryan] > Manually test exactly-once JDBC sink >

[jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types

[ https://issues.apache.org/jira/browse/FLINK-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322002#comment-17322002 ] David Anderson commented on FLINK-5964: --- I don't think this issue should simply be closed. AFAIK,

[jira] [Updated] (FLINK-5964) Change TypeSerializers to allow construction of immutable types

[ https://issues.apache.org/jira/browse/FLINK-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-5964: -- Labels: (was: stale-minor) > Change TypeSerializers to allow construction of immutable types

[jira] [Closed] (FLINK-22260) Source schema in CREATE TABLE LIKE statements is not inferred correctly

[ https://issues.apache.org/jira/browse/FLINK-22260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22260. Resolution: Fixed Fixed in 1.13.0: 1e0da5e5756e4c39f260a1e18aad3460f7fc67d9 > Source schema in

[GitHub] [flink] twalthr closed pull request #15606: [FLINK-22260][table-planner-blink] Use unresolvedSchema during operation convertions

twalthr closed pull request #15606: URL: https://github.com/apache/flink/pull/15606 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

flinkbot edited a comment on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820206631 ## CI report: * e5376c2615f0b279744a92fb1b037d60834d5e22 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15598: [FLINK-22136][e2e] Console output changed to exception in DataStreamA…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * e16ddc3fb9157cc0b70ea07023202a2ebdd9fe15 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15496: [FLINK-21990][streaming] Cancel task before clean up if execution was…

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

<    1   2   3   4   5   >