[GitHub] [flink] flinkbot edited a comment on pull request #13214: [FLINK-18938][tableSQL/API] Throw better exception message for quering sink-only connector

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13214: URL: https://github.com/apache/flink/pull/13214#issuecomment-678119788 ## CI report: * ef62ec54b70560a9dabc09f020f7386d907aab20 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13213: [FLINK-18975][docs-zh] Translate the 'Execution Plans' page of "Application Development's Managing Execution" into Chinese

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13213: URL: https://github.com/apache/flink/pull/13213#issuecomment-678078933 ## CI report: * fb912cc8e0ed16cd64bd35e833809fb97db41803 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13212: URL: https://github.com/apache/flink/pull/13212#issuecomment-678069566 ## CI report: * Unknown: [CANCELED](TBD) * b3602a770dcbc2c274ad64f858ed55d68b70039e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13212: URL: https://github.com/apache/flink/pull/13212#issuecomment-678069566 ## CI report: * Unknown: [CANCELED](TBD) * b3602a770dcbc2c274ad64f858ed55d68b70039e UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #13213: [FLINK-18975][docs-zh] Translate the 'Execution Plans' page of "Application Development's Managing Execution" into Chinese

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13213: URL: https://github.com/apache/flink/pull/13213#issuecomment-678078933 ## CI report: * fb912cc8e0ed16cd64bd35e833809fb97db41803 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13214: [FLINK-18938][tableSQL/API] Throw better exception message for quering sink-only connector

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13214: URL: https://github.com/apache/flink/pull/13214#issuecomment-678119788 ## CI report: * ef62ec54b70560a9dabc09f020f7386d907aab20 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on pull request #13212: URL: https://github.com/apache/flink/pull/13212#issuecomment-678601215 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] RocMarshal commented on pull request #13213: [FLINK-18975][docs-zh] Translate the 'Execution Plans' page of "Application Development's Managing Execution" into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on pull request #13213: URL: https://github.com/apache/flink/pull/13213#issuecomment-678601235 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #13214: [FLINK-18938][tableSQL/API] Throw better exception message for quering sink-only connector

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13214: URL: https://github.com/apache/flink/pull/13214#issuecomment-678119788 ## CI report: * ef62ec54b70560a9dabc09f020f7386d907aab20 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on a change in pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on a change in pull request #13212: URL: https://github.com/apache/flink/pull/13212#discussion_r475051665 ## File path: docs/monitoring/historyserver.zh.md ## @@ -22,62 +22,69 @@ specific language governing permissions and limitations under the License. -

[GitHub] [flink] RocMarshal commented on a change in pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on a change in pull request #13212: URL: https://github.com/apache/flink/pull/13212#discussion_r475051363 ## File path: docs/monitoring/historyserver.zh.md ## @@ -22,62 +22,69 @@ specific language governing permissions and limitations under the License. -

[GitHub] [flink-docker] zhuzhurk merged pull request #39: Update Dockerfiles for 1.10.2 release

2020-08-21 Thread GitBox
zhuzhurk merged pull request #39: URL: https://github.com/apache/flink-docker/pull/39 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 t

[GitHub] [flink-docker] zhuzhurk merged pull request #38: Add GPG key for 1.10.2 release and update test script

2020-08-21 Thread GitBox
zhuzhurk merged pull request #38: URL: https://github.com/apache/flink-docker/pull/38 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 t

[jira] [Comment Edited] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-08-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181926#comment-17181926 ] Jiayi Liao edited comment on FLINK-19016 at 8/22/20, 4:30 AM:

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182236#comment-17182236 ] Dian Fu commented on FLINK-18675: - It seems duplicate with FLINK-18856 and has been addr

[jira] [Closed] (FLINK-18819) All the PubSub tests are failing

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18819. --- Fix Version/s: (was: 1.11.2) (was: 1.12.0) Resolution: Cannot Reproduce Cl

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182233#comment-17182233 ] Dian Fu commented on FLINK-17274: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182232#comment-17182232 ] Dian Fu commented on FLINK-16947: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182231#comment-17182231 ] Dian Fu commented on FLINK-18634: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Comment Edited] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182231#comment-17182231 ] Dian Fu edited comment on FLINK-18634 at 8/22/20, 2:46 AM: --- In

[jira] [Commented] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182230#comment-17182230 ] Dian Fu commented on FLINK-19012: - Another instance on master: https://dev.azure.com/ap

[jira] [Updated] (FLINK-18855) Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18855: Fix Version/s: 1.12.0 > Translate the "Cluster Execution" page of "Application Development's DataSet > AP

[jira] [Closed] (FLINK-18855) Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18855. --- Resolution: Fixed master: 5500435372cdf258e4f0a646089c85389e25e94d > Translate the "Cluster Execution" page

[GitHub] [flink] dianfu closed pull request #13173: [FLINK-18855][docs-zh] Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

2020-08-21 Thread GitBox
dianfu closed pull request #13173: URL: https://github.com/apache/flink/pull/13173 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 t

[GitHub] [flink] dianfu commented on a change in pull request #13173: [FLINK-18855][docs-zh] Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

2020-08-21 Thread GitBox
dianfu commented on a change in pull request #13173: URL: https://github.com/apache/flink/pull/13173#discussion_r475030431 ## File path: docs/dev/cluster_execution.zh.md ## @@ -25,27 +25,27 @@ under the License. * This will be replaced by the TOC {:toc} -Flink programs can

[GitHub] [flink] RocMarshal commented on pull request #13172: [FLINK-18854][docs-zh] Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on pull request #13172: URL: https://github.com/apache/flink/pull/13172#issuecomment-678572640 @Thesharing Could you help me to review this PR if you have free time? Thank you. This is an

[GitHub] [flink] RocMarshal commented on pull request #13173: [FLINK-18855][docs-zh] Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on pull request #13173: URL: https://github.com/apache/flink/pull/13173#issuecomment-678571817 @dianfu Could you help me to merge this PR if there is nothing inappropriate? Thank you. This is a

[jira] [Closed] (FLINK-18813) Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18813. --- Fix Version/s: 1.12.0 Resolution: Fixed master: c9e46694fcf0e84c7b5d9428a31a77683ec0170d > Translate

[GitHub] [flink] dianfu closed pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-21 Thread GitBox
dianfu closed pull request #13089: URL: https://github.com/apache/flink/pull/13089 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 t

[GitHub] [flink] dianfu commented on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-21 Thread GitBox
dianfu commented on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-678570567 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] RocMarshal commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-21 Thread GitBox
RocMarshal commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r475024133 ## File path: docs/try-flink/local_installation.zh.md ## @@ -26,36 +26,35 @@ under the License. {% if site.version contains "SNAPSHOT" %} - NOT

[GitHub] [flink] dianfu commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-21 Thread GitBox
dianfu commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r474762668 ## File path: docs/try-flink/local_installation.zh.md ## @@ -26,36 +26,35 @@ under the License. {% if site.version contains "SNAPSHOT" %} - NOTE: T

[GitHub] [flink] flinkbot edited a comment on pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13175: URL: https://github.com/apache/flink/pull/13175#issuecomment-674839926 ## CI report: * 78f6ef8e0aa36ddc08ecd4a6984ec465c0192ec7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] sjwiesman commented on pull request #132: [FLINK-18979][docs] Update docs to better emphasize remote functions

2020-08-21 Thread GitBox
sjwiesman commented on pull request #132: URL: https://github.com/apache/flink-statefun/pull/132#issuecomment-678432084 Thanks for the review @morsapaes . I've addressed your feedback and also updated the README's in a seperate commit. I'm going on vacation next week so I went ahead and sq

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #132: [FLINK-18979][docs] Update docs to better emphasize remote functions

2020-08-21 Thread GitBox
sjwiesman commented on a change in pull request #132: URL: https://github.com/apache/flink-statefun/pull/132#discussion_r474857047 ## File path: docs/index.md ## @@ -23,16 +23,19 @@ specific language governing permissions and limitations under the License. --> -**Stateful F

[GitHub] [flink] morsapaes commented on pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

2020-08-21 Thread GitBox
morsapaes commented on pull request #13203: URL: https://github.com/apache/flink/pull/13203#issuecomment-678426366 👌🏻 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] sjwiesman commented on pull request #13203: [FLINK-18984][python][docs] Add tutorial documentation for Python DataStream API

2020-08-21 Thread GitBox
sjwiesman commented on pull request #13203: URL: https://github.com/apache/flink/pull/13203#issuecomment-678424666 I'm going to be on vacation for the next week, maybe @morsapaes can take a look at this? This is an automate

[GitHub] [flink] flinkbot edited a comment on pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13175: URL: https://github.com/apache/flink/pull/13175#issuecomment-674839926 ## CI report: * 635f839466122e36674a38a9845c2d6b5eb5c244 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 85c9bbac2d9ca07435fbd80d76208fa2a51e5d37 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13175: URL: https://github.com/apache/flink/pull/13175#issuecomment-674839926 ## CI report: * 635f839466122e36674a38a9845c2d6b5eb5c244 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-21 Thread GitBox
curcur commented on pull request #13175: URL: https://github.com/apache/flink/pull/13175#issuecomment-678391416 With updated version ``` 9213 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Restoring job 49eabb33b8dfc35

[GitHub] [flink] curcur commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-21 Thread GitBox
curcur commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r474816716 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void setDiscardCallback(@Nu

[GitHub] [flink] curcur commented on a change in pull request #13175: [FLINK-18955][Checkpointing] Add checkpoint path to job startup/restore message

2020-08-21 Thread GitBox
curcur commented on a change in pull request #13175: URL: https://github.com/apache/flink/pull/13175#discussion_r474816716 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -320,6 +320,12 @@ void setDiscardCallback(@Nu

[jira] [Closed] (FLINK-18993) Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

2020-08-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18993. - Resolution: Fixed Fixed via master: df525b77d29ccd89649a64e5faad96c93f61ca08 1.11.2: 5e9bd610f3

[GitHub] [flink] tillrohrmann closed pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

2020-08-21 Thread GitBox
tillrohrmann closed pull request #13198: URL: https://github.com/apache/flink/pull/13198 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 g

[jira] [Assigned] (FLINK-18993) Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

2020-08-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-18993: - Assignee: Peng > Invoke sanityCheckTotalFlinkMemory method incorrectly in > JobManager

[jira] [Updated] (FLINK-18993) Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

2020-08-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18993: -- Fix Version/s: 1.11.2 1.12.0 > Invoke sanityCheckTotalFlinkMemory method in

[jira] [Commented] (FLINK-19011) Parallelize the restore operation in OperatorStateBackend

2020-08-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181981#comment-17181981 ] Jiayi Liao commented on FLINK-19011: [~sewen] Mmm... probably you're right because w

[jira] [Comment Edited] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-08-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181926#comment-17181926 ] Jiayi Liao edited comment on FLINK-19016 at 8/21/20, 4:26 PM:

[jira] [Comment Edited] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-08-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181926#comment-17181926 ] Jiayi Liao edited comment on FLINK-19016 at 8/21/20, 4:26 PM:

[jira] [Comment Edited] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-08-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181926#comment-17181926 ] Jiayi Liao edited comment on FLINK-19016 at 8/21/20, 4:23 PM:

[jira] [Created] (FLINK-19024) Remove unused "releaseMemory" from ResultSubpartition

2020-08-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19024: Summary: Remove unused "releaseMemory" from ResultSubpartition Key: FLINK-19024 URL: https://issues.apache.org/jira/browse/FLINK-19024 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on pull request #13206: [FLINK-18948][python] Add end to end test for Python DataStream API.

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13206: URL: https://github.com/apache/flink/pull/13206#issuecomment-677500353 ## CI report: * 5b6041fc76df9a5345ae672cd29e5e3b0be51f73 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lgo commented on pull request #12345: draft: [FLINK-17971] [Runtime/StateBackends] Add RocksDB SST ingestion for batch writes

2020-08-21 Thread GitBox
lgo commented on pull request #12345: URL: https://github.com/apache/flink/pull/12345#issuecomment-678368305 Unfortunately not. The changes should be code complete, but I did not find the time to test and evaluate perf on running cluster yet and had backported to 1.9.1 for that. Tha

[GitHub] [flink] flinkbot edited a comment on pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13024: URL: https://github.com/apache/flink/pull/13024#issuecomment-666148245 ## CI report: * eb611d5b39f997fa3e986b5d163cb65a44b4b0ba UNKNOWN * e505da81c290c0ab3f21defb1ef0f3a3f7be69eb Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] dianfu commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-21 Thread GitBox
dianfu commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r474762668 ## File path: docs/try-flink/local_installation.zh.md ## @@ -26,36 +26,35 @@ under the License. {% if site.version contains "SNAPSHOT" %} - NOTE: T

[jira] [Created] (FLINK-19023) Remove pruning of Record Serializer Buffer

2020-08-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19023: Summary: Remove pruning of Record Serializer Buffer Key: FLINK-19023 URL: https://issues.apache.org/jira/browse/FLINK-19023 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] rmetzger commented on a change in pull request #12823: FLINK-18013: Refactor Hadoop utils to a single module

2020-08-21 Thread GitBox
rmetzger commented on a change in pull request #12823: URL: https://github.com/apache/flink/pull/12823#discussion_r474752292 ## File path: flink-hadoop-utils/pom.xml ## @@ -0,0 +1,78 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http://www.w3.org/2001/

[jira] [Commented] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-08-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181926#comment-17181926 ] Jiayi Liao commented on FLINK-19016: [~sewen] All of your assumptions are right. (BT

[GitHub] [flink] rmetzger commented on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
rmetzger commented on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678327440 I assumed the tests to be stable, because my personal CI finished [pretty green](https://dev.azure.com/rmetzger/Flink/_build/results?buildId=8308&view=results). I will investig

[GitHub] [flink] rmetzger edited a comment on pull request #13162: [FLINK-18685][API / DataStream]JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-08-21 Thread GitBox
rmetzger edited a comment on pull request #13162: URL: https://github.com/apache/flink/pull/13162#issuecomment-678321188 This is the error I'm seeing ``` java.lang.IllegalStateException: MiniCluster is not yet running or has already been shut down. at org.apache.flink.util.P

[GitHub] [flink] rmetzger commented on pull request #13162: [FLINK-18685][API / DataStream]JobClient.getAccumulators() blocks until streaming job has finished in local environment

2020-08-21 Thread GitBox
rmetzger commented on pull request #13162: URL: https://github.com/apache/flink/pull/13162#issuecomment-678321188 This is the error I'm seeing ``` java.lang.IllegalStateException: MiniCluster is not yet running or has already been shut down. at org.apache.flink.util.Precondi

[GitHub] [flink-web] sjwiesman commented on pull request #371: [hotfix] Add makefile

2020-08-21 Thread GitBox
sjwiesman commented on pull request #371: URL: https://github.com/apache/flink-web/pull/371#issuecomment-678314215 merged in a229405453080b7f70a9d04fae5e6d22129d20bc This is an automated message from the Apache Git Service. T

[GitHub] [flink-web] sjwiesman closed pull request #371: [hotfix] Add makefile

2020-08-21 Thread GitBox
sjwiesman closed pull request #371: URL: https://github.com/apache/flink-web/pull/371 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 t

[jira] [Commented] (FLINK-18797) docs and examples use deprecated forms of keyBy

2020-08-21 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181913#comment-17181913 ] David Anderson commented on FLINK-18797: [~rmetzger] No, I only looked at keyBy.

[jira] [Updated] (FLINK-19022) AkkaRpcActor failed to start but no exception information

2020-08-21 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-19022: - Description: My job appeared that JM could not start normally, and the JM container was finally killed

[GitHub] [flink] flinkbot edited a comment on pull request #13214: [FLINK-18938][tableSQL/API] Throw better exception message for quering sink-only connector

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13214: URL: https://github.com/apache/flink/pull/13214#issuecomment-678119788 ## CI report: * ef62ec54b70560a9dabc09f020f7386d907aab20 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19022) AkkaRpcActor failed to start but no exception information

2020-08-21 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181911#comment-17181911 ] tartarus commented on FLINK-19022: -- [~chesnay]  [~trohrmann]  How about adding log prin

[jira] [Created] (FLINK-19022) AkkaRpcActor failed to start but no exception information

2020-08-21 Thread tartarus (Jira)
tartarus created FLINK-19022: Summary: AkkaRpcActor failed to start but no exception information Key: FLINK-19022 URL: https://issues.apache.org/jira/browse/FLINK-19022 Project: Flink Issue Type:

[jira] [Created] (FLINK-19021) Cleanups of the ResultPartition components

2020-08-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19021: Summary: Cleanups of the ResultPartition components Key: FLINK-19021 URL: https://issues.apache.org/jira/browse/FLINK-19021 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-18970) Adding Junit TestMarkers

2020-08-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181900#comment-17181900 ] Stephan Ewen commented on FLINK-18970: -- This distinction already exists: Files endi

[jira] [Commented] (FLINK-19011) Parallelize the restore operation in OperatorStateBackend

2020-08-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181898#comment-17181898 ] Stephan Ewen commented on FLINK-19011: -- Union state has caused us much trouble thro

[jira] [Commented] (FLINK-19016) Checksum mismatch when restore from RocksDB

2020-08-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181897#comment-17181897 ] Stephan Ewen commented on FLINK-19016: -- Thanks for reporting this. Can you help us

[GitHub] [flink] morsapaes commented on a change in pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

2020-08-21 Thread GitBox
morsapaes commented on a change in pull request #13193: URL: https://github.com/apache/flink/pull/13193#discussion_r474700929 ## File path: docs/dev/python/user-guide/table/python_table_api_connectors.md ## @@ -0,0 +1,194 @@ +--- +title: "Connectors" +nav-parent_id: python_tabl

[GitHub] [flink-web] sjwiesman opened a new pull request #371: [hotfix] Add makefile

2020-08-21 Thread GitBox
sjwiesman opened a new pull request #371: URL: https://github.com/apache/flink-web/pull/371 Adds a makefile to add explicit commands for rebuilding vs running locally. This is an automated message from the Apache Git Service

[GitHub] [flink] flinkbot edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 85c9bbac2d9ca07435fbd80d76208fa2a51e5d37 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] morsapaes commented on a change in pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

2020-08-21 Thread GitBox
morsapaes commented on a change in pull request #13193: URL: https://github.com/apache/flink/pull/13193#discussion_r474666933 ## File path: docs/dev/python/user-guide/table/python_table_api_connectors.md ## @@ -0,0 +1,194 @@ +--- +title: "Connectors" +nav-parent_id: python_tabl

[GitHub] [flink] flinkbot edited a comment on pull request #13144: [FLINK-15853][hive][table-planner-blink] Use the new type inference f…

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13144: URL: https://github.com/apache/flink/pull/13144#issuecomment-673924067 ## CI report: * 9b69c04b6a987bf81e21fd8a7c062fb72fe7ccb5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19020) Add more metrics around async operations and backpressure

2020-08-21 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-19020: Summary: Add more metrics around async operations and backpressure Key: FLINK-19020 URL: https://issues.apache.org/jira/browse/FLINK-19020 Project: Flink Iss

[jira] [Created] (FLINK-19019) Add HDFS / S3 / GCS support to Flink-StateFun Docker image.

2020-08-21 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-19019: Summary: Add HDFS / S3 / GCS support to Flink-StateFun Docker image. Key: FLINK-19019 URL: https://issues.apache.org/jira/browse/FLINK-19019 Project: Flink

[jira] [Commented] (FLINK-18797) docs and examples use deprecated forms of keyBy

2020-08-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181894#comment-17181894 ] Robert Metzger commented on FLINK-18797: Thanks a lot for filing a ticket for th

[GitHub] [flink] flinkbot commented on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
flinkbot commented on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 85c9bbac2d9ca07435fbd80d76208fa2a51e5d37 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rmetzger edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
rmetzger edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678283618 Note: I'm still investigating one last unstable test `FunctionITCase.testInvalidUseOfTableFunction()` T

[GitHub] [flink] rmetzger commented on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
rmetzger commented on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678283618 Note: I'm still reviewing one last unstable test `FunctionITCase.testInvalidUseOfTableFunction()` This is an a

[jira] [Comment Edited] (FLINK-19005) used metaspace grow on every execution

2020-08-21 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181871#comment-17181871 ] Matthias edited comment on FLINK-19005 at 8/21/20, 1:09 PM:

[jira] [Comment Edited] (FLINK-19005) used metaspace grow on every execution

2020-08-21 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181871#comment-17181871 ] Matthias edited comment on FLINK-19005 at 8/21/20, 1:09 PM:

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

2020-08-21 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181871#comment-17181871 ] Matthias commented on FLINK-19005: -- Thanks for the update: A quick diff shows already t

[jira] [Created] (FLINK-19018) Add connection timeout to remote functions.

2020-08-21 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-19018: Summary: Add connection timeout to remote functions. Key: FLINK-19018 URL: https://issues.apache.org/jira/browse/FLINK-19018 Project: Flink Issue Type: Impro

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 1df875a397cf4d7cf68e46f695a01ef6734b3af1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-08-21 Thread GitBox
flinkbot commented on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678277886 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

2020-08-21 Thread GitBox
flinkbot edited a comment on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673492124 ## CI report: * 0e9c4198095239ebee07a466a5e23de1a60809ac Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-16866) Make job submission non-blocking

2020-08-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16866: --- Labels: pull-request-available (was: ) > Make job submission non-blocking > ---

[GitHub] [flink] rmetzger opened a new pull request #13217: [FLINK-16866] Make jobsubmission non-blocking

2020-08-21 Thread GitBox
rmetzger opened a new pull request #13217: URL: https://github.com/apache/flink/pull/13217 ## What is the purpose of the change This is changing the semantics of the job submission: Instead of completing the `Dispatcher.submitJob()` future after all the initialization happened (whic

[jira] [Commented] (FLINK-19005) used metaspace grow on every execution

2020-08-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181864#comment-17181864 ] Guillermo Sánchez commented on FLINK-19005: --- I have uploaded heap_dump_after_1

[jira] [Comment Edited] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181861#comment-17181861 ] Till Rohrmann edited comment on FLINK-18959 at 8/21/20, 12:48 PM:

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-08-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181861#comment-17181861 ] Till Rohrmann commented on FLINK-18959: --- I agree that we should fix this issue [~J

[jira] [Updated] (FLINK-19017) Increases the visibility of a remote function call failures and retires

2020-08-21 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19017: - Summary: Increases the visibility of a remote function call failures and retires (was: Increase

[jira] [Updated] (FLINK-19005) used metaspace grow on every execution

2020-08-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guillermo Sánchez updated FLINK-19005: -- Attachment: heap_dump_after_1_execution.zip > used metaspace grow on every execution >

[jira] [Updated] (FLINK-19005) used metaspace grow on every execution

2020-08-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guillermo Sánchez updated FLINK-19005: -- Attachment: (was: heap_dump_after_1_execution.zip) > used metaspace grow on every

[GitHub] [flink] flinkbot commented on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

2020-08-21 Thread GitBox
flinkbot commented on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 1df875a397cf4d7cf68e46f695a01ef6734b3af1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

  1   2   3   >