[jira] [Resolved] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

[ https://issues.apache.org/jira/browse/FLINK-10922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10922. --- Resolution: Fixed Fixed via master: 33fbb42bb02c5490883c41d96a12ea5357ea7246

[jira] [Assigned] (FLINK-10934) Implement KubernetesJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN reassigned FLINK-10934: --- Assignee: JIN SUN > Implement KubernetesJobClusterEntrypoint >

[GitHub] yanghua commented on issue #7142: [FLINK-10931] Exclude transitive dependence on Kafka-client

yanghua commented on issue #7142: [FLINK-10931] Exclude transitive dependence on Kafka-client URL: https://github.com/apache/flink/pull/7142#issuecomment-440084229 @zentol It's strange. Yesterday, in my own Travis, the CI for FLINK-10922 was failed. The maven reported these error message

[jira] [Commented] (FLINK-10931) Exclude transitive dependence on Kafka-client

[ https://issues.apache.org/jira/browse/FLINK-10931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692438#comment-16692438 ] ASF GitHub Bot commented on FLINK-10931: yanghua commented on issue #7142: [FLINK-10931] Exclude

[jira] [Commented] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692571#comment-16692571 ] xuqianjin commented on FLINK-10926: --- hi [~xueyu7452] It was found in version 1.6.2 but I'm sure it's

[jira] [Created] (FLINK-10938) Enable Flink on native k8s E2E Tests in Travis CI

JIN SUN created FLINK-10938: --- Summary: Enable Flink on native k8s E2E Tests in Travis CI Key: FLINK-10938 URL: https://issues.apache.org/jira/browse/FLINK-10938 Project: Flink Issue Type:

[GitHub] vtkstef commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

vtkstef commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r234799715 ## File path:

[jira] [Updated] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-10926: -- Affects Version/s: 1.6.2 > Fix the problem for function TIMESTAMPDIFF in Table >

[jira] [Commented] (FLINK-10919) Flink binary distribution too large

[ https://issues.apache.org/jira/browse/FLINK-10919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692569#comment-16692569 ] vinoyang commented on FLINK-10919: -- [~till.rohrmann]  Currently, the typical pattern of Flink combined

[jira] [Created] (FLINK-10939) Add documents for Flink on native k8s

JIN SUN created FLINK-10939: --- Summary: Add documents for Flink on native k8s Key: FLINK-10939 URL: https://issues.apache.org/jira/browse/FLINK-10939 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9461: --- Assignee: vinoyang > Disentangle flink-connector-kafka from flink-table and flink-json >

[jira] [Created] (FLINK-10934) Implement KubernetesJobClusterEntrypoint

JIN SUN created FLINK-10934: --- Summary: Implement KubernetesJobClusterEntrypoint Key: FLINK-10934 URL: https://issues.apache.org/jira/browse/FLINK-10934 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10933) Implement KubernetesSessionClusterEntrypoint

JIN SUN created FLINK-10933: --- Summary: Implement KubernetesSessionClusterEntrypoint Key: FLINK-10933 URL: https://issues.apache.org/jira/browse/FLINK-10933 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10937) Add scripts to create docker image for k8s

JIN SUN created FLINK-10937: --- Summary: Add scripts to create docker image for k8s Key: FLINK-10937 URL: https://issues.apache.org/jira/browse/FLINK-10937 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692324#comment-16692324 ] ASF GitHub Bot commented on FLINK-10932: isunjin opened a new pull request #7144: [FLINK-10932]

[jira] [Reopened] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10481: --- > Wordcount end-to-end test in docker env unstable >

[jira] [Reopened] (FLINK-10670) Fix Correlate codegen error

[ https://issues.apache.org/jira/browse/FLINK-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10670: --- > Fix Correlate codegen error > --- > > Key:

[GitHub] isunjin opened a new pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation

isunjin opened a new pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/7144 ## What is the purpose of the change Initialize the skeleton module to start native k8s integration

[jira] [Reopened] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-8997: -- > Add sliding window aggregation to the job > - > >

[jira] [Closed] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10481. - Resolution: Fixed Fix Version/s: (was: 1.7.1) (was: 1.8.0)

[jira] [Closed] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8997. Resolution: Fixed Fix Version/s: (was: 1.7.1) (was: 1.8.0)

[jira] [Commented] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

[ https://issues.apache.org/jira/browse/FLINK-10922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692313#comment-16692313 ] ASF GitHub Bot commented on FLINK-10922: asfgit closed pull request #7140: [FLINK-10922]

[GitHub] asfgit closed pull request #7140: [FLINK-10922] Refactor the placement of the Flink Kafka connector end to end test module

asfgit closed pull request #7140: [FLINK-10922] Refactor the placement of the Flink Kafka connector end to end test module URL: https://github.com/apache/flink/pull/7140 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Created] (FLINK-10935) Implement KubeClient with Faric8 Kubernetes clients

JIN SUN created FLINK-10935: --- Summary: Implement KubeClient with Faric8 Kubernetes clients Key: FLINK-10935 URL: https://issues.apache.org/jira/browse/FLINK-10935 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

[ https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692342#comment-16692342 ] ASF GitHub Bot commented on FLINK-9083: --- vtkstef commented on a change in pull request #6782:

[jira] [Commented] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692541#comment-16692541 ] ASF GitHub Bot commented on FLINK-10932: TisonKun commented on a change in pull request #7144:

[jira] [Commented] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692540#comment-16692540 ] ASF GitHub Bot commented on FLINK-10932: TisonKun commented on a change in pull request #7144:

[jira] [Commented] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692542#comment-16692542 ] ASF GitHub Bot commented on FLINK-10932: TisonKun commented on a change in pull request #7144:

[jira] [Assigned] (FLINK-10929) Add support for Apache Arrow

[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10929: Assignee: vinoyang > Add support for Apache Arrow > > >

[jira] [Updated] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10932: --- Labels: pull-request-available (was: ) > Initial flink-kubernetes module with empty

[jira] [Created] (FLINK-10936) Implement Command line tools

JIN SUN created FLINK-10936: --- Summary: Implement Command line tools Key: FLINK-10936 URL: https://issues.apache.org/jira/browse/FLINK-10936 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-10935) Implement KubeClient with Faric8 Kubernetes clients

[ https://issues.apache.org/jira/browse/FLINK-10935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN reassigned FLINK-10935: --- Assignee: JIN SUN > Implement KubeClient with Faric8 Kubernetes clients >

[jira] [Closed] (FLINK-10670) Fix Correlate codegen error

[ https://issues.apache.org/jira/browse/FLINK-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10670. - Resolution: Fixed Fix Version/s: (was: 1.7.1) 1.7.0 Updated fix

[jira] [Comment Edited] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689936#comment-16689936 ] Ken Krugler edited comment on FLINK-9541 at 11/19/18 11:37 PM: --- I'd asked

[jira] [Comment Edited] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689936#comment-16689936 ] Ken Krugler edited comment on FLINK-9541 at 11/19/18 11:38 PM: --- I'd asked

[GitHub] TisonKun commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation

TisonKun commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/7144#discussion_r234843453 ## File path:

[GitHub] TisonKun commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation

TisonKun commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/7144#discussion_r234843542 ## File path:

[GitHub] TisonKun commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation

TisonKun commented on a change in pull request #7144: [FLINK-10932] [ResourceManager] Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/7144#discussion_r234843511 ## File path:

[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692610#comment-16692610 ] Yun Tang edited comment on FLINK-9043 at 11/20/18 3:55 AM: --- I quite agree with

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692669#comment-16692669 ] vinoyang commented on FLINK-10892: -- [~zjffdu] Flink on YARN is just one of the running models supported

[jira] [Updated] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

[ https://issues.apache.org/jira/browse/FLINK-10922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10922: - Fix Version/s: 1.7.0 > Refactor the placement of the Flink Kafka connector end to end test module >

[jira] [Created] (FLINK-10941) Slots prematurely released which still contain unconsumed data

Qi created FLINK-10941: -- Summary: Slots prematurely released which still contain unconsumed data Key: FLINK-10941 URL: https://issues.apache.org/jira/browse/FLINK-10941 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692701#comment-16692701 ] Jeff Zhang commented on FLINK-10892: We don't need to set it as an yarn app name in api level, but

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692715#comment-16692715 ] vinoyang commented on FLINK-10892: -- [~zjffdu] I have already said that Application is just a concept of

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692609#comment-16692609 ] Jeff Zhang commented on FLINK-10892: [~yanghua] Shouldn't we expose it in ExecutionEnvironment,

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-440143611 Hi, @azagrebin , please help to review this when you have time.

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692689#comment-16692689 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692744#comment-16692744 ] Rafi Aroch commented on FLINK-10941: Saw same issue with Flink 1.5.4. Job fails with same symptoms. 

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692776#comment-16692776 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] pnowojski commented on issue #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector

pnowojski commented on issue #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector URL: https://github.com/apache/flink/pull/7038#issuecomment-440173975 @tillrohrmann yes, they do not add much value and yes, they are not worth blowing up the release binaries. However they

[jira] [Updated] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-10868: -- Description: Currently, YarnResourceManager does use  yarn.maximum-failed-containers as limit

[jira] [Created] (FLINK-10942) Deduplicate common codes in OutputEmitterTest

zhijiang created FLINK-10942: Summary: Deduplicate common codes in OutputEmitterTest Key: FLINK-10942 URL: https://issues.apache.org/jira/browse/FLINK-10942 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692768#comment-16692768 ] ASF GitHub Bot commented on FLINK-8159: --- dianfu commented on issue #5080: [FLINK-8159] [cep] Add

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r234892171 ## File path:

[GitHub] zhijiangW commented on issue #7146: [FLINK-10942][network, test] Deduplicate common codes in OutputEmitterTest

zhijiangW commented on issue #7146: [FLINK-10942][network,test] Deduplicate common codes in OutputEmitterTest URL: https://github.com/apache/flink/pull/7146#issuecomment-440170847 cc @pnowojski This is an automated message

[GitHub] dianfu commented on issue #5080: [FLINK-8159] [cep] Add rich support for SelectWrapper and FlatSelectWrapper

dianfu commented on issue #5080: [FLINK-8159] [cep] Add rich support for SelectWrapper and FlatSelectWrapper URL: https://github.com/apache/flink/pull/5080#issuecomment-440170762 Close this PR as it is duplicate with #7110

[jira] [Commented] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692586#comment-16692586 ] xueyu commented on FLINK-10926: --- hi, [~x1q1j1], Version 1.6.2 does not support timestampdiff. This

[jira] [Updated] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

[ https://issues.apache.org/jira/browse/FLINK-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10940: --- Labels: pull-request-available (was: ) > Refactor the maven dependencies of Kafka 0.8

[GitHub] yanghua opened a new pull request #7145: [FLINK-10940] Refactor the maven dependencies of Kafka 0.8 connector

yanghua opened a new pull request #7145: [FLINK-10940] Refactor the maven dependencies of Kafka 0.8 connector URL: https://github.com/apache/flink/pull/7145 ## What is the purpose of the change *This pull request refactors the maven dependencies of Kafka 0.8 connector* ##

[jira] [Closed] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10892. Resolution: Not A Problem Release Note: We can set it via CLI option or API

[jira] [Closed] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

[ https://issues.apache.org/jira/browse/FLINK-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10940. Resolution: Won't Fix Release Note: In-depth, Kafka 0.8 connector is indeed different from other

[jira] [Commented] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

[ https://issues.apache.org/jira/browse/FLINK-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692670#comment-16692670 ] ASF GitHub Bot commented on FLINK-10940: yanghua closed pull request #7145: [FLINK-10940]

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692740#comment-16692740 ] ASF GitHub Bot commented on FLINK-8159: --- sunjincheng121 commented on a change in pull request

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692742#comment-16692742 ] ASF GitHub Bot commented on FLINK-8159: --- sunjincheng121 commented on a change in pull request

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r234878521 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r234882983 ## File path:

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692741#comment-16692741 ] ASF GitHub Bot commented on FLINK-8159: --- sunjincheng121 commented on a change in pull request

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692739#comment-16692739 ] ASF GitHub Bot commented on FLINK-8159: --- sunjincheng121 commented on a change in pull request

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692738#comment-16692738 ] ASF GitHub Bot commented on FLINK-8159: --- sunjincheng121 commented on a change in pull request

[jira] [Created] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

vinoyang created FLINK-10940: Summary: Refactor the maven dependencies of Kafka 0.8 connector Key: FLINK-10940 URL: https://issues.apache.org/jira/browse/FLINK-10940 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692723#comment-16692723 ] Dian Fu commented on FLINK-7599: Sure, go ahead. > Support aggregation functions in the define and

[GitHub] dianfu closed pull request #5080: [FLINK-8159] [cep] Add rich support for SelectWrapper and FlatSelectWrapper

dianfu closed pull request #5080: [FLINK-8159] [cep] Add rich support for SelectWrapper and FlatSelectWrapper URL: https://github.com/apache/flink/pull/5080 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] yanghua commented on issue #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector

yanghua commented on issue #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector URL: https://github.com/apache/flink/pull/7038#issuecomment-440177013 @pnowojski How about providing a `flink-examples/flink-examples-e2e` module to place these end-to-end examples?

[jira] [Commented] (FLINK-10926) Fix the problem for function TIMESTAMPDIFF in Table

[ https://issues.apache.org/jira/browse/FLINK-10926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692592#comment-16692592 ] xuqianjin commented on FLINK-10926: ---  [~xueyu7452]  Well, I will check again when the version of 1.7

[jira] [Commented] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

[ https://issues.apache.org/jira/browse/FLINK-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692598#comment-16692598 ] ASF GitHub Bot commented on FLINK-10940: yanghua opened a new pull request #7145: [FLINK-10940]

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692610#comment-16692610 ] Yun Tang commented on FLINK-9043: - I quite agreed with [~sihuazhou]'s idea, user just need to provide the

[jira] [Commented] (FLINK-10928) Job unable to stabilise after restart

[ https://issues.apache.org/jira/browse/FLINK-10928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692618#comment-16692618 ] Biao Liu commented on FLINK-10928: -- Hi [~djharper] 1. "Why does YARN kill the containers with out of

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692764#comment-16692764 ] ASF GitHub Bot commented on FLINK-8159: --- dianfu closed pull request #5080: [FLINK-8159] [cep] Add

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692607#comment-16692607 ] vinoyang commented on FLINK-10892: -- [~dawidwys] is right. He gave an option based on the config option.

[jira] [Comment Edited] (FLINK-10928) Job unable to stabilise after restart

[ https://issues.apache.org/jira/browse/FLINK-10928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692618#comment-16692618 ] Biao Liu edited comment on FLINK-10928 at 11/20/18 4:08 AM: Hi [~djharper]

[jira] [Updated] (FLINK-10942) Deduplicate common codes in OutputEmitterTest

[ https://issues.apache.org/jira/browse/FLINK-10942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10942: --- Labels: pull-request-available (was: ) > Deduplicate common codes in OutputEmitterTest >

[jira] [Commented] (FLINK-10942) Deduplicate common codes in OutputEmitterTest

[ https://issues.apache.org/jira/browse/FLINK-10942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692705#comment-16692705 ] ASF GitHub Bot commented on FLINK-10942: zhijiangW opened a new pull request #7146:

[GitHub] zhijiangW opened a new pull request #7146: [FLINK-10942][network, test] Deduplicate common codes in OutputEmitterTest

zhijiangW opened a new pull request #7146: [FLINK-10942][network,test] Deduplicate common codes in OutputEmitterTest URL: https://github.com/apache/flink/pull/7146 ## What is the purpose of the change *There are many duplicated codes in `OutputEmitterTest` to make it difficult to

[jira] [Commented] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692708#comment-16692708 ] Zhenqiu Huang commented on FLINK-10868: --- [~till.rohrmann] I am working on a fix in

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r234885688 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r234885267 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface

sunjincheng121 commented on a change in pull request #7110: [FLINK-8159] [cep] Pattern(Flat)SelectFunctions should support RichFunction interface URL: https://github.com/apache/flink/pull/7110#discussion_r234883989 ## File path:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692772#comment-16692772 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r234892484 ## File path:

[jira] [Commented] (FLINK-10942) Deduplicate common codes in OutputEmitterTest

[ https://issues.apache.org/jira/browse/FLINK-10942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692770#comment-16692770 ] ASF GitHub Bot commented on FLINK-10942: zhijiangW commented on issue #7146:

[jira] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692786#comment-16692786 ] ASF GitHub Bot commented on FLINK-10791: pnowojski commented on issue #7038: [FLINK-10791]

[jira] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692802#comment-16692802 ] ASF GitHub Bot commented on FLINK-10791: yanghua commented on issue #7038: [FLINK-10791] Provide

[GitHub] yanghua commented on issue #7142: [FLINK-10931] Exclude transitive dependence on Kafka-client

yanghua commented on issue #7142: [FLINK-10931] Exclude transitive dependence on Kafka-client URL: https://github.com/apache/flink/pull/7142#issuecomment-439961872 @tillrohrmann It seems this PR would block FLINK-10922. cc @pnowojski

[jira] [Closed] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10481. Resolution: Fixed Fix Version/s: (was: 1.5.6) Fixed via: master:

[jira] [Commented] (FLINK-10931) Exclude transitive dependence on Kafka-client

[ https://issues.apache.org/jira/browse/FLINK-10931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691966#comment-16691966 ] ASF GitHub Bot commented on FLINK-10931: yanghua commented on issue #7142: [FLINK-10931] Exclude

[GitHub] yanghua opened a new pull request #7142: [FLINK-10931] Exclude transitive dependence on Kafka-client

yanghua opened a new pull request #7142: [FLINK-10931] Exclude transitive dependence on Kafka-client URL: https://github.com/apache/flink/pull/7142 ## What is the purpose of the change *This pull request excludes transitive dependence on Kafka-client* ## Brief change log

[jira] [Closed] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-8997. --- Resolution: Fixed Fix Version/s: 1.7.1 Fixed via: master:

[jira] [Commented] (FLINK-10931) Exclude transitive dependence on Kafka-client

[ https://issues.apache.org/jira/browse/FLINK-10931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691962#comment-16691962 ] ASF GitHub Bot commented on FLINK-10931: yanghua opened a new pull request #7142: [FLINK-10931]

[jira] [Updated] (FLINK-10931) Exclude transitive dependence on Kafka-client

[ https://issues.apache.org/jira/browse/FLINK-10931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10931: --- Labels: pull-request-available (was: ) > Exclude transitive dependence on Kafka-client >

[jira] [Created] (FLINK-10931) Exclude transitive dependence on Kafka-client

vinoyang created FLINK-10931: Summary: Exclude transitive dependence on Kafka-client Key: FLINK-10931 URL: https://issues.apache.org/jira/browse/FLINK-10931 Project: Flink Issue Type:

  1   2   3   4   >