[GitHub] [flink] StephanEwen edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
StephanEwen edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-586354299 Interestingly, with proper eager closing of the directory streams, the workaround in

[GitHub] [flink-statefun] StephanEwen merged pull request #24: [FLINK-16066] StateBinder binds persisted values in inner class

2020-02-14 Thread GitBox
StephanEwen merged pull request #24: [FLINK-16066] StateBinder binds persisted values in inner class URL: https://github.com/apache/flink-statefun/pull/24 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink-statefun] StephanEwen commented on issue #24: [FLINK-16066] StateBinder binds persisted values in inner class

2020-02-14 Thread GitBox
StephanEwen commented on issue #24: [FLINK-16066] StateBinder binds persisted values in inner class URL: https://github.com/apache/flink-statefun/pull/24#issuecomment-586389984 Looks good, will merge this. This is an

[jira] [Assigned] (FLINK-16061) Disable state multiplexing

2020-02-14 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16061: Assignee: Igal Shilman > Disable state multiplexing > -- > >

[GitHub] [flink-statefun] StephanEwen merged pull request #19: [FLINK-15956] Add HTTP function protocol

2020-02-14 Thread GitBox
StephanEwen merged pull request #19: [FLINK-15956] Add HTTP function protocol URL: https://github.com/apache/flink-statefun/pull/19 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Assigned] (FLINK-16066) StateBinder should pickup persisted values in inner class

2020-02-14 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16066: Assignee: Igal Shilman > StateBinder should pickup persisted values in inner class >

[jira] [Assigned] (FLINK-16062) Remove the use of a checkpointLock

2020-02-14 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16062: Assignee: Igal Shilman > Remove the use of a checkpointLock >

[GitHub] [flink-statefun] StephanEwen commented on issue #19: [FLINK-15956] Add HTTP function protocol

2020-02-14 Thread GitBox
StephanEwen commented on issue #19: [FLINK-15956] Add HTTP function protocol URL: https://github.com/apache/flink-statefun/pull/19#issuecomment-586388713 Thanks! Merging this... This is an automated message from the Apache

[jira] [Assigned] (FLINK-16020) Use Flink-1.10 released version instead of the snapshot version

2020-02-14 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16020: Assignee: Igal Shilman > Use Flink-1.10 released version instead of the snapshot version

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037130#comment-17037130 ] YufeiLiu commented on FLINK-15959: -- I've made some modification of description according to the

[jira] [Issue Comment Deleted] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Comment: was deleted (was: I've made some modification of description according to the comments,

[jira] [Comment Edited] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037120#comment-17037120 ] YufeiLiu edited comment on FLINK-15959 at 2/14/20 5:25 PM: --- I've made some

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037127#comment-17037127 ] YufeiLiu commented on FLINK-15959: -- I've made some modification of description according to the

[jira] [Issue Comment Deleted] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Comment: was deleted (was: I've made some modification of description according to the comments,

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-586287248 ## CI report: * 1529c3a8abb5e2b758e6a80e2f7359288f87e3d7 Travis:

[GitHub] [flink-statefun] StephanEwen commented on a change in pull request #19: [FLINK-15956] Add HTTP function protocol

2020-02-14 Thread GitBox
StephanEwen commented on a change in pull request #19: [FLINK-15956] Add HTTP function protocol URL: https://github.com/apache/flink-statefun/pull/19#discussion_r379549979 ## File path:

[GitHub] [flink-statefun] StephanEwen commented on a change in pull request #19: [FLINK-15956] Add HTTP function protocol

2020-02-14 Thread GitBox
StephanEwen commented on a change in pull request #19: [FLINK-15956] Add HTTP function protocol URL: https://github.com/apache/flink-statefun/pull/19#discussion_r379540884 ## File path:

[jira] [Commented] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037120#comment-17037120 ] YufeiLiu commented on FLINK-15959: -- I've made some modification of description according to the

[jira] [Updated] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Description: Flink removed `-n` option after FLIP-6, change to ResourceManager start a new worker when

[GitHub] [flink] rmetzger commented on a change in pull request #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-14 Thread GitBox
rmetzger commented on a change in pull request #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#discussion_r379543557 ## File path: tools/azure-pipelines/jobs-template.yml ## @@

[jira] [Updated] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Issue Type: Improvement (was: New Feature) > Add min/max number of slots configuration to limit total

[jira] [Updated] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Description: Flink removed `-n` option after FLIP-6, change to ResourceManager start a new worker when

[jira] [Updated] (FLINK-16066) StateBinder should pickup persisted values in inner class

2020-02-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16066: --- Labels: pull-request-available (was: ) > StateBinder should pickup persisted values in

[GitHub] [flink-statefun] StephanEwen merged pull request #23: [FLINK-16062][FLINK-16061] [FLINK-16020] Use Flink 1.10.0

2020-02-14 Thread GitBox
StephanEwen merged pull request #23: [FLINK-16062][FLINK-16061] [FLINK-16020] Use Flink 1.10.0 URL: https://github.com/apache/flink-statefun/pull/23 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-statefun] igalshilman opened a new pull request #24: [FLINK-16066] StateBinder binds persisted values in inner class

2020-02-14 Thread GitBox
igalshilman opened a new pull request #24: [FLINK-16066] StateBinder binds persisted values in inner class URL: https://github.com/apache/flink-statefun/pull/24 This PR enhance StateBinder to bind persisted values/tables that are defined within a class that is annotated with a

[GitHub] [flink-statefun] StephanEwen commented on issue #23: [FLINK-16062][FLINK-16061] [FLINK-16020] Use Flink 1.10.0

2020-02-14 Thread GitBox
StephanEwen commented on issue #23: [FLINK-16062][FLINK-16061] [FLINK-16020] Use Flink 1.10.0 URL: https://github.com/apache/flink-statefun/pull/23#issuecomment-586372433 Looks good to me! Will merge this... This is

[GitHub] [flink] flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-586287248 ## CI report: * 1529c3a8abb5e2b758e6a80e2f7359288f87e3d7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-585252480 ## CI report: * 7415250749dd788f3ed8abc7106593b7946db170 Travis:

[GitHub] [flink-statefun] StephanEwen commented on issue #21: [hotfix][README] Update the contribution section.

2020-02-14 Thread GitBox
StephanEwen commented on issue #21: [hotfix][README] Update the contribution section. URL: https://github.com/apache/flink-statefun/pull/21#issuecomment-586369868 Looks good, thanks for updating this. This is an automated

[GitHub] [flink-statefun] StephanEwen merged pull request #21: [hotfix][README] Update the contribution section.

2020-02-14 Thread GitBox
StephanEwen merged pull request #21: [hotfix][README] Update the contribution section. URL: https://github.com/apache/flink-statefun/pull/21 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#issuecomment-580319851 ## CI report: * 322bf186867ed0ec1a867ba7919e39e3c437aba0 Travis:

[GitHub] [flink] StephanEwen commented on issue #11085: [FLINK-16000] Move "Project Build Setup" to "Getting Started" in documentation

2020-02-14 Thread GitBox
StephanEwen commented on issue #11085: [FLINK-16000] Move "Project Build Setup" to "Getting Started" in documentation URL: https://github.com/apache/flink/pull/11085#issuecomment-586367351 I agree with both of Konstantin's suggestions. Maybe we could add a sentence that this is the

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

2020-02-14 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037105#comment-17037105 ] Liu commented on FLINK-16030: - Sorry for late reply. For quick fix, I send ping message to server and expect

[jira] [Updated] (FLINK-16062) Remove the use of a checkpointLock

2020-02-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16062: --- Labels: pull-request-available (was: ) > Remove the use of a checkpointLock >

[GitHub] [flink-statefun] igalshilman opened a new pull request #23: [FLINK-16062][FLINK-16061] [FLINK-16020] Use Flink 1.10.0

2020-02-14 Thread GitBox
igalshilman opened a new pull request #23: [FLINK-16062][FLINK-16061] [FLINK-16020] Use Flink 1.10.0 URL: https://github.com/apache/flink-statefun/pull/23 This PR uses the released Flink version, 1.10.0, instead of 1.10-SNAPSHOT. This includes the following: * Change the maven

[jira] [Updated] (FLINK-15959) Add min/max number of slots configuration to limit total number of slots

2020-02-14 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-15959: - Description: Flink removed `-n` option after FLIP-6, change to ResourceManager start a new worker when

[GitHub] [flink] StephanEwen commented on issue #11091: [FLINK-16041] Expand "popular" documentation sections by default

2020-02-14 Thread GitBox
StephanEwen commented on issue #11091: [FLINK-16041] Expand "popular" documentation sections by default URL: https://github.com/apache/flink/pull/11091#issuecomment-586361846 Looks good to me. +1 to merge this This is an

[GitHub] [flink] StephanEwen commented on issue #11087: [FLINK-16049] Remove outdated "Best Practices" section from Application Development Section

2020-02-14 Thread GitBox
StephanEwen commented on issue #11087: [FLINK-16049] Remove outdated "Best Practices" section from Application Development Section URL: https://github.com/apache/flink/pull/11087#issuecomment-586361030 +1 This is super outdated. Please merge this also for the `release-1.10`

[jira] [Commented] (FLINK-16030) Add heartbeat between netty server and client to detect long connection alive

2020-02-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037094#comment-17037094 ] Stephan Ewen commented on FLINK-16030: -- We had a discussion some time ago about "richer exception

[GitHub] [flink] flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-585252480 ## CI report: * 7415250749dd788f3ed8abc7106593b7946db170 Travis:

[GitHub] [flink] StephanEwen edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
StephanEwen edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-586354299 Interestingly, with proper eager closing of the directory streams, this workaround is also no longer

[GitHub] [flink] StephanEwen commented on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
StephanEwen commented on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-586354299 Interestingly, with proper eager closing of the directory streams, this workaround is also no longer

[jira] [Created] (FLINK-16067) Flink's CalciteParser swallows error position information

2020-02-14 Thread Fabian Hueske (Jira)
Fabian Hueske created FLINK-16067: - Summary: Flink's CalciteParser swallows error position information Key: FLINK-16067 URL: https://issues.apache.org/jira/browse/FLINK-16067 Project: Flink

[GitHub] [flink] StephanEwen commented on a change in pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
StephanEwen commented on a change in pull request #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#discussion_r379511980 ## File path:

[jira] [Commented] (FLINK-15998) In Glossary, make "Application Cluster" description more concise, don't mention job clusters

2020-02-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037069#comment-17037069 ] Aljoscha Krettek commented on FLINK-15998: -- Sure! > In Glossary, make "Application Cluster"

[GitHub] [flink] aljoscha commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

2020-02-14 Thread GitBox
aljoscha commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586343357 @pnowojski Wasn't there an issue that the Async I/O operator and continuous file reader should never be chained

[GitHub] [flink] flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor URL: https://github.com/apache/flink/pull/11098#issuecomment-586328210 ## CI report: * df7f0151d94bc7705c87baf855ae3d8d57f7e463 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests URL: https://github.com/apache/flink/pull/11096#issuecomment-586300012 ## CI report: * 6f1f37ee8baceee6d08b4c4d2439d46f2c144688 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * 8bdc077ea0813363d120eed404a2f4cd93ef0f9a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#issuecomment-580319851 ## CI report: * 322bf186867ed0ec1a867ba7919e39e3c437aba0 Travis:

[jira] [Created] (FLINK-16066) StateBinder should pickup persisted values in inner class

2020-02-14 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16066: Summary: StateBinder should pickup persisted values in inner class Key: FLINK-16066 URL: https://issues.apache.org/jira/browse/FLINK-16066 Project: Flink

[jira] [Commented] (FLINK-16061) Disable state multiplexing

2020-02-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037034#comment-17037034 ] Seth Wiesman commented on FLINK-16061: -- :) > Disable state multiplexing >

[jira] [Comment Edited] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-14 Thread Yu Li (Jira)
ULT:' > Picked up _JAVA_OPTIONS: > -Djava.io.tmpdir=/private/tmp/apache-flink-test-20200214-33361-1jotper > -Duser.home=/Users/jueding/Library/Caches/Homebrew/java_cache > Error: Could not find or load main class > org.apache.flink.runtime.util.BashJavaUtils > [ERROR] Could

[jira] [Created] (FLINK-16065) Unignore FileUtilsTest.testDeleteDirectoryConcurrently()

2020-02-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-16065: Summary: Unignore FileUtilsTest.testDeleteDirectoryConcurrently() Key: FLINK-16065 URL: https://issues.apache.org/jira/browse/FLINK-16065 Project: Flink

[jira] [Created] (FLINK-16064) Introduce HELM charts for StatefulFunctions

2020-02-14 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16064: Summary: Introduce HELM charts for StatefulFunctions Key: FLINK-16064 URL: https://issues.apache.org/jira/browse/FLINK-16064 Project: Flink Issue Type: Task

[jira] [Closed] (FLINK-12651) Add "Style Guide" to Documentation Contribution Guide

2020-02-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12651. Resolution: Fixed asf-site: 6b35e86404b04d90db7a3fbb665e4af80c10cabe > Add "Style Guide"

[GitHub] [flink] flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 Travis:

[GitHub] [flink] flinkbot commented on issue #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor

2020-02-14 Thread GitBox
flinkbot commented on issue #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor URL: https://github.com/apache/flink/pull/11098#issuecomment-586328210 ## CI report: * df7f0151d94bc7705c87baf855ae3d8d57f7e463 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

2020-02-14 Thread GitBox
flinkbot commented on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586328258 ## CI report: * 09de912ae24b854486670dd6122ea62758055bae UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-586287248 ## CI report: * 1529c3a8abb5e2b758e6a80e2f7359288f87e3d7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-585252480 ## CI report: * 7415250749dd788f3ed8abc7106593b7946db170 Travis:

[jira] [Created] (FLINK-16063) Add back-pressure mechanism

2020-02-14 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16063: Summary: Add back-pressure mechanism Key: FLINK-16063 URL: https://issues.apache.org/jira/browse/FLINK-16063 Project: Flink Issue Type: Task

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * 8bdc077ea0813363d120eed404a2f4cd93ef0f9a Travis:

[jira] [Created] (FLINK-16062) Remove the use of a checkpointLock

2020-02-14 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16062: Summary: Remove the use of a checkpointLock Key: FLINK-16062 URL: https://issues.apache.org/jira/browse/FLINK-16062 Project: Flink Issue Type: Task

[jira] [Closed] (FLINK-15969) Do not multiplex both PersistedValue and PersistedTable with a single MapState state handle

2020-02-14 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-15969. Resolution: Won't Fix There is no need for state multiplexing anymore > Do not multiplex both

[GitHub] [flink] flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#issuecomment-580319851 ## CI report: * 322bf186867ed0ec1a867ba7919e39e3c437aba0 Travis:

[jira] [Created] (FLINK-16061) Disable state multiplexing

2020-02-14 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16061: Summary: Disable state multiplexing Key: FLINK-16061 URL: https://issues.apache.org/jira/browse/FLINK-16061 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-16052) Homebrew test failed with 1.10.0 dist package

2020-02-14 Thread Yu Li (Jira)
BashJavaUtils > [ERROR] The last line of the BashJavaUtils outputs is expected to be the > execution result, following the prefix 'BASH_JAVA_UTILS_EXEC_RESULT:' > Picked up _JAVA_OPTIONS: > -Djava.io.tmpdir=/private/tmp/apache-flink-test-20200214-33361-1jotper > -Duser.home=/Users/jued

[GitHub] [flink] AHeise commented on a change in pull request #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests

2020-02-14 Thread GitBox
AHeise commented on a change in pull request #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests URL: https://github.com/apache/flink/pull/11096#discussion_r379471450 ## File path:

[GitHub] [flink] wuchong commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource

2020-02-14 Thread GitBox
wuchong commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource URL: https://github.com/apache/flink/pull/10005#issuecomment-586319303 Once @godfreyhe is fine with the changes on `TestingFilterableTableSource`, I think it can be

[GitHub] [flink] libenchao closed pull request #11040: [hotfix] Copy StreamWindowSQLExample.jar to target dir

2020-02-14 Thread GitBox
libenchao closed pull request #11040: [hotfix] Copy StreamWindowSQLExample.jar to target dir URL: https://github.com/apache/flink/pull/11040 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] libenchao commented on issue #11040: [hotfix] Copy StreamWindowSQLExample.jar to target dir

2020-02-14 Thread GitBox
libenchao commented on issue #11040: [hotfix] Copy StreamWindowSQLExample.jar to target dir URL: https://github.com/apache/flink/pull/11040#issuecomment-586316925 closing because https://github.com/apache/flink/commit/edfbbb71d21e766749a2ea52db5cc94c863301e7 has fixed this issue.

[jira] [Closed] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set.

2020-02-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1730. --- Resolution: Won't Do I'm closing this now since there is no more activity and the code base

[jira] [Closed] (FLINK-2245) Programs that contain collect() reported as multiple jobs in the Web frontend

2020-02-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2245. --- Resolution: Won't Do I'm closing this now since there is no more activity and the code base

[GitHub] [flink] flinkbot commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

2020-02-14 Thread GitBox
flinkbot commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586314064 ## CI report: * 696fdaf53d04470d7e2917a3d88b3738408eb849 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11096: [FLINK-16056][runtime][tests] fix CFRO creation in tests URL: https://github.com/apache/flink/pull/11096#issuecomment-586300012 ## CI report: * 6f1f37ee8baceee6d08b4c4d2439d46f2c144688 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11094: [hotfix][table-common] Remove deprecated DataTypes.ANY(...)

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11094: [hotfix][table-common] Remove deprecated DataTypes.ANY(...) URL: https://github.com/apache/flink/pull/11094#issuecomment-586275479 ## CI report: * 2e17b27cf25fd5c52cce8c9c295c45cc9ccae724 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-585252480 ## CI report: * 7415250749dd788f3ed8abc7106593b7946db170 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * 8bdc077ea0813363d120eed404a2f4cd93ef0f9a Travis:

[GitHub] [flink] YuvalItzchakov commented on issue #9780: [FLINK-14042] [flink-table-planner] Fix TemporalTable row schema always inferred as nullable

2020-02-14 Thread GitBox
YuvalItzchakov commented on issue #9780: [FLINK-14042] [flink-table-planner] Fix TemporalTable row schema always inferred as nullable URL: https://github.com/apache/flink/pull/9780#issuecomment-586311747 @twalthr @aljoscha Did anything change with respect to Flink 1.10 on this issue?

[GitHub] [flink] flinkbot commented on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

2020-02-14 Thread GitBox
flinkbot commented on issue #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099#issuecomment-586311345 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines

2020-02-14 Thread GitBox
flinkbot edited a comment on issue #10976: [FLINK-13978][build system] Add experimental support for building on Azure Pipelines URL: https://github.com/apache/flink/pull/10976#issuecomment-580319851 ## CI report: * 322bf186867ed0ec1a867ba7919e39e3c437aba0 Travis:

[jira] [Updated] (FLINK-16038) Expose hitRate metric for JDBCLookupFunction

2020-02-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16038: --- Labels: pull-request-available (was: ) > Expose hitRate metric for JDBCLookupFunction >

[GitHub] [flink] YuvalItzchakov commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource

2020-02-14 Thread GitBox
YuvalItzchakov commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource URL: https://github.com/apache/flink/pull/10005#issuecomment-586310807 Is there anything else I can do to push this through? @aljoscha

[GitHub] [flink] libenchao opened a new pull request #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction

2020-02-14 Thread GitBox
libenchao opened a new pull request #11099: [FLINK-16038][jdbc] Add hitRate metric for JDBCLookupFunction URL: https://github.com/apache/flink/pull/11099 ## What is the purpose of the change Add hitRate metric for JDBCLookupFunction. ## Brief change log Add a

[GitHub] [flink] flinkbot commented on issue #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor

2020-02-14 Thread GitBox
flinkbot commented on issue #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor URL: https://github.com/apache/flink/pull/11098#issuecomment-586308473 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-16060) Create MVP of multiple input processor

2020-02-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16060: --- Labels: pull-request-available (was: ) > Create MVP of multiple input processor >

[GitHub] [flink] pnowojski opened a new pull request #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor

2020-02-14 Thread GitBox
pnowojski opened a new pull request #11098: [FLINK-16060][task] Implement working StreamMultipleInputProcessor URL: https://github.com/apache/flink/pull/11098 This PR adds a basic support for multiple input operators and relevant interfaces. This doesn't fully support input

[jira] [Updated] (FLINK-15331) Create a table from a changelog

2020-02-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15331: Description: This an umbrella issue for the feature of interpreting a changelog as a table. It can be

[jira] [Assigned] (FLINK-15331) Create a table from a changelog

2020-02-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15331: --- Assignee: Jark Wu > Create a table from a changelog > --- > >

[jira] [Created] (FLINK-16060) Create MVP of multiple input processor

2020-02-14 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-16060: -- Summary: Create MVP of multiple input processor Key: FLINK-16060 URL: https://issues.apache.org/jira/browse/FLINK-16060 Project: Flink Issue Type:

[jira] [Updated] (FLINK-16059) Order properties in REST API docs alphabetically

2020-02-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16059: - Issue Type: Improvement (was: Bug) > Order properties in REST API docs alphabetically

[jira] [Updated] (FLINK-16059) Order properties in REST API docs alphabetically

2020-02-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16059: - Priority: Minor (was: Major) > Order properties in REST API docs alphabetically >

[jira] [Closed] (FLINK-16059) Order properties in REST API docs alphabetically

2020-02-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16059. Resolution: Fixed master: 59882813be3cc0e324017c099108367f18a7027a > Order properties

[GitHub] [flink] flinkbot commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default

2020-02-14 Thread GitBox
flinkbot commented on issue #11097: [FLINK-16057][runtime] chain ContinuousFileReaderOperator by default URL: https://github.com/apache/flink/pull/11097#issuecomment-586301026 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

2020-02-14 Thread GitBox
zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r379444141 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -168,6 +168,14 @@

<    1   2   3   4   >