[GitHub] [flink] aljoscha commented on pull request #11326: [FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink

aljoscha commented on pull request #11326: URL: https://github.com/apache/flink/pull/11326#issuecomment-702031110 I think we should merge this after all. The code is very simple but if we provide it we avoid different users having to re-implement it in their own code. Plus, having the

[GitHub] [flink-web] rutuja2807 opened a new pull request #384: Improved Docs

rutuja2807 opened a new pull request #384: URL: https://github.com/apache/flink-web/pull/384 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[jira] [Assigned] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-19447: -- Assignee: Miklos Gergely > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with

[GitHub] [flink] aljoscha commented on pull request #13473: [FLINK-19264][runtime] Add JobID to ExecutionAttemptID

aljoscha commented on pull request #13473: URL: https://github.com/apache/flink/pull/13473#issuecomment-702023979 So? Can we merge? 樂 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Comment Edited] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205396#comment-17205396 ] Piotr Nowojski edited comment on FLINK-18662 at 10/1/20, 9:34 AM: -- I’ve

[jira] [Commented] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205396#comment-17205396 ] Piotr Nowojski commented on FLINK-18662: I’ve found an issue with “processed data during

[jira] [Closed] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18818. Fix Version/s: 1.11.3 1.12.0 Assignee: Yun Gao

[GitHub] [flink] aljoscha commented on pull request #13496: [FLINK-18818][filesystem][tests] Ignores exceptions after files written successfully in HadoopRenameCommitter test

aljoscha commented on pull request #13496: URL: https://github.com/apache/flink/pull/13496#issuecomment-702011812 Thanks a lot for this fix! I merged it.  This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] aljoscha closed pull request #13496: [FLINK-18818][filesystem][tests] Ignores exceptions after files written successfully in HadoopRenameCommitter test

aljoscha closed pull request #13496: URL: https://github.com/apache/flink/pull/13496 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205392#comment-17205392 ] Aljoscha Krettek commented on FLINK-19479: -- Yes, it's basically the same but for joins. Should

[jira] [Updated] (FLINK-19462) Checkpoint statistics for unfinished task snapshots

[ https://issues.apache.org/jira/browse/FLINK-19462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19462: -- Labels: usability (was: ) > Checkpoint statistics for unfinished task snapshots >

[jira] [Closed] (FLINK-19426) Streaming File Sink end-to-end test sometimes fails with "Could not assign resource ... to current execution ..."

[ https://issues.apache.org/jira/browse/FLINK-19426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19426. --- Resolution: Duplicate Duplicate of FLINK-19388. > Streaming File Sink end-to-end test

[GitHub] [flink] flinkbot edited a comment on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

flinkbot edited a comment on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900 ## CI report: * c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN * ad971fd47ab3ac9e813afae9713c75986646 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

flinkbot edited a comment on pull request #13525: URL: https://github.com/apache/flink/pull/13525#issuecomment-701444731 ## CI report: * 7309386d95647358780ec4e8a615567f720c7987 Azure:

[jira] [Commented] (FLINK-19426) Streaming File Sink end-to-end test sometimes fails with "Could not assign resource ... to current execution ..."

[ https://issues.apache.org/jira/browse/FLINK-19426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205370#comment-17205370 ] Andrey Zagrebin commented on FLINK-19426: - The error has been reproduced in the CI run 

[jira] [Comment Edited] (FLINK-19426) Streaming File Sink end-to-end test sometimes fails with "Could not assign resource ... to current execution ..."

[ https://issues.apache.org/jira/browse/FLINK-19426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204727#comment-17204727 ] Andrey Zagrebin edited comment on FLINK-19426 at 10/1/20, 8:30 AM: --- I

[GitHub] [flink] azagrebin closed pull request #13526: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test with fix and AWS credentials

azagrebin closed pull request #13526: URL: https://github.com/apache/flink/pull/13526 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] azagrebin closed pull request #13527: [FLINK-19426][NOT FOR REVIEW] Loop CI failing test without fix and AWS credentials

azagrebin closed pull request #13527: URL: https://github.com/apache/flink/pull/13527 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot edited a comment on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

flinkbot edited a comment on pull request #13528: URL: https://github.com/apache/flink/pull/13528#issuecomment-701916570 ## CI report: * 6c34d1439fe62b9705fac808f5f15daf556604b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

flinkbot edited a comment on pull request #13525: URL: https://github.com/apache/flink/pull/13525#issuecomment-701444731 ## CI report: * 7309386d95647358780ec4e8a615567f720c7987 Azure:

[jira] [Commented] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205354#comment-17205354 ] Miklos Gergely commented on FLINK-19447: [~dian.fu] thanks for the screenshots, never thought

[GitHub] [flink] miklosgergely commented on a change in pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

miklosgergely commented on a change in pull request #13525: URL: https://github.com/apache/flink/pull/13525#discussion_r498058981 ## File path: flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/util/HBaseTestingClusterAutoStarter.java

[GitHub] [flink] miklosgergely commented on a change in pull request #13525: [FLINK-19447][hbase] Run HBase 2.2 integration test only if hadoop version is between 2.8.0 - 3.0.3

miklosgergely commented on a change in pull request #13525: URL: https://github.com/apache/flink/pull/13525#discussion_r498058649 ## File path: flink-connectors/flink-connector-hbase-2.2/pom.xml ## @@ -45,6 +45,9 @@ under the License.

[GitHub] [flink-web] zentol edited a comment on pull request #381: improve doc.

zentol edited a comment on pull request #381: URL: https://github.com/apache/flink-web/pull/381#issuecomment-701959588 I do not think this really enhances the documentation. If you wish to make a contribution to Flink, please read the [contribution

[GitHub] [flink-web] zentol closed pull request #383: Update .gitignore

zentol closed pull request #383: URL: https://github.com/apache/flink-web/pull/383 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] zentol closed pull request #381: improve doc.

zentol closed pull request #381: URL: https://github.com/apache/flink-web/pull/381 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] zentol commented on pull request #383: Update .gitignore

zentol commented on pull request #383: URL: https://github.com/apache/flink-web/pull/383#issuecomment-701959302 Closing due to #382. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-web] zentol commented on pull request #381: improve doc.

zentol commented on pull request #381: URL: https://github.com/apache/flink-web/pull/381#issuecomment-701959588 I do not think this really enhances the documentation. This is an automated message from the Apache Git Service.

[GitHub] [flink-web] zentol commented on pull request #382: Update .gitignore

zentol commented on pull request #382: URL: https://github.com/apache/flink-web/pull/382#issuecomment-701959058 The [contribution guide](https://flink.apache.org/contributing/how-to-contribute.html) should give you all the information you need ;)

[GitHub] [flink-web] zentol closed pull request #382: Update .gitignore

zentol closed pull request #382: URL: https://github.com/apache/flink-web/pull/382 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Created] (FLINK-19485) Consider runtime-mode when creating the StreamGraph

Kostas Kloudas created FLINK-19485: -- Summary: Consider runtime-mode when creating the StreamGraph Key: FLINK-19485 URL: https://issues.apache.org/jira/browse/FLINK-19485 Project: Flink

[jira] [Closed] (FLINK-19392) Detect the execution mode based on the sources in the job.

[ https://issues.apache.org/jira/browse/FLINK-19392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19392. -- Resolution: Implemented Merged on master with c2e3399200010527e06e698b191bd5290f1d2ce4 and

[jira] [Updated] (FLINK-19392) Detect the execution mode based on the sources in the job.

[ https://issues.apache.org/jira/browse/FLINK-19392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19392: --- Fix Version/s: 1.12.0 > Detect the execution mode based on the sources in the job. >

[GitHub] [flink] kl0u closed pull request #13502: [FLINK-19392] Add the execution.runtime-mode

kl0u closed pull request #13502: URL: https://github.com/apache/flink/pull/13502 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result

[ https://issues.apache.org/jira/browse/FLINK-18988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205314#comment-17205314 ] Konstantin Knauf commented on FLINK-18988: -- [~danny0405] Thank you for working on this issue.

[GitHub] [flink] flinkbot edited a comment on pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

flinkbot edited a comment on pull request #13521: URL: https://github.com/apache/flink/pull/13521#issuecomment-701282459 ## CI report: * 4824a2e5258649246c5372200dd44fb61e20d012 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

flinkbot edited a comment on pull request #13528: URL: https://github.com/apache/flink/pull/13528#issuecomment-701916570 ## CI report: * 6c34d1439fe62b9705fac808f5f15daf556604b7 Azure:

[jira] [Commented] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205297#comment-17205297 ] Arvid Heise commented on FLINK-19400: - Merged into master as part of FLINK-16972. > Removed unused

[jira] [Closed] (FLINK-19400) Removed unused BufferPoolOwner

[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19400. --- Resolution: Fixed > Removed unused BufferPoolOwner > -- > >

[jira] [Updated] (FLINK-16972) Fix non-blocking output availability logic.

[ https://issues.apache.org/jira/browse/FLINK-16972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16972: Affects Version/s: 1.12.0 > Fix non-blocking output availability logic. >

[jira] [Commented] (FLINK-16972) Fix non-blocking output availability logic.

[ https://issues.apache.org/jira/browse/FLINK-16972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205295#comment-17205295 ] Arvid Heise commented on FLINK-16972: - Merged into master as

[GitHub] [flink] AHeise merged pull request #13499: [FLINK-16972][network] LocalBufferPool eagerly fetches global segments to ensure proper availability.

AHeise merged pull request #13499: URL: https://github.com/apache/flink/pull/13499 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] shudhanshubisht08 opened a new pull request #383: Update .gitignore

shudhanshubisht08 opened a new pull request #383: URL: https://github.com/apache/flink-web/pull/383 Nice work. Can I Do some Changes in this This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-web] shudhanshubisht08 opened a new pull request #382: Update .gitignore

shudhanshubisht08 opened a new pull request #382: URL: https://github.com/apache/flink-web/pull/382 I want to make some contribution to this project This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

flinkbot commented on pull request #13528: URL: https://github.com/apache/flink/pull/13528#issuecomment-701916570 ## CI report: * 6c34d1439fe62b9705fac808f5f15daf556604b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13521: [FLINK-19472] Implement a one input sorting DataInput

flinkbot edited a comment on pull request #13521: URL: https://github.com/apache/flink/pull/13521#issuecomment-701282459 ## CI report: * b127687d16b67d98077b0fb108a024e6d7b2dca3 Azure:

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19249: --- Issue Type: Improvement (was: Bug) > Job would wait sometime(~10 min) before failover if

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19249: --- Priority: Critical (was: Blocker) > Job would wait sometime(~10 min) before failover if

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19249: --- Fix Version/s: (was: 1.11.3) > Job would wait sometime(~10 min) before failover if some

[GitHub] [flink] flinkbot commented on pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

flinkbot commented on pull request #13528: URL: https://github.com/apache/flink/pull/13528#issuecomment-701909456 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 to track the

[jira] [Updated] (FLINK-19477) Translate page 'python_table_api_connectors' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19477: --- Labels: pull-request-available (was: ) > Translate page 'python_table_api_connectors' into

[GitHub] [flink] wangxlong opened a new pull request #13528: [FLINK-19477][docs-zh][python] Translate page "python_table_api_connectors" into Chinese

wangxlong opened a new pull request #13528: URL: https://github.com/apache/flink/pull/13528 ## What is the purpose of the change Translate page "python_table_api_connectors" into Chinese ## Brief change log Translate page "python_table_api_connectors" into Chinese

<    1   2