[jira] [Commented] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224465#comment-17224465 ] Matthias commented on FLINK-19914: -- And another one:  https://dev.azure.com/mapohl/flin

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Labels: FLINK-19913 (was: ) > Table API & SQL Data Types Document error > ---

[jira] [Issue Comment Deleted] (FLINK-19911) Read checkpoint stream with buffer to speedup restore

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-19911: --- Comment: was deleted (was: Flink job [code link| [https://github.com/1996fanrui/fanrui-learning/blob/eb9ed4

[jira] [Commented] (FLINK-19911) Read checkpoint stream with buffer to speedup restore

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224458#comment-17224458 ] fanrui commented on FLINK-19911: Adjust the buffer size and do some more detailed tests

[jira] [Assigned] (FLINK-19840) Add a rocksdb and heap timers configuration validation

[ https://issues.apache.org/jira/browse/FLINK-19840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-19840: --- Assignee: Igal Shilman > Add a rocksdb and heap timers configuration valida

[jira] [Closed] (FLINK-19840) Add a rocksdb and heap timers configuration validation

[ https://issues.apache.org/jira/browse/FLINK-19840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19840. --- Fix Version/s: statefun-2.2.1 statefun-2.3.0 Resolution: Fi

[jira] [Commented] (FLINK-19915) wrong comments of cep test

[ https://issues.apache.org/jira/browse/FLINK-19915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224448#comment-17224448 ] jackylau commented on FLINK-19915: -- https://github.com/apache/flink/pull/13874 > wrong

[jira] [Closed] (FLINK-19908) FlinkLogicalTableSourceScan and CommonPhysicalTableSourceScan should respect source reuse config option

[ https://issues.apache.org/jira/browse/FLINK-19908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-19908. -- Resolution: Implemented master: 4467277dcf80d18b2898d4ec93c634dc33d25b2d > FlinkLogicalTableSourceSca

[jira] [Assigned] (FLINK-19908) FlinkLogicalTableSourceScan and CommonPhysicalTableSourceScan should respect source reuse config option

[ https://issues.apache.org/jira/browse/FLINK-19908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-19908: -- Assignee: Caizhi Weng > FlinkLogicalTableSourceScan and CommonPhysicalTableSourceScan should

[jira] [Created] (FLINK-19915) wrong comments of cep test

jackylau created FLINK-19915: Summary: wrong comments of cep test Key: FLINK-19915 URL: https://issues.apache.org/jira/browse/FLINK-19915 Project: Flink Issue Type: Bug Components: Libr

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224440#comment-17224440 ] Jingsong Lee commented on FLINK-19843: -- PR: https://github.com/apache/flink/pull/13

[jira] [Updated] (FLINK-19915) wrong comments of cep test

[ https://issues.apache.org/jira/browse/FLINK-19915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19915: - Description: {code:java} // code placeholder @Test public void testNFACompilerPatternEndsWithNotFollowe

[jira] [Commented] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224441#comment-17224441 ] 白恒 commented on FLINK-13680: Hi guys, It looks like a long time has passed, is this issue st

[jira] [Updated] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable

[ https://issues.apache.org/jira/browse/FLINK-19805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19805: --- Attachment: mvn-2.log > LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is insta

[jira] [Updated] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable

[ https://issues.apache.org/jira/browse/FLINK-19805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19805: --- Fix Version/s: 1.12.0 > LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is insta

[jira] [Updated] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable

[ https://issues.apache.org/jira/browse/FLINK-19805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19805: --- Priority: Blocker (was: Major) > LeaderChangeClusterComponentsTest.testReelectionOfJobMaste

[jira] [Commented] (FLINK-19805) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster is instable

[ https://issues.apache.org/jira/browse/FLINK-19805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224439#comment-17224439 ] Robert Metzger commented on FLINK-19805: I'm upgrading this ticket to a blocker.

[jira] [Assigned] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19843: --- Assignee: Jingsong Lee > ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed

[jira] [Updated] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19645: --- Priority: Blocker (was: Critical) > ShuffleCompressionITCase.testDataCompressionForBlocking

[jira] [Commented] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224436#comment-17224436 ] Robert Metzger commented on FLINK-19645: Upgrading to Blocker > ShuffleCompress

[jira] [Updated] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

[ https://issues.apache.org/jira/browse/FLINK-19760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19760: --- Component/s: API / DataStream > Make the `GlobalCommitter` a standalone interface that does

[jira] [Updated] (FLINK-19773) Exponential backoff restart strategy

[ https://issues.apache.org/jira/browse/FLINK-19773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19773: --- Component/s: Runtime / Coordination > Exponential backoff restart strategy > ---

[jira] [Updated] (FLINK-19798) Support creating hive table input splits in parallel

[ https://issues.apache.org/jira/browse/FLINK-19798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19798: --- Component/s: Table SQL / Ecosystem > Support creating hive table input splits in parallel >

[jira] [Updated] (FLINK-19763) Missing test MetricUtilsTest.testNonHeapMetricUsageNotStatic

[ https://issues.apache.org/jira/browse/FLINK-19763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19763: --- Component/s: Runtime / Metrics > Missing test MetricUtilsTest.testNonHeapMetricUsageNotStati

[jira] [Updated] (FLINK-19875) Integrate file compaction to filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19875: --- Component/s: Connectors / FileSystem > Integrate file compaction to filesystem connector > -

[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[ https://issues.apache.org/jira/browse/FLINK-19881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19881: --- Component/s: Table SQL / Runtime > Optimize temporal join with upsert-Source(upsert-kafka) >

[jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery

[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19774: --- Component/s: Runtime / Task > Introduce Sub Partition View Version for Approximate Local Rec

[jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family

[ https://issues.apache.org/jira/browse/FLINK-19895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19895: --- Component/s: Runtime / Task > Unify Life Cycle Management of ResultPartitionType Pipelined F

[jira] [Closed] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18846. Resolution: Invalid > Set a meaningful operator name for the filesystem sink > ---

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224434#comment-17224434 ] CloseRiver commented on FLINK-18846: [~lzljs3620320],Yes now that the problem will n

[jira] [Updated] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19914: Priority: Critical (was: Major) > TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224432#comment-17224432 ] Jingsong Lee commented on FLINK-18846: -- I think we can close this ticket, what do y

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224430#comment-17224430 ] Yang Wang commented on FLINK-19909: --- [~kkl0u] I know we need to have different behavio

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224431#comment-17224431 ] CloseRiver commented on FLINK-18846: Yes ,i just found that [~lzljs3620320]. > Set

[jira] [Comment Edited] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224428#comment-17224428 ] CloseRiver edited comment on FLINK-18846 at 11/2/20, 5:54 AM:

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-19909: -- Attachment: log.jm > Flink application in attach mode could not terminate when the only job is > canc

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224429#comment-17224429 ] Jingsong Lee commented on FLINK-18846: -- Hi [~ZhuShang], It suddenly occurred to me

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224428#comment-17224428 ] CloseRiver commented on FLINK-18846: [~jark]，The filesystem sink operator is a disca

[jira] [Commented] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224427#comment-17224427 ] Dian Fu commented on FLINK-19645: - [~kevin.cyj] Any progress on this issue? It seems tha

[jira] [Commented] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224426#comment-17224426 ] Dian Fu commented on FLINK-19865: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224425#comment-17224425 ] Dian Fu commented on FLINK-19645: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224424#comment-17224424 ] Dian Fu commented on FLINK-19914: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Assigned] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18846: --- Assignee: CloseRiver (was: zhuqi) > Set a meaningful operator name for the filesystem sink > -

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Affects Version/s: (was: 1.11.0) 1.12.0 1.11.1 > Tab

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Fix Version/s: (was: 1.11.0) > Table API & SQL Data Types Document error > ---

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Issue Type: Improvement (was: Bug) > Table API & SQL Data Types Document error >

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224411#comment-17224411 ] Jingsong Lee commented on FLINK-19843: -- Can be re-produced by: {code:java} in flink

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224410#comment-17224410 ] Jingsong Lee commented on FLINK-19843: -- The classloader was closed by: {code:java}

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224409#comment-17224409 ] CloseRiver commented on FLINK-18846: Thx [~zhuqi] [~jark],I want to take this, Coul

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224407#comment-17224407 ] zhuqi commented on FLINK-18846: --- Hi [~ZhuShang]  Feel free to take it, if you want. > Se

[jira] [Commented] (FLINK-19911) Read checkpoint stream with buffer to speedup restore

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224406#comment-17224406 ] fanrui commented on FLINK-19911: Flink job [code link| [https://github.com/1996fanrui/f

[jira] [Commented] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224403#comment-17224403 ] Jun Zhang commented on FLINK-19896: --- Thanks Jark, let's see how it fits into Rank oper

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224401#comment-17224401 ] CloseRiver commented on FLINK-18846: Hi [~zhuqi],are you still working on this issue

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224398#comment-17224398 ] Dian Fu commented on FLINK-19843: - Thanks a lot [~lzljs3620320] ~ > ParquetFsStreamingS

[jira] [Comment Edited] (FLINK-19894) Use iloc for positional slicing instead of direct slicing in from_pandas

[ https://issues.apache.org/jira/browse/FLINK-19894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224397#comment-17224397 ] Dian Fu edited comment on FLINK-19894 at 11/2/20, 2:36 AM: --- Fi

[jira] [Closed] (FLINK-19894) Use iloc for positional slicing instead of direct slicing in from_pandas

[ https://issues.apache.org/jira/browse/FLINK-19894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19894. --- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed Fixed in master via ea43832f2304561

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224394#comment-17224394 ] Jingsong Lee commented on FLINK-19843: -- Thanks for reporting, [~dian.fu], I'll take

[jira] [Assigned] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19914: --- Assignee: Leonard Xu > TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is > i

[jira] [Commented] (FLINK-18929) Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section

[ https://issues.apache.org/jira/browse/FLINK-18929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224391#comment-17224391 ] Huang Xingbo commented on FLINK-18929: -- We already have a link to the python api do

[jira] [Commented] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224389#comment-17224389 ] Dian Fu commented on FLINK-19914: - Another instance: https://dev.azure.com/apache-flink

[jira] [Updated] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19914: Labels: test-stability (was: ) > TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is

[jira] [Created] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

Dian Fu created FLINK-19914: --- Summary: TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable Key: FLINK-19914 URL: https://issues.apache.org/jira/browse/FLINK-19914 Project: Flink

[jira] [Commented] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224388#comment-17224388 ] Dian Fu commented on FLINK-19865: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224387#comment-17224387 ] Dian Fu commented on FLINK-19843: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

[ https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224386#comment-17224386 ] Dian Fu commented on FLINK-19699: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent

[ https://issues.apache.org/jira/browse/FLINK-19913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19913: Description: The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsist

[jira] [Created] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent

sunjincheng created FLINK-19913: --- Summary: The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent Key: FLINK-19913 URL: https://issues.apache.org/jira/browse/FLINK-19913

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224263#comment-17224263 ] Jark Wu commented on FLINK-19912: - What's the error when serializing {{RowData}} into JS

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19909: --- Fix Version/s: 1.11.3 > Flink application in attach mode could not terminate when the only j

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19909: --- Affects Version/s: 1.11.3 > Flink application in attach mode could not terminate when the on

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19909: --- Priority: Blocker (was: Critical) > Flink application in attach mode could not terminate wh

[jira] [Created] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

hailong wang created FLINK-19912: Summary: Support ignoreParseErrors option for json serializationSchema Key: FLINK-19912 URL: https://issues.apache.org/jira/browse/FLINK-19912 Project: Flink

[jira] [Updated] (FLINK-19911) Read checkpoint stream with buffer to speedup restore

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-19911: --- Description: Heap StateBackend needs to serialize each Java Object into the file system during snapshot. Ro

[jira] [Updated] (FLINK-19911) Read checkpoint stream with buffer to speedup restore

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-19911: --- Component/s: FileSystems > Read checkpoint stream with buffer to speedup restore > -

[jira] [Created] (FLINK-19911) Read checkpoint stream with buffer to speedup restore

fanrui created FLINK-19911: -- Summary: Read checkpoint stream with buffer to speedup restore Key: FLINK-19911 URL: https://issues.apache.org/jira/browse/FLINK-19911 Project: Flink Issue Type: Improve

[jira] [Comment Edited] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224253#comment-17224253 ] Kostas Kloudas edited comment on FLINK-19909 at 11/1/20, 12:58 PM: ---

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224253#comment-17224253 ] Kostas Kloudas commented on FLINK-19909: [~fly_in_gis] We want different behavio

[jira] [Comment Edited] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224244#comment-17224244 ] Yang Wang edited comment on FLINK-19909 at 11/1/20, 10:18 AM:

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224244#comment-17224244 ] Yang Wang commented on FLINK-19909: --- [~kkl0u] Thanks for your response. Hmm. Actually,

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Description: source code !image-2020-11-01-16-52-07-420.png! but the document is wrong !image-2020-

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Priority: Major (was: Minor) > Table API & SQL Data Types Document error > --

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Priority: Trivial (was: Major) > Table API & SQL Data Types Document error >

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Priority: Critical (was: Trivial) > Table API & SQL Data Types Document error > -

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Priority: Blocker (was: Critical) > Table API & SQL Data Types Document error > -

[jira] [Updated] (FLINK-19910) Table API & SQL Data Types Document error

[ https://issues.apache.org/jira/browse/FLINK-19910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZiHaoDeng updated FLINK-19910: -- Priority: Minor (was: Blocker) > Table API & SQL Data Types Document error >

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224241#comment-17224241 ] Kostas Kloudas commented on FLINK-19909: Thanks for opening this [~fly_in_gis]!

[jira] [Created] (FLINK-19910) Table API & SQL Data Types Document error

ZiHaoDeng created FLINK-19910: - Summary: Table API & SQL Data Types Document error Key: FLINK-19910 URL: https://issues.apache.org/jira/browse/FLINK-19910 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

Yang Wang created FLINK-19909: - Summary: Flink application in attach mode could not terminate when the only job is canceled Key: FLINK-19909 URL: https://issues.apache.org/jira/browse/FLINK-19909 Project: