[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

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

[jira] [Closed] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-19816. - Resolution: Fixed Fixed via 1.12.0: cb850fdda2b40866f3b0782e038ae4bce35c9eb0 1.11.3: a2925a0d2e

[GitHub] [flink] tillrohrmann closed pull request #14100: [BP-1.11][FLINK-19816] Make job state cleanup dependent on final job result

2020-11-18 Thread GitBox
tillrohrmann closed pull request #14100: URL: https://github.com/apache/flink/pull/14100 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

[GitHub] [flink] tillrohrmann commented on pull request #14100: [BP-1.11][FLINK-19816] Make job state cleanup dependent on final job result

2020-11-18 Thread GitBox
tillrohrmann commented on pull request #14100: URL: https://github.com/apache/flink/pull/14100#issuecomment-729506536 Manually merged via a2925a0d2e894bf28aaced2993ec453589d143de This is an automated message from the Apache G

[GitHub] [flink] flinkbot edited a comment on pull request #14108: [FLINK-20183][python] Fix the default PYTHONPATH is overwritten in client side

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14108: URL: https://github.com/apache/flink/pull/14108#issuecomment-729368144 ## CI report: * 90d6ba76b1efb64f7dd9949f5bbbe027185636bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14112: [FLINK-20207][python] improve the error message printed when submitting the pyflink jobs via 'flink run'.

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14112: URL: https://github.com/apache/flink/pull/14112#issuecomment-729496292 ## CI report: * 61e1b28fc13ad5ddc3b7898f4f79d1905c6e145b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14113: [FLINK-20202][python] Add the Check of Unsupported Result Type in Pandas UDAF

2020-11-18 Thread GitBox
flinkbot commented on pull request #14113: URL: https://github.com/apache/flink/pull/14113#issuecomment-729508037 ## CI report: * 9bd25bd7728f8097a45b11b0a871a13277c92c9f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-6984) Do not recover CompletedCheckpointStore on every restore

2020-11-18 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-6984: -- Fix Version/s: 1.12.0 > Do not recover CompletedCheckpointStore on every restore >

[jira] [Closed] (FLINK-6984) Do not recover CompletedCheckpointStore on every restore

2020-11-18 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-6984. - Resolution: Duplicate Resoloved in FLINK-19596. > Do not recover CompletedCheckpointStore on every resto

[GitHub] [flink] JingsongLi merged pull request #14097: [FLINK-20028][table-planner-blink] FileCompactionITCase is unstable

2020-11-18 Thread GitBox
JingsongLi merged pull request #14097: URL: https://github.com/apache/flink/pull/14097 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-20028) FileCompactionITCase is unstable

2020-11-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234352#comment-17234352 ] Jingsong Lee commented on FLINK-20028: -- master (1.12): 2465b7150301a114c36ff07b098e

[jira] [Closed] (FLINK-20028) FileCompactionITCase is unstable

2020-11-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20028. Resolution: Fixed > FileCompactionITCase is unstable > > >

[GitHub] [flink] dianfu closed pull request #14108: [FLINK-20183][python] Fix the default PYTHONPATH is overwritten in client side

2020-11-18 Thread GitBox
dianfu closed pull request #14108: URL: https://github.com/apache/flink/pull/14108 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] wuchong commented on pull request #12998: [FLINK-18731][table-planner-blink] Fix monotonicity logic of UNIX_TIMESTAMP & UUID functions

2020-11-18 Thread GitBox
wuchong commented on pull request #12998: URL: https://github.com/apache/flink/pull/12998#issuecomment-729519905 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #12998: [FLINK-18731][table-planner-blink] Fix monotonicity logic of UNIX_TIMESTAMP & UUID functions

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

[GitHub] [flink] godfreyhe commented on pull request #12998: [FLINK-18731][table-planner-blink] Fix monotonicity logic of UNIX_TIMESTAMP & UUID functions

2020-11-18 Thread GitBox
godfreyhe commented on pull request #12998: URL: https://github.com/apache/flink/pull/12998#issuecomment-729521417 my private azure is green https://dev.azure.com/godfreyhe/godfreyhe-flink/_build/results?buildId=74&view=results -

[GitHub] [flink] wuchong commented on a change in pull request #13933: [FLINK-19946][Connectors / HBase]Support sink parallelism configuration for Hbase connector

2020-11-18 Thread GitBox
wuchong commented on a change in pull request #13933: URL: https://github.com/apache/flink/pull/13933#discussion_r525896588 ## File path: docs/dev/table/connectors/hbase.md ## @@ -162,6 +162,13 @@ Connector Options can be set to '0' with the flush interval set allowing f

[jira] [Assigned] (FLINK-20197) FileSink fails with UnsupportedOperationException when using default values

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20197: Assignee: Yun Gao > FileSink fails with UnsupportedOperationException when using

[GitHub] [flink] wuchong closed pull request #12998: [FLINK-18731][table-planner-blink] Fix monotonicity logic of UNIX_TIMESTAMP & UUID functions

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

[jira] [Closed] (FLINK-18731) The monotonicity of UNIX_TIMESTAMP function is not correct

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18731. --- Resolution: Fixed Fixed in master (1.12.0): - 8c301ba850d2ddc11a59802e4b916a9dcd8b42d9 - 60906fa9c3217c4f3

[GitHub] [flink] twalthr commented on pull request #14106: [FLINK-17424][e2e] Adopt download strategy of Kafka tests in Elasticsearch tests

2020-11-18 Thread GitBox
twalthr commented on pull request #14106: URL: https://github.com/apache/flink/pull/14106#issuecomment-729523679 Thanks @leonardBang. I removed the version as a parameter. I will merge this if there are no objections. This i

[jira] [Assigned] (FLINK-20183) Fix the default PYTHONPATH is overwritten in client side

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20183: --- Assignee: Huang Xingbo > Fix the default PYTHONPATH is overwritten in client side > ---

[jira] [Updated] (FLINK-20183) Fix the default PYTHONPATH is overwritten in client side

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20183: Affects Version/s: 1.10.0 > Fix the default PYTHONPATH is overwritten in client side > ---

[jira] [Closed] (FLINK-20183) Fix the default PYTHONPATH is overwritten in client side

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20183. --- Fix Version/s: 1.11.3 1.10.3 1.12.0 Resolution: Fixed Fixed in

[GitHub] [flink] flinkbot edited a comment on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728845125 ## CI report: * 870375c22611f70c998db671632c6484552b0488 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14113: [FLINK-20202][python] Add the Check of Unsupported Result Type in Pandas UDAF

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14113: URL: https://github.com/apache/flink/pull/14113#issuecomment-729508037 ## CI report: * 9bd25bd7728f8097a45b11b0a871a13277c92c9f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19979) Sanity check after bash e2e tests for no leftover processes

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234365#comment-17234365 ] Robert Metzger commented on FLINK-19979: The common pattern seems that this acti

[GitHub] [flink] wuchong commented on pull request #14080: [FLINK-19996][e2e] Add end-to-end IT case for Debezium + Kafka + temporal join

2020-11-18 Thread GitBox
wuchong commented on pull request #14080: URL: https://github.com/apache/flink/pull/14080#issuecomment-729527918 As discussed offline, let's move this tests to IT cases. This is an automated message from the Apache Git Servi

[GitHub] [flink] wuchong merged pull request #14102: [FLINK-19635][hbase] Fix HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-11-18 Thread GitBox
wuchong merged pull request #14102: URL: https://github.com/apache/flink/pull/14102 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18712: --- Fix Version/s: (was: 1.12.0) > Flink RocksDB statebackend memory leak issue > -

[jira] [Closed] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19635. --- Resolution: Fixed Fixed in master (1.12.0): 7ae2be5167b4b143d3aaef2b9bc58faadc2d3a26 > HBaseConnectorITCase

[jira] [Updated] (FLINK-20170) json deserialize decimal loses precision

2020-11-18 Thread Mulan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mulan updated FLINK-20170: -- Attachment: image-2020-11-18-16-51-35-317.png > json deserialize decimal loses precision > ---

[jira] [Created] (FLINK-20210) "RequestFactory" interface in flink elasticsearch connector doesn't support "routing" param

2020-11-18 Thread Oneway Chen (Jira)
Oneway Chen created FLINK-20210: --- Summary: "RequestFactory" interface in flink elasticsearch connector doesn't support "routing" param Key: FLINK-20210 URL: https://issues.apache.org/jira/browse/FLINK-20210

[jira] [Created] (FLINK-20209) Add missing checkpoint configuration to Flink UI

2020-11-18 Thread Peidian Li (Jira)
Peidian Li created FLINK-20209: -- Summary: Add missing checkpoint configuration to Flink UI Key: FLINK-20209 URL: https://issues.apache.org/jira/browse/FLINK-20209 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-20170) json deserialize decimal loses precision

2020-11-18 Thread Mulan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234378#comment-17234378 ] Mulan commented on FLINK-20170: --- I try out this in 1.11 version using new field 'connector

[jira] [Updated] (FLINK-20209) Add missing checkpoint configuration to Flink UI

2020-11-18 Thread Peidian Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peidian Li updated FLINK-20209: --- Description: Some of the [checkpointing configurations|https://ci.apache.org/projects/flink/flink-d

[GitHub] [flink] flinkbot edited a comment on pull request #13933: [FLINK-19946][Connectors / HBase]Support sink parallelism configuration for Hbase connector

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

[jira] [Updated] (FLINK-20209) Add missing checkpoint configuration to Flink UI

2020-11-18 Thread Peidian Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peidian Li updated FLINK-20209: --- Attachment: image-2020-11-18-16-54-31-638.png > Add missing checkpoint configuration to Flink UI > -

[GitHub] [flink] flinkbot edited a comment on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728845125 ## CI report: * 870375c22611f70c998db671632c6484552b0488 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14106: [FLINK-17424][e2e] Adopt download strategy of Kafka tests in Elasticsearch tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #14111: [FLINK-20191][document] Add documents for FLIP-95 ability interfaces

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14111: URL: https://github.com/apache/flink/pull/14111#issuecomment-729488072 ## CI report: * 94088ed1b38fec47e5e43d7d399021003a1b7482 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dianfu commented on a change in pull request #14113: [FLINK-20202][python] Add the Check of Unsupported Result Type in Pandas UDAF

2020-11-18 Thread GitBox
dianfu commented on a change in pull request #14113: URL: https://github.com/apache/flink/pull/14113#discussion_r525912705 ## File path: docs/dev/python/table-api-users-guide/udfs/vectorized_python_udfs.md ## @@ -66,6 +66,7 @@ table_env.sql_query("SELECT add(bigint, bigint) FRO

[jira] [Assigned] (FLINK-20202) Add the Check of Unsupported Result Type in Pandas UDAF

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20202: --- Assignee: Huang Xingbo > Add the Check of Unsupported Result Type in Pandas UDAF >

[jira] [Updated] (FLINK-20202) Add check of unsupported result type in Pandas UDAF

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20202: Summary: Add check of unsupported result type in Pandas UDAF (was: Add the Check of Unsupported Result Ty

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2020-11-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234402#comment-17234402 ] Yang Wang commented on FLINK-17196: --- I have to revive this ticket again. Because curre

[jira] [Created] (FLINK-20211) Can not get the JobManager web ip according to the document

2020-11-18 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20211: - Summary: Can not get the JobManager web ip according to the document Key: FLINK-20211 URL: https://issues.apache.org/jira/browse/FLINK-20211 Project: Flink Issue

[jira] [Updated] (FLINK-20211) Can not get the JobManager web ip according to the document

2020-11-18 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20211: -- Description: According to [https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deploymen

[GitHub] [flink] aljoscha opened a new pull request #14114: [FLINK-20153] Add documentation for BATCH execution mode

2020-11-18 Thread GitBox
aljoscha opened a new pull request #14114: URL: https://github.com/apache/flink/pull/14114 This adds documentation for the new `BATCH` execution mode. We also explain `STREAMING` execution mode because there is no central page that explains the basic behavior, so far. ## Does this p

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

2020-11-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10954: - Fix Version/s: (was: 1.12.0) 1.13.0 > Hardlink from files of previous local store

[jira] [Updated] (FLINK-20153) Add documentation for BATCH execution mode

2020-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20153: --- Labels: pull-request-available (was: ) > Add documentation for BATCH execution mode > -

[jira] [Comment Edited] (FLINK-18121) Support creating Docker image from local Flink distribution

2020-11-18 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234342#comment-17234342 ] Guowei Ma edited comment on FLINK-18121 at 11/18/20, 9:13 AM:

[GitHub] [flink] wuchong closed pull request #14074: [FLINK-20129][table ecosystem] Create a zh download page for all optional sql client components

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

[jira] [Closed] (FLINK-20129) Create a zh download page for all optional sql client components

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20129. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master (1.12.0): d950bbd898caf39e87bab200633cfe4ab88

[GitHub] [flink] flinkbot commented on pull request #14114: [FLINK-20153] Add documentation for BATCH execution mode

2020-11-18 Thread GitBox
flinkbot commented on pull request #14114: URL: https://github.com/apache/flink/pull/14114#issuecomment-729545405 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 #13884: [FLINK-19921][runtime] Remove legacy restart strategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #13933: [FLINK-19946][Connectors / HBase]Support sink parallelism configuration for Hbase connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #14106: [FLINK-17424][e2e] Adopt download strategy of Kafka tests in Elasticsearch tests

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

[jira] [Assigned] (FLINK-20207) Improve the error message printed when submitting the pyflink jobs via 'flink run'

2020-11-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20207: --- Assignee: Wei Zhong > Improve the error message printed when submitting the pyflink jobs via 'flink

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234412#comment-17234412 ] Till Rohrmann commented on FLINK-19461: --- Should we maybe fail if we see an unrecog

[GitHub] [flink] kl0u closed pull request #14082: [FLINK-20143][yarn] Support non-qualified path for Yarn shared lib

2020-11-18 Thread GitBox
kl0u closed pull request #14082: URL: https://github.com/apache/flink/pull/14082 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 the

[jira] [Commented] (FLINK-20211) Can not get the JobManager web ip according to the document

2020-11-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234413#comment-17234413 ] Yang Wang commented on FLINK-20211: --- Nice catch. I think it should be {{kubectl get se

[GitHub] [flink-web] wuchong merged pull request #393: [FLINK-20129] Link to zh SQL components download page

2020-11-18 Thread GitBox
wuchong merged pull request #393: URL: https://github.com/apache/flink-web/pull/393 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Comment Edited] (FLINK-20129) Create a zh download page for all optional sql client components

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234410#comment-17234410 ] Jark Wu edited comment on FLINK-20129 at 11/18/20, 9:27 AM:

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234415#comment-17234415 ] Robert Metzger commented on FLINK-19461: Yes, I believe this is a helpful improv

[jira] [Commented] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234416#comment-17234416 ] Till Rohrmann commented on FLINK-18785: --- I think there is not much we can do about

[jira] [Closed] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18785. - Fix Version/s: (was: 1.11.4) (was: 1.10.3) (was

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234418#comment-17234418 ] Till Rohrmann commented on FLINK-19461: --- I think we are still using the same libra

[GitHub] [flink] rkhachatryan commented on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

2020-11-18 Thread GitBox
rkhachatryan commented on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-729554352 Thanks for merging! > Known channels are fully initialized including state persister in task thread before being passed to network thread Before this PR, the f

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234420#comment-17234420 ] Till Rohrmann commented on FLINK-19461: --- Do you wanna create a ticket for this pro

[GitHub] [flink] alpinegizmo commented on a change in pull request #14114: [FLINK-20153] Add documentation for BATCH execution mode

2020-11-18 Thread GitBox
alpinegizmo commented on a change in pull request #14114: URL: https://github.com/apache/flink/pull/14114#discussion_r525933950 ## File path: docs/dev/datastream_execution_mode.md ## @@ -0,0 +1,242 @@ +--- +title: "Execution Mode (Batch/Streaming)" +nav-id: datastream_execution

[jira] [Created] (FLINK-20212) Fail command line interfaces when provided with an unrecognized option

2020-11-18 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20212: -- Summary: Fail command line interfaces when provided with an unrecognized option Key: FLINK-20212 URL: https://issues.apache.org/jira/browse/FLINK-20212 Project:

[GitHub] [flink] leitsiang opened a new pull request #14115: [hotfix][docs] fix table systemFunction lag description.

2020-11-18 Thread GitBox
leitsiang opened a new pull request #14115: URL: https://github.com/apache/flink/pull/14115 ## What is the purpose of the change In systemFunctions.md and systemFunctions.zh.md function lag's description should "Returns the value of expression at the offsetth row **before** t

[GitHub] [flink-docker] tillrohrmann commented on a change in pull request #43: [FLINK-19125] Adopt Jemalloc as default memory allocator to avoid memory leak

2020-11-18 Thread GitBox
tillrohrmann commented on a change in pull request #43: URL: https://github.com/apache/flink-docker/pull/43#discussion_r525944915 ## File path: docker-entrypoint.sh ## @@ -93,21 +94,41 @@ prepare_job_manager_start() { envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "$

[GitHub] [flink-docker] tillrohrmann commented on a change in pull request #43: [FLINK-19125] Adopt Jemalloc as default memory allocator to avoid memory leak

2020-11-18 Thread GitBox
tillrohrmann commented on a change in pull request #43: URL: https://github.com/apache/flink-docker/pull/43#discussion_r525945766 ## File path: docker-entrypoint.sh ## @@ -93,21 +94,41 @@ prepare_job_manager_start() { envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "$

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234425#comment-17234425 ] Robert Metzger commented on FLINK-19461: I filed FLINK-20212 for it. Since it's

[GitHub] [flink] flinkbot commented on pull request #14115: [hotfix][docs] fix table systemFunction lag description.

2020-11-18 Thread GitBox
flinkbot commented on pull request #14115: URL: https://github.com/apache/flink/pull/14115#issuecomment-729560791 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-20213) Partition commit is delayed when records keep coming

2020-11-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20213: - Fix Version/s: 1.11.3 > Partition commit is delayed when records keep coming > -

[jira] [Created] (FLINK-20213) Partition commit is delayed when records keep coming

2020-11-18 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-20213: Summary: Partition commit is delayed when records keep coming Key: FLINK-20213 URL: https://issues.apache.org/jira/browse/FLINK-20213 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment on pull request #13884: [FLINK-19921][runtime] Remove legacy restart strategy

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

[jira] [Commented] (FLINK-20209) Add missing checkpoint configuration to Flink UI

2020-11-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234435#comment-17234435 ] Yun Tang commented on FLINK-20209: -- The information of 'unalignedCheckpoints' has been

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

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

[jira] [Created] (FLINK-20214) Unnecessary warning log when starting a k8s session cluster

2020-11-18 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20214: - Summary: Unnecessary warning log when starting a k8s session cluster Key: FLINK-20214 URL: https://issues.apache.org/jira/browse/FLINK-20214 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #14114: [FLINK-20153] Add documentation for BATCH execution mode

2020-11-18 Thread GitBox
flinkbot commented on pull request #14114: URL: https://github.com/apache/flink/pull/14114#issuecomment-729567248 ## CI report: * 70975eba381f72d59bfefd5d5b344e79121e09db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-20213) Partition commit is delayed when records keep coming

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20213: Component/s: Table SQL / Ecosystem > Partition commit is delayed when records keep coming > --

[jira] [Updated] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

2020-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-16057: -- Fix Version/s: 1.12.0 > Performance regression in ContinuousFileReaderOperator > -

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

2020-11-18 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234445#comment-17234445 ] Suhan Mao commented on FLINK-18202: --- [~twalthr] Sure. It will be an honor to contribut

[jira] [Closed] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

2020-11-18 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20143. -- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed master: 424d41d124871

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * 517b53a68f3e9c8c0897cd7afba90b8a9befaa4f Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13882: [FLINK-19919][runtime] Remove legacy scheduling in ExecutionGraph components

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

[GitHub] [flink] flinkbot edited a comment on pull request #13883: [FLINK-19920][runtime] Remove legacy failover strategy

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #13883: URL: https://github.com/apache/flink/pull/13883#issuecomment-720449982 ## CI report: * 598917cee8c1482777d6c3f513d9a09d5acadacf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14114: [FLINK-20153] Add documentation for BATCH execution mode

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14114: URL: https://github.com/apache/flink/pull/14114#issuecomment-729567248 ## CI report: * 70975eba381f72d59bfefd5d5b344e79121e09db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20170) json deserialize decimal loses precision

2020-11-18 Thread CaoZhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234455#comment-17234455 ] CaoZhen commented on FLINK-20170: - hi all, I've had this problem too. I think the probl

[jira] [Comment Edited] (FLINK-20170) json deserialize decimal loses precision

2020-11-18 Thread CaoZhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234455#comment-17234455 ] CaoZhen edited comment on FLINK-20170 at 11/18/20, 10:16 AM: -

[GitHub] [flink-docker] Myasuka commented on a change in pull request #43: [FLINK-19125] Adopt Jemalloc as default memory allocator to avoid memory leak

2020-11-18 Thread GitBox
Myasuka commented on a change in pull request #43: URL: https://github.com/apache/flink-docker/pull/43#discussion_r525968923 ## File path: docker-entrypoint.sh ## @@ -93,21 +94,41 @@ prepare_job_manager_start() { envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF

[GitHub] [flink] flinkbot commented on pull request #14115: [hotfix][docs] fix table systemFunction lag description.

2020-11-18 Thread GitBox
flinkbot commented on pull request #14115: URL: https://github.com/apache/flink/pull/14115#issuecomment-729579954 ## CI report: * 46a1adc285805e0b6254598dbe7f3f629211166e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] dawidwys commented on a change in pull request #14114: [FLINK-20153] Add documentation for BATCH execution mode

2020-11-18 Thread GitBox
dawidwys commented on a change in pull request #14114: URL: https://github.com/apache/flink/pull/14114#discussion_r525965548 ## File path: docs/dev/datastream_execution_mode.md ## @@ -0,0 +1,242 @@ +--- +title: "Execution Mode (Batch/Streaming)" +nav-id: datastream_execution_mo

[GitHub] [flink] wuchong commented on pull request #14110: [FLINK-20200][table-planner] SQL Hints are not supported in CREATE VI…

2020-11-18 Thread GitBox
wuchong commented on pull request #14110: URL: https://github.com/apache/flink/pull/14110#issuecomment-729583905 @danny0405 could you help to open a pull request for release-1.11 branch? I think this problem also exists in 1.11. ---

[GitHub] [flink] wuchong commented on pull request #14110: [FLINK-20200][table-planner] SQL Hints are not supported in CREATE VI…

2020-11-18 Thread GitBox
wuchong commented on pull request #14110: URL: https://github.com/apache/flink/pull/14110#issuecomment-729584307 Build is passed: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=9732&view=results This

[jira] [Updated] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

2020-11-18 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20203: -- Component/s: Deployment / Kubernetes > Could not find any document about how to build a Flink image fr

  1   2   3   4   5   >