[GitHub] [flink] tillrohrmann closed pull request #9630: [FLINK-13964] Let HighAvailabilityServices create cluster and client side HA services

tillrohrmann closed pull request #9630: [FLINK-13964] Let HighAvailabilityServices create cluster and client side HA services URL: https://github.com/apache/flink/pull/9630 This is an automated message from the Apache Git

[GitHub] [flink] tillrohrmann commented on issue #9630: [FLINK-13964] Let HighAvailabilityServices create cluster and client side HA services

tillrohrmann commented on issue #9630: [FLINK-13964] Let HighAvailabilityServices create cluster and client side HA services URL: https://github.com/apache/flink/pull/9630#issuecomment-528744019 Thanks for the review @TisonKun. Merging this PR.

[GitHub] [flink] flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo …

flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo … URL: https://github.com/apache/flink/pull/9432#issuecomment-521082590 ## CI report: * d78dad6818e94f70666df4d7fca91c71b717bf3a : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput

flinkbot commented on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput URL: https://github.com/apache/flink/pull/9635#issuecomment-528762211 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13987: --- Description: As the job running, the log files are becoming large. Current log api returns all contents，it

[jira] [Updated] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13987: --- Description: As the job running, the log files are becoming large. Current log api returns all contents，it

[GitHub] [flink] flinkbot edited a comment on issue #9571: [FLINK-13922][docs] Translate headings of task_failure_recovery.zh.md into English

flinkbot edited a comment on issue #9571: [FLINK-13922][docs] Translate headings of task_failure_recovery.zh.md into English URL: https://github.com/apache/flink/pull/9571#issuecomment-526591967 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 #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

flinkbot edited a comment on issue #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload. URL: https://github.com/apache/flink/pull/8885#issuecomment-505649918 Thanks a lot for your contribution to the Apache

[GitHub] [flink] flinkbot edited a comment on issue #9525: [FLINK-13363][docs] Add documentation for streaming aggregate performance tuning

flinkbot edited a comment on issue #9525: [FLINK-13363][docs] Add documentation for streaming aggregate performance tuning URL: https://github.com/apache/flink/pull/9525#issuecomment-524508170 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 #9509: [FLINK-13750][client] Separate client/cluster-side high-availability services

flinkbot edited a comment on issue #9509: [FLINK-13750][client] Separate client/cluster-side high-availability services URL: https://github.com/apache/flink/pull/9509#issuecomment-523852903 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 #9597: [FLINK-13941][fs-connector] Do not delete partial part files from S3.

flinkbot edited a comment on issue #9597: [FLINK-13941][fs-connector] Do not delete partial part files from S3. URL: https://github.com/apache/flink/pull/9597#issuecomment-527188085 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 #9554: [FLNK-13885] Remove HighAvailabilityOptions#HA_JOB_DELAY

flinkbot edited a comment on issue #9554: [FLNK-13885] Remove HighAvailabilityOptions#HA_JOB_DELAY URL: https://github.com/apache/flink/pull/9554#issuecomment-525758494 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #9485: [FLINK-13775][table-planner-blink] Refactor ExpressionConverter(RexNodeConverter) in blink

flinkbot edited a comment on issue #9485: [FLINK-13775][table-planner-blink] Refactor ExpressionConverter(RexNodeConverter) in blink URL: https://github.com/apache/flink/pull/9485#issuecomment-522652393 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator

flinkbot edited a comment on issue #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator URL: https://github.com/apache/flink/pull/9564#issuecomment-526484775 Thanks a lot for your contribution to the

[GitHub] [flink] flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size

flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size URL: https://github.com/apache/flink/pull/9587#issuecomment-526995997 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519953396 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] flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#issuecomment-514435923 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 #9595: [FLINK-13586] Make ClosureCleaner.clean() backwards compatible with 1.8.0

flinkbot edited a comment on issue #9595: [FLINK-13586] Make ClosureCleaner.clean() backwards compatible with 1.8.0 URL: https://github.com/apache/flink/pull/9595#issuecomment-527060493 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 #9404: [FLINK-13667][ml] Add the utility class for the Table

flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519869219 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321591396 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9631: [FLINK-13977] Replace HighAvailabilityServices#getWebMonitorLeaderElectionService with #getClusterRestEndpointLeaderElectionService

tillrohrmann commented on issue #9631: [FLINK-13977] Replace HighAvailabilityServices#getWebMonitorLeaderElectionService with #getClusterRestEndpointLeaderElectionService URL: https://github.com/apache/flink/pull/9631#issuecomment-528744804 Thanks for the review @TisonKun. Merging this

[GitHub] [flink] tillrohrmann commented on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

tillrohrmann commented on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-528746955 Merging this PR now. This is an automated message

[GitHub] [flink] tillrohrmann closed pull request #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

tillrohrmann closed pull request #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555 This is an automated message from the Apache Git Service. To respond to

[jira] [Resolved] (FLINK-13970) Remove LifoSetQueue and SetQueue

[ https://issues.apache.org/jira/browse/FLINK-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13970. --- Resolution: Done Done via 906b630253bb0f8fccdecc7b1ad8514f1a8d75a0 > Remove LifoSetQueue

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for dubuggability

flinkbot edited a comment on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for dubuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-528767160 ## CI report: * 313d9b3295124b77fee967c76f63f5aef9bd3db8 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput

flinkbot edited a comment on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput URL: https://github.com/apache/flink/pull/9635#issuecomment-528767193 ## CI report: * 47780ee7ffe484a87e03f533d035f1fef50bb28b : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9551: [FLINK-13882] Remove ProcessReaper

flinkbot edited a comment on issue #9551: [FLINK-13882] Remove ProcessReaper URL: https://github.com/apache/flink/pull/9551#issuecomment-525740540 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

[GitHub] [flink] flinkbot edited a comment on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

flinkbot edited a comment on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#issuecomment-501187829 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 #8780: [travis] Increase travis cache timeout to 1200

flinkbot edited a comment on issue #8780: [travis] Increase travis cache timeout to 1200 URL: https://github.com/apache/flink/pull/8780#issuecomment-503019109 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] flinkbot edited a comment on issue #9594: [FLINK-13618] Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 savepoint

flinkbot edited a comment on issue #9594: [FLINK-13618] Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9594#issuecomment-527027836 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9592: [FLINK-13617] Update FlinkKafkaProducer011MigrationTest to restore from 1.9 savepoint

flinkbot edited a comment on issue #9592: [FLINK-13617] Update FlinkKafkaProducer011MigrationTest to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9592#issuecomment-527023742 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9519: [FLINK-13826][table-planner][hive] Support INSERT OVERWRITE for Hive …

flinkbot edited a comment on issue #9519: [FLINK-13826][table-planner][hive] Support INSERT OVERWRITE for Hive … URL: https://github.com/apache/flink/pull/9519#issuecomment-524218956 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 #9557: [FLINK-13891][build] Increment flink-shaded version

flinkbot edited a comment on issue #9557: [FLINK-13891][build] Increment flink-shaded version URL: https://github.com/apache/flink/pull/9557#issuecomment-526141576 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 #9526: [FLINK-13614][Tests] Add MigrationVersion.v1_9

flinkbot edited a comment on issue #9526: [FLINK-13614][Tests] Add MigrationVersion.v1_9 URL: https://github.com/apache/flink/pull/9526#issuecomment-524521158 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] flinkbot edited a comment on issue #9550: [FLINK-13805] Properly forward cause for slot removal in SlotManager

flinkbot edited a comment on issue #9550: [FLINK-13805] Properly forward cause for slot removal in SlotManager URL: https://github.com/apache/flink/pull/9550#issuecomment-525737651 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 for blocking operators

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

[GitHub] [flink] flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring

flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring URL: https://github.com/apache/flink/pull/9507#issuecomment-523837860 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] flinkbot edited a comment on issue #9567: [FLINK-13887] [core] Ensure defaultInputDependencyConstraint to be non-null when setting it in ExecutionConfig

flinkbot edited a comment on issue #9567: [FLINK-13887] [core] Ensure defaultInputDependencyConstraint to be non-null when setting it in ExecutionConfig URL: https://github.com/apache/flink/pull/9567#issuecomment-526566234 Thanks a lot for your contribution to the Apache Flink project.

[GitHub] [flink] flinkbot edited a comment on issue #8583: [FLINK-11820][serialization] SimpleStringSchema handle message record which value is null

flinkbot edited a comment on issue #8583: [FLINK-11820][serialization] SimpleStringSchema handle message record which value is null URL: https://github.com/apache/flink/pull/8583#issuecomment-497632160 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9579: [FLINK-13925] use current thread's context classloader as parent of flink classloader

flinkbot edited a comment on issue #9579: [FLINK-13925] use current thread's context classloader as parent of flink classloader URL: https://github.com/apache/flink/pull/9579#issuecomment-526652922 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9560: [FLINK-13897][oss] Move NOTICE file into META-INF directory

flinkbot edited a comment on issue #9560: [FLINK-13897][oss] Move NOTICE file into META-INF directory URL: https://github.com/apache/flink/pull/9560#issuecomment-526167658 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #9545: [FLINK-13355][docs] Add documentation for Temporal Table Join in blink planner

flinkbot edited a comment on issue #9545: [FLINK-13355][docs] Add documentation for Temporal Table Join in blink planner URL: https://github.com/apache/flink/pull/9545#issuecomment-525376120 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 #9553: [FLINK-13883] Remove unused AkkaOptions related to Akka's death watch

flinkbot edited a comment on issue #9553: [FLINK-13883] Remove unused AkkaOptions related to Akka's death watch URL: https://github.com/apache/flink/pull/9553#issuecomment-525754901 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 #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942#issuecomment-470819951 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 #8967: [FLINK-13059][Cassandra Connector] Release Semaphore correctly on Exception in send()

flinkbot edited a comment on issue #8967: [FLINK-13059][Cassandra Connector] Release Semaphore correctly on Exception in send() URL: https://github.com/apache/flink/pull/8967#issuecomment-508044485 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9600: [FLINK-13621][Tests] Update ContinuousFileProcessingMigrationTest to restore from 1.9 savepoint

flinkbot edited a comment on issue #9600: [FLINK-13621][Tests] Update ContinuousFileProcessingMigrationTest to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9600#issuecomment-527366945 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #9575: [FLINK-13912][client] Remove ClusterClient#getClusterConnectionInfo

flinkbot edited a comment on issue #9575: [FLINK-13912][client] Remove ClusterClient#getClusterConnectionInfo URL: https://github.com/apache/flink/pull/9575#issuecomment-526605083 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 #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523876599 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9512: [FLINK-13819][coordination] Introduce State for RpcEndpoint

flinkbot edited a comment on issue #9512: [FLINK-13819][coordination] Introduce State for RpcEndpoint URL: https://github.com/apache/flink/pull/9512#issuecomment-523894000 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #9589: [FLINK-13615][Tests] Update CEPMigrationTest to restore from 1.9 savepoint

flinkbot edited a comment on issue #9589: [FLINK-13615][Tests] Update CEPMigrationTest to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9589#issuecomment-527011963 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 #9590: [FLINK-13616][Tests] Update BucketingSinkMigrationTest to restore from 1.9 savepoint

flinkbot edited a comment on issue #9590: [FLINK-13616][Tests] Update BucketingSinkMigrationTest to restore from 1.9 savepoint URL: https://github.com/apache/flink/pull/9590#issuecomment-527017146 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9568: [Flink-12164][tests] Harden JobMasterTest#testJobFailureWhenTaskExecutorHeartbeatTimeout

flinkbot edited a comment on issue #9568: [Flink-12164][tests] Harden JobMasterTest#testJobFailureWhenTaskExecutorHeartbeatTimeout URL: https://github.com/apache/flink/pull/9568#issuecomment-526582123 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] tillrohrmann commented on issue #9629: [FLINK-13960] Add throwing HighAvailabilityServices#getWebMonitorLeaderRetriever default impl

tillrohrmann commented on issue #9629: [FLINK-13960] Add throwing HighAvailabilityServices#getWebMonitorLeaderRetriever default impl URL: https://github.com/apache/flink/pull/9629#issuecomment-528743000 Thanks for the review @TisonKun. Merging this PR.

[jira] [Closed] (FLINK-13977) Adapt HighAvailabilityServices#getWebMonitorLeaderElectionService to #getClusterRestEndpointLeaderRetriever

[ https://issues.apache.org/jira/browse/FLINK-13977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13977. - Release Note: Implementations of `HighAvailabilityServices` should implement

[jira] [Resolved] (FLINK-13868) Job vertex add taskmanager id in rest api

[ https://issues.apache.org/jira/browse/FLINK-13868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13868. --- Resolution: Done Done via 1d53e8d8ffd354d5a4f51aac767f5e45321cbdda > Job vertex add

[GitHub] [flink] rmetzger commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml

rmetzger commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#discussion_r321612892 ## File path: azure-pipelines.yml ## @@ -0,0 +1,79 @@ +# Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] rmetzger commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml

rmetzger commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#discussion_r321612563 ## File path: azure-pipelines.yml ## @@ -0,0 +1,79 @@ +# Licensed to the Apache Software Foundation (ASF) under

[jira] [Commented] (FLINK-13892) HistoryServerTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924009#comment-16924009 ] Gary Yao commented on FLINK-13892: -- Another instance

[GitHub] [flink] flinkbot edited a comment on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs

flinkbot edited a comment on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs URL: https://github.com/apache/flink/pull/9617#issuecomment-527968624 ## CI report: * ecf3897b7c61bca5a65d3ecc66a009d6ab91c596 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for dubuggability

flinkbot commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for dubuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-528758790 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13987: --- Description: As the job running, the log files are becoming large. Current log api returns all contents，it

[GitHub] [flink] flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

flinkbot edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-526715445 ## CI report: *

[jira] [Closed] (FLINK-13960) Provide default implementation for deprecated HighAvailabilityServices.getWebMonitorLeaderRetriever

[ https://issues.apache.org/jira/browse/FLINK-13960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13960. - Resolution: Done Done via d2957bd543b0a188520df733def6e456ceac73d1 > Provide default

[GitHub] [flink] tillrohrmann closed pull request #9629: [FLINK-13960] Add throwing HighAvailabilityServices#getWebMonitorLeaderRetriever default impl

tillrohrmann closed pull request #9629: [FLINK-13960] Add throwing HighAvailabilityServices#getWebMonitorLeaderRetriever default impl URL: https://github.com/apache/flink/pull/9629 This is an automated message from the

[jira] [Closed] (FLINK-13964) Remove usage of deprecated methods from MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-13964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-13964. - Release Note: Implementations of `HighAvailabilityServices` should now implement

[GitHub] [flink] tillrohrmann closed pull request #9631: [FLINK-13977] Replace HighAvailabilityServices#getWebMonitorLeaderElectionService with #getClusterRestEndpointLeaderElectionService

tillrohrmann closed pull request #9631: [FLINK-13977] Replace HighAvailabilityServices#getWebMonitorLeaderElectionService with #getClusterRestEndpointLeaderElectionService URL: https://github.com/apache/flink/pull/9631

[GitHub] [flink] tillrohrmann closed pull request #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

tillrohrmann closed pull request #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue URL: https://github.com/apache/flink/pull/9633 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs

flinkbot edited a comment on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs URL: https://github.com/apache/flink/pull/9617#issuecomment-527968624 ## CI report: * ecf3897b7c61bca5a65d3ecc66a009d6ab91c596 : SUCCESS

[jira] [Updated] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13987: --- Description: As log files becoming more large, current log api often blocks or don't work. It's unfriendly

[jira] [Created] (FLINK-13987) add new logs api, see more log files and can see logs by pages

lining created FLINK-13987: -- Summary: add new logs api, see more log files and can see logs by pages Key: FLINK-13987 URL: https://issues.apache.org/jira/browse/FLINK-13987 Project: Flink Issue

[jira] [Commented] (FLINK-13821) Website must link to License etc

[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924018#comment-16924018 ] Fabian Hueske commented on FLINK-13821: --- Thanks [~sebb], I'll have a look. > Website must link to

[GitHub] [flink] yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-528763841 Hi @kl0u thanks a lot for the suggestions.

[GitHub] [flink] flinkbot edited a comment on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs

flinkbot edited a comment on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs URL: https://github.com/apache/flink/pull/9617#issuecomment-527968624 ## CI report: * ecf3897b7c61bca5a65d3ecc66a009d6ab91c596 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for dubuggability

flinkbot commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for dubuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-528767160 ## CI report: * 313d9b3295124b77fee967c76f63f5aef9bd3db8 : UNKNOWN

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321591563 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321568219 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321564917 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321594173 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321595371 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321561428 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321590759 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/pipeline/Model.java

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321593051 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321559019 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321568740 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321589569 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/MLSession.java

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321561281 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321559677 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321576287 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/MLSession.java

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r321568532 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo …

flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo … URL: https://github.com/apache/flink/pull/9432#issuecomment-521082590 ## CI report: * d78dad6818e94f70666df4d7fca91c71b717bf3a : SUCCESS

[GitHub] [flink] azagrebin commented on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs

azagrebin commented on issue #9617: [FLINK-13963] Consolidate Hadoop file systems usage and Hadoop integration docs URL: https://github.com/apache/flink/pull/9617#issuecomment-528754162 Thanks for the review @aljoscha I applied the changes and synced the zh file Do you want to have

[jira] [Updated] (FLINK-13987) add new logs api, see more log files and can see logs by pages

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-13987: --- Description: As the job running, the log files are becoming large. Current log api often blocks or don't

[GitHub] [flink] yxu-valleytider edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

yxu-valleytider edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-528763841 Hi @kl0u thanks a lot for the suggestions.

[GitHub] [flink] flinkbot commented on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput

flinkbot commented on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput URL: https://github.com/apache/flink/pull/9635#issuecomment-528767193 ## CI report: * 47780ee7ffe484a87e03f533d035f1fef50bb28b : UNKNOWN

[GitHub] [flink] kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-528767272 Hi @yxu-valleytider , I am reviewing the PR now. The tests

[GitHub] [flink] flinkbot edited a comment on issue #9513: [FLINK-13769][Coordination] Close RM connection in TaskExecutor.onStop and do not reconnect

flinkbot edited a comment on issue #9513: [FLINK-13769][Coordination] Close RM connection in TaskExecutor.onStop and do not reconnect URL: https://github.com/apache/flink/pull/9513#issuecomment-523896867 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] dmvk commented on issue #9596: [FLINK-13445] Add 'jobmanager.containerized.heap-cutoff-{min,ratio}' …

dmvk commented on issue #9596: [FLINK-13445] Add 'jobmanager.containerized.heap-cutoff-{min,ratio}' … URL: https://github.com/apache/flink/pull/9596#issuecomment-528746177 @tillrohrmann would you have time to look at this one? Thanks D.

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924013#comment-16924013 ] Gary Yao commented on FLINK-13748: -- Another instance https://api.travis-ci.org/v3/job/581399567/log.txt

  1   2   3   4   5   6   >