[GitHub] flink issue #6136: [FLINK-4303] [CEP] Add CEP examples

Github user kisimple commented on the issue: https://github.com/apache/flink/pull/6136 cc @twalthr ---

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505698#comment-16505698 ] ASF GitHub Bot commented on FLINK-4303: --- Github user kisimple commented on the issue:

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505696#comment-16505696 ] ASF GitHub Bot commented on FLINK-4303: --- Github user kisimple commented on the issue:

[GitHub] flink issue #6136: [FLINK-4303] [CEP] Add CEP examples

Github user kisimple commented on the issue: https://github.com/apache/flink/pull/6136 @medcv Thanks for your review :) Updated as your suggestions. ---

[GitHub] flink pull request #6141: flink-metrics-datadog: beautify metric name by exc...

GitHub user DmitryBe opened a pull request: https://github.com/apache/flink/pull/6141 flink-metrics-datadog: beautify metric name by excluding host_name, tm_id, and task|job_manager values from metric name and providing them as tags this allows to aggregate values by using tags in

[jira] [Assigned] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint

[ https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9552: --- Assignee: vinoyang > NPE in SpanningRecordSerializer during checkpoint >

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505638#comment-16505638 ] ASF GitHub Bot commented on FLINK-4303: --- Github user kisimple commented on a diff in the pull

[GitHub] flink pull request #6136: FLINK-4303] [CEP] Add CEP examples

Github user kisimple commented on a diff in the pull request: https://github.com/apache/flink/pull/6136#discussion_r193941724 --- Diff: flink-examples/flink-examples-cep/src/main/java/org/apache/flink/cep/examples/java/monitoring/TemperatureMonitoring.java --- @@ -0,0 +1,147 @@

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505637#comment-16505637 ] ASF GitHub Bot commented on FLINK-9554: --- Github user zjffdu commented on the issue:

[GitHub] flink issue #6140: [FLINK-9554] flink scala shell doesn't work in yarn mode

Github user zjffdu commented on the issue: https://github.com/apache/flink/pull/6140 @tillrohrmann Could you help review it ? Thanks ---

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505627#comment-16505627 ] ASF GitHub Bot commented on FLINK-9554: --- GitHub user zjffdu opened a pull request:

[GitHub] flink pull request #6140: [FLINK-9554] flink scala shell doesn't work in yar...

GitHub user zjffdu opened a pull request: https://github.com/apache/flink/pull/6140 [FLINK-9554] flink scala shell doesn't work in yarn mode ## What is the purpose of the change This PR is trying to fix the issue of scala-shell unable to run in yarn mode. ##

[jira] [Closed] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

[ https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng closed FLINK-9329. -- Resolution: Invalid > hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table > source

[jira] [Commented] (FLINK-9554) flink scala shell doesn't work in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505619#comment-16505619 ] Jeff Zhang commented on FLINK-9554: --- FLINK-8795 is about scala shell hangs when running flink job in

[jira] [Created] (FLINK-9554) flink scala shell doesn't work in yarn mode

Jeff Zhang created FLINK-9554: - Summary: flink scala shell doesn't work in yarn mode Key: FLINK-9554 URL: https://issues.apache.org/jira/browse/FLINK-9554 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9553) Migrate integration tests for DataSinkITCase

Deepak Sharma created FLINK-9553: Summary: Migrate integration tests for DataSinkITCase Key: FLINK-9553 URL: https://issues.apache.org/jira/browse/FLINK-9553 Project: Flink Issue Type:

[jira] [Created] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint

Truong Duc Kien created FLINK-9552: -- Summary: NPE in SpanningRecordSerializer during checkpoint Key: FLINK-9552 URL: https://issues.apache.org/jira/browse/FLINK-9552 Project: Flink Issue

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505602#comment-16505602 ] ASF GitHub Bot commented on FLINK-4303: --- Github user medcv commented on a diff in the pull request:

[GitHub] flink pull request #6136: FLINK-4303] [CEP] Add CEP examples

Github user medcv commented on a diff in the pull request: https://github.com/apache/flink/pull/6136#discussion_r193934789 --- Diff: flink-examples/flink-examples-cep/src/main/scala/org/apache/flink/cep/examples/scala/monitoring/TemperatureMonitoring.scala --- @@ -0,0 +1,107 @@

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505601#comment-16505601 ] ASF GitHub Bot commented on FLINK-4303: --- Github user medcv commented on a diff in the pull request:

[GitHub] flink pull request #6136: FLINK-4303] [CEP] Add CEP examples

Github user medcv commented on a diff in the pull request: https://github.com/apache/flink/pull/6136#discussion_r193934744 --- Diff: flink-examples/flink-examples-cep/src/main/java/org/apache/flink/cep/examples/java/monitoring/TemperatureMonitoring.java --- @@ -0,0 +1,147 @@

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505598#comment-16505598 ] ASF GitHub Bot commented on FLINK-4303: --- Github user medcv commented on the issue:

[GitHub] flink issue #6136: FLINK-4303] [CEP] Add CEP examples

Github user medcv commented on the issue: https://github.com/apache/flink/pull/6136 @kisimple Recently I started to work on same example. I ran your code on my local and it did work perfectly. I could see some checkstyle errors that I think travis might pick them up. I have

[jira] [Closed] (FLINK-9482) Not applicable functions for TIME

[ https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-9482. - Resolution: Fixed > Not applicable functions for TIME > - > >

[jira] [Commented] (FLINK-9482) Not applicable functions for TIME

[ https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505575#comment-16505575 ] ASF GitHub Bot commented on FLINK-9482: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6121: [FLINK-9482] [table] EXTRACT function argument val...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6121 ---

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505512#comment-16505512 ] Indrajit Roychoudhury commented on FLINK-9061: -- [~neoeahit] [~jgrier] I'll pick this up next

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505461#comment-16505461 ] Jamie Grier commented on FLINK-9061: [~neoeahit] This will affect all versions. > add entropy to s3

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505447#comment-16505447 ] Monal Daxini commented on FLINK-9061: - In addition to what [~stevenz3wu] and [~jgrier] suggest, it

[GitHub] flink pull request #6138: [FLINK-9550][DOC]FlinkCEP snippet example has some...

GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/6138 [FLINK-9550][DOC]FlinkCEP snippet example has some syntax errors ## What is the purpose of the change Fixing FlinkCEP snippet code syntax errors and data type mismatches ##

[jira] [Commented] (FLINK-9539) Integrate flink-shaded 4.0

[ https://issues.apache.org/jira/browse/FLINK-9539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505396#comment-16505396 ] ASF GitHub Bot commented on FLINK-9539: --- Github user medcv commented on the issue:

[GitHub] flink issue #6128: [FLINK-9539][build] Integrate flink-shaded 4.0

Github user medcv commented on the issue: https://github.com/apache/flink/pull/6128 +1 ---

[jira] [Commented] (FLINK-9551) FlinkCEP Scala Combining Patterns table has a missing pattern

[ https://issues.apache.org/jira/browse/FLINK-9551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505380#comment-16505380 ] ASF GitHub Bot commented on FLINK-9551: --- GitHub user medcv opened a pull request:

[GitHub] flink pull request #6139: [FLINK-9551][DOCS]FlinkCEP Scala Combining Pattern...

GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/6139 [FLINK-9551][DOCS]FlinkCEP Scala Combining Patterns table has a missing pattern ## What is the purpose of the change in FlinkCEP documentation section related to Combining Patterns

[jira] [Commented] (FLINK-9550) FlinkCEP snippet example has some syntax errors

[ https://issues.apache.org/jira/browse/FLINK-9550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505367#comment-16505367 ] ASF GitHub Bot commented on FLINK-9550: --- GitHub user medcv opened a pull request:

[jira] [Updated] (FLINK-9551) FlinkCEP Scala Combining Patterns table has a missing pattern

[ https://issues.apache.org/jira/browse/FLINK-9551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-9551: --- Summary: FlinkCEP Scala Combining Patterns table has a missing pattern (was: FlinkCEP Scala

[jira] [Created] (FLINK-9551) FlinkCEP Scala Combining Patterns table has two missing pattern

Yazdan Shirvany created FLINK-9551: -- Summary: FlinkCEP Scala Combining Patterns table has two missing pattern Key: FLINK-9551 URL: https://issues.apache.org/jira/browse/FLINK-9551 Project: Flink

[jira] [Created] (FLINK-9550) FlinkCEP snippet example has some syntax errors

Yazdan Shirvany created FLINK-9550: -- Summary: FlinkCEP snippet example has some syntax errors Key: FLINK-9550 URL: https://issues.apache.org/jira/browse/FLINK-9550 Project: Flink Issue

[jira] [Commented] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes

[ https://issues.apache.org/jira/browse/FLINK-9549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505345#comment-16505345 ] ASF GitHub Bot commented on FLINK-9549: --- GitHub user medcv opened a pull request:

[GitHub] flink pull request #6137: [FLINK-9549][DOC]Fix FlickCEP Docs broken link and...

GitHub user medcv opened a pull request: https://github.com/apache/flink/pull/6137 [FLINK-9549][DOC]Fix FlickCEP Docs broken link and minor style changes ## What is the purpose of the change Fixing FlickCEP broken link and minor style changes ## Does this pull

[jira] [Created] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes

Yazdan Shirvany created FLINK-9549: -- Summary: Fix FlickCEP Docs broken link and minor style changes Key: FLINK-9549 URL: https://issues.apache.org/jira/browse/FLINK-9549 Project: Flink

[GitHub] flink pull request #6131: [hotfix][docs] Fix Table API scala example code

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6131 ---

[jira] [Created] (FLINK-9548) Flink Apache Kudu Connector

Sandish Kumar HN created FLINK-9548: --- Summary: Flink Apache Kudu Connector Key: FLINK-9548 URL: https://issues.apache.org/jira/browse/FLINK-9548 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505047#comment-16505047 ] ASF GitHub Bot commented on FLINK-4303: --- Github user kisimple commented on the issue:

[GitHub] flink issue #6136: FLINK-4303] [CEP] Add CEP examples

Github user kisimple commented on the issue: https://github.com/apache/flink/pull/6136 cc @kl0u ---

[jira] [Commented] (FLINK-4303) Add CEP examples

[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505046#comment-16505046 ] ASF GitHub Bot commented on FLINK-4303: --- GitHub user kisimple opened a pull request:

[GitHub] flink pull request #6136: FLINK-4303] [CEP] Add CEP examples

GitHub user kisimple opened a pull request: https://github.com/apache/flink/pull/6136 FLINK-4303] [CEP] Add CEP examples ## What is the purpose of the change Currently neither CEP Java nor CEP Scala contain a runnable example. This PR fixes the problem by adding a

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505042#comment-16505042 ] Vipul Singh commented on FLINK-9061: We are also seem to be affected by this. I wanted to check

[jira] [Comment Edited] (FLINK-9547) CEP pattern not called on windowed stream

[ https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505021#comment-16505021 ] Lucas Resch edited comment on FLINK-9547 at 6/7/18 6:07 PM: [~dawidwys] I

[jira] [Comment Edited] (FLINK-9547) CEP pattern not called on windowed stream

[ https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505021#comment-16505021 ] Lucas Resch edited comment on FLINK-9547 at 6/7/18 6:06 PM: [~dawidwys] I

[jira] [Commented] (FLINK-9547) CEP pattern not called on windowed stream

[ https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505021#comment-16505021 ] Lucas Resch commented on FLINK-9547: I created a small example that does something similar. Somehow

[GitHub] flink issue #6130: [FLINK-9545] Support read a file multiple times in Flink ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/6130 You're effectively only explaining what this feature is, but not why it is actually needed. We have to gauge whether this feature is useful for other users as well before we decide to maintain it.

[jira] [Commented] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505017#comment-16505017 ] ASF GitHub Bot commented on FLINK-9545: --- Github user zentol commented on the issue:

[GitHub] flink issue #6130: [FLINK-9545] Support read a file multiple times in Flink ...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/6130 @aljoscha Motivation: We have the requirements to read a bunch files, each file to read multiple times, to feed our streams Specifically we need

[jira] [Commented] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504916#comment-16504916 ] ASF GitHub Bot commented on FLINK-9545: --- Github user bowenli86 commented on the issue:

[jira] [Updated] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-9545: Description: Motivation: We have the requirements to read a bunch files, each file to read multiple

[jira] [Commented] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504913#comment-16504913 ] Bowen Li commented on FLINK-9545: - [~aljoscha] I updated the description > Support read a file multiple

[jira] [Updated] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-9545: Description: Motivation: We have the requirements to read a bunch files, each file to read multiple

[jira] [Commented] (FLINK-9538) Make KeyedStateFunction an interface

[ https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504863#comment-16504863 ] ASF GitHub Bot commented on FLINK-9538: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #6134: [FLINK-9538] Make KeyedStateFunction an interface

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6134 Sorry @yanghua , will have a look tomorrow. You really don't need to ping me every hour, will get to it as soon as I have some time. ---

[GitHub] flink issue #6134: [FLINK-9538] Make KeyedStateFunction an interface

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6134 cc @dawidwys refactored code, please review again~ ---

[jira] [Commented] (FLINK-9538) Make KeyedStateFunction an interface

[ https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504859#comment-16504859 ] ASF GitHub Bot commented on FLINK-9538: --- Github user yanghua commented on the issue:

[jira] [Commented] (FLINK-9547) CEP pattern not called on windowed stream

[ https://issues.apache.org/jira/browse/FLINK-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504834#comment-16504834 ] Dawid Wysakowicz commented on FLINK-9547: - Hi [~MLNotW]. Could you provide a runnable example

[jira] [Commented] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504826#comment-16504826 ] ASF GitHub Bot commented on FLINK-9168: --- Github user surryr commented on a diff in the pull

[GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto...

Github user surryr commented on a diff in the pull request: https://github.com/apache/flink/pull/5845#discussion_r193793061 --- Diff: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarProducer.java --- @@ -0,0 +1,304 @@

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504820#comment-16504820 ] swy commented on FLINK-9506: thank for response [~sihuazhou], the key length is around 50 chars. We will

[jira] [Created] (FLINK-9547) CEP pattern not called on windowed stream

Lucas Resch created FLINK-9547: -- Summary: CEP pattern not called on windowed stream Key: FLINK-9547 URL: https://issues.apache.org/jira/browse/FLINK-9547 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504729#comment-16504729 ] Sihua Zhou commented on FLINK-9506: --- Hi [~yow] From the top of my head, I list answers here: - >> 1.

[jira] [Commented] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot

[ https://issues.apache.org/jira/browse/FLINK-9262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504725#comment-16504725 ] Aljoscha Krettek commented on FLINK-9262: - What dependencies do you have set in your pom? I

[jira] [Commented] (FLINK-9540) Apache Flink 1.4.2 S3 Hadoop library for Hadoop 2.7 is built for Hadoop 2.8 and fails

[ https://issues.apache.org/jira/browse/FLINK-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504723#comment-16504723 ] Razvan commented on FLINK-9540: --- Hi [~aljoscha],   Not sure I understand the question :) So what I'm

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504685#comment-16504685 ] ASF GitHub Bot commented on FLINK-9444: --- Github user tragicjun commented on the issue:

[GitHub] flink issue #6082: [FLINK-9444][table] KafkaAvroTableSource failed to work f...

Github user tragicjun commented on the issue: https://github.com/apache/flink/pull/6082 The latest commit uses **Types.OBJECT_ARRAY** to map Avro array type. Hence, Avro **GenericData.Array** has to be converted into regular java arrays back (see **AvroRowSerializationSchema**) and

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504675#comment-16504675 ] swy commented on FLINK-9506: [~sihuazhou] your idea is brilliant, but the first test result is not show too

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

[ https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504535#comment-16504535 ] ASF GitHub Bot commented on FLINK-9503: --- Github user yanghua commented on a diff in the pull

[GitHub] flink pull request #6129: [FLINK-9503] Migrate integration tests for iterati...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6129#discussion_r193707442 --- Diff: flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorsITCase.java --- @@ -170,12 +162,12 @@ public void

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

[ https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504518#comment-16504518 ] ASF GitHub Bot commented on FLINK-9503: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6129: [FLINK-9503] Migrate integration tests for iterati...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6129#discussion_r193702401 --- Diff: flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorsITCase.java --- @@ -170,12 +162,12 @@ public void

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

[ https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504515#comment-16504515 ] ASF GitHub Bot commented on FLINK-9503: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6129: [FLINK-9503] Migrate integration tests for iterati...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6129#discussion_r193701993 --- Diff: flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorsITCase.java --- @@ -117,7 +107,9 @@ public boolean filter(Long

[jira] [Commented] (FLINK-9538) Make KeyedStateFunction an interface

[ https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504512#comment-16504512 ] ASF GitHub Bot commented on FLINK-9538: --- Github user yanghua commented on the issue:

[GitHub] flink issue #6134: [FLINK-9538] Make KeyedStateFunction an interface

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6134 cc @dawidwys ---

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504489#comment-16504489 ] Fabian Hueske commented on FLINK-9528: -- True, highly-selective filters would definitely be an issue.

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504471#comment-16504471 ] Hequn Cheng commented on FLINK-9528: Hi, [~fhueske]. Considering the anti-spamming scenario, users

[jira] [Commented] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504452#comment-16504452 ] ASF GitHub Bot commented on FLINK-9545: --- Github user aljoscha commented on the issue:

[jira] [Comment Edited] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503505#comment-16503505 ] Sihua Zhou edited comment on FLINK-9506 at 6/7/18 9:25 AM: --- [~yow] Maybe there

[GitHub] flink issue #6130: [FLINK-9545] Support read a file multiple times in Flink ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6130 I posted on the Jira issue: https://issues.apache.org/jira/browse/FLINK-9545?focusedCommentId=16504451=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16504451: What's the

[jira] [Commented] (FLINK-9545) Support read a file multiple times in Flink DataStream

[ https://issues.apache.org/jira/browse/FLINK-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504451#comment-16504451 ] Aljoscha Krettek commented on FLINK-9545: - [~phoenixjiangnan] What is the motivation for this

[jira] [Updated] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

[ https://issues.apache.org/jira/browse/FLINK-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8067: Fix Version/s: 1.6.0 > User code ClassLoader not set before calling ProcessingTimeCallback

[jira] [Commented] (FLINK-9482) Not applicable functions for TIME

[ https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504439#comment-16504439 ] ASF GitHub Bot commented on FLINK-9482: --- Github user bioker commented on a diff in the pull

[GitHub] flink pull request #6121: [FLINK-9482] [table] EXTRACT function argument val...

Github user bioker commented on a diff in the pull request: https://github.com/apache/flink/pull/6121#discussion_r193677135 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/validation/ScalarFunctionsValidationTest.scala --- @@ -98,16 +98,45

[jira] [Commented] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0

[ https://issues.apache.org/jira/browse/FLINK-9546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504408#comment-16504408 ] ASF GitHub Bot commented on FLINK-9546: --- Github user sihuazhou commented on the issue:

[GitHub] flink pull request #6135: [FLINK-9546][core] Fix the checking of heartbeatTi...

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/6135 [FLINK-9546][core] Fix the checking of heartbeatTimeoutIntervalMs in HeartbeatMonitor. ## What is the purpose of the change The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be

[jira] [Commented] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0

[ https://issues.apache.org/jira/browse/FLINK-9546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504407#comment-16504407 ] ASF GitHub Bot commented on FLINK-9546: --- GitHub user sihuazhou opened a pull request:

[GitHub] flink issue #6135: [FLINK-9546][core] Fix the checking of heartbeatTimeoutIn...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/6135 cc @tillrohrmann ---

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504406#comment-16504406 ] ASF GitHub Bot commented on FLINK-9498: --- Github user pnowojski commented on the issue:

[GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6116 I think the problem here is not that some of your versions are conflicting with flink, but that your dependencies are on their own conflicting. When I check: > mvn -Dhadoop.version=2.7.0

[jira] [Created] (FLINK-9546) The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0

Sihua Zhou created FLINK-9546: - Summary: The heartbeatTimeoutIntervalMs of HeartbeatMonitor should be larger than 0 Key: FLINK-9546 URL: https://issues.apache.org/jira/browse/FLINK-9546 Project: Flink

[jira] [Commented] (FLINK-9482) Not applicable functions for TIME

[ https://issues.apache.org/jira/browse/FLINK-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504403#comment-16504403 ] ASF GitHub Bot commented on FLINK-9482: --- Github user bioker commented on a diff in the pull

[GitHub] flink pull request #6121: [FLINK-9482] [table] EXTRACT function argument val...

Github user bioker commented on a diff in the pull request: https://github.com/apache/flink/pull/6121#discussion_r193663108 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/validation/ScalarFunctionsValidationTest.scala --- @@ -98,16 +98,45

[GitHub] flink issue #6131: [hotfix][docs] Fix Table API scala example code

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/6131 Hi @zjffdu, thanks for the fix! +1 to merge ---

  1   2   >