[GitHub] flink issue #2736: [FLINK-4174] Enhance evictor functionality

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2736 Sure, you're very welcome! `1.2` should be the fix version since that's going to be the first version that has this new code. --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667338#comment-15667338 ] ASF GitHub Bot commented on FLINK-5063: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #2813: [backport] [FLINK-5063] Discard state handles of d...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2813 [backport] [FLINK-5063] Discard state handles of declined or expired state handles This is backport of #2812 for the release-1.1 branch. Whenever the checkpoint coordinator receives an

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667326#comment-15667326 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667333#comment-15667333 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667330#comment-15667330 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667335#comment-15667335 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667327#comment-15667327 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667328#comment-15667328 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667334#comment-15667334 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667329#comment-15667329 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667332#comment-15667332 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667324#comment-15667324 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88028071 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -57

[jira] [Commented] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

[ https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667331#comment-15667331 ] ASF GitHub Bot commented on FLINK-5056: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88021880 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -42

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88027157 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -57

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88021378 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -23

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88025970 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -57

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88022818 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -48

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88019203 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88016998 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -26

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88016560 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -15

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88019498 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java --- @@

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88018720 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultToleranceITCase.

[GitHub] flink pull request #2797: [FLINK-5056] Makes the BucketingSink rescalable.

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2797#discussion_r88019886 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@ -34

[GitHub] flink issue #2802: Minor fixes

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2802 Line 110 is closed by `` on line 85. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabl

[GitHub] flink pull request #2812: [FLINK-5063] Discard state handles of declined or ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2812 [FLINK-5063] Discard state handles of declined or expired state handles Whenever the checkpoint coordinator receives an acknowledge checkpoint message which belongs to the job maintained by

[jira] [Commented] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667321#comment-15667321 ] ASF GitHub Bot commented on FLINK-5063: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements

[ https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667309#comment-15667309 ] vishnu viswanath commented on FLINK-4369: - Fixed by [FLINK-4174] > EvictingWindow

[jira] [Closed] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath closed FLINK-4174. --- Resolution: Fixed > Enhance Window Evictor > -- > > Key: F

[jira] [Closed] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements

[ https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath closed FLINK-4369. --- Resolution: Fixed > EvictingWindowOperator Must Actually Evict Elements >

[jira] [Commented] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures.

[ https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667277#comment-15667277 ] Gyula Fora commented on FLINK-4182: --- Hi, I have observed the same scenario in many of

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667290#comment-15667290 ] ASF GitHub Bot commented on FLINK-4174: --- Github user soniclavier closed the pull req

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667289#comment-15667289 ] ASF GitHub Bot commented on FLINK-4174: --- Github user soniclavier commented on the is

[GitHub] flink issue #2736: [FLINK-4174] Enhance evictor functionality

Github user soniclavier commented on the issue: https://github.com/apache/flink/pull/2736 Thank you for your guidance @aljoscha 😄. Could you please tell me what Fix version I should keep for these JIRAs --- If your project is set up for it, you can reply to this email and have you

[GitHub] flink pull request #2736: [FLINK-4174] Enhance evictor functionality

Github user soniclavier closed the pull request at: https://github.com/apache/flink/pull/2736 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures.

[ https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667283#comment-15667283 ] Gyula Fora commented on FLINK-4182: --- Ah sorry those jobs were 1.1.3 (I am not sure if th

[jira] [Created] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores

Gyula Fora created FLINK-5071: - Summary: YARN: yarn.containers.vcores config not respected when checking for vcores Key: FLINK-5071 URL: https://issues.apache.org/jira/browse/FLINK-5071 Project: Flink

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667250#comment-15667250 ] Timo Walther commented on FLINK-4872: - [~mju] can you also give an example for the cla

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r88021648 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -800,4 +907,39 @@ public StreamExecutionEn

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667225#comment-15667225 ] ASF GitHub Bot commented on FLINK-4997: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

Github user VenturaDelMonte commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r88021488 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -800,4 +907,39 @@ public StreamExec

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667222#comment-15667222 ] ASF GitHub Bot commented on FLINK-4997: --- Github user VenturaDelMonte commented on a

[jira] [Commented] (FLINK-4872) Type erasure problem exclusively on cluster execution

[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667216#comment-15667216 ] Timo Walther commented on FLINK-4872: - I will look into this issue. > Type erasure pr

[jira] [Commented] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

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

[jira] [Resolved] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

[ https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4801. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1.2.0 with 6f09ecded9e22a5eaa548ebbddb9b28d

[GitHub] flink pull request #2625: [FLINK-4801] [types] Input type inference is fault...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2625 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

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

[GitHub] flink issue #2625: [FLINK-4801] [types] Input type inference is faulty with ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2625 Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

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

[GitHub] flink issue #2650: [FLINK-4563] [metrics] scope caching not adjusted for mul...

Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2650 @zentol, thanks for your review and comments! I updated tests. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does n

[jira] [Assigned] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Shoshin reassigned FLINK-3133: Assignee: Alexander Shoshin (was: Evgeny Kincharov) > Introduce collect()/coun()/p

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667131#comment-15667131 ] Anton Mushin commented on FLINK-4832: - Ok. Could you check [commit|https://github.com

[jira] [Assigned] (FLINK-2186) Rework CSV import to support very wide files

[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-2186: Assignee: Anton Solovev > Rework CSV import to support very wide files > --

[jira] [Commented] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos.

[ https://issues.apache.org/jira/browse/FLINK-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667040#comment-15667040 ] Timo Walther commented on FLINK-4969: - The definition of type information using String

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667036#comment-15667036 ] ASF GitHub Bot commented on FLINK-4563: --- Github user ex00 commented on a diff in the

[GitHub] flink pull request #2650: [FLINK-4563] [metrics] scope caching not adjusted ...

Github user ex00 commented on a diff in the pull request: https://github.com/apache/flink/pull/2650#discussion_r88007685 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroupTest.java --- @@ -44,4 +52,132 @@ protected QueryScopeInfo cre

[jira] [Assigned] (FLINK-3849) Add FilterableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-3849: Assignee: Anton Solovev > Add FilterableTableSource interface and translation rule > --

[jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files

[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-2186: - Assignee: (was: Anton Solovev) > Rework CSV import to support very wide files > --

[jira] [Assigned] (FLINK-2186) Rework CSV import to support very wide files

[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-2186: Assignee: Anton Solovev > Rework CSV import to support very wide files > --

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666951#comment-15666951 ] ASF GitHub Bot commented on FLINK-4997: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r88001538 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -800,4 +907,39 @@ public StreamExecutionEn

[jira] [Created] (FLINK-5070) Unable to use Scala's BeanProperty with classes

Jakub Nowacki created FLINK-5070: Summary: Unable to use Scala's BeanProperty with classes Key: FLINK-5070 URL: https://issues.apache.org/jira/browse/FLINK-5070 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666872#comment-15666872 ] Timo Walther commented on FLINK-4604: - I think the missing type for {{NULL}} is a Calc

[GitHub] flink issue #2367: [FLINK-3703][cep] Add sequence matching semantics to disc...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2367 Hi @LordFB I don't think there is currently a way to do it in cep-flink. I am still waiting for Till's review for this PR, but he seems to be really busy with other work. Maybe t

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

[ https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666860#comment-15666860 ] ASF GitHub Bot commented on FLINK-3703: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-4260) Allow SQL's LIKE ESCAPE

[ https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666848#comment-15666848 ] ASF GitHub Bot commented on FLINK-4260: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #2758: [FLINK-4260] Support specifying ESCAPE character i...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2758#discussion_r87993759 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/sql/SqlITCase.java --- @@ -118,4 +119,39 @@ public void testJoin() throws

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

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

[GitHub] flink issue #2740: [FLINK-4964] [ml]

Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/2740 Hello @tfournier314 I tested your code and it does seem that partitions are sorted only internally, which is expected and `zipWithIndex` is AFAIK unaware of the sorted (as in key range) order of

[jira] [Commented] (FLINK-4260) Allow SQL's LIKE ESCAPE

[ https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666791#comment-15666791 ] ASF GitHub Bot commented on FLINK-4260: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #2758: [FLINK-4260] Support specifying ESCAPE character i...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2758#discussion_r87988814 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/sql/SqlITCase.java --- @@ -118,4 +119,39 @@ public void testJoin() throws

[GitHub] flink pull request #2811: [Flink-4541] Support for SQL NOT IN operator

GitHub user AlexanderShoshin opened a pull request: https://github.com/apache/flink/pull/2811 [Flink-4541] Support for SQL NOT IN operator NOT IN was not working with nested queries because of missed DataSet cross join rule. I added DataSetSingleRowCrossRule that converts a

[jira] [Assigned] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4263: --- Assignee: Timo Walther (was: Jark Wu) > SQL's VALUES does not work properly > --

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666782#comment-15666782 ] Timo Walther commented on FLINK-4832: - We should first fix FLINK-4263 before we implem

[jira] [Commented] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666756#comment-15666756 ] Jakub Nowacki commented on FLINK-4498: -- Adding to the above, Scala example in the doc

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2653 @wuchong thanks for the PR. I will also review it the next days. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does n

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[GitHub] flink issue #2367: [FLINK-3703][cep] Add sequence matching semantics to disc...

Github user LordFB commented on the issue: https://github.com/apache/flink/pull/2367 Hi @mushketyk and @tillrohrmann, are there any updates on this Pull Request? Or is there already a way to change the matching behaviour in FlinkCEP? --- If your project is set up for it, you

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

GitHub user tonycox opened a pull request: https://github.com/apache/flink/pull/2810 [FLINK-3848] Add ProjectableTableSource interface and translation rule. Extend CsvTableSource to implement projection You can merge this pull request into a Git repository by running: $ git pul

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

[jira] [Commented] (FLINK-5069) Pending checkpoint statistics gauge

[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1594#comment-1594 ] ASF GitHub Bot commented on FLINK-5069: --- GitHub user zhuhaifengleon opened a pull re

[GitHub] flink pull request #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

GitHub user zhuhaifengleon opened a pull request: https://github.com/apache/flink/pull/2809 [FLINK-5069] [Metrics] Pending checkpoint statistics gauge This PR introduce pending checkpoints statistics gauge, which help to check the state When checkpoints can't be done. following

[jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager

[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1588#comment-1588 ] ASF GitHub Bot commented on FLINK-4927: --- GitHub user shuai-xu opened a pull request:

[GitHub] flink pull request #2808: [FLINK-4927] [yarn]Implement FLI-6 YARN Resource M...

GitHub user shuai-xu opened a pull request: https://github.com/apache/flink/pull/2808 [FLINK-4927] [yarn]Implement FLI-6 YARN Resource Manager This pr is for issue #[4927](https://issues.apache.org/jira/browse/FLINK-4927) The Flink YARN Resource Manager communicates with YA

[jira] [Assigned] (FLINK-4693) Add session group-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-4693: -- Assignee: sunjincheng > Add session group-windows for batch tables > --

[jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup

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

[GitHub] flink pull request #2807: [FLINK-4631] Prevent some possible NPEs.

GitHub user chermenin opened a pull request: https://github.com/apache/flink/pull/2807 [FLINK-4631] Prevent some possible NPEs. Added additional conditions in several places to check possible NPEs. This PR must completely solve [FLINK-4631](https://issues.apache.org/jira/browse/FLI

[jira] [Updated] (FLINK-5069) Pending checkpoint statistics gauge

[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-5069: -- Component/s: Metrics > Pending checkpoint statistics gauge > --- > >

[jira] [Created] (FLINK-5069) Pending checkpoint statistics gauge

zhuhaifeng created FLINK-5069: - Summary: Pending checkpoint statistics gauge Key: FLINK-5069 URL: https://issues.apache.org/jira/browse/FLINK-5069 Project: Flink Issue Type: Improvement

[GitHub] flink issue #2802: Minor fixes

Github user bitchelov commented on the issue: https://github.com/apache/flink/pull/2802 Hi, @greghogan . I made some update in "sidenav.html". But lets find out what’s going on. The first div opens (74 line) and closed at (76). Div that we forgot to close is on line 110 and I’m g

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

Github user VenturaDelMonte commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r87975777 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -459,7 +545,28 @@ public WindowedSt

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1527#comment-1527 ] ASF GitHub Bot commented on FLINK-4997: --- Github user VenturaDelMonte commented on a

[jira] [Commented] (FLINK-5068) YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error

[ https://issues.apache.org/jira/browse/FLINK-5068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1520#comment-1520 ] Ufuk Celebi commented on FLINK-5068: Do you have a restart strategy configured? Should

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1502#comment-1502 ] ASF GitHub Bot commented on FLINK-4997: --- Github user VenturaDelMonte commented on a

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

Github user VenturaDelMonte commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r87974146 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -800,4 +907,39 @@ public StreamExec

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

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

[GitHub] flink issue #2736: [FLINK-4174] Enhance evictor functionality

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2736 I merged it. Thanks for your work and working with me on this: 😃 Could you please close this PR and the two Jira Issues that it solves? --- If your project is set up for it, you can rep

<    1   2   3   >