[jira] [Updated] (FLINK-9915) Add TO_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9915: Issue Type: Sub-task (was: New Feature) Parent: FLINK-6810 > Add TO_BASE64 function for table/sql

[jira] [Updated] (FLINK-9916) Add FROM_BASE64 function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9916: Issue Type: Sub-task (was: New Feature) Parent: FLINK-6810 > Add FROM_BASE64 function for table/sq

[jira] [Assigned] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated

[ https://issues.apache.org/jira/browse/FLINK-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10105: Assignee: Dawid Wysakowicz > Test failure because of jobmanager.execution.failove

[jira] [Created] (FLINK-10106) Include test name in temp directory of e2e test

Till Rohrmann created FLINK-10106: - Summary: Include test name in temp directory of e2e test Key: FLINK-10106 URL: https://issues.apache.org/jira/browse/FLINK-10106 Project: Flink Issue Type:

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208830206 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/Flink

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208831842 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208833159 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/lo

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208833101 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/lo

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208835846 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harne

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208835295 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/da

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208829502 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.sca

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[GitHub] azagrebin commented on a change in pull request #6425: [FLINK-9664][Doc] fixing documentation in ML quick start

azagrebin commented on a change in pull request #6425: [FLINK-9664][Doc] fixing documentation in ML quick start URL: https://github.com/apache/flink/pull/6425#discussion_r208837648 ## File path: docs/dev/libs/ml/quickstart.md ## @@ -129,6 +129,10 @@ and the [test set here

[GitHub] pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208835295 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/da

[jira] [Commented] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described

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

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[GitHub] fhueske opened a new pull request #6527: [hotfix] [docs] Fix ProcessWindowFunction code snippets.

fhueske opened a new pull request #6527: [hotfix] [docs] Fix ProcessWindowFunction code snippets. URL: https://github.com/apache/flink/pull/6527 ## What is the purpose of the change - Fix the code snippets for the `ProcessWindowFunction` in the documentation ## Brief change lo

[GitHub] tillrohrmann commented on issue #6496: [FLINK-10063][tests] Use runit to supervise mesos processes.

tillrohrmann commented on issue #6496: [FLINK-10063][tests] Use runit to supervise mesos processes. URL: https://github.com/apache/flink/pull/6496#issuecomment-411672800 Merging this PR. This is an automated message from the

[jira] [Commented] (FLINK-10063) Jepsen: Automatically restart Mesos Processes

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

[GitHub] asfgit closed pull request #6496: [FLINK-10063][tests] Use runit to supervise mesos processes.

asfgit closed pull request #6496: [FLINK-10063][tests] Use runit to supervise mesos processes. URL: https://github.com/apache/flink/pull/6496 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 thi

[jira] [Commented] (FLINK-10063) Jepsen: Automatically restart Mesos Processes

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

[jira] [Resolved] (FLINK-10063) Jepsen: Automatically restart Mesos Processes

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

[jira] [Updated] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated

[ https://issues.apache.org/jira/browse/FLINK-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10105: - Affects Version/s: 1.7.0 > Test failure because of jobmanager.execution.failover-strateg

[jira] [Resolved] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated

[ https://issues.apache.org/jira/browse/FLINK-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10105. -- Resolution: Fixed Fix Version/s: 1.7.0 > Test failure because of jobmanager.exe

[jira] [Assigned] (FLINK-10106) Include test name in temp directory of e2e test

[ https://issues.apache.org/jira/browse/FLINK-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10106: Assignee: Dawid Wysakowicz > Include test name in temp directory of e2e test > --

[jira] [Created] (FLINK-10107) SQL Client end-to-end test fails for releases

Timo Walther created FLINK-10107: Summary: SQL Client end-to-end test fails for releases Key: FLINK-10107 URL: https://issues.apache.org/jira/browse/FLINK-10107 Project: Flink Issue Type: Bug

[GitHub] fhueske commented on issue #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

fhueske commented on issue #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#issuecomment-411683146 Thanks for the PR @walterddr! I did not have a detailed look, but we would also need to add suppor

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

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

[GitHub] tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508#issuecomment-411685212 @twalthr @suez1224 could you please review?

[GitHub] twalthr opened a new pull request #6528: [FLINK-10107] [e2e] Exclude conflicting SQL JARs from test

twalthr opened a new pull request #6528: [FLINK-10107] [e2e] Exclude conflicting SQL JARs from test URL: https://github.com/apache/flink/pull/6528 ## What is the purpose of the change This is a temporary solution for fixing the SQL Client end-to-end test for releases. ##

[jira] [Updated] (FLINK-10107) SQL Client end-to-end test fails for releases

[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10107: --- Labels: pull-request-available (was: ) > SQL Client end-to-end test fails for releases > --

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

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

[jira] [Created] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException

Xingcan Cui created FLINK-10108: --- Summary: DATE_FORMAT function in sql test throws a NumberFormatException Key: FLINK-10108 URL: https://issues.apache.org/jira/browse/FLINK-10108 Project: Flink

[GitHub] dawidwys opened a new pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test

dawidwys opened a new pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test URL: https://github.com/apache/flink/pull/6529 Simple improvement for e2e tests debuggability. This is an automated

[jira] [Commented] (FLINK-10106) Include test name in temp directory of e2e test

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

[jira] [Updated] (FLINK-10106) Include test name in temp directory of e2e test

[ https://issues.apache.org/jira/browse/FLINK-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10106: --- Labels: pull-request-available (was: ) > Include test name in temp directory of e2e test >

[jira] [Commented] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

[ https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574534#comment-16574534 ] Aljoscha Krettek commented on FLINK-7829: - [~mingleizhang] yes, absolutely > Rem

[jira] [Commented] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated

[ https://issues.apache.org/jira/browse/FLINK-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574535#comment-16574535 ] Chesnay Schepler commented on FLINK-10105: -- master: 4607b2e6b6a5d9b3286bc5a0745

[GitHub] zentol commented on a change in pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test

zentol commented on a change in pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test URL: https://github.com/apache/flink/pull/6529#discussion_r208858966 ## File path: flink-end-to-end-tests/test-scripts/test-runner-common.sh ## @@ -29,12

[jira] [Commented] (FLINK-10106) Include test name in temp directory of e2e test

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

[GitHub] dawidwys commented on a change in pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test

dawidwys commented on a change in pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test URL: https://github.com/apache/flink/pull/6529#discussion_r208860682 ## File path: flink-end-to-end-tests/test-scripts/test-runner-common.sh ## @@ -29,

[GitHub] dawidwys commented on a change in pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test

dawidwys commented on a change in pull request #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test URL: https://github.com/apache/flink/pull/6529#discussion_r208860682 ## File path: flink-end-to-end-tests/test-scripts/test-runner-common.sh ## @@ -29,

[jira] [Commented] (FLINK-10106) Include test name in temp directory of e2e test

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

[jira] [Commented] (FLINK-10106) Include test name in temp directory of e2e test

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

[jira] [Commented] (FLINK-10106) Include test name in temp directory of e2e test

[ https://issues.apache.org/jira/browse/FLINK-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574553#comment-16574553 ] ASF GitHub Bot commented on FLINK-10106: dawidwys commented on issue #6529: [FLI

[GitHub] dawidwys commented on issue #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test

dawidwys commented on issue #6529: [FLINK-10106][e2e] Included test name in temp directory of e2e test URL: https://github.com/apache/flink/pull/6529#issuecomment-411696699 It does not work well when one of the parameters is url/uri. Fixing.

[jira] [Created] (FLINK-10109) Add documentation for StreamingFileSink

Aljoscha Krettek created FLINK-10109: Summary: Add documentation for StreamingFileSink Key: FLINK-10109 URL: https://issues.apache.org/jira/browse/FLINK-10109 Project: Flink Issue Type: S

[jira] [Created] (FLINK-10110) Harden e2e Kafka shutdown

Till Rohrmann created FLINK-10110: - Summary: Harden e2e Kafka shutdown Key: FLINK-10110 URL: https://issues.apache.org/jira/browse/FLINK-10110 Project: Flink Issue Type: Improvement

[GitHub] tillrohrmann opened a new pull request #6530: [FLINK-10110][tests] Harden Kafka component shut down for E2E tests

tillrohrmann opened a new pull request #6530: [FLINK-10110][tests] Harden Kafka component shut down for E2E tests URL: https://github.com/apache/flink/pull/6530 ## What is the purpose of the change Instead of only calling kafka-server-stop.sh and zookeeper-server-stop.sh which can f

[jira] [Commented] (FLINK-10110) Harden e2e Kafka shutdown

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

[jira] [Updated] (FLINK-10110) Harden e2e Kafka shutdown

[ https://issues.apache.org/jira/browse/FLINK-10110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10110: --- Labels: pull-request-available (was: ) > Harden e2e Kafka shutdown > --

[GitHub] tillrohrmann opened a new pull request #6531: [FLINK-10110][tests] Harden Kafka component shut down for E2E tests

tillrohrmann opened a new pull request #6531: [FLINK-10110][tests] Harden Kafka component shut down for E2E tests URL: https://github.com/apache/flink/pull/6531 ## What is the purpose of the change Instead of only calling kafka-server-stop.sh and zookeeper-server-stop.sh which can f

[jira] [Commented] (FLINK-10110) Harden e2e Kafka shutdown

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

[GitHub] rickhofstede commented on issue #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern"

rickhofstede commented on issue #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern" URL: https://github.com/apache/flink/pull/6503#issuecomment-411703560 @yanghua Since you've reviewed my commits, let me please ask you the following. It appear

[jira] [Commented] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern"

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

[jira] [Closed] (FLINK-9894) Potential Data Race

[ https://issues.apache.org/jira/browse/FLINK-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 closed FLINK-9894. -- Resolution: Incomplete > Potential Data Race > --- > > Key: FLINK-9894 >

[jira] [Assigned] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-10108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-10108: -- Assignee: Ruidong Li > DATE_FORMAT function in sql test throws a NumberFormatException >

[GitHub] aljoscha opened a new pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink

aljoscha opened a new pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink URL: https://github.com/apache/flink/pull/6532 I kept this simple on purpose and defer mostly to the Javadocs, which I assume will be more accurate over time and they already have good explanati

[jira] [Commented] (FLINK-10109) Add documentation for StreamingFileSink

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

[jira] [Updated] (FLINK-10109) Add documentation for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10109: --- Labels: pull-request-available (was: ) > Add documentation for StreamingFileSink >

[jira] [Updated] (FLINK-10079) Automatically register sink table from external catalogs

[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10079: -- Fix Version/s: (was: 1.6.0) 1.7.0 > Automatically register sink table f

[jira] [Updated] (FLINK-10099) Rework YarnResourceManagerTest

[ https://issues.apache.org/jira/browse/FLINK-10099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10099: -- Fix Version/s: (was: 1.6.0) 1.7.0 > Rework YarnResourceManagerTest > --

[jira] [Updated] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9749: - Fix Version/s: (was: 1.6.0) 1.7.0 > Rework Bucketing Sink > --

[jira] [Updated] (FLINK-9980) wiki-edits quickstart docs aren't clear enough

[ https://issues.apache.org/jira/browse/FLINK-9980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9980: - Fix Version/s: (was: 1.6.0) 1.7.0 > wiki-edits quickstart docs aren't clea

[jira] [Updated] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9749: - Fix Version/s: (was: 1.7.0) 1.6.0 > Rework Bucketing Sink > --

[GitHub] twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r208876405 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/logi

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Assigned] (FLINK-9795) Update Mesos documentation for flip6

[ https://issues.apache.org/jira/browse/FLINK-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9795: --- Assignee: Gary Yao > Update Mesos documentation for flip6 > > >

[jira] [Commented] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-10108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574698#comment-16574698 ] Timo Walther commented on FLINK-10108: -- The DATE_FORMAT function is completely brok

[jira] [Closed] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-10108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10108. Resolution: Duplicate > DATE_FORMAT function in sql test throws a NumberFormatException >

[jira] [Created] (FLINK-10111) Test failure because of HAQueryableStateFsBackendITCase#testMapState thorws NPE

vinoyang created FLINK-10111: Summary: Test failure because of HAQueryableStateFsBackendITCase#testMapState thorws NPE Key: FLINK-10111 URL: https://issues.apache.org/jira/browse/FLINK-10111 Project: Flin

[jira] [Commented] (FLINK-9433) SystemProcessingTimeService does not work properly

[ https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574704#comment-16574704 ] Ruidong Li commented on FLINK-9433: --- How about add a clear thread with Java DelayQueue

[GitHub] yanghua commented on issue #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern"

yanghua commented on issue #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern" URL: https://github.com/apache/flink/pull/6503#issuecomment-411724977 hi @rickhofstede , Travis build error is not caused by your code. So, take it easy. The next time you

[jira] [Commented] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern"

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

[GitHub] yanghua edited a comment on issue #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern"

yanghua edited a comment on issue #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern" URL: https://github.com/apache/flink/pull/6503#issuecomment-411724977 hi @rickhofstede , Travis build error is not caused by your code. So, take it easy. The next t

[jira] [Commented] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern"

[ https://issues.apache.org/jira/browse/FLINK-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574709#comment-16574709 ] ASF GitHub Bot commented on FLINK-10072: yanghua edited a comment on issue #6503

[GitHub] tillrohrmann closed pull request #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen sockets for WebFront…

tillrohrmann closed pull request #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen sockets for WebFront… URL: https://github.com/apache/flink/pull/5920 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 pro

[GitHub] tillrohrmann commented on issue #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen sockets for WebFront…

tillrohrmann commented on issue #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen sockets for WebFront… URL: https://github.com/apache/flink/pull/5920#issuecomment-411731732 I will close this PR since it seems to be inactive. If you still want to work on it @trionesadam please reopen

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574733#comment-16574733 ] ASF GitHub Bot commented on FLINK-9231: --- tillrohrmann commented on issue #5920: [FL

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574734#comment-16574734 ] ASF GitHub Bot commented on FLINK-9231: --- tillrohrmann closed pull request #5920: [F

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

[ https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574738#comment-16574738 ] Timo Walther commented on FLINK-9964: - I think we should not mixup formats. If you re

[jira] [Comment Edited] (FLINK-9433) SystemProcessingTimeService does not work properly

[ https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574704#comment-16574704 ] Ruidong Li edited comment on FLINK-9433 at 8/9/18 12:07 PM: H

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

[ https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574750#comment-16574750 ] buptljy commented on FLINK-9964: [~twalthr] I mean the json schema of a csv format data.

[GitHub] azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call

azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call URL: https://github.com/apache/flink/pull/5996#discussion_r208905065 ## File path: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/str

[GitHub] azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call

azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call URL: https://github.com/apache/flink/pull/5996#discussion_r208904205 ## File path: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/str

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

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

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

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

[GitHub] azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call

azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call URL: https://github.com/apache/flink/pull/5996#discussion_r208906401 ## File path: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/str

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

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

[GitHub] azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call

azagrebin commented on a change in pull request #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call URL: https://github.com/apache/flink/pull/5996#discussion_r208905291 ## File path: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/str

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

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

[jira] [Created] (FLINK-10112) https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT

Yazdan Shirvany created FLINK-10112: --- Summary: https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT Key: FLINK-10112 URL: https://issues.apache.org/jira/browse/FLINK-10112 Project: Flink

[jira] [Updated] (FLINK-10112) https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-10112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yazdan Shirvany updated FLINK-10112: Description: Flink 1.6 has been released but I still can see 1.6-SNAPSHOT on https://ci.ap

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

[ https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574807#comment-16574807 ] Timo Walther commented on FLINK-9964: - We had a discussion recently where somebody wa

  1   2   3   >