[GitHub] [flink] AHeise commented on a change in pull request #14348: [FLINK-20433][tests] Stabilizing UnalignedCheckpointITCase.

2020-12-14 Thread GitBox
AHeise commented on a change in pull request #14348: URL: https://github.com/apache/flink/pull/14348#discussion_r543123013 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointTestBase.java ## @@ -103,11 +101,6 @@ @Rule

[GitHub] [flink] flinkbot edited a comment on pull request #14367: [FLINK-20601][docs] Rework PyFlink CLI documentation.

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14367: URL: https://github.com/apache/flink/pull/14367#issuecomment-743040989 ## CI report: * 8825b36cf590e53bf15837534ad4797594031ed5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20601) Rework PyFlink CLI documentation

2020-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20601: --- Labels: pull-request-available (was: ) > Rework PyFlink CLI documentation > ---

[GitHub] [flink] shuiqiangchen commented on pull request #14367: [FLINK-20601][docs] Rework PyFlink CLI documentation.

2020-12-14 Thread GitBox
shuiqiangchen commented on pull request #14367: URL: https://github.com/apache/flink/pull/14367#issuecomment-745104687 Hi @XComp, Sorry for the late reply. Thank you for creating the JIRA, I have renamed the commit message and PR title accordingly. Please have a look.

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 4741d372abe2f11a1639c70a6937a2421a41c41e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-20540) The baseurl for pg database is incorrect in JdbcCatalog page

2020-12-14 Thread zhangzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249514#comment-17249514 ] zhangzhao commented on FLINK-20540: --- [~Leonard Xu], Can Merge the PR?  This is PR [add

[jira] [Closed] (FLINK-20354) Rework standalone deployment documentation page

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20354. -- Fix Version/s: 1.12.1 Resolution: Fixed Merged on master in https://github.com/apache/

[GitHub] [flink] rmetzger closed pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-14 Thread GitBox
rmetzger closed pull request #14346: URL: https://github.com/apache/flink/pull/14346 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] rmetzger commented on pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-14 Thread GitBox
rmetzger commented on pull request #14346: URL: https://github.com/apache/flink/pull/14346#issuecomment-745080117 Thanks a lot for the extensive review. Merging this now. This is an automated message from the Apache Git Servi

[GitHub] [flink] V1ncentzzZ commented on pull request #14370: [FLINK-20582][docs] Fix typos in `CREATE Statements` docs.

2020-12-14 Thread GitBox
V1ncentzzZ commented on pull request #14370: URL: https://github.com/apache/flink/pull/14370#issuecomment-745075273 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Created] (FLINK-20607) a wrong example in udfs page.

2020-12-14 Thread shizhengchao (Jira)
shizhengchao created FLINK-20607: Summary: a wrong example in udfs page. Key: FLINK-20607 URL: https://issues.apache.org/jira/browse/FLINK-20607 Project: Flink Issue Type: Bug Compo

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 2d5ac91ee373efed1ede7da63abbfdbbfb60aabf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 2d5ac91ee373efed1ede7da63abbfdbbfb60aabf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 2d5ac91ee373efed1ede7da63abbfdbbfb60aabf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] godfreyhe commented on a change in pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
godfreyhe commented on a change in pull request #14380: URL: https://github.com/apache/flink/pull/14380#discussion_r543012556 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMultipleInput.java ## @

[GitHub] [flink] TsReaper commented on a change in pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
TsReaper commented on a change in pull request #14380: URL: https://github.com/apache/flink/pull/14380#discussion_r543010165 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMultipleInput.java ## @@

[GitHub] [flink] lessonone1 commented on pull request #13026: fixFlinkSqlInsertQuerySinkFieldNotMatch

2020-12-14 Thread GitBox
lessonone1 commented on pull request #13026: URL: https://github.com/apache/flink/pull/13026#issuecomment-745020893 bad way This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] lessonone1 closed pull request #13026: fixFlinkSqlInsertQuerySinkFieldNotMatch

2020-12-14 Thread GitBox
lessonone1 closed pull request #13026: URL: https://github.com/apache/flink/pull/13026 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2020-12-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249460#comment-17249460 ] Huang Xingbo commented on FLINK-20495: -- [https://dev.azure.com/apache-flink/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 2d5ac91ee373efed1ede7da63abbfdbbfb60aabf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249459#comment-17249459 ] Huang Xingbo commented on FLINK-20389: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] godfreyhe commented on a change in pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
godfreyhe commented on a change in pull request #14380: URL: https://github.com/apache/flink/pull/14380#discussion_r542990713 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMultipleInput.java ##

[GitHub] [flink] godfreyhe commented on a change in pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
godfreyhe commented on a change in pull request #14380: URL: https://github.com/apache/flink/pull/14380#discussion_r542993092 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMultipleInput.java ## @

[GitHub] [flink] xiaoHoly commented on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-14 Thread GitBox
xiaoHoly commented on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-745005984 hi,@dianfu. do you have time to review my code This is an automated message from the Apache Git Service. To re

[jira] [Commented] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-14 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249440#comment-17249440 ] HideOnBush commented on FLINK-20576: The ORC format cannot be read, but the parquet

[jira] [Comment Edited] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-14 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249440#comment-17249440 ] HideOnBush edited comment on FLINK-20576 at 12/15/20, 2:11 AM: ---

[GitHub] [flink] godfreyhe commented on a change in pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
godfreyhe commented on a change in pull request #14380: URL: https://github.com/apache/flink/pull/14380#discussion_r542990713 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMultipleInput.java ##

[jira] [Closed] (FLINK-20509) Refactor verifyPlan methods in TableTestBase

2020-12-14 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20509. -- Resolution: Done master: 7b68d537b185c921fd509ab3e78afe5ed7e47c79 > Refactor verifyPlan methods in Ta

[jira] [Updated] (FLINK-20509) Refactor verifyPlan methods in TableTestBase

2020-12-14 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20509: --- Summary: Refactor verifyPlan methods in TableTestBase (was: Refactor verifyPlan method in TableTest

[GitHub] [flink] godfreyhe merged pull request #14360: [FLINK-20509][table-planner-blink] Refactor verifyPlan method in TableTestBase

2020-12-14 Thread GitBox
godfreyhe merged pull request #14360: URL: https://github.com/apache/flink/pull/14360 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-20385) Allow to read metadata for Canal-json format

2020-12-14 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249429#comment-17249429 ] wangfei commented on FLINK-20385: - When will this version come online? > Allow to read

[jira] [Commented] (FLINK-18906) Support checkpointing with multiple input operator chained with sources

2020-12-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249428#comment-17249428 ] Xintong Song commented on FLINK-18906: -- True, thank you [~pnowojski]. > Support ch

[GitHub] [flink] flinkbot edited a comment on pull request #14383: [FLINK-20589] Remove old scheduling strategies

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14383: URL: https://github.com/apache/flink/pull/14383#issuecomment-744695966 ## CI report: * b0dd813486c720d47f477968adb04322c6d6b1ba Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20606) sql client cannot create function using user classes from jar which specified by -j option

2020-12-14 Thread akisaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] akisaya updated FLINK-20606: Description: with flink version 1.12.0(versions before also affected) I started a sql cli  with a hive ca

[jira] [Updated] (FLINK-20606) sql client cannot create function using user classes from jar which specified by -j option

2020-12-14 Thread akisaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] akisaya updated FLINK-20606: Description: with flink version 1.12.0(versions before also affected) I started a sql cli  with a hive ca

[jira] [Commented] (FLINK-20606) sql client cannot create function using user classes from jar which specified by -j option

2020-12-14 Thread akisaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249398#comment-17249398 ] akisaya commented on FLINK-20606: - [~jark],I would like make a  pr to this issue, can yo

[jira] [Created] (FLINK-20606) sql client cannot create function using user classes from jar which specified by -j option

2020-12-14 Thread akisaya (Jira)
akisaya created FLINK-20606: --- Summary: sql client cannot create function using user classes from jar which specified by -j option Key: FLINK-20606 URL: https://issues.apache.org/jira/browse/FLINK-20606

[GitHub] [flink] flinkbot edited a comment on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744503895 ## CI report: * e61e157c3e00951e26fb98849d641fc917a14b64 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zentol closed pull request #14382: [FLINK-20605][coordination] Only process acknowledgements from registered TaskExecutors

2020-12-14 Thread GitBox
zentol closed pull request #14382: URL: https://github.com/apache/flink/pull/14382 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-playgrounds] alpinegizmo merged pull request #12: Added a guide for Windows users.

2020-12-14 Thread GitBox
alpinegizmo merged pull request #12: URL: https://github.com/apache/flink-playgrounds/pull/12 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

[GitHub] [flink] flinkbot edited a comment on pull request #14383: [FLINK-20589] Remove old scheduling strategies

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

[GitHub] [flink] flinkbot edited a comment on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744503895 ## CI report: * 6ea39ec0119663f4641aa5ae4074efa5d7a34322 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #13879: URL: https://github.com/apache/flink/pull/13879#issuecomment-720415853 ## CI report: * 365f22a4626a975b9b556776947306db7dfdfeb1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14383: [FLINK-20589] Remove old scheduling strategies

2020-12-14 Thread GitBox
flinkbot commented on pull request #14383: URL: https://github.com/apache/flink/pull/14383#issuecomment-744695966 ## CI report: * b0dd813486c720d47f477968adb04322c6d6b1ba UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744503895 ## CI report: * 6ea39ec0119663f4641aa5ae4074efa5d7a34322 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14383: [FLINK-20589] Remove old scheduling strategies

2020-12-14 Thread GitBox
flinkbot commented on pull request #14383: URL: https://github.com/apache/flink/pull/14383#issuecomment-744690562 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

[jira] [Assigned] (FLINK-20594) Remove DefaultExecutionSlotAllocator

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20594: -- Assignee: Robert Metzger > Remove DefaultExecutionSlotAllocator > ---

[jira] [Updated] (FLINK-20589) Remove old scheduling strategies

2020-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20589: --- Labels: pull-request-available (was: ) > Remove old scheduling strategies > ---

[GitHub] [flink] rmetzger opened a new pull request #14383: [FLINK-20589] Remove old scheduling strategies

2020-12-14 Thread GitBox
rmetzger opened a new pull request #14383: URL: https://github.com/apache/flink/pull/14383 ## What is the purpose of the change After the implementation of the pipelined region scheduler (FLINK-16430), we no longer need the old LazyFromSourcesSchedulingStrategy and EagerSchedulingSt

[GitHub] [flink-playgrounds] alpinegizmo commented on a change in pull request #12: Added a guide for Windows users.

2020-12-14 Thread GitBox
alpinegizmo commented on a change in pull request #12: URL: https://github.com/apache/flink-playgrounds/pull/12#discussion_r542725837 ## File path: operations-playground/README.md ## @@ -36,6 +36,11 @@ docker-compose up -d You can check if the playground was successfully sta

[GitHub] [flink] flinkbot edited a comment on pull request #14382: [FLINK-20605][coordination] Only process acknowledgements from registered TaskExecutors

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

[GitHub] [flink] flinkbot commented on pull request #14382: [FLINK-20605][coordination] Only process acknowledgements from registered TaskExecutors

2020-12-14 Thread GitBox
flinkbot commented on pull request #14382: URL: https://github.com/apache/flink/pull/14382#issuecomment-744654488 ## CI report: * aa893307da9bafa60c73346203554de0303b11c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] zentol commented on a change in pull request #14372: [FLINK-19259][Kinesis] Remove references to allow classloader unloading

2020-12-14 Thread GitBox
zentol commented on a change in pull request #14372: URL: https://github.com/apache/flink/pull/14372#discussion_r542644960 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java ## @@ -423,4

[GitHub] [flink] zentol commented on a change in pull request #14372: [FLINK-19259][Kinesis] Remove references to allow classloader unloading

2020-12-14 Thread GitBox
zentol commented on a change in pull request #14372: URL: https://github.com/apache/flink/pull/14372#discussion_r542666752 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java ## @@ -423,4

[GitHub] [flink] zentol commented on a change in pull request #14372: [FLINK-19259][Kinesis] Remove references to allow classloader unloading

2020-12-14 Thread GitBox
zentol commented on a change in pull request #14372: URL: https://github.com/apache/flink/pull/14372#discussion_r542666752 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java ## @@ -423,4

[GitHub] [flink] zentol commented on a change in pull request #14372: [FLINK-19259][Kinesis] Remove references to allow classloader unloading

2020-12-14 Thread GitBox
zentol commented on a change in pull request #14372: URL: https://github.com/apache/flink/pull/14372#discussion_r542643500 ## File path: flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java ## @@ -128,12 +129,11 @@ * * The releas

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * b7d1707557148278604a497b07e2682b342da246 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14382: [FLINK-20605][coordination] Only process acknowledgements from registered TaskExecutors

2020-12-14 Thread GitBox
flinkbot commented on pull request #14382: URL: https://github.com/apache/flink/pull/14382#issuecomment-744640957 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

[jira] [Updated] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20605: --- Labels: pull-request-available (was: ) > DeclarativeSlotManager crashes if slot allocation

[GitHub] [flink] zentol opened a new pull request #14382: [FLINK-20605][coordination] Only process acknowledgements from registered TaskExecutors

2020-12-14 Thread GitBox
zentol opened a new pull request #14382: URL: https://github.com/apache/flink/pull/14382 It is possible that a notification from a task executor about a slot being allocated can be processed after that very task executor has unregistered itself from the resource manager. As a result we

[jira] [Updated] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20605: - Description: It is possible that a notification from a task executor about a slot being

[jira] [Created] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown

2020-12-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-20605: Summary: DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown Key: FLINK-20605 URL: https://issues.apache.org/jira/brows

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249199#comment-17249199 ] Robert Metzger commented on FLINK-20389: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-20529) Publish Dockerfiles for release 1.12.0

2020-12-14 Thread roberto hashioka (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249190#comment-17249190 ] roberto hashioka commented on FLINK-20529: -- Are we good to use this image [htt

[GitHub] [flink] flinkbot edited a comment on pull request #14379: [FLINK-20563][hive] Support built-in functions for Hive versions prio…

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14379: URL: https://github.com/apache/flink/pull/14379#issuecomment-73009 ## CI report: * a413199ba00fdf4b41b09e7cf4bcf02bcd6da0ce Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13424: [FLINK-19219] Run JobManager initialization in separate thread to make it cancellable

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #13424: URL: https://github.com/apache/flink/pull/13424#issuecomment-694863633 ## CI report: * f247ac96fef0e62881f4726e87f56291e72e883a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 2d5ac91ee373efed1ede7da63abbfdbbfb60aabf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #13879: URL: https://github.com/apache/flink/pull/13879#issuecomment-720415853 ## CI report: * 52a32b3e279a3c17dfe865e6d09e1b57d5b29bfc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #13879: URL: https://github.com/apache/flink/pull/13879#issuecomment-720415853 ## CI report: * 52a32b3e279a3c17dfe865e6d09e1b57d5b29bfc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14378: [FLINK-20522][table] Make implementing a built-in function straightforward

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14378: URL: https://github.com/apache/flink/pull/14378#issuecomment-744402991 ## CI report: * 0e6914c466a975c74a0c0d49f7635d7d33ef00e2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744503895 ## CI report: * 6ea39ec0119663f4641aa5ae4074efa5d7a34322 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14360: [FLINK-20509][table-planner-blink] Refactor verifyPlan method in TableTestBase

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14360: URL: https://github.com/apache/flink/pull/14360#issuecomment-742794536 ## CI report: * b35d38f035e0d4155cc958559b69e7d111463baf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 897fe1eb2bb46f63f8cea373c5b5d917070823b5 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14346: URL: https://github.com/apache/flink/pull/14346#issuecomment-741680007 ## CI report: * 395f8fc742495a2a4dccf2597123c3d2b1986e02 UNKNOWN * 8e4e06a171990c09da0438ed1b2432df5ec59989 UNKNOWN * 293ea9218bb6340b069cb9e55f55052b8ed4

[jira] [Comment Edited] (FLINK-20591) Remove JobManagerOptions.SCHEDULING_STRATEGY

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

[jira] [Commented] (FLINK-20591) Remove JobManagerOptions.SCHEDULING_STRATEGY

2020-12-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249082#comment-17249082 ] Till Rohrmann commented on FLINK-20591: --- Yes, I would suggest doing it as you prop

[GitHub] [flink] flinkbot edited a comment on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744503895 ## CI report: * 6ea39ec0119663f4641aa5ae4074efa5d7a34322 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20591) Remove JobManagerOptions.SCHEDULING_STRATEGY

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249048#comment-17249048 ] Robert Metzger commented on FLINK-20591: It seems that the approximate local rec

[jira] [Updated] (FLINK-19832) Improve handling of immediately failed physical slot in SlotSharingExecutionSlotAllocator

2020-12-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19832: -- Fix Version/s: 1.12.1 1.13.0 > Improve handling of immediately failed physi

[jira] [Assigned] (FLINK-20591) Remove JobManagerOptions.SCHEDULING_STRATEGY

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20591: -- Assignee: Robert Metzger > Remove JobManagerOptions.SCHEDULING_STRATEGY > ---

[GitHub] [flink] flinkbot commented on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot commented on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744503895 ## CI report: * 6ea39ec0119663f4641aa5ae4074efa5d7a34322 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14346: [FLINK-20354] Rework standalone docs pages

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

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 6d0f9c6a32d65c82e657cfcab048a98aa4445429 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-20584) Document: Streaming File Sink - ORC Format, example of Scala, file is empty after being written

2020-12-14 Thread lundong he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249028#comment-17249028 ] lundong he commented on FLINK-20584: I have fixed this problem and created a pull re

[GitHub] [flink] flinkbot commented on pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
flinkbot commented on pull request #14381: URL: https://github.com/apache/flink/pull/14381#issuecomment-744496137 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

[jira] [Updated] (FLINK-20588) Add docker-compose as appendix to Mesos documentation

2020-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20588: --- Labels: pull-request-available (was: ) > Add docker-compose as appendix to Mesos documentat

[GitHub] [flink] XComp opened a new pull request #14381: [FLINK-20588] Added resource files for deploying a Flink on Mesos cluster locally.

2020-12-14 Thread GitBox
XComp opened a new pull request #14381: URL: https://github.com/apache/flink/pull/14381 ## What is the purpose of the change The configuration files enable the user to run Flink on Mesos locally. ## Brief change log The Mesos documentation was appended. ## Ver

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 9f3deb69af6892fc676aa87e1d1b55981eded305 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-20593) Remove EagerSchedulingStrategy

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20593: -- Assignee: Robert Metzger > Remove EagerSchedulingStrategy > -

[jira] [Updated] (FLINK-20541) ClusterID is not used in the method!

2020-12-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20541: - Fix Version/s: (was: 1.11.3) > ClusterID is not used in the method! > --

[jira] [Assigned] (FLINK-20592) Remove LazyFromSourcesSchedulingStrategy

2020-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20592: -- Assignee: Robert Metzger > Remove LazyFromSourcesSchedulingStrategy > ---

[GitHub] [flink] wenlong88 commented on a change in pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
wenlong88 commented on a change in pull request #14380: URL: https://github.com/apache/flink/pull/14380#discussion_r542417579 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMultipleInput.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14360: [FLINK-20509][table-planner-blink] Refactor verifyPlan method in TableTestBase

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14360: URL: https://github.com/apache/flink/pull/14360#issuecomment-742794536 ## CI report: * 98ab7e587e5e25f0dfdcfd7f0d59b812b4ad8606 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14346: [FLINK-20354] Rework standalone docs pages

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

[GitHub] [flink] flinkbot edited a comment on pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

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

[jira] [Comment Edited] (FLINK-19656) Automatically replace delimiter in metric name components

2020-12-14 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249007#comment-17249007 ] Etienne Chauchot edited comment on FLINK-19656 at 12/14/20, 2:03 PM: -

[jira] [Commented] (FLINK-19656) Automatically replace delimiter in metric name components

2020-12-14 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249007#comment-17249007 ] Etienne Chauchot commented on FLINK-19656: -- Hi [~chesnay], thanks for your answ

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * 6b2d6e05fdbd4b579c68007e5001bd1cabe1dd7b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14380: [FLINK-20515][table-planner-blink] Separate the implementation of BatchExecMultipleInput and StreamExecMultipleInput

2020-12-14 Thread GitBox
flinkbot edited a comment on pull request #14380: URL: https://github.com/apache/flink/pull/14380#issuecomment-73572 ## CI report: * 2d5ac91ee373efed1ede7da63abbfdbbfb60aabf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14379: [FLINK-20563][hive] Support built-in functions for Hive versions prio…

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

  1   2   3   >