[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security vulnerabi

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security vulnerabi

[GitHub] [flink] zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

2019-04-08 Thread GitBox
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r272989781 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security vulnerabi

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

2019-04-08 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security vulnerabi

[GitHub] [flink] flinkbot commented on issue #8122: [FLINK-12121] [State Backends] Use composition instead of inheritance for the InternalKeyContext logic in backend

2019-04-08 Thread GitBox
flinkbot commented on issue #8122: [FLINK-12121] [State Backends] Use composition instead of inheritance for the InternalKeyContext logic in backend URL: https://github.com/apache/flink/pull/8122#issuecomment-480782903 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Comment Edited] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-04-08 Thread Tony Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812308#comment-16812308 ] Tony Xintong Song edited comment on FLINK-12122 at 4/8/19 10:50 AM: --

[jira] [Updated] (FLINK-12121) Use composition instead of inheritance for the InternalKeyContext logic in backend

2019-04-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12121: --- Labels: pull-request-available (was: ) > Use composition instead of inheritance for the Int

[GitHub] [flink] carp84 opened a new pull request #8122: [FLINK-12121] [State Backends] Use composition instead of inheritance for the InternalKeyContext logic in backend

2019-04-08 Thread GitBox
carp84 opened a new pull request #8122: [FLINK-12121] [State Backends] Use composition instead of inheritance for the InternalKeyContext logic in backend URL: https://github.com/apache/flink/pull/8122 ## What is the purpose of the change This PR changes keyed backend to use compositi

[jira] [Comment Edited] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-04-08 Thread Tony Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812308#comment-16812308 ] Tony Xintong Song edited comment on FLINK-12122 at 4/8/19 10:46 AM: --

[jira] [Assigned] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu reassigned FLINK-10437: -- Assignee: Ji Liu > Some of keys under withDeprecatedKeys aren't marked as @depreacted > -

[jira] [Comment Edited] (FLINK-7916) Remove NetworkStackThroughputITCase

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812155#comment-16812155 ] Ji Liu edited comment on FLINK-7916 at 4/8/19 10:40 AM: Agree, I

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272976560 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginUtils

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272975453 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginUtils

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272975830 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginUtils

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-04-08 Thread Tony Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812308#comment-16812308 ] Tony Xintong Song commented on FLINK-12122: --- Hi [~till.rohrmann], I agree with

[jira] [Comment Edited] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812271#comment-16812271 ] Ji Liu edited comment on FLINK-10437 at 4/8/19 10:12 AM: - I have

[jira] [Assigned] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

2019-04-08 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8902: -- Assignee: Andrey Zagrebin > Re-scaling job sporadically fails with KeeperException > -

[GitHub] [flink] zhijiangW commented on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

2019-04-08 Thread GitBox
zhijiangW commented on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor URL: https://github.com/apache/flink/pull/7835#issuecomment-480765630 Thanks for reviews and above suggestions @azagrebin .

[GitHub] [flink] twalthr commented on a change in pull request #8062: [FLINK-11884][table] Implement expression resolution on top of new Expressions

2019-04-08 Thread GitBox
twalthr commented on a change in pull request #8062: [FLINK-11884][table] Implement expression resolution on top of new Expressions URL: https://github.com/apache/flink/pull/8062#discussion_r272965435 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/ta

[jira] [Closed] (FLINK-12106) Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an

2019-04-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-12106. - Resolution: Duplicate Thanks for reporting this issue [~Hutchins]. [~maguowei] is right and this

[jira] [Updated] (FLINK-12123) Upgrade Jepsen to 0.1.13 in flink-jepsen

2019-04-08 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-12123: - Fix Version/s: (was: 1.8.0) 1.9.0 > Upgrade Jepsen to 0.1.13 in flink-jepsen > --

[jira] [Updated] (FLINK-12123) Upgrade Jepsen to 0.1.13 in flink-jepsen

2019-04-08 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-12123: - Description: Raise version of the jepsen dependency in {{flink-jepsen/project.clj}} to 0.1.13. (was: Ra

[jira] [Created] (FLINK-12123) Upgrade Jepsen to 0.1.13 in flink-jepsen

2019-04-08 Thread Gary Yao (JIRA)
Gary Yao created FLINK-12123: Summary: Upgrade Jepsen to 0.1.13 in flink-jepsen Key: FLINK-12123 URL: https://issues.apache.org/jira/browse/FLINK-12123 Project: Flink Issue Type: Improvement

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272965384 ## File path: flink-table/flink-table-runtime-blink/src/

[GitHub] [flink] twalthr commented on a change in pull request #8062: [FLINK-11884][table] Implement expression resolution on top of new Expressions

2019-04-08 Thread GitBox
twalthr commented on a change in pull request #8062: [FLINK-11884][table] Implement expression resolution on top of new Expressions URL: https://github.com/apache/flink/pull/8062#discussion_r272964598 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/ta

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272964014 ## File path: flink-table/flink-table-runtime-blink/src/

issues@flink.apache.org

2019-04-08 Thread Lifei Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812283#comment-16812283 ] Lifei Chen commented on FLINK-7464: --- Hi,  [~sunjincheng121],  I think `FIRST_VALUE` and

[jira] [Assigned] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-04-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-12122: - Assignee: Till Rohrmann > Spread out tasks evenly across all available registered TaskM

[jira] [Created] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-04-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-12122: - Summary: Spread out tasks evenly across all available registered TaskManagers Key: FLINK-12122 URL: https://issues.apache.org/jira/browse/FLINK-12122 Project: Flink

[jira] [Comment Edited] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812271#comment-16812271 ] Ji Liu edited comment on FLINK-10437 at 4/8/19 9:34 AM: [~Tison]

[jira] [Commented] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread Ji Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812271#comment-16812271 ] Ji Liu commented on FLINK-10437: [~Tison] I have checked usages of _ConfigOption.withDep

[jira] [Commented] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded

2019-04-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812268#comment-16812268 ] sunjincheng commented on FLINK-10984: - +1 for this proposal. I think this JIRA shoul

[GitHub] [flink] tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers

2019-04-08 Thread GitBox
tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers URL: https://github.com/apache/flink/pull/8002#discussion_r272951340 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/m

[jira] [Commented] (FLINK-12008) Support read a whole directory or multiple input data files for read apis of HadoopInputs

2019-04-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812265#comment-16812265 ] Fabian Hueske commented on FLINK-12008: --- Yes, IIRC we recently added support for m

[GitHub] [flink] tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers

2019-04-08 Thread GitBox
tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers URL: https://github.com/apache/flink/pull/8002#discussion_r272955876 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/m

[GitHub] [flink] tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers

2019-04-08 Thread GitBox
tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers URL: https://github.com/apache/flink/pull/8002#discussion_r272954758 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/m

[jira] [Updated] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded

2019-04-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10984: --- Labels: pull-request-available (was: ) > Move flink-shaded-hadoop to flink-shaded > ---

[GitHub] [flink] tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers

2019-04-08 Thread GitBox
tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers URL: https://github.com/apache/flink/pull/8002#discussion_r272951210 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/m

[GitHub] [flink] tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers

2019-04-08 Thread GitBox
tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers URL: https://github.com/apache/flink/pull/8002#discussion_r272956271 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/m

[GitHub] [flink] tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers

2019-04-08 Thread GitBox
tillrohrmann commented on a change in pull request #8002: [FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters Suppliers URL: https://github.com/apache/flink/pull/8002#discussion_r272950654 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/m

[GitHub] [flink] flinkbot commented on issue #8121: [FLINK-10437]Some of keys under withDeprecatedKeys aren't marked as @…

2019-04-08 Thread GitBox
flinkbot commented on issue #8121: [FLINK-10437]Some of keys under withDeprecatedKeys aren't marked as @… URL: https://github.com/apache/flink/pull/8121#issuecomment-480754474 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] tianchen92 opened a new pull request #8121: [FLINK-10437]Some of keys under withDeprecatedKeys aren't marked as @…

2019-04-08 Thread GitBox
tianchen92 opened a new pull request #8121: [FLINK-10437]Some of keys under withDeprecatedKeys aren't marked as @… URL: https://github.com/apache/flink/pull/8121 …depreacted ## What is the purpose of the change *RestOptions#BIND_ADDRESS is withDeprecatedKeys(WebOptions

[jira] [Updated] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10437: --- Labels: pull-request-available (was: ) > Some of keys under withDeprecatedKeys aren't marke

[GitHub] [flink] tzulitai commented on a change in pull request #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends

2019-04-08 Thread GitBox
tzulitai commented on a change in pull request #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends URL: https://github.com/apache/flink/pull/8078#discussion_r272922134 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/

[GitHub] [flink] tzulitai commented on a change in pull request #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends

2019-04-08 Thread GitBox
tzulitai commented on a change in pull request #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends URL: https://github.com/apache/flink/pull/8078#discussion_r272921407 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/

[GitHub] [flink] tzulitai commented on a change in pull request #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends

2019-04-08 Thread GitBox
tzulitai commented on a change in pull request #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends URL: https://github.com/apache/flink/pull/8078#discussion_r272922020 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

2019-04-08 Thread GitBox
zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272944389 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[jira] [Commented] (FLINK-12121) Use composition instead of inheritance for the InternalKeyContext logic in backend

2019-04-08 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812243#comment-16812243 ] Yu Li commented on FLINK-12121: --- Mark as a blocker of FLINK-12066 > Use composition inste

[jira] [Created] (FLINK-12121) Use composition instead of inheritance for the InternalKeyContext logic in backend

2019-04-08 Thread Yu Li (JIRA)
Yu Li created FLINK-12121: - Summary: Use composition instead of inheritance for the InternalKeyContext logic in backend Key: FLINK-12121 URL: https://issues.apache.org/jira/browse/FLINK-12121 Project: Flink

[GitHub] [flink] KurtYoung commented on issue #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on issue #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#issuecomment-480743717 BTW, i think we need some dedicated tests for all rank functions.

[jira] [Commented] (FLINK-10437) Some of keys under withDeprecatedKeys aren't marked as @depreacted

2019-04-08 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812233#comment-16812233 ] TisonKun commented on FLINK-10437: -- Yes. You might decide whether replace with {{withFa

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272878173 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272880935 ## File path: flink-table/flink-table-runtime-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272879137 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272878814 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272879175 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272878861 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272882131 ## File path: flink-table/flink-table-runtime-blink/src/

[GitHub] [flink] KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation

2019-04-08 Thread GitBox
KurtYoung commented on a change in pull request #8109: [FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to StreamTransformation URL: https://github.com/apache/flink/pull/8109#discussion_r272878296 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272922309 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/DirectoryBa

[jira] [Commented] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

2019-04-08 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1681#comment-1681 ] Flavio Pompermaier commented on FLINK-4785: --- Which url is no longer valid? [htt

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272927782 ## File path: flink-core/src/test/java/org/apache/flink/core/plugin/DirectoryBa

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272925609 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginLoade

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272927404 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginManag

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272923859 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/DirectoryBa

[GitHub] [flink] pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem

2019-04-08 Thread GitBox
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce Plugin/Loading system and integrate it with FileSystem URL: https://github.com/apache/flink/pull/8038#discussion_r272921337 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/DirectoryBa

[jira] [Commented] (FLINK-10684) Improve the CSV reading process

2019-04-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812221#comment-16812221 ] Fabian Hueske commented on FLINK-10684: --- Hi, please have a look at https://issues.

[jira] [Commented] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

2019-04-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812220#comment-16812220 ] Till Rohrmann commented on FLINK-8801: -- Hi [~Tao Yang] and [~yanyan300300], thanks f

[GitHub] [flink] JingsongLi commented on issue #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

2019-04-08 Thread GitBox
JingsongLi commented on issue #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#issuecomment-480731189 I try implement it like "immediately determine the left and right boundary", but even if we immediate

[jira] [Updated] (FLINK-12010) Kinesis Producer problems on Alpine Linux image

2019-04-08 Thread Mario Georgiev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mario Georgiev updated FLINK-12010: --- Description: {code:java} Error relocating /tmp/amazon-kinesis-producer-native-binaries/kine

[jira] [Updated] (FLINK-11855) Race condition in EmbeddedLeaderService

2019-04-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11855: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

2019-04-08 Thread GitBox
zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272919268 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[GitHub] [flink] flinkbot edited a comment on issue #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends

2019-04-08 Thread GitBox
flinkbot edited a comment on issue #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends URL: https://github.com/apache/flink/pull/8078#issuecomment-477977949 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[GitHub] [flink] tzulitai commented on issue #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends

2019-04-08 Thread GitBox
tzulitai commented on issue #8078: [FLINK-12066] [State Backends] Remove StateSerializerProvider field in keyed state backends URL: https://github.com/apache/flink/pull/8078#issuecomment-480712590 @flinkbot approve description @flinkbot approve consensus

[jira] [Commented] (FLINK-8033) Build Flink with JDK 9

2019-04-08 Thread Takanobu Asanuma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812167#comment-16812167 ] Takanobu Asanuma commented on FLINK-8033: - bq. because you still have to solve mo

[jira] [Commented] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2019-04-08 Thread LiuJi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812161#comment-16812161 ] LiuJi commented on FLINK-3991: -- Hi [~Zentol] It seems now in ConfigConstants, some deprecate

<    1   2   3