[GitHub] [flink] eskabetxe commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

eskabetxe commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-525004541 @flinkbot attention @kl0u This is an

[GitHub] [flink] flinkbot commented on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot commented on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525053464 ## CI report: * fc93ac2188416b5b9a2c92fa0c4893d842e167ce : UNKNOWN

[GitHub] [flink] bowenli86 commented on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

bowenli86 commented on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-525059547 LGTM, merging. I created [FLINK-13866](https://issues.apache.org/jira/browse/FLINK-13866) to track the

[jira] [Created] (FLINK-13864) StreamingFileSink: Allow inherited classes to extend StreamingFileSink correctly

Kailash Hassan Dayanand created FLINK-13864: --- Summary: StreamingFileSink: Allow inherited classes to extend StreamingFileSink correctly Key: FLINK-13864 URL:

[GitHub] [flink] xuefuz commented on a change in pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

xuefuz commented on a change in pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#discussion_r317731126 ## File path:

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916054#comment-16916054 ] Gyula Fora commented on FLINK-13850: I think having clear and well structured code for configuration

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916082#comment-16916082 ] Gyula Fora commented on FLINK-13850: Maybe we should come up with a better name like

[GitHub] [flink] flinkbot edited a comment on issue #9536: [FLINK-13863] Update Flink Operations Playground to Flink 1.9.0

flinkbot edited a comment on issue #9536: [FLINK-13863] Update Flink Operations Playground to Flink 1.9.0 URL: https://github.com/apache/flink/pull/9536#issuecomment-524930274 ## CI report: * 88d9c42a1d6a0f59fe2be418304e0b27691727f6 : SUCCESS

[GitHub] [flink] walterddr commented on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

walterddr commented on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-524970594 Thanks for quickly address the comment. @tillrohrmann do you have additional comments? I will try merging

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916071#comment-16916071 ] Kostas Kloudas commented on FLINK-13850: In general I agree with the idea of making the Config a

[GitHub] [flink] flinkbot edited a comment on issue #9486: [FLINK-13789] move prefix out of the format string

flinkbot edited a comment on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-522731408 ## CI report: * 6b1de55f21733476acacf0de3df5c859e6d49a48 : CANCELED

[GitHub] [flink] bowenli86 edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

bowenli86 edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-525059547 LGTM. W.r.t testing, shall we at least add build profiles for these newly added Hive versions in

[GitHub] [flink] bowenli86 edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

bowenli86 edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-525059547 LGTM. W.r.t testing, shall we at least add build profiles for these newly added Hive versions in

[GitHub] [flink] flinkbot edited a comment on issue #9491: [FLINK-12749] Add Flink Operations Playground

flinkbot edited a comment on issue #9491: [FLINK-12749] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9491#issuecomment-522965231 ## CI report: * e8d9855138cff89f1c728ad334d13b0beae5b159 : SUCCESS

[GitHub] [flink-playgrounds] sjwiesman edited a comment on issue #3: [FLINK-13863] Update playgrounds to Flink 1.9.0

sjwiesman edited a comment on issue #3: [FLINK-13863] Update playgrounds to Flink 1.9.0 URL: https://github.com/apache/flink-playgrounds/pull/3#issuecomment-524964635 @fhueske I built the image and went through the steps in apache/flink#9536 and everything worked perfectly +1

[GitHub] [flink-playgrounds] sjwiesman commented on issue #3: [FLINK-13863] Update playgrounds to Flink 1.9.0

sjwiesman commented on issue #3: [FLINK-13863] Update playgrounds to Flink 1.9.0 URL: https://github.com/apache/flink-playgrounds/pull/3#issuecomment-524964635 @fhueske I went through the steps in apache/flink#9536 and everything worked perfectly +1

[GitHub] [flink] xuefuz opened a new pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

xuefuz opened a new pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524 …rsions ## What is the purpose of the change Support all 1.2 and 2.3 minor Hive versions instead of currently 1.2.1 and

[jira] [Created] (FLINK-13865) Support custom config in Flink docker image

Dagang Wei created FLINK-13865: -- Summary: Support custom config in Flink docker image Key: FLINK-13865 URL: https://issues.apache.org/jira/browse/FLINK-13865 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916025#comment-16916025 ] Kostas Kloudas commented on FLINK-13850: Before we have such a change, let's think of what we

[GitHub] [flink] xuefuz commented on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

xuefuz commented on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-524974073 PR updated based on review feedback. @bowenli86 could you take another look? Thanks.

[GitHub] [flink] xuefuz closed pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

xuefuz closed pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524 This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-13866) develop testing plan for many Hive versions that we support

Bowen Li created FLINK-13866: Summary: develop testing plan for many Hive versions that we support Key: FLINK-13866 URL: https://issues.apache.org/jira/browse/FLINK-13866 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot commented on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525052373 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] xuefuz commented on issue #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as…

xuefuz commented on issue #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as… URL: https://github.com/apache/flink/pull/8727#issuecomment-524951457 @docete Thanks for the contribution and sharing your thoughts. While I know there is another ticket dealing with

[GitHub] [flink] tweise opened a new pull request #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

tweise opened a new pull request #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537 Cosmetic changes to avoid confusion! This is an

[GitHub] [flink] flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525053464 ## CI report: * fc93ac2188416b5b9a2c92fa0c4893d842e167ce : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-524486870 ## CI report: * b14e1be6754588ea64242b6ea79a272c78d6728a : SUCCESS

[GitHub] [flink] haodang commented on issue #9486: [FLINK-13789] move prefix out of the format string

haodang commented on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-525053003 Thanks @StephanEwen and @TisonKun. That makes sense. Just made the change.

[GitHub] [flink] flinkbot edited a comment on issue #9486: [FLINK-13789] move prefix out of the format string

flinkbot edited a comment on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-522731408 ## CI report: * 6b1de55f21733476acacf0de3df5c859e6d49a48 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-524486870 ## CI report: * b14e1be6754588ea64242b6ea79a272c78d6728a : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9538: [docs][hotfix] fix typos

flinkbot commented on issue #9538: [docs][hotfix] fix typos URL: https://github.com/apache/flink/pull/9538#issuecomment-525095494 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment

[GitHub] [flink] YngwieWang commented on issue #9535: [hotfix][docs] fix typos

YngwieWang commented on issue #9535: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9535#issuecomment-525095524 > @YngwieWang you can make use of `git commit --amend` and then `git push --force` to rewrite subject of a commit in pull request. Thanks for your

[GitHub] [flink] flinkbot commented on issue #9538: [docs][hotfix] fix typos

flinkbot commented on issue #9538: [docs][hotfix] fix typos URL: https://github.com/apache/flink/pull/9538#issuecomment-525097982 ## CI report: * 07c04045c445ccd5d844ffc733d01ac7adbf88ee : UNKNOWN This is an

[GitHub] [flink] flinkbot commented on issue #9539: [hotfix][docs] fix typos

flinkbot commented on issue #9539: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9539#issuecomment-525098010 ## CI report: * 9430aca9b85c3a226cf5d5546e174d57daa8174e : UNKNOWN This is an

[GitHub] [flink] Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522054960 @flinkbot attention @yanghua @buptljy This

[GitHub] [flink] Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-525112986 @flinkbot run travis This is an automated message

[jira] [Updated] (FLINK-13765) Introduce the TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Summary: Introduce the TwoInputSelectionHandler for selecting input in

[jira] [Updated] (FLINK-13765) Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Summary: Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[GitHub] [flink] flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540#issuecomment-525126046 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13859) JSONDeserializationSchema spell error

[ https://issues.apache.org/jira/browse/FLINK-13859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13859: --- Labels: pull-request-available (was: ) > JSONDeserializationSchema spell error >

[GitHub] [flink] flinkbot edited a comment on issue #9539: [hotfix][docs] Fix typo

flinkbot edited a comment on issue #9539: [hotfix][docs] Fix typo URL: https://github.com/apache/flink/pull/9539#issuecomment-525098010 ## CI report: * 9430aca9b85c3a226cf5d5546e174d57daa8174e : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/124669373)

[GitHub] [flink] taizilongxu opened a new pull request #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

taizilongxu opened a new pull request #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540 ## What is the purpose of the change The doc spell error ## Brief change log JsonDeserializationSchema ->

[GitHub] [flink] zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-525149250 @flinkbot run travis

[GitHub] [flink] YngwieWang opened a new pull request #9538: [docs][hotfix] fix typos

YngwieWang opened a new pull request #9538: [docs][hotfix] fix typos URL: https://github.com/apache/flink/pull/9538 [docs][hotfix] fix two typos This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] TisonKun commented on issue #9535: [hotfix][docs] fix typos

TisonKun commented on issue #9535: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9535#issuecomment-525094603 @YngwieWang you can make use of `git commit --amend` and then `git push --force` to rewrite subject of a commit in pull request.

[GitHub] [flink] YngwieWang opened a new pull request #9539: [hotfix][docs] fix typos

YngwieWang opened a new pull request #9539: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9539 [hotfix][docs] fix typos This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] YngwieWang commented on issue #9538: [hotfix][docs] Fix typo

YngwieWang commented on issue #9538: [hotfix][docs] Fix typo URL: https://github.com/apache/flink/pull/9538#issuecomment-525101528 > Thanks for your contribution @YngwieWang! > > Follow the standard in our community we use pattern `[hotfix][] ...` thus I would suggest commit with

[GitHub] [flink] Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-525108063 @flinkbot run travis This is an automated

[GitHub] [flink] Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-525108063 @flinkbot run travis This is an automated message

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916283#comment-16916283 ] Jark Wu commented on FLINK-9477: Hi [~x1q1j1], it would be great if you can summarize the

[jira] [Commented] (FLINK-13862) Remove or rewrite Execution Plan docs

[ https://issues.apache.org/jira/browse/FLINK-13862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916282#comment-16916282 ] TisonKun commented on FLINK-13862: -- After a close look I would prefer removing it at least for now.

[GitHub] [flink] Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#discussion_r317868102 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[GitHub] [flink] JingsongLi commented on a change in pull request #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

JingsongLi commented on a change in pull request #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#discussion_r317879792 ## File path: docs/dev/table/sql.md ## @@ -813,6 +813,222

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[jira] [Commented] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916323#comment-16916323 ] Kurt Young commented on FLINK-13517: I've updated the fix version to 1.9.1 since this is not

[GitHub] [flink] flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540#issuecomment-525128086 ## CI report: * 5cb9691c978214d5f868c0e6a43f782b05b29ff6 : UNKNOWN

[jira] [Updated] (FLINK-13105) Add documentation for blink planner's built-in functions

[ https://issues.apache.org/jira/browse/FLINK-13105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13105: --- Fix Version/s: 1.10.0 > Add documentation for blink planner's built-in functions >

[jira] [Updated] (FLINK-13354) Add documentation for how to use blink planner

[ https://issues.apache.org/jira/browse/FLINK-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13354: --- Fix Version/s: 1.10.0 > Add documentation for how to use blink planner >

[jira] [Updated] (FLINK-13564) blink planner should also throw exception if constant with YEAR TO MONTH resolution was used for group windows

[ https://issues.apache.org/jira/browse/FLINK-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13564: --- Fix Version/s: 1.10.0 > blink planner should also throw exception if constant with YEAR TO MONTH >

[jira] [Comment Edited] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916370#comment-16916370 ] Dian Fu edited comment on FLINK-13488 at 8/27/19 5:01 AM: -- Hi [~ykt836], I

[GitHub] [flink] flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525053464 ## CI report: * fc93ac2188416b5b9a2c92fa0c4893d842e167ce : SUCCESS

[GitHub] [flink] TisonKun commented on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

TisonKun commented on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-525094298 @travis run travis This is an

[jira] [Commented] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916286#comment-16916286 ] zhijiang commented on FLINK-10995: -- [~ykt836], this Jira is for improving the serialization stack in

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[GitHub] [flink] xuefuz commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

xuefuz commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-525118500 As a reference, Hive has been doing, which seems quite simple.

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[jira] [Updated] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13637: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Anchors not working in

[jira] [Updated] (FLINK-13501) Fixes a few issues in documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13501: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Fixes a few

[jira] [Commented] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916338#comment-16916338 ] Kurt Young commented on FLINK-13415: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13415: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Document how

[jira] [Commented] (FLINK-13706) add documentation of how to use Hive functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916339#comment-16916339 ] Kurt Young commented on FLINK-13706: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13706) add documentation of how to use Hive functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13706: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > add

[jira] [Updated] (FLINK-13359) Add documentation for DDL introduction

[ https://issues.apache.org/jira/browse/FLINK-13359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13359: --- Fix Version/s: 1.10.0 > Add documentation for DDL introduction >

[jira] [Updated] (FLINK-13362) Add documentation for Kafka & ES & FileSystem DDL

[ https://issues.apache.org/jira/browse/FLINK-13362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13362: --- Fix Version/s: 1.10.0 > Add documentation for Kafka & ES & FileSystem DDL >

[GitHub] [flink] YngwieWang commented on issue #9535: [hotfix][docs] fix typos

YngwieWang commented on issue #9535: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9535#issuecomment-525093702 > @YngwieWang thank you for contribution! > > Could you please fix the PR subject and the commit message to include `[docs]` part. > Also, please

[GitHub] [flink] YngwieWang closed pull request #9535: [hotfix][docs] fix typos

YngwieWang closed pull request #9535: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9535 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on issue #9539: [hotfix][docs] fix typos

flinkbot commented on issue #9539: [hotfix][docs] fix typos URL: https://github.com/apache/flink/pull/9539#issuecomment-525096500 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-523878082 ## CI report: * 7e7bc9b213b2fadb8759449b65e5be19b11aa829 : FAILURE

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13526: --- Fix Version/s: 1.10.0 > Switching to a non existing catalog or database crashes sql-client >

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13534: --- Fix Version/s: 1.10.0 > Unable to query Hive table with decimal column >

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916336#comment-16916336 ] Kurt Young commented on FLINK-13488: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > flink-python

[jira] [Updated] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13517: --- Fix Version/s: 1.10.0 > Restructure Hive Catalog documentation >

[jira] [Updated] (FLINK-13490) Fix return null in JDBCUtils::getFieldFromResultSet

[ https://issues.apache.org/jira/browse/FLINK-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13490: --- Fix Version/s: 1.10.0 > Fix return null in JDBCUtils::getFieldFromResultSet >

[jira] [Commented] (FLINK-13501) Fixes a few issues in documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916337#comment-16916337 ] Kurt Young commented on FLINK-13501: I've updated the fix version to 1.9.1 since this is not

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[jira] [Updated] (FLINK-13865) Support custom config in Flink docker image

[ https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dagang Wei updated FLINK-13865: --- Component/s: (was: Deployment / Kubernetes) Deployment / Docker

[jira] [Commented] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916401#comment-16916401 ] zhijiang commented on FLINK-10995: -- I think it was not planned in release-1.10 before. We could discuss

[jira] [Commented] (FLINK-13865) Support custom config in Flink docker image

[ https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916402#comment-16916402 ] Dagang Wei commented on FLINK-13865: I noticed FLINK-13380 which is helpful for Kubernetes, but it

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[jira] [Updated] (FLINK-13865) Support custom config in Flink docker image

[ https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dagang Wei updated FLINK-13865: --- Environment: (was: I noticed FLINK-13380 which is helpful for Kubernetes, but it is still

[jira] [Updated] (FLINK-13765) Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Description: In StreamTwoInputSelectableProcessor there are three fields \{InputSelectable, 

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13526: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Switching to a non existing catalog or

[jira] [Commented] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916319#comment-16916319 ] Kurt Young commented on FLINK-13526: I've updated the fix version to 1.9.1 since this is not

[jira] [Commented] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916320#comment-16916320 ] Kurt Young commented on FLINK-13637: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13517: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Restructure Hive Catalog documentation >

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

  1   2   3   4   5   >