[GitHub] [flink] flinkbot commented on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

flinkbot commented on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868#issuecomment-575029714 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] klion26 edited a comment on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

klion26 edited a comment on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868#issuecomment-575028797 cc @carp84 @wuchong This is an automated m

[GitHub] [flink] klion26 commented on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

klion26 commented on issue #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868#issuecomment-575028797 cc @carp84 This is an automated message from the

[GitHub] [flink] klion26 opened a new pull request #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock

klion26 opened a new pull request #10868: [FLINK-15278][docs-zh] Update Chinese version StreamingFileSink dock URL: https://github.com/apache/flink/pull/10868 ## What is the purpose of the change Sync the Chinese version doc of `StreamingFileSink` ## Verifying this change

[GitHub] [flink] xintongsong commented on a change in pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

xintongsong commented on a change in pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#discussion_r367270089 ## File path: flink-yarn/src/test/java/org

[GitHub] [flink] flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-572897310 ## CI report: * 6a9eb6f6b70dc406a0c2285da4b02b17a18e4c7b Travis: [SUCCESS](https://travis-ci.c

[jira] [Created] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

Yangze Guo created FLINK-15611: -- Summary: KafkaITCase.testOneToOneSources fails on Travis Key: FLINK-15611 URL: https://issues.apache.org/jira/browse/FLINK-15611 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-15608) State Processor api Write new state will get NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-15608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HunterHunter closed FLINK-15608. > State Processor api Write new state will get NullPointerException > --

[jira] [Resolved] (FLINK-15608) State Processor api Write new state will get NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-15608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HunterHunter resolved FLINK-15608. -- Resolution: Not A Bug flink-state-processor-api 1.9.0  are not compatible flink-runtime 1.9.1

[jira] [Comment Edited] (FLINK-10308) remove docker folder

[ https://issues.apache.org/jira/browse/FLINK-10308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016481#comment-17016481 ] ptmagic edited comment on FLINK-10308 at 1/16/20 7:12 AM: -- Plea

[jira] [Comment Edited] (FLINK-15176) Add '--job-classname' to flink-container 'job-cluster-job.yaml.template'

[ https://issues.apache.org/jira/browse/FLINK-15176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016478#comment-17016478 ] ptmagic edited comment on FLINK-15176 at 1/16/20 7:12 AM: -- Plea

[jira] [Comment Edited] (FLINK-10140) Log files are not available via web UI in containerized environment

[ https://issues.apache.org/jira/browse/FLINK-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016495#comment-17016495 ] ptmagic edited comment on FLINK-10140 at 1/16/20 7:12 AM: -- Star

[jira] [Commented] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016607#comment-17016607 ] Jingsong Lee commented on FLINK-15609: -- Hi [~jark] , these new functions can be use

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table…

flinkbot edited a comment on issue #10822: [FLINK-15081][docs-zh]Translate "Concepts & Common API" page of Table… URL: https://github.com/apache/flink/pull/10822#issuecomment-572897310 ## CI report: * 6a9eb6f6b70dc406a0c2285da4b02b17a18e4c7b Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] curcur edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-575012464 Thank you so much @zhuzhurk for reviewing the code and providing great suggestions and feed

[GitHub] [flink] curcur commented on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-575012464 Thank you so much @zhuzhurk for reviewing the code and providing great suggestions and feedbacks!

[GitHub] [flink] KarmaGYZ edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

KarmaGYZ edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-574945954 Thanks a lot to point out this @tillrohrmann . I update the PR. E2E tests passed https://travis-ci.org/

[jira] [Comment Edited] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016596#comment-17016596 ] Jark Wu edited comment on FLINK-15609 at 1/16/20 6:43 AM: -- Shou

[jira] [Commented] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016596#comment-17016596 ] Jark Wu commented on FLINK-15609: - Should we mark a higher priority for this issue. AFAI

[GitHub] [flink] flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-574982744 ## CI report: * 3d94fa8f5a675706dcb974b397452d165bcee987 Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae Travis: [SUCCESS](ht

[jira] [Updated] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

[ https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-15610: -- Description: For example:[https://help.aliyun.com/knowledge_detail/98948.html?spm=a2c4g.11186631.2.3.

[jira] [Created] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

hehuiyuan created FLINK-15610: - Summary: How to achieve the udf that the number of return column is uncertain Key: FLINK-15610 URL: https://issues.apache.org/jira/browse/FLINK-15610 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] yanghua commented on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

yanghua commented on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574997174 Hi @aljoscha Can you please review this PR? I have also updated the NOTICE file.

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-574982744 ## CI report: * 3d94fa8f5a675706dcb974b397452d165bcee987 Travis: [PENDING](ht

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

flinkbot commented on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-574982744 ## CI report: * 3d94fa8f5a675706dcb974b397452d165bcee987 UNKNOWN Bot comma

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550 ## CI report: * 7a61978007a5a02723a561ee145d82e2413e51ae Travis: [SUCCESS](ht

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] klion26 commented on a change in pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

klion26 commented on a change in pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#discussion_r367226527 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jobm

[GitHub] [flink] flinkbot commented on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

flinkbot commented on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-574976242 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[jira] [Created] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

Jingsong Lee created FLINK-15609: Summary: Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions Key: FLINK-15609 URL: https://issues.apache.org/jira/browse/FLINK-15609

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14701: --- Labels: pull-request-available (was: ) > Slot leaks if SharedSlotOversubscribedException ha

[GitHub] [flink] zhuzhurk opened a new pull request #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

zhuzhurk opened a new pull request #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867 ## What is the purpose of the change If a SharedSlotOversubscribedException happens, the MultiTaskSlot wi

[GitHub] [flink] flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574591161 ## CI report: * f4506ad0e9302a279940670fa90c305c240b3c12 Travis: [SUCCESS](

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r367223282 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Fix Version/s: (was: 1.11.0) > Slot leaks if SharedSlotOversubscribedException happens > -

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Fix Version/s: 1.11.0 1.9.2 > Slot leaks if SharedSlotOversubscribedException happens >

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Affects Version/s: (was: 1.10.0) > Slot leaks if SharedSlotOversubscribedException happens > -

[jira] [Reopened] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-14701: - Assignee: Zhu Zhu Reopen this issue since it's still a issue in 1.9 and we should fix it. > Slot leak

[jira] [Issue Comment Deleted] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Comment: was deleted (was: This issue does not exist anymore since SharedSlotOversubscribedException is r

[jira] [Created] (FLINK-15608) State Processor api Write new state will get NullPointerException

HunterHunter created FLINK-15608: Summary: State Processor api Write new state will get NullPointerException Key: FLINK-15608 URL: https://issues.apache.org/jira/browse/FLINK-15608 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574591161 ## CI report: * f4506ad0e9302a279940670fa90c305c240b3c12 Travis: [PENDING](

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis: [FA

[GitHub] [flink] flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574591065 ## CI report: * 5f9cd2224ef458e5068f3179aa5be025848f8723 Travis: [SUCCESS](https://t

[jira] [Commented] (FLINK-15599) SQL client requires both legacy and blink planner to be on the classpath

[ https://issues.apache.org/jira/browse/FLINK-15599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016517#comment-17016517 ] Jingsong Lee commented on FLINK-15599: -- We can port {{FunctionService}} to table-co

[jira] [Closed] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-14701. --- Fix Version/s: (was: 1.9.2) (was: 1.10.0) Resolution: Won't Fix This issue

[jira] [Commented] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016512#comment-17016512 ] Zhenghua Gao commented on FLINK-15602: -- Hi [~dwysakowicz] [~tiwalter] I investigate

[GitHub] [flink] qiuxiafei commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

qiuxiafei commented on a change in pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#discussion_r367216115 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/dataproc/vector/Ve

[GitHub] [flink] flinkbot edited a comment on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

flinkbot edited a comment on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685#issuecomment-568872421 ## CI report: * 18d9268b1f2106fceaffe388ff9e4e1babdad452 Azure: [SUCCESS](h

[jira] [Comment Edited] (FLINK-15546) Obscure error message from ScalarOperatorGens::generateCast

[ https://issues.apache.org/jira/browse/FLINK-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016491#comment-17016491 ] Jingsong Lee edited comment on FLINK-15546 at 1/16/20 3:27 AM: ---

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[jira] [Commented] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016504#comment-17016504 ] Jingsong Lee commented on FLINK-15607: -- > add restart process into the test to veri

[jira] [Issue Comment Deleted] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15582: Comment: was deleted (was: [~trohrmann] this is a pre-requisite for removing LegacyScheduler but I think

[jira] [Updated] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15582: Fix Version/s: (was: 1.10.0) 1.11.0 > Enable batch scheduling tests in LegacySchedu

[jira] [Closed] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-15307. --- Resolution: Fixed Fixed via: master: 5984e7e363c87ebef4e6a9b501ca36d9d20fe798 > Subclasses of FailoverStra

[GitHub] [flink] zhuzhurk closed pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

zhuzhurk closed pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848 This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink] flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574591161 ## CI report: * f4506ad0e9302a279940670fa90c305c240b3c12 Travis: [PENDING](

[jira] [Commented] (FLINK-10140) Log files are not available via web UI in containerized environment

[ https://issues.apache.org/jira/browse/FLINK-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016495#comment-17016495 ] ptmagic commented on FLINK-10140: - Start the job manager or task manager in the backgrou

[GitHub] [flink] xintongsong commented on a change in pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

xintongsong commented on a change in pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#discussion_r367211936 ## File path: flink-yarn/src/main/java/org

[jira] [Commented] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016492#comment-17016492 ] Jark Wu commented on FLINK-15607: - [~lzljs3620320] Thanks for pointing it out, however,

[jira] [Commented] (FLINK-15546) Obscure error message from ScalarOperatorGens::generateCast

[ https://issues.apache.org/jira/browse/FLINK-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016491#comment-17016491 ] Jingsong Lee commented on FLINK-15546: -- [~docete] Yes, do you want to fix this and

[GitHub] [flink] xintongsong commented on a change in pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

xintongsong commented on a change in pull request #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#discussion_r367209409 ## File path: flink-yarn/src/test/java/org

[GitHub] [flink] flinkbot edited a comment on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

flinkbot edited a comment on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685#issuecomment-568872421 ## CI report: * 18d9268b1f2106fceaffe388ff9e4e1babdad452 Azure: [SUCCESS](h

[jira] [Commented] (FLINK-15603) Show "barrier lag" in checkpoint statistics

[ https://issues.apache.org/jira/browse/FLINK-15603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016484#comment-17016484 ] Congxian Qiu(klion26) commented on FLINK-15603: --- And we may add some debug

[GitHub] [flink] flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

flinkbot edited a comment on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-568630874 ## CI report: * 1e6a533950438cf87afae1af481e227f5671688b Travis: [SUCCESS](https://travis-ci.c

[jira] [Commented] (FLINK-10308) remove docker folder

[ https://issues.apache.org/jira/browse/FLINK-10308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016481#comment-17016481 ] ptmagic commented on FLINK-10308: - Please assign to me > remove docker folder > ---

[jira] [Commented] (FLINK-15176) Add '--job-classname' to flink-container 'job-cluster-job.yaml.template'

[ https://issues.apache.org/jira/browse/FLINK-15176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016478#comment-17016478 ] ptmagic commented on FLINK-15176: - Please assign to me，look like add some comment to job

[GitHub] [flink] JingsongLi commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

JingsongLi commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f… URL: https://github.com/apache/flink/pull/10857#issuecomment-574957473 > @JingsongLi This PR is for FLINK-15592 - Batch mode not work too. - ROW_NUMBER is the function rela

[GitHub] [flink] zjffdu commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

zjffdu commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f… URL: https://github.com/apache/flink/pull/10857#issuecomment-574956435 @JingsongLi This PR is for FLINK-15592 This is an

[GitHub] [flink] flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574591065 ## CI report: * 5f9cd2224ef458e5068f3179aa5be025848f8723 Travis: [SUCCESS](https://t

[GitHub] [flink] yanghua commented on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

yanghua commented on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574954559 @flinkbot run travis This is

[GitHub] [flink] yanghua commented on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

yanghua commented on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574954527 Relevant test error. rebuild now.

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-15247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016473#comment-17016473 ] vinoyang commented on FLINK-15247: -- Another instance: https://api.travis-ci.com/v3/job/

[jira] [Commented] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016469#comment-17016469 ] Jingsong Lee commented on FLINK-15607: -- [~jark] We have tests, though very simple.

[jira] [Commented] (FLINK-15599) SQL client requires both legacy and blink planner to be on the classpath

[ https://issues.apache.org/jira/browse/FLINK-15599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016467#comment-17016467 ] Jingsong Lee commented on FLINK-15599: -- Thanks [~dwysakowicz] , Good catch! +1, loo

[GitHub] [flink] flinkbot edited a comment on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

flinkbot edited a comment on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685#issuecomment-568872421 ## CI report: * 18d9268b1f2106fceaffe388ff9e4e1babdad452 Azure: [SUCCESS](h

[jira] [Commented] (FLINK-15607) throw exception when users trying to use Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016461#comment-17016461 ] Jark Wu commented on FLINK-15607: - I discussed with [~lzljs3620320] about this yesterday

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r367200322 ## File path: flink-streaming-java/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574591065 ## CI report: * 5f9cd2224ef458e5068f3179aa5be025848f8723 Travis: [SUCCESS](https://t

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r367200322 ## File path: flink-streaming-java/src/mai

[GitHub] [flink] KarmaGYZ commented on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

KarmaGYZ commented on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-574945954 Thanks a lot to point out this @tillrohrmann . I update the PR.

[GitHub] [flink] banmoy commented on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

banmoy commented on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685#issuecomment-574942577 @flinkbot run travis This is a

[GitHub] [flink] xintongsong commented on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

xintongsong commented on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574942430 Thank you @tillrohrmann. I've addressed your comments. -

[GitHub] [flink] banmoy commented on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible

banmoy commented on issue #10685: [FLINK-14843][e2e] Refactor bucketing sink test to make it more stable and comprehensible URL: https://github.com/apache/flink/pull/10685#issuecomment-574942495 travis on ce56c02 failed with `BackPressureITCase` which is tracked in [FLINK-15247](https://is

[jira] [Updated] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Description: To use plugin library you need to add it to the flink classpath. The documentation explains

[jira] [Updated] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Labels: (was: pull-request-available) > Add custom libs to Flink classpath with an environment variable.

  1   2   3   4   5   >