[GitHub] [flink] wuchong commented on a change in pull request #14029: [FLINK-20084][planner] Fix NPE when generating watermark for record w…

2020-11-10 Thread GitBox
wuchong commented on a change in pull request #14029: URL: https://github.com/apache/flink/pull/14029#discussion_r521176325 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushWatermarkIntoTableSourceScanRuleBase.java

[jira] [Commented] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception

2020-11-10 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229818#comment-17229818 ] Rui Li commented on FLINK-19630: Yeah I think documentation is all we can do at the mome

[GitHub] [flink] flinkbot edited a comment on pull request #14029: [FLINK-20084][planner] Fix NPE when generating watermark for record w…

2020-11-10 Thread GitBox
flinkbot edited a comment on pull request #14029: URL: https://github.com/apache/flink/pull/14029#issuecomment-725258730 ## CI report: * a128055b2b0d97ce6673363c7885c97b17ba6e07 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-15906) physical memory exceeded causing being killed by yarn

2020-11-10 Thread yang gang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229817#comment-17229817 ] yang gang commented on FLINK-15906: --- {code:java} Closing TaskExecutor connection conta

[GitHub] [flink] Shawn-Hx commented on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-11-10 Thread GitBox
Shawn-Hx commented on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-725266494 @klion26 Thanks for your reminder. I have resolved the conflict. PTAL. This is an automated message from the Ap

[GitHub] [flink] wuchong commented on pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

2020-11-10 Thread GitBox
wuchong commented on pull request #14027: URL: https://github.com/apache/flink/pull/14027#issuecomment-725265512 The changes on `JoinTest.xml` is a fix of UpdateKindTrait inference of Join operator. The streaming join operator just forward all the input records and can't drop UPDATE_BEFORE

[jira] [Commented] (FLINK-19303) Disable WAL in RocksDB recovery

2020-11-10 Thread Juha Mynttinen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229815#comment-17229815 ] Juha Mynttinen commented on FLINK-19303: It's possible that a later RocksDB vers

[jira] [Commented] (FLINK-14482) Bump up rocksdb version

2020-11-10 Thread Juha Mynttinen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229814#comment-17229814 ] Juha Mynttinen commented on FLINK-14482: Hey, I'm trying to understand this JIRA

[jira] [Assigned] (FLINK-20084) Fix NPE when generating watermark for record whose rowtime field is null after watermark push down

2020-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20084: --- Assignee: Shengkai Fang > Fix NPE when generating watermark for record whose rowtime field is null

[jira] [Updated] (FLINK-20085) Remove RemoteFunctionStateMigrator code paths from StateFun

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20085: Issue Type: Task (was: Bug) > Remove RemoteFunctionStateMigrator code paths from

[jira] [Created] (FLINK-20085) Remove RemoteFunctionStateMigrator code paths from StateFun

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20085: --- Summary: Remove RemoteFunctionStateMigrator code paths from StateFun Key: FLINK-20085 URL: https://issues.apache.org/jira/browse/FLINK-20085 Project: F

[jira] [Commented] (FLINK-19979) Sanity check after bash e2e tests for no leftover processes

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229811#comment-17229811 ] Robert Metzger commented on FLINK-19979: This is making good progress. I can pro

[GitHub] [flink] klion26 commented on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-11-10 Thread GitBox
klion26 commented on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-725259657 @Shawn-Hx when I was to merge this pr, found that there is some conflict, could you please resolve the conflict, so that I can merge this. thanks and sorry for the inconvenience

[GitHub] [flink] flinkbot commented on pull request #14029: [FLINK-20084][planner] Fix NPE when generating watermark for record w…

2020-11-10 Thread GitBox
flinkbot commented on pull request #14029: URL: https://github.com/apache/flink/pull/14029#issuecomment-725258730 ## CI report: * a128055b2b0d97ce6673363c7885c97b17ba6e07 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Assigned] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-16947: -- Assignee: (was: Robert Metzger) > ArtifactResolutionException: Could not transfer

[jira] [Closed] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20035. -- Resolution: Fixed > BlockingShuffleITCase unstable with "Could not start rest endpoint on any

[jira] [Commented] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229808#comment-17229808 ] Robert Metzger commented on FLINK-20035: Fixed in https://github.com/apache/fli

[GitHub] [flink] rmetzger merged pull request #13992: [FLINK-20035][tests] Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase

2020-11-10 Thread GitBox
rmetzger merged pull request #13992: URL: https://github.com/apache/flink/pull/13992 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] rmetzger commented on pull request #13992: [FLINK-20035][tests] Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase

2020-11-10 Thread GitBox
rmetzger commented on pull request #13992: URL: https://github.com/apache/flink/pull/13992#issuecomment-725258225 Merging ... This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] godfreyhe commented on a change in pull request #14029: [FLINK-20084][planner] Fix NPE when generating watermark for record w…

2020-11-10 Thread GitBox
godfreyhe commented on a change in pull request #14029: URL: https://github.com/apache/flink/pull/14029#discussion_r521164123 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/SourceWatermarkITCase.scala ## @@

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229806#comment-17229806 ] Robert Metzger commented on FLINK-16947: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] flinkbot commented on pull request #14029: [FLINK-20084][planner] Fix NPE when generating watermark for record w…

2020-11-10 Thread GitBox
flinkbot commented on pull request #14029: URL: https://github.com/apache/flink/pull/14029#issuecomment-725254026 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 pro

[jira] [Commented] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

2020-11-10 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229805#comment-17229805 ] Arvid Heise commented on FLINK-19585: - The last two reports of master are FLINK-2006

[jira] [Updated] (FLINK-20084) Fix NPE when generating watermark for record whose rowtime field is null after watermark push down

2020-11-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20084: --- Labels: pull-request-available (was: ) > Fix NPE when generating watermark for record whose

[GitHub] [flink] fsk119 opened a new pull request #14029: [FLINK-20084][planner] Fix NPE when generating watermark for record w…

2020-11-10 Thread GitBox
fsk119 opened a new pull request #14029: URL: https://github.com/apache/flink/pull/14029 …hose rowtime field is null after watermark push down ## What is the purpose of the change *Fix a bug.* ## Verifying this change This change added tests and can be ver

[jira] [Commented] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229803#comment-17229803 ] Robert Metzger commented on FLINK-20068: Thanks a lot for the explanation and fi

[jira] [Assigned] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20068: Assignee: Jiangjie Qin > KafkaSubscriberTest.testTopicPatternSubscriber failed with unexp

[jira] [Resolved] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-20068. -- Fix Version/s: 1.11.3 Resolution: Fixed Merged to master. cacb4c1fb1d6123d0aeb93d550ffc

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229801#comment-17229801 ] Robert Metzger commented on FLINK-19964: Thanks a lot for the fix! > Gelly ITCa

[GitHub] [flink] becketqin closed pull request #14022: [FLINK-20068] Enhance the topic creation guarantee to ensure all the …

2020-11-10 Thread GitBox
becketqin closed pull request #14022: URL: https://github.com/apache/flink/pull/14022 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 t

[GitHub] [flink] becketqin commented on pull request #14022: [FLINK-20068] Enhance the topic creation guarantee to ensure all the …

2020-11-10 Thread GitBox
becketqin commented on pull request #14022: URL: https://github.com/apache/flink/pull/14022#issuecomment-725251041 Merged to master. cacb4c1fb1d6123d0aeb93d550ffcafa6ad4a8fb Cherry-picked to 1.11: 18e4c1ba5b66c704b3ea7e5ba8fb7f3499207903 ---

[jira] [Assigned] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-19300: --- Assignee: Xiang Gao > Timer loss after restoring from savepoint > -

[jira] [Updated] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19300: --- Affects Version/s: 1.8.0 > Timer loss after restoring from savepoint > -

[jira] [Updated] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19300: --- Fix Version/s: 1.11.3 1.12.0 > Timer loss after restoring from savepoint

[jira] [Updated] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19300: --- Priority: Blocker (was: Critical) > Timer loss after restoring from savepoint > ---

[jira] [Comment Edited] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229796#comment-17229796 ] Tzu-Li (Gordon) Tai edited comment on FLINK-19300 at 11/11/20, 7:09 AM: --

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229796#comment-17229796 ] Tzu-Li (Gordon) Tai commented on FLINK-19300: - Just a comment on the severit

[jira] [Created] (FLINK-20084) Fix NPE when generating watermark for record whose rowtime field is null after watermark push down

2020-11-10 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20084: - Summary: Fix NPE when generating watermark for record whose rowtime field is null after watermark push down Key: FLINK-20084 URL: https://issues.apache.org/jira/browse/FLINK-200

[jira] [Comment Edited] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229790#comment-17229790 ] Tzu-Li (Gordon) Tai edited comment on FLINK-19300 at 11/11/20, 7:06 AM: --

[jira] [Comment Edited] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229790#comment-17229790 ] Tzu-Li (Gordon) Tai edited comment on FLINK-19300 at 11/11/20, 7:05 AM: --

[jira] [Comment Edited] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229790#comment-17229790 ] Tzu-Li (Gordon) Tai edited comment on FLINK-19300 at 11/11/20, 7:05 AM: --

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229793#comment-17229793 ] Tzu-Li (Gordon) Tai commented on FLINK-19300: - As for priority of this issue

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229790#comment-17229790 ] Tzu-Li (Gordon) Tai commented on FLINK-19300: - This looks like a real issue,

[jira] [Comment Edited] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229790#comment-17229790 ] Tzu-Li (Gordon) Tai edited comment on FLINK-19300 at 11/11/20, 7:03 AM: --

[jira] [Issue Comment Deleted] (FLINK-20004) UpperLimitExceptionParameter description is misleading

2020-11-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20004: --- Comment: was deleted (was: [~f.pompermaier], you could refer to MessageQueryParameter. In M

[jira] [Updated] (FLINK-20083) OrcFsStreamingSinkITCase times out

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20083: --- Fix Version/s: 1.12.0 > OrcFsStreamingSinkITCase times out > ---

[jira] [Assigned] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

2020-11-10 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20065: --- Assignee: Arvid Heise > UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutE

[jira] [Created] (FLINK-20083) OrcFsStreamingSinkITCase times out

2020-11-10 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20083: -- Summary: OrcFsStreamingSinkITCase times out Key: FLINK-20083 URL: https://issues.apache.org/jira/browse/FLINK-20083 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-20083) OrcFsStreamingSinkITCase times out

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20083: --- Priority: Critical (was: Major) > OrcFsStreamingSinkITCase times out >

[jira] [Updated] (FLINK-20083) OrcFsStreamingSinkITCase times out

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20083: --- Issue Type: Bug (was: Improvement) > OrcFsStreamingSinkITCase times out > -

[GitHub] [flink] AHeise commented on a change in pull request #14024: [FLINK-20079][task] Fix StreamTask initialization order

2020-11-10 Thread GitBox
AHeise commented on a change in pull request #14024: URL: https://github.com/apache/flink/pull/14024#discussion_r521147841 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java ## @@ -531,8 +534,10 @@ public void invoke(Long

[jira] [Commented] (FLINK-20046) StreamTableAggregateTests.test_map_view_iterate is instable

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229786#comment-17229786 ] Robert Metzger commented on FLINK-20046: https://dev.azure.com/rmetzger/Flink/_b

[jira] [Commented] (FLINK-20004) UpperLimitExceptionParameter description is misleading

2020-11-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229784#comment-17229784 ] Nicholas Jiang commented on FLINK-20004: [~f.pompermaier], you could refer to Me

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread david weinstein (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229782#comment-17229782 ] david weinstein commented on FLINK-19300: - We're using Flink version 1.8. > Tim

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229780#comment-17229780 ] Robert Metzger commented on FLINK-19300: Thanks a lot for reporting this. Which

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-10 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229777#comment-17229777 ] Arvid Heise commented on FLINK-19964: - Yes sorry about that, but I realized that exa

[jira] [Resolved] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-10 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19964. - Resolution: Fixed > Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph > -

[GitHub] [flink] AHeise merged pull request #14023: [FLINK-19964][network] Avoid proactively pulling segments in destroyed LocalBufferPool.

2020-11-10 Thread GitBox
AHeise merged pull request #14023: URL: https://github.com/apache/flink/pull/14023 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

2020-11-10 Thread GitBox
flinkbot edited a comment on pull request #14027: URL: https://github.com/apache/flink/pull/14027#issuecomment-725222729 ## CI report: * 6d29e26c756f853e68d2930a2fc9cdbf41174f2f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-10 Thread GitBox
flinkbot edited a comment on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725222918 ## CI report: * 0e105679613efd2a1ccc80b678445bbcc23042cb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur closed pull request #13677: Single task scheduler

2020-11-10 Thread GitBox
curcur closed pull request #13677: URL: https://github.com/apache/flink/pull/13677 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 t

[jira] [Created] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-10 Thread 陳昌倬
(陳昌倬) Attachments: image-20201110-060934.png Hi, * Our Flink application (Java 11 + Scala 2.12) has the following problem when executing it. It cannot be run in Flink cluster. * The problem is similar to https://issues.apache.org/jira/browse/SPARK-25047, so maybe the same fix shall be implemented in

[jira] [Commented] (FLINK-19044) Web UI reports incorrect timeline for the FINISHED state of a subtask

2020-11-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229766#comment-17229766 ] Robert Metzger commented on FLINK-19044: Is this a problem of the REST API, or i

[GitHub] [flink] becketqin commented on pull request #14022: [FLINK-20068] Enhance the topic creation guarantee to ensure all the …

2020-11-10 Thread GitBox
becketqin commented on pull request #14022: URL: https://github.com/apache/flink/pull/14022#issuecomment-725224684 @PatrickRen @Sxnan Thanks for helping verify the fix. I'll merge the PR now. This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-10 Thread GitBox
flinkbot commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725222918 ## CI report: * 0e105679613efd2a1ccc80b678445bbcc23042cb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229763#comment-17229763 ] Jiangjie Qin commented on FLINK-20068: -- This is a legacy issue caused by asynchrono

[GitHub] [flink] flinkbot commented on pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

2020-11-10 Thread GitBox
flinkbot commented on pull request #14027: URL: https://github.com/apache/flink/pull/14027#issuecomment-725222729 ## CI report: * 6d29e26c756f853e68d2930a2fc9cdbf41174f2f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-20074) ChangelogSourceITCase.testRegularJoin fail

2020-11-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20074: --- Labels: pull-request-available test-stability (was: test-stability) > ChangelogSourceITCase

[jira] [Resolved] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-13733. -- Fix Version/s: 1.11.3 Resolution: Fixed > FlinkKafkaInternalProducerITCase.testHappyPat

[GitHub] [flink] flinkbot commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-10 Thread GitBox
flinkbot commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725219422 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 pro

[jira] [Commented] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229761#comment-17229761 ] Jiangjie Qin commented on FLINK-13733: -- The patch has been merged to master. cb2d13

[jira] [Updated] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

2020-11-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20020: --- Labels: pull-request-available (was: ) > Make UnsuccessfulExecutionException part of the >

[GitHub] [flink] SteNicholas opened a new pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-10 Thread GitBox
SteNicholas opened a new pull request #14028: URL: https://github.com/apache/flink/pull/14028 ## What is the purpose of the change *Currently, different implementations of the `JobClient` throw different exceptions. The `ClusterClientJobClientAdapter` wraps the exception from the `J

[GitHub] [flink] flinkbot commented on pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

2020-11-10 Thread GitBox
flinkbot commented on pull request #14027: URL: https://github.com/apache/flink/pull/14027#issuecomment-725218189 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 pro

[GitHub] [flink] becketqin closed pull request #14021: [FLINK-13733][connector/kafka] Make FlinkKafkaInternalProducerITCase more robust

2020-11-10 Thread GitBox
becketqin closed pull request #14021: URL: https://github.com/apache/flink/pull/14021 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 t

[GitHub] [flink] becketqin commented on pull request #14021: [FLINK-13733][connector/kafka] Make FlinkKafkaInternalProducerITCase more robust

2020-11-10 Thread GitBox
becketqin commented on pull request #14021: URL: https://github.com/apache/flink/pull/14021#issuecomment-725218181 Merged to master. cb2d137adc9ea1e46a67513c1e0f2469bb05bff4 This is an automated message from the Apache Git

[GitHub] [flink] wuchong opened a new pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joini…

2020-11-10 Thread GitBox
wuchong opened a new pull request #14027: URL: https://github.com/apache/flink/pull/14027 …ng on changelog source without updates ## What is the purpose of the change This PR fixes the exception when get the plan of JOIN on changelog source which doesn't contain update

[GitHub] [flink] becketqin commented on pull request #14021: [FLINK-13733][connector/kafka] Make FlinkKafkaInternalProducerITCase more robust

2020-11-10 Thread GitBox
becketqin commented on pull request #14021: URL: https://github.com/apache/flink/pull/14021#issuecomment-725216164 @PatrickRen Thanks a lot for the thorough tests. The patch LGTM. This is an automated message from the Apache

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Fix Version/s: 1.12.0 > ExecutorNotifier should run handler in the main thread when receive an

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Affects Version/s: 1.11.2 > ExecutorNotifier should run handler in the main thread when receive

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Fix Version/s: 1.11.3 > ExecutorNotifier should run handler in the main thread when receive an

[jira] [Created] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-11-10 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-20081: Summary: ExecutorNotifier should run handler in the main thread when receive an exception from the callable. Key: FLINK-20081 URL: https://issues.apache.org/jira/browse/FLINK-2008

[jira] [Assigned] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-11-10 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20081: Assignee: Jiangjie Qin > ExecutorNotifier should run handler in the main thread when rece

[jira] [Commented] (FLINK-20065) UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229747#comment-17229747 ] Dian Fu commented on FLINK-20065: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-17096) Minibatch Group Agg support state ttl

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229745#comment-17229745 ] Dian Fu commented on FLINK-17096: - [~jark] Thanks a lot~ > Minibatch Group Agg support

[jira] [Commented] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229744#comment-17229744 ] Dian Fu commented on FLINK-19630: - [~neighborhood] Thanks a lot for the feedback. [~lzl

[jira] [Assigned] (FLINK-20074) ChangelogSourceITCase.testRegularJoin fail

2020-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20074: --- Assignee: Jark Wu > ChangelogSourceITCase.testRegularJoin fail > --

[jira] [Commented] (FLINK-18139) Unaligned checkpoints checks wrong channels for inflight data.

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229743#comment-17229743 ] Dian Fu commented on FLINK-18139: - [~AHeise] Could we close this ticket as the PR is alr

[jira] [Closed] (FLINK-18456) CompressionFactoryITCase.testWriteCompressedFile fails with "expected:<1> but was:<2>"

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18456. --- Resolution: Cannot Reproduce Closing this ticket for now as it has not occurred for almost half a year. > C

[jira] [Closed] (FLINK-18698) org.apache.flink.sql.parser.utils.ParserResource compile error

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18698. --- Resolution: Invalid Closing this ticket as it seems not a bug. > org.apache.flink.sql.parser.utils.ParserRe

[jira] [Commented] (FLINK-17096) Minibatch Group Agg support state ttl

2020-11-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229738#comment-17229738 ] Jark Wu commented on FLINK-17096: - Yes [~dian.fu]. I will review and merge this pull req

[jira] [Updated] (FLINK-19044) Web UI reports incorrect timeline for the FINISHED state of a subtask

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19044: Fix Version/s: 1.12.0 > Web UI reports incorrect timeline for the FINISHED state of a subtask > --

[jira] [Commented] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception

2020-11-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229736#comment-17229736 ] Jingsong Lee commented on FLINK-19630: -- [~lirui] I think we can document this. > S

[jira] [Updated] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19253: Fix Version/s: 1.12.0 > SourceReaderTestBase.testAddSplitToExistingFetcher hangs > ---

[jira] [Updated] (FLINK-19982) AggregateReduceGroupingITCase.testSingleAggOnTable_SortAgg fails with "RuntimeException: Job restarted"

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19982: Fix Version/s: 1.12.0 > AggregateReduceGroupingITCase.testSingleAggOnTable_SortAgg fails with > "RuntimeE

[jira] [Updated] (FLINK-19989) Add collect operation in Python DataStream API

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19989: Fix Version/s: 1.13.0 > Add collect operation in Python DataStream API > -

[jira] [Updated] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20030: Fix Version/s: 1.12.0 > Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken >

[jira] [Commented] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception

2020-11-10 Thread Lsw_aka_laplace (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229732#comment-17229732 ] Lsw_aka_laplace commented on FLINK-19630: - [~dian.fu] Hi, Actually I have solve

[jira] [Closed] (FLINK-20066) BatchPandasUDAFITTests.test_group_aggregate_with_aux_group unstable

2020-11-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20066. --- Resolution: Fixed This should have been address in FLINK-19842 > BatchPandasUDAFITTests.test_group_aggregat

[GitHub] [flink] flinkbot edited a comment on pull request #14021: [FLINK-13733][connector/kafka] Make FlinkKafkaInternalProducerITCase more robust

2020-11-10 Thread GitBox
flinkbot edited a comment on pull request #14021: URL: https://github.com/apache/flink/pull/14021#issuecomment-724820662 ## CI report: * 685a334e4b6fa71ee9a95c74aaf3b7ba2557d05e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   >