[GitHub] [flink] flinkbot commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

flinkbot commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#issuecomment-524796983 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Created] (FLINK-13857) Remove remaining UdfAnalyzer configurations

Dawid Wysakowicz created FLINK-13857: Summary: Remove remaining UdfAnalyzer configurations Key: FLINK-13857 URL: https://issues.apache.org/jira/browse/FLINK-13857 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

flinkbot commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#issuecomment-524800250 ## CI report: * 91573e211775dcbb1f35c0797854c09b18da76cf : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

flinkbot edited a comment on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-502053854 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519129010 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-524801835 @flinkbot run travis

[GitHub] [flink] flinkbot edited a comment on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

flinkbot edited a comment on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#issuecomment-524800250 ## CI report: * 91573e211775dcbb1f35c0797854c09b18da76cf : PENDING

[jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915667#comment-16915667 ] Stephan Ewen commented on FLINK-13856: -- In general, that is a good idea. However, this is an

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

StephanEwen 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_r317541029 ## File path:

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

StephanEwen commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-524806312 @flinkbot approve until architecture This is an

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

StephanEwen 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_r317541740 ## File path:

[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-522729564 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

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

StephanEwen commented on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-524807971 If we are now doing string concatenation anyways, should we just remove `String.format` all together here? In this way (mixing the

[GitHub] [flink] flinkbot edited a comment on issue #9487: [FLINK-13791][docs] Speed up sidenav by using group_by

flinkbot edited a comment on issue #9487: [FLINK-13791][docs] Speed up sidenav by using group_by URL: https://github.com/apache/flink/pull/9487#issuecomment-522781093 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot edited a comment on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages

flinkbot edited a comment on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages URL: https://github.com/apache/flink/pull/9488#issuecomment-522821968 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error .

flinkbot edited a comment on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error . URL: https://github.com/apache/flink/pull/9532#issuecomment-524795310 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] StephanEwen commented on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages

StephanEwen commented on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages URL: https://github.com/apache/flink/pull/9488#issuecomment-524810524 Looks good, merging this. This is an automated

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

TisonKun commented on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-524810605 make sense to change it into ```java return prefix + "-" + transactionalId; ``` since we don't want to do more

[jira] [Commented] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915689#comment-16915689 ] Xiaogang Shi commented on FLINK-13848: -- Hi [~SleePy], what's your detailed plan on implementing

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[jira] [Updated] (FLINK-13858) Add flink-connector-elasticsearch6 Specify the field as the primary key id

[ https://issues.apache.org/jira/browse/FLINK-13858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hubin updated FLINK-13858: -- Description: For example, syncing an order table sink to es6, order_id is primary key `insert into

[GitHub] [flink] flinkbot edited a comment on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages

flinkbot edited a comment on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages URL: https://github.com/apache/flink/pull/9488#issuecomment-522821968 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3

flinkbot edited a comment on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3 URL: https://github.com/apache/flink/pull/9479#issuecomment-522434059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9487: [FLINK-13791][docs] Speed up sidenav by using group_by

flinkbot edited a comment on issue #9487: [FLINK-13791][docs] Speed up sidenav by using group_by URL: https://github.com/apache/flink/pull/9487#issuecomment-522781093 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

flinkbot edited a comment on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-506144046 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Assigned] (FLINK-13853) Running HA (file, async) end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13853: - Assignee: Till Rohrmann > Running HA (file, async) end-to-end test failed on Travis >

[GitHub] [flink] TisonKun removed a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

TisonKun removed a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-514062316 cc @aljoscha This is an automated

[jira] [Updated] (FLINK-13728) Fix wrong closing tag order in sidenav

[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13728: - Fix Version/s: 1.9.1 > Fix wrong closing tag order in sidenav >

[GitHub] [flink] flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-513163929 ## CI report: * 9ed756e881fddd5260407dee970cbf2636e93824 : FAILURE

[jira] [Closed] (FLINK-13728) Fix wrong closing tag order in sidenav

[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13728. > Fix wrong closing tag order in sidenav > -- > >

[jira] [Closed] (FLINK-13724) Remove unnecessary whitespace from the docs' sidenav

[ https://issues.apache.org/jira/browse/FLINK-13724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13724. > Remove unnecessary whitespace from the docs' sidenav >

[jira] [Resolved] (FLINK-13724) Remove unnecessary whitespace from the docs' sidenav

[ https://issues.apache.org/jira/browse/FLINK-13724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13724. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Commented] (FLINK-13728) Fix wrong closing tag order in sidenav

[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915723#comment-16915723 ] Stephan Ewen commented on FLINK-13728: -- Fixed in 1.9.1 via 9ba0a8906e24fa864a89df65edbc95c25ec3f6dd

[jira] [Resolved] (FLINK-13791) Speed up sidenav by using group_by

[ https://issues.apache.org/jira/browse/FLINK-13791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13791. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13791) Speed up sidenav by using group_by

[ https://issues.apache.org/jira/browse/FLINK-13791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13791. > Speed up sidenav by using group_by > -- > > Key:

[jira] [Closed] (FLINK-13726) Build docs with jekyll 4.0.0.pre.beta1

[ https://issues.apache.org/jira/browse/FLINK-13726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13726. > Build docs with jekyll 4.0.0.pre.beta1 > -- > >

[jira] [Resolved] (FLINK-13729) Update website generation dependencies

[ https://issues.apache.org/jira/browse/FLINK-13729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13729. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13729) Update website generation dependencies

[ https://issues.apache.org/jira/browse/FLINK-13729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13729. > Update website generation dependencies > -- > >

[jira] [Resolved] (FLINK-13726) Build docs with jekyll 4.0.0.pre.beta1

[ https://issues.apache.org/jira/browse/FLINK-13726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13726. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Resolved] (FLINK-13725) Use sassc for faster doc generation

[ https://issues.apache.org/jira/browse/FLINK-13725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13725. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-13725) Use sassc for faster doc generation

[ https://issues.apache.org/jira/browse/FLINK-13725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13725. > Use sassc for faster doc generation > --- > > Key:

[GitHub] [flink] dawidwys edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

dawidwys edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-524825904 I add @aljoscha & @kl0u, as I think they were considering removing the class whatsoever (if I am not

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

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce the InputSelectionHandler for selecting next input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522359714 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-513113444 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] StephanEwen commented on issue #9527: [FLINK-13832] Rename DefaultRollingPolicy create to builder

StephanEwen commented on issue #9527: [FLINK-13832] Rename DefaultRollingPolicy create to builder URL: https://github.com/apache/flink/pull/9527#issuecomment-524826440 It would be nice to have a project-wide standard for how we call the "builder creator" method. Shall we [DISCUSS]

[GitHub] [flink] flinkbot commented on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries

flinkbot commented on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries URL: https://github.com/apache/flink/pull/9534#issuecomment-524831130 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries

flinkbot edited a comment on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries URL: https://github.com/apache/flink/pull/9534#issuecomment-524832739 ## CI report: * f7011481a7d175125fb2792385f048b71aca9715 : PENDING

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915745#comment-16915745 ] TisonKun commented on FLINK-13417: -- I started a thread in ZooKeeper community to see if there are known

[GitHub] [flink] TisonKun commented on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

TisonKun commented on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-524836767 @dawidwys yes that is what we proposed in client api enhancement thread. However, before we decide to remove it,

[GitHub] [flink] flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-516836559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-513113444 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] YngwieWang commented on a change in pull request #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

YngwieWang commented on a change in pull request #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#discussion_r317576974 ## File path: docs/dev/api_concepts.zh.md ## @@ -164,43 +123,29 @@

[GitHub] [flink] flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-516836559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot commented on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error .

flinkbot commented on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error . URL: https://github.com/apache/flink/pull/9532#issuecomment-524795310 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] danny0405 commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

danny0405 commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#discussion_r317530274 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

flinkbot edited a comment on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#issuecomment-524796983 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] eskabetxe commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

eskabetxe commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#issuecomment-524797368 @flinkbot attention @gyfora

[GitHub] [flink] wuchong commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

wuchong commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#discussion_r317535810 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error .

flinkbot edited a comment on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error . URL: https://github.com/apache/flink/pull/9532#issuecomment-524796729 ## CI report: * d89edda46691593429ad804fdd0417e6008a0a39 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-518523202 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Resolved] (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 ] Jark Wu resolved FLINK-13362. - Resolution: Fixed master: b820606916421f40ffa700c9a403d0782f618320 1.9.1:  

[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-522052035 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

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

[ https://issues.apache.org/jira/browse/FLINK-13359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13359. - Resolution: Fixed maste: 00b6e8bd3ae3943c24e0538debcae82df35dac4d 1.9.1: 

[GitHub] [flink] StephanEwen commented on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3

StephanEwen commented on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3 URL: https://github.com/apache/flink/pull/9479#issuecomment-524806553 Looks good, merging this... This

[GitHub] [flink] flinkbot edited a comment on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

flinkbot edited a comment on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-502053854 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] danny0405 commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

danny0405 commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#discussion_r317544517 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

flinkbot edited a comment on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-518524777 ## CI report: * f99e66ffb4356f8132b48d352b27686a6ad958f5 : SUCCESS

[GitHub] [flink] danny0405 commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction

danny0405 commented on issue #9366: [FLINK-13359][docs] Add documentation for DDL introduction URL: https://github.com/apache/flink/pull/9366#issuecomment-524808773 Thanks for your nice review @wuchong , your review really helps a lot !

[GitHub] [flink] danny0405 commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

danny0405 commented on a change in pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#discussion_r317544517 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

flinkbot edited a comment on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#issuecomment-524800250 ## CI report: * 91573e211775dcbb1f35c0797854c09b18da76cf : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages

flinkbot edited a comment on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages URL: https://github.com/apache/flink/pull/9488#issuecomment-522821968 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] TisonKun commented on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages

TisonKun commented on issue #9488: [hotfix][docs] Update local setup tutorials to fit new log messages URL: https://github.com/apache/flink/pull/9488#issuecomment-524810954 Thanks for your review! This is an automated

[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-522729564 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-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] andrew.D.lin updated FLINK-13856: - Component/s: Runtime / Checkpointing > Reduce the delete file api when the checkpoint is

[jira] [Created] (FLINK-13858) Add flink-connector-elasticsearch6 Specify the field as the primary key id

hubin created FLINK-13858: - Summary: Add flink-connector-elasticsearch6 Specify the field as the primary key id Key: FLINK-13858 URL: https://issues.apache.org/jira/browse/FLINK-13858 Project: Flink

[jira] [Updated] (FLINK-13728) Fix wrong closing tag order in sidenav

[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13728: - Fix Version/s: 1.10.0 > Fix wrong closing tag order in sidenav >

[GitHub] [flink] flinkbot edited a comment on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error .

flinkbot edited a comment on issue #9532: [hotfix][docs] Fix the dependent version of the hive connector error . URL: https://github.com/apache/flink/pull/9532#issuecomment-524796729 ## CI report: * d89edda46691593429ad804fdd0417e6008a0a39 : SUCCESS

[jira] [Resolved] (FLINK-13728) Fix wrong closing tag order in sidenav

[ https://issues.apache.org/jira/browse/FLINK-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13728. -- Resolution: Fixed Fixed via b1c2e213302cd68758761c60a1ccff85c5c67203 > Fix wrong closing tag

[GitHub] [flink] flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

flinkbot edited a comment on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-513113444 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524185771 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915740#comment-16915740 ] Till Rohrmann commented on FLINK-13417: --- Are we intending to drop support for ZooKeeper {{3.4}}?

[GitHub] [flink] flinkbot commented on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries

flinkbot commented on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries URL: https://github.com/apache/flink/pull/9534#issuecomment-524832739 ## CI report: * f7011481a7d175125fb2792385f048b71aca9715 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries

flinkbot edited a comment on issue #9534: [FLINK-13853][e2e] Update common_ha.sh test expression to count recoveries URL: https://github.com/apache/flink/pull/9534#issuecomment-524831130 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[GitHub] [flink] YngwieWang commented on a change in pull request #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

YngwieWang commented on a change in pull request #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#discussion_r317443607 ## File path: docs/dev/api_concepts.zh.md ## @@ -24,68 +24,46 @@ specific

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

[ https://issues.apache.org/jira/browse/FLINK-13859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] limbo updated FLINK-13859: -- Description: In kafka page the JsonDeserializationSchema would be JSONDeserializationSchema

[GitHub] [flink] YngwieWang commented on a change in pull request #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

YngwieWang commented on a change in pull request #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#discussion_r317576784 ## File path: docs/dev/api_concepts.zh.md ## @@ -95,31 +73,19 @@

[GitHub] [flink] flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-516836559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-13428) StreamingFileSink allow part file name to be configurable

[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915552#comment-16915552 ] Gyula Fora commented on FLINK-13428: Maybe fixing the docs can be combined with 

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[jira] [Updated] (FLINK-13292) NullPointerException when reading a string field in a nested struct from an Orc file.

[ https://issues.apache.org/jira/browse/FLINK-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alejandro Sellero updated FLINK-13292: -- Attachment: output.orc > NullPointerException when reading a string field in a nested

[jira] [Updated] (FLINK-13292) NullPointerException when reading a string field in a nested struct from an Orc file.

[ https://issues.apache.org/jira/browse/FLINK-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alejandro Sellero updated FLINK-13292: -- Attachment: one_row.json > NullPointerException when reading a string field in a

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519129010 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Created] (FLINK-13852) Support storing in-progress/pending files in different directories (StreamingFileSink)

Gyula Fora created FLINK-13852: -- Summary: Support storing in-progress/pending files in different directories (StreamingFileSink) Key: FLINK-13852 URL: https://issues.apache.org/jira/browse/FLINK-13852

[jira] [Commented] (FLINK-13609) StreamingFileSink - reset part counter on bucket change

[ https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915578#comment-16915578 ] Joao Boto commented on FLINK-13609: --- [~gyfora] maybe this can be address on

[jira] [Commented] (FLINK-13547) Verify and correct string function's semantic for Blink planner

[ https://issues.apache.org/jira/browse/FLINK-13547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915595#comment-16915595 ] Jark Wu commented on FLINK-13547: - Hi [~KevinZwx], the removed function can be definitely introduced in

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[jira] [Created] (FLINK-13854) Support Aggregating in Join and CoGroup

Jiayi Liao created FLINK-13854: -- Summary: Support Aggregating in Join and CoGroup Key: FLINK-13854 URL: https://issues.apache.org/jira/browse/FLINK-13854 Project: Flink Issue Type: New Feature

<    1   2   3   4   5   >