[jira] [Updated] (FLINK-10188) Solve nondeterministic functions problem for retraction

[ https://issues.apache.org/jira/browse/FLINK-10188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-10188: Description: Currently, Retraction has not considered non-deterministic functions. For sql like:

[jira] [Created] (FLINK-10188) Solve nondeterministic functions problem for retraction

Hequn Cheng created FLINK-10188: --- Summary: Solve nondeterministic functions problem for retraction Key: FLINK-10188 URL: https://issues.apache.org/jira/browse/FLINK-10188 Project: Flink Issue T

[jira] [Updated] (FLINK-10187) Fix LogicalUnnestRule to match Correlate/Uncollect correctly

[ https://issues.apache.org/jira/browse/FLINK-10187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10187: --- Labels: pull-request-available (was: ) > Fix LogicalUnnestRule to match Correlate/Uncollect

[jira] [Commented] (FLINK-10187) Fix LogicalUnnestRule to match Correlate/Uncollect correctly

[ https://issues.apache.org/jira/browse/FLINK-10187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587012#comment-16587012 ] ASF GitHub Bot commented on FLINK-10187: suez1224 opened a new pull request #659

[GitHub] suez1224 opened a new pull request #6592: [FLINK-10187][Table API & SQL] Fix LogicalUnnestRule to match correlate->...->project->uncollect cor…

suez1224 opened a new pull request #6592: [FLINK-10187][Table API & SQL] Fix LogicalUnnestRule to match correlate->...->project->uncollect cor… URL: https://github.com/apache/flink/pull/6592 ## What is the purpose of the change *Fix LogicalUnnestRule to also match correlate->...->pro

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587010#comment-16587010 ] ASF GitHub Bot commented on FLINK-10145: Guibo-Pan commented on issue #6576: [FL

[GitHub] Guibo-Pan commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

Guibo-Pan commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#issuecomment-414564921 Thanks for your patient review, @xccui . I have update the docs and styles. I am not so familiar with `CodeGenerato

[jira] [Created] (FLINK-10187) Fix LogicalUnnestRule to match Correlate/Uncollect correctly

Shuyi Chen created FLINK-10187: -- Summary: Fix LogicalUnnestRule to match Correlate/Uncollect correctly Key: FLINK-10187 URL: https://issues.apache.org/jira/browse/FLINK-10187 Project: Flink Iss

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586973#comment-16586973 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on issue #6576: [FLINK-

[GitHub] xccui commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#issuecomment-414559283 Hi @Guibo-Pan, in SQL convention, any null argument will lead to a null result. Thus when generating a scalar function call,

[jira] [Commented] (FLINK-8868) Support Table Function as Table for Stream Sql

[ https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586971#comment-16586971 ] Ruidong Li commented on FLINK-8868: --- [~hequn8128] I've tried that SQL without 'Lateral'

[jira] [Updated] (FLINK-8868) Support Table Function as Table for Stream Sql

[ https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-8868: -- Description: for stream sql: support SQL like:  SELECT * FROM TABLE(tf("a")) for batch sql: udtf might

[jira] [Commented] (FLINK-8868) Support Table Function as Table for Stream Sql

[ https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586949#comment-16586949 ] Hequn Cheng commented on FLINK-8868: Would it better to write the SQL as: SELECT * FR

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586925#comment-16586925 ] ASF GitHub Bot commented on FLINK-10145: Guibo-Pan commented on a change in pull

[GitHub] Guibo-Pan commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

Guibo-Pan commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211477186 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functio

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586921#comment-16586921 ] ASF GitHub Bot commented on FLINK-10145: Guibo-Pan commented on a change in pull

[GitHub] Guibo-Pan commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

Guibo-Pan commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211476309 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/B

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586920#comment-16586920 ] ASF GitHub Bot commented on FLINK-10145: Guibo-Pan commented on a change in pull

[GitHub] Guibo-Pan commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

Guibo-Pan commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211475986 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/S

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211457492 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressio

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586800#comment-16586800 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586803#comment-16586803 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586807#comment-16586807 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211455681 ## File path: docs/dev/table/functions.md ## @@ -2400,6 +2400,18 @@ SUBSTRING(string FROM

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586808#comment-16586808 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586805#comment-16586805 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211460298 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/S

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211456540 ## File path: docs/dev/table/functions.md ## @@ -2400,6 +2400,18 @@ SUBSTRING(string FROM

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211458977 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/Scala

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211456990 ## File path: docs/dev/table/functions.md ## @@ -2592,6 +2604,18 @@ STRING.substring(INT1,

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211459387 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/Built

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586804#comment-16586804 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211457188 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressio

[GitHub] xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

xccui commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211456089 ## File path: docs/dev/table/functions.md ## @@ -2400,6 +2400,18 @@ SUBSTRING(string FROM

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586806#comment-16586806 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586802#comment-16586802 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586801#comment-16586801 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on a change in pull req

[jira] [Commented] (FLINK-10060) Add RTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586798#comment-16586798 ] ASF GitHub Bot commented on FLINK-10060: yanghua commented on issue #6509: [FLIN

[GitHub] yanghua commented on issue #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL

yanghua commented on issue #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6509#issuecomment-414527124 @xccui Thank you very much! I just looked at the differences and I will pay attention to correcting the details next time.

[jira] [Commented] (FLINK-10186) FindBugs warnings: Random object created and used only once

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586787#comment-16586787 ] ASF GitHub Bot commented on FLINK-10186: hiroakiy opened a new pull request #659

[jira] [Updated] (FLINK-10186) FindBugs warnings: Random object created and used only once

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10186: --- Labels: pull-request-available (was: ) > FindBugs warnings: Random object created and used

[GitHub] hiroakiy opened a new pull request #6591: [FLINK-10186] Fix FindBugs warnings: Random object created and used o…

hiroakiy opened a new pull request #6591: [FLINK-10186] Fix FindBugs warnings: Random object created and used o… URL: https://github.com/apache/flink/pull/6591 This PR fixes a DMI_RANDOM_USED_ONLY_ONCE warning reported by FindBugs-3.0.1 ([http://findbugs.sourceforge.net/](http://findbugs.s

[jira] [Created] (FLINK-10186) FindBugs warnings: Random object created and used only once

Hiroaki Yoshida created FLINK-10186: --- Summary: FindBugs warnings: Random object created and used only once Key: FLINK-10186 URL: https://issues.apache.org/jira/browse/FLINK-10186 Project: Flink

[jira] [Commented] (FLINK-10060) Add RTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586739#comment-16586739 ] ASF GitHub Bot commented on FLINK-10060: xccui commented on issue #6509: [FLINK-

[GitHub] xccui commented on issue #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL

xccui commented on issue #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6509#issuecomment-414517575 Hi @yanghua, thanks for your efforts. I did some minor refactorings and merged this PR. It'd be better if you could spend som

[jira] [Resolved] (FLINK-10060) Add RTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-10060. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0 ad15d4f9af87206db4bc33c084680440453

[jira] [Commented] (FLINK-10060) Add RTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586735#comment-16586735 ] ASF GitHub Bot commented on FLINK-10060: asfgit closed pull request #6509: [FLIN

[GitHub] asfgit closed pull request #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL

asfgit closed pull request #6509: [FLINK-10060] [table] Add RTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6509 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 provenance: As t

[jira] [Commented] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586727#comment-16586727 ] ASF GitHub Bot commented on FLINK-9962: --- bowenli86 commented on issue #6492: [FLINK

[GitHub] bowenli86 commented on issue #6492: [FLINK-9962] [FS connector] allow users to specify TimeZone in DateTimeBucketer

bowenli86 commented on issue #6492: [FLINK-9962] [FS connector] allow users to specify TimeZone in DateTimeBucketer URL: https://github.com/apache/flink/pull/6492#issuecomment-414513166 @kl0u a couple things that may need attention: - powerMock needs to stay in order to mock static

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

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

[GitHub] tillrohrmann opened a new pull request #6590: [Backport 1.4][FLINK-10011] Release JobGraph from SubmittedJobGraphStore

tillrohrmann opened a new pull request #6590: [Backport 1.4][FLINK-10011] Release JobGraph from SubmittedJobGraphStore URL: https://github.com/apache/flink/pull/6590 ## What is the purpose of the change Backport of #6587 for `release-1.4`. ---

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

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

[GitHub] tillrohrmann opened a new pull request #6589: [Backport 1.5][FLINK-10011] Release JobGraph from SubmittedJobGraphStore

tillrohrmann opened a new pull request #6589: [Backport 1.5][FLINK-10011] Release JobGraph from SubmittedJobGraphStore URL: https://github.com/apache/flink/pull/6589 ## What is the purpose of the change Backport of #6587 for `release-1.5`. ---

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

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

[GitHub] tillrohrmann opened a new pull request #6588: [Backport 1.6][FLINK-10011] Release JobGraph from SubmittedJobGraphStore

tillrohrmann opened a new pull request #6588: [Backport 1.6][FLINK-10011] Release JobGraph from SubmittedJobGraphStore URL: https://github.com/apache/flink/pull/6588 ## What is the purpose of the change Backport of #6587 for `release-1.6`. ---

[jira] [Updated] (FLINK-10011) Old job resurrected during HA failover

[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10011: --- Labels: pull-request-available (was: ) > Old job resurrected during HA failover > -

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

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

[GitHub] tillrohrmann opened a new pull request #6587: [FLINK-10011] Release JobGraph from SubmittedJobGraphStore

tillrohrmann opened a new pull request #6587: [FLINK-10011] Release JobGraph from SubmittedJobGraphStore URL: https://github.com/apache/flink/pull/6587 ## What is the purpose of the change This PR fixes the problem that sometimes `JobGraphs` cannot be removed from the `ZooKeeperSubm

[jira] [Commented] (FLINK-10185) Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous

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

[jira] [Updated] (FLINK-10185) Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous

[ https://issues.apache.org/jira/browse/FLINK-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10185: --- Labels: pull-request-available (was: ) > Make ZooKeeperStateHandleStore#releaseAndTryRemove

[GitHub] tillrohrmann opened a new pull request #6586: [FLINK-10185] Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous

tillrohrmann opened a new pull request #6586: [FLINK-10185] Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous URL: https://github.com/apache/flink/pull/6586 ## What is the purpose of the change Remove the asynchronous callback from ZooKeeperStateHandleStore#releaseAndTr

[jira] [Created] (FLINK-10185) Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous

Till Rohrmann created FLINK-10185: - Summary: Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous Key: FLINK-10185 URL: https://issues.apache.org/jira/browse/FLINK-10185 Project: Flink

[GitHub] fhueske commented on a change in pull request #6549: [FLINK-10127] Add Instant to basic types

fhueske commented on a change in pull request #6549: [FLINK-10127] Add Instant to basic types URL: https://github.com/apache/flink/pull/6549#discussion_r211405853 ## File path: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java ## @@ -150,6 +151,12 @

[jira] [Commented] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant

[ https://issues.apache.org/jira/browse/FLINK-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586574#comment-16586574 ] ASF GitHub Bot commented on FLINK-10127: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586571#comment-16586571 ] Nico Kruber commented on FLINK-9878: Fixed via: - `release-1.5`: 9e421a438dd830c6be72

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586567#comment-16586567 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK closed pull request #6355: [FLINK-98

[GitHub] NicoK closed pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

NicoK closed pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355 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 provenance: As this is

[jira] [Commented] (FLINK-10181) Add anchor link to individual rest requests

[ https://issues.apache.org/jira/browse/FLINK-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586487#comment-16586487 ] ASF GitHub Bot commented on FLINK-10181: fhueske commented on issue #6584: [FLIN

[GitHub] fhueske commented on issue #6584: [FLINK-10181][rest][docs] Add anchor links to rest requests

fhueske commented on issue #6584: [FLINK-10181][rest][docs] Add anchor links to rest requests URL: https://github.com/apache/flink/pull/6584#issuecomment-414456353 +1 to merge. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586462#comment-16586462 ] Till Rohrmann commented on FLINK-9101: -- Another instance: https://api.travis-ci.org/

[jira] [Commented] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586461#comment-16586461 ] Till Rohrmann commented on FLINK-9101: -- Another instance: https://api.travis-ci.org/

[jira] [Comment Edited] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586326#comment-16586326 ] William Cummings edited comment on FLINK-10184 at 8/20/18 6:11 PM: ---

[jira] [Comment Edited] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586326#comment-16586326 ] William Cummings edited comment on FLINK-10184 at 8/20/18 6:07 PM: ---

[jira] [Comment Edited] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586326#comment-16586326 ] William Cummings edited comment on FLINK-10184 at 8/20/18 6:06 PM: ---

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586326#comment-16586326 ] William Cummings commented on FLINK-10184: -- I am also experiencing this issue i

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586304#comment-16586304 ] ASF GitHub Bot commented on FLINK-10042: azagrebin commented on a change in pull

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586301#comment-16586301 ] ASF GitHub Bot commented on FLINK-10042: azagrebin commented on a change in pull

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586300#comment-16586300 ] ASF GitHub Bot commented on FLINK-10042: azagrebin commented on a change in pull

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586302#comment-16586302 ] ASF GitHub Bot commented on FLINK-10042: azagrebin commented on a change in pull

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586303#comment-16586303 ] ASF GitHub Bot commented on FLINK-10042: azagrebin commented on a change in pull

[GitHub] azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556#discussion_r210962023 ## File path: flink-runtime/src/main/java/or

[GitHub] azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556#discussion_r211340145 ## File path: flink-state-backends/flink-sta

[GitHub] azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556#discussion_r211193248 ## File path: flink-runtime/src/main/java/or

[GitHub] azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556#discussion_r211342224 ## File path: flink-state-backends/flink-sta

[GitHub] azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

azagrebin commented on a change in pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556#discussion_r211325634 ## File path: flink-state-backends/flink-sta

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586228#comment-16586228 ] ASF GitHub Bot commented on FLINK-9325: --- sihuazhou commented on issue #5982: [FLINK

[GitHub] sihuazhou commented on issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkpoint only when the writing is truly successful

sihuazhou commented on issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkpoint only when the writing is truly successful URL: https://github.com/apache/flink/pull/5982#issuecomment-414390311 Hi @StephanEwen thanks for your comments! I was caught up by some terrible work

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586215#comment-16586215 ] ASF GitHub Bot commented on FLINK-10059: asfgit closed pull request #6494: [FLIN

[jira] [Resolved] (FLINK-10059) Add LTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-10059. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0 37420794e4df425204ec0c896f233ca22e0

[GitHub] asfgit closed pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

asfgit closed pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494 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 provenance: As t

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586188#comment-16586188 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~elevy], I don't believe

[jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

[ https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586182#comment-16586182 ] ASF GitHub Bot commented on FLINK-10172: fhueske commented on a change in pull r

[GitHub] fhueske commented on a change in pull request #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser

fhueske commented on a change in pull request #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser URL: https://github.com/apache/flink/pull/6585#discussion_r211326743 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/a

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586177#comment-16586177 ] Elias Levy commented on FLINK-10184: [~Jamalarm] this seems like a duplicate of FLIN

[jira] [Updated] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10184: Description: We have encountered a blocking issue when upgrading our cluster to 1.

[jira] [Commented] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

[ https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586173#comment-16586173 ] ASF GitHub Bot commented on FLINK-10172: walterddr opened a new pull request #65

[jira] [Created] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

Thomas Wozniakowski created FLINK-10184: --- Summary: HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel Key: FLINK-10184 URL: https://issues.apache.org/jira/browse/FLINK-10184

[jira] [Updated] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc

[ https://issues.apache.org/jira/browse/FLINK-10172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10172: --- Labels: pull-request-available (was: ) > Inconsistentcy in ExpressionParser and ExpressionD

[GitHub] walterddr opened a new pull request #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser

walterddr opened a new pull request #6585: [FLINK-10172][table]re-adding asc & desc suffix expression to expressionParser URL: https://github.com/apache/flink/pull/6585 ## What is the purpose of the change Fix Java expressionParser not correctly resolving `asc` and `desc` keyword.

  1   2   3   4   >