[GitHub] [flink] wuchong commented on a change in pull request #9459: [FLINK-13742][table-planner-blink] Fix code generation when aggregation contains both distinct aggregate with and without filter.

wuchong commented on a change in pull request #9459: [FLINK-13742][table-planner-blink] Fix code generation when aggregation contains both distinct aggregate with and without filter. URL: https://github.com/apache/flink/pull/9459#discussion_r314977208 ## File path:

[jira] [Updated] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13759: Description: Here is an instance: https://api.travis-ci.org/v3/job/572950228/log.txt There is an error

[jira] [Created] (FLINK-13759) All builds for master branch are failed during compile stage

Jark Wu created FLINK-13759: --- Summary: All builds for master branch are failed during compile stage Key: FLINK-13759 URL: https://issues.apache.org/jira/browse/FLINK-13759 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector

flinkbot commented on issue #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector URL: https://github.com/apache/flink/pull/9473#issuecomment-522319984 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Resolved] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic

[ https://issues.apache.org/jira/browse/FLINK-12602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12602. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed via

[GitHub] [flink] tillrohrmann closed pull request #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector

tillrohrmann closed pull request #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector URL: https://github.com/apache/flink/pull/9473 This is an automated message from the Apache Git Service. To

[GitHub] [flink] tillrohrmann closed pull request #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

tillrohrmann closed pull request #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472 This is an automated message from the Apache Git

[jira] [Resolved] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13759. --- Resolution: Fixed Fixed via 814190e9f2efc067a004bef6af86c2541e33aada > All builds for

[jira] [Commented] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909983#comment-16909983 ] Stephan Ewen commented on FLINK-13717: -- I think having {{taskmanager.bind-host}} configurable makes

[GitHub] [flink] wzhero1 commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

wzhero1 commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#discussion_r314991911 ## File path: docs/_includes/generated/yarn_config_configuration.html ##

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[GitHub] [flink] becketqin commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

becketqin commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#issuecomment-522300748 @xuyang1706 Thanks for the performance comparison and for updating the patch. The

[GitHub] [flink] asfgit closed pull request #9455: [FLINK-13739][table-blink] JDK String to bytes should specify UTF-8 encoding

asfgit closed pull request #9455: [FLINK-13739][table-blink] JDK String to bytes should specify UTF-8 encoding URL: https://github.com/apache/flink/pull/9455 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13760: Description: FLINK-13688 introduced a {{flink-test-utils}} dependency in {{flink-connector-hive}}.

[jira] [Resolved] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13739. - Resolution: Fixed Fix Version/s: 1.9.1 Fixed in master: 130f4e85a0dc7498e67e591155aa0b0470b5950d

[GitHub] [flink] wuchong opened a new pull request #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector

wuchong opened a new pull request #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector URL: https://github.com/apache/flink/pull/9473 ## What is the purpose of the change FLINK-13688 introduced a flink-test-utils dependency in

[GitHub] [flink] flinkbot commented on issue #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector

flinkbot commented on issue #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector URL: https://github.com/apache/flink/pull/9473#issuecomment-522320467 ## CI report: * 712d9d5a83592bf5e86d4cbbc39f63763ef6eb7a : PENDING

[GitHub] [flink] wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#discussion_r314985269 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#discussion_r314985216 ## File path:

[jira] [Updated] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13688: -- Fix Version/s: 1.10.0 > HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with

[jira] [Commented] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909974#comment-16909974 ] Till Rohrmann commented on FLINK-13688: --- Please don't forget to set the correct fixVersion fields

[GitHub] [flink] wuchong commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

wuchong commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472#issuecomment-522326554 I have the same question. It should fail for a long time ago. Could this because of Travis caching

[GitHub] [flink] flinkbot edited a comment on issue #9352: FLINK-13317 Merge NetUtils and ClientUtils

flinkbot edited a comment on issue #9352: FLINK-13317 Merge NetUtils and ClientUtils URL: https://github.com/apache/flink/pull/9352#issuecomment-518010490 ## CI report: * 2c2b8ec8ad260a021792fb7ac41e2c1c15da0722 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9352: FLINK-13317 Merge NetUtils and ClientUtils

flinkbot edited a comment on issue #9352: FLINK-13317 Merge NetUtils and ClientUtils URL: https://github.com/apache/flink/pull/9352#issuecomment-518010490 ## CI report: * 2c2b8ec8ad260a021792fb7ac41e2c1c15da0722 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[GitHub] [flink] izhangzhihao opened a new pull request #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated

izhangzhihao opened a new pull request #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated URL: https://github.com/apache/flink/pull/9474 ## What is the purpose of the change `SplitStream` should be deprecated because `SplitJavaStream` is

[jira] [Commented] (FLINK-13432) Set max polling interval threshold for job result polling

[ https://issues.apache.org/jira/browse/FLINK-13432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909967#comment-16909967 ] Stephan Ewen commented on FLINK-13432: -- A "long poll" is a single poll that blocks until a result

[jira] [Updated] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13759: -- Component/s: Build System > All builds for master branch are failed during compile stage >

[jira] [Resolved] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13760. --- Resolution: Fixed Fixed via 1.10.0: 64938e5317cca98054cfd944eb89f9e53f067ae8 1.9.1:

[jira] [Updated] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13760: -- Component/s: Build System > Fix hardcode Scala version dependency in hive connector >

[GitHub] [flink] flinkbot edited a comment on issue #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector

flinkbot edited a comment on issue #9473: [FLINK-13760][hive] Fix hardcode Scala version dependency in hive connector URL: https://github.com/apache/flink/pull/9473#issuecomment-522320467 ## CI report: * 712d9d5a83592bf5e86d4cbbc39f63763ef6eb7a : CANCELED

[jira] [Updated] (FLINK-13752) TaskDeploymentDescriptor cannot be recycled by GC due to referenced by an anonymous function

[ https://issues.apache.org/jira/browse/FLINK-13752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13752: -- Priority: Critical (was: Major) > TaskDeploymentDescriptor cannot be recycled by GC due to

[GitHub] [flink] flinkbot edited a comment on issue #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated

flinkbot edited a comment on issue #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated URL: https://github.com/apache/flink/pull/9474#issuecomment-522322366 ## CI report: * 15bc2a5626c87d571fdcf776315db1008617f5e2 : SUCCESS

[GitHub] [flink] asfgit closed pull request #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable

asfgit closed pull request #9462: [FLINK-13738][blink-table-planner] Fix NegativeArraySizeException in LongHybridHashTable URL: https://github.com/apache/flink/pull/9462 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

flinkbot commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472#issuecomment-522318158 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13759: --- Labels: pull-request-available (was: ) > All builds for master branch are failed during

[GitHub] [flink] Johnlon commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

Johnlon commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-522321464 Rewound my repo to before my commits and tried tsts on master. Unable to run the tests cleanly

[GitHub] [flink] flinkbot commented on issue #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated

flinkbot commented on issue #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated URL: https://github.com/apache/flink/pull/9474#issuecomment-522322366 ## CI report: * 15bc2a5626c87d571fdcf776315db1008617f5e2 : PENDING

[jira] [Updated] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13760: -- Fix Version/s: 1.10.0 > Fix hardcode Scala version dependency in hive connector >

[jira] [Commented] (FLINK-4256) Fine-grained recovery

[ https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16909980#comment-16909980 ] Stephan Ewen commented on FLINK-4256: - This is in fact working for streaming as well, not only for

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

wzhero1 commented on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-522332605 @walterddr Thanks for your detailed research. I will change the doc and add a test in

[jira] [Assigned] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13738: --- Assignee: Jingsong Lee > NegativeArraySizeException in LongHybridHashTable >

[jira] [Updated] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13760: --- Labels: pull-request-available (was: ) > Fix hardcode Scala version dependency in hive

[GitHub] [flink] flinkbot commented on issue #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated

flinkbot commented on issue #9474: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated URL: https://github.com/apache/flink/pull/9474#issuecomment-522321774 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13759: -- Priority: Blocker (was: Major) > All builds for master branch are failed during compile

[jira] [Updated] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13760: -- Affects Version/s: 1.10.0 1.9.0 > Fix hardcode Scala version

[jira] [Updated] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13759: -- Affects Version/s: 1.10.0 > All builds for master branch are failed during compile stage >

[GitHub] [flink] flinkbot edited a comment on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

flinkbot edited a comment on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472#issuecomment-522318572 ## CI report: * 23a72b27a850b7b2b1f66ed662d5ca1dc5bd0697 : SUCCESS

[jira] [Updated] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13759: -- Fix Version/s: 1.10.0 > All builds for master branch are failed during compile stage >

[jira] [Updated] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

[ https://issues.apache.org/jira/browse/FLINK-13760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13760: -- Priority: Blocker (was: Major) > Fix hardcode Scala version dependency in hive connector >

[jira] [Closed] (FLINK-11630) TaskExecutor does not wait for Task termination when terminating itself

[ https://issues.apache.org/jira/browse/FLINK-11630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11630. - Resolution: Fixed Fix Version/s: 1.9.1 1.10.0 Fixed via 1.10.0:

[GitHub] [flink] tillrohrmann closed pull request #9072: [FLINK-11630] Wait for the termination of all running Tasks when shutting down TaskExecutor

tillrohrmann closed pull request #9072: [FLINK-11630] Wait for the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/9072 This is an automated message from the Apache

[jira] [Created] (FLINK-13761) `SplitStream` should be deprecated because `SplitJavaStream` is deprecated

zhihao zhang created FLINK-13761: Summary: `SplitStream` should be deprecated because `SplitJavaStream` is deprecated Key: FLINK-13761 URL: https://issues.apache.org/jira/browse/FLINK-13761 Project:

[jira] [Created] (FLINK-13762) Integrate the implementation of ForwardingValveOutputHandler for StreamOne/TwoInputProcessor

zhijiang created FLINK-13762: Summary: Integrate the implementation of ForwardingValveOutputHandler for StreamOne/TwoInputProcessor Key: FLINK-13762 URL: https://issues.apache.org/jira/browse/FLINK-13762

[GitHub] [flink] flinkbot edited a comment on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

flinkbot edited a comment on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d5fa0c8c2c46bafaf2e62a02743378a1e5399b35 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

flinkbot edited a comment on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d5fa0c8c2c46bafaf2e62a02743378a1e5399b35 : FAILURE

[jira] [Resolved] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13738. - Resolution: Fixed Fix Version/s: (was: 1.10.0) 1.9.1 Fixed in master:

[jira] [Assigned] (FLINK-13759) All builds for master branch are failed during compile stage

[ https://issues.apache.org/jira/browse/FLINK-13759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13759: --- Assignee: Jark Wu > All builds for master branch are failed during compile stage >

[GitHub] [flink] wuchong opened a new pull request #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

wuchong opened a new pull request #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472 ## What is the purpose of the change Fix builds for master branch are failed during compile

[GitHub] [flink] flinkbot commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

flinkbot commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472#issuecomment-522318572 ## CI report: * 23a72b27a850b7b2b1f66ed662d5ca1dc5bd0697 : PENDING

[jira] [Created] (FLINK-13760) Fix hardcode Scala version dependency in hive connector

Jark Wu created FLINK-13760: --- Summary: Fix hardcode Scala version dependency in hive connector Key: FLINK-13760 URL: https://issues.apache.org/jira/browse/FLINK-13760 Project: Flink Issue Type:

[GitHub] [flink] tillrohrmann closed pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

tillrohrmann closed pull request #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757 This is an automated message from the Apache

[GitHub] [flink] izhangzhihao commented on issue #9474: [FLINK-13761][ScalaAPI]`SplitStream` should be deprecated because `SplitJavaStream` is deprecated

izhangzhihao commented on issue #9474: [FLINK-13761][ScalaAPI]`SplitStream` should be deprecated because `SplitJavaStream` is deprecated URL: https://github.com/apache/flink/pull/9474#issuecomment-522328934 @flinkbot please recheck the pull request title.

[GitHub] [flink] flinkbot commented on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

flinkbot commented on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355405 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] flinkbot commented on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

flinkbot commented on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355867 ## CI report: * df58cd55f5ca284e412ebbfc35c336e4f012974c :

[jira] [Created] (FLINK-13765) Introduce the InputSelectionHandler for selecting next input in StreamTwoInputSelectableProcessor

zhijiang created FLINK-13765: Summary: Introduce the InputSelectionHandler for selecting next input in StreamTwoInputSelectableProcessor Key: FLINK-13765 URL: https://issues.apache.org/jira/browse/FLINK-13765

[GitHub] [flink] flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[jira] [Updated] (FLINK-13763) Master build is broken because of wrong Maven version

[ https://issues.apache.org/jira/browse/FLINK-13763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13763: -- Description: Currently, all master builds fail on Travis because Maven {{3.6.0}} is being

[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 #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor

flinkbot edited a comment on issue #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9475#issuecomment-522352954 ## CI report: * 7048a7504f200a099b5e4e42844888f51ba604aa : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[jira] [Created] (FLINK-13763) Master build is broken because of wrong Maven version

Till Rohrmann created FLINK-13763: - Summary: Master build is broken because of wrong Maven version Key: FLINK-13763 URL: https://issues.apache.org/jira/browse/FLINK-13763 Project: Flink

[GitHub] [flink] tillrohrmann commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage

tillrohrmann commented on issue #9472: [FLINK-13759][builds] Fix builds for master branch are failed during compile stage URL: https://github.com/apache/flink/pull/9472#issuecomment-522349471 The reason why the build failed was indeed a cache inconsistency and not

[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-522352406 thanks for the update @wzhero1 . I just ran [some E2E

[jira] [Updated] (FLINK-13762) Integrate the implementation of ForwardingValveOutputHandler for StreamOne/TwoInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13762: - Description: Currently StreamOneInputProcessor and StreamTwoInputSelectableProcessor have separate

[jira] [Updated] (FLINK-13762) Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13762: - Summary: Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor (was:

[GitHub] [flink] zhijiangW opened a new pull request #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor

zhijiangW opened a new pull request #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9475 ## What is the purpose of the change Currently `StreamOneInputProcessor` and

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

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

[GitHub] [flink] zhijiangW opened a new pull request #9477: [FLINK-13765][task] Introduce the InputSelectionHandler for selecting next input in StreamTwoInputSelectableProcessor

zhijiangW opened a new pull request #9477: [FLINK-13765][task] Introduce the InputSelectionHandler for selecting next input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477 ## What is the purpose of the change In

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

flinkbot commented 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 project.

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

flinkbot commented on issue #9477: [FLINK-13765][task] Introduce the InputSelectionHandler for selecting next input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: * 71e7fae9a212e19c83e1fe6d656de49a39334aa2 :

[jira] [Commented] (FLINK-13763) Master build is broken because of wrong Maven version

[ https://issues.apache.org/jira/browse/FLINK-13763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910034#comment-16910034 ] Till Rohrmann commented on FLINK-13763: --- Maybe it is caused by a Travis cache inconsistency

[jira] [Resolved] (FLINK-13317) Merge NetUtils and ClientUtils

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

[jira] [Created] (FLINK-13764) Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

zhijiang created FLINK-13764: Summary: Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor Key: FLINK-13764 URL: https://issues.apache.org/jira/browse/FLINK-13764

[jira] [Updated] (FLINK-13764) Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13764: - Component/s: Runtime / Metrics > Pass the counter of numRecordsIn into the constructors of >

[jira] [Updated] (FLINK-13764) Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13764: --- Labels: pull-request-available (was: ) > Pass the counter of numRecordsIn into the

[GitHub] [flink] zhijiangW opened a new pull request #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

zhijiangW opened a new pull request #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9476 ## What is the purpose of the change Currently the counter of `numRecordsIn`

[GitHub] [flink] flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

flinkbot edited a comment on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-521825874 ## CI report: * 1242679f7bd5ec3f7c1115006e978267abafc84b : CANCELED

[jira] [Commented] (FLINK-13731) flink sql support window with alignment

[ https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910014#comment-16910014 ] Jimmy Wong commented on FLINK-13731: Hi  [~zhaoshijie], I think you can convert the timestamp with

[jira] [Closed] (FLINK-13763) Master build is broken because of wrong Maven version

[ https://issues.apache.org/jira/browse/FLINK-13763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13763. - Resolution: Fixed Fix Version/s: (was: 1.10.0) Clearing the cache of the master

[GitHub] [flink] tillrohrmann closed pull request #9352: FLINK-13317 Merge NetUtils and ClientUtils

tillrohrmann closed pull request #9352: FLINK-13317 Merge NetUtils and ClientUtils URL: https://github.com/apache/flink/pull/9352 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on issue #9471: [FLINK-13754][task] Decouple OperatorChain from StreamStatusMaintainer

flinkbot edited a comment on issue #9471: [FLINK-13754][task] Decouple OperatorChain from StreamStatusMaintainer URL: https://github.com/apache/flink/pull/9471#issuecomment-522269622 ## CI report: * 46356e9f2ac97632021b3450f2585ea8b6120175 : FAILURE

[jira] [Updated] (FLINK-13762) Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13762: --- Labels: pull-request-available (was: ) > Implement a unified StatusWatermarkOutputHandler

[GitHub] [flink] flinkbot commented on issue #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor

flinkbot commented on issue #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9475#issuecomment-522352624 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] flinkbot commented on issue #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor

flinkbot commented on issue #9475: [FLINK-13762][task] Implement a unified StatusWatermarkOutputHandler for StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9475#issuecomment-522352954 ## CI report: * 7048a7504f200a099b5e4e42844888f51ba604aa : PENDING

[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] walterddr edited a comment on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

walterddr edited a comment on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-522352406 thanks for the update @wzhero1 . I just ran [some E2E

[GitHub] [flink] flinkbot edited a comment on issue #9471: [FLINK-13754][task] Decouple OperatorChain from StreamStatusMaintainer

flinkbot edited a comment on issue #9471: [FLINK-13754][task] Decouple OperatorChain from StreamStatusMaintainer URL: https://github.com/apache/flink/pull/9471#issuecomment-522269622 ## CI report: * 46356e9f2ac97632021b3450f2585ea8b6120175 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor

flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructors of StreamOne/TwoInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355867 ## CI report: * df58cd55f5ca284e412ebbfc35c336e4f012974c

  1   2   >