[GitHub] [flink] flinkbot commented on pull request #14120: [FLINK-19984][core] Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

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

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234562#comment-17234562 ] Aljoscha Krettek commented on FLINK-20115: -- I initially wanted to have the disc

[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=17234563#comment-17234563 ] CaoZhen commented on FLINK-20170: - Can I try to fix this problem after having a plan? >

[jira] [Updated] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17159: - Fix Version/s: (was: 1.11.3) > ES6 ElasticsearchSinkITCase unstable > --

[jira] [Closed] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17159. Resolution: Fixed This is hopefully fixed by switching to use testcontainers for the ES i

[GitHub] [flink] aljoscha closed pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-18 Thread GitBox
aljoscha closed pull request #14096: URL: https://github.com/apache/flink/pull/14096 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] aljoscha commented on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-18 Thread GitBox
aljoscha commented on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-729647353 Merged! This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

2020-11-18 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234572#comment-17234572 ] Kostas Kloudas commented on FLINK-20115: Of course we can add it if we think tha

[GitHub] [flink] lirui-apache commented on a change in pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

2020-11-18 Thread GitBox
lirui-apache commented on a change in pull request #13998: URL: https://github.com/apache/flink/pull/13998#discussion_r526058826 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ContinuousHiveSplitEnumerator.java ## @@ -158,12

[GitHub] [flink] flinkbot edited a comment on pull request #14098: [FLINK-17049][table-planner-blink] Support casting of rows

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

[GitHub] [flink] flinkbot edited a comment on pull request #14099: [Flink-20190][API/DataStream]A New Window Trigger that can trigger window operation both by event time interval、event count

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #14099: URL: https://github.com/apache/flink/pull/14099#issuecomment-728904723 ## CI report: * 08f1d98c193fb11a0a38fc86157ab07dc597d73a 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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14119: [FLINK-20165] Update test docker image & improve YARN logging

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

[GitHub] [flink] flinkbot edited a comment on pull request #14120: [FLINK-19984][core] Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTe

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

[GitHub] [flink] zodo opened a new pull request #14121: [FLINK-20158][connectors/kafka] Add ResultTypeQueryable interface to …

2020-11-18 Thread GitBox
zodo opened a new pull request #14121: URL: https://github.com/apache/flink/pull/14121 ## What is the purpose of the change Allow the DataStream API to get the return type directly from the `KafkaSource`, without specifying `.returns(...)`. ## Brief change log - `Ka

[jira] [Updated] (FLINK-20158) KafkaSource does not implement ResultTypeQueryable

2020-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20158: --- Labels: pull-request-available (was: ) > KafkaSource does not implement ResultTypeQueryable

[GitHub] [flink] flinkbot commented on pull request #14121: [FLINK-20158][connectors/kafka] Add ResultTypeQueryable interface to …

2020-11-18 Thread GitBox
flinkbot commented on pull request #14121: URL: https://github.com/apache/flink/pull/14121#issuecomment-729661080 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-20098) Don't add flink-connector-files to flink-dist

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20098: --- Priority: Critical (was: Major) > Don't add flink-connector-files to flink-dist > -

[jira] [Created] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-18 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20220: -- Summary: DataSet.collect() uses TaskExecutionState for transferring user-payload Key: FLINK-20220 URL: https://issues.apache.org/jira/browse/FLINK-20220 Project:

[jira] [Updated] (FLINK-20098) Don't add flink-connector-files to flink-dist, make dependencies explicit

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20098: - Summary: Don't add flink-connector-files to flink-dist, make dependencies explicit (was

[jira] [Commented] (FLINK-20124) Test pipelined region scheduler

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234605#comment-17234605 ] Robert Metzger commented on FLINK-20124: Found a problem with DataSet.collect();

[GitHub] [flink] flinkbot edited a comment on pull request #13291: [FLINK-18988][table] Continuous query with LATERAL and LIMIT produces…

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

[GitHub] [flink] aljoscha opened a new pull request #14122: [FLINK-20098] Don't add flink-connector-files to flink-dist, make dependencies explicit

2020-11-18 Thread GitBox
aljoscha opened a new pull request #14122: URL: https://github.com/apache/flink/pull/14122 [FLINK-20098] Don't add flink-connector-files to flink-dist, make dependencies explicit We currently add both flink-connector-files and flink-connector-base to flink-dist. This implie

[GitHub] [flink] aljoscha commented on pull request #14122: [FLINK-20098] Don't add flink-connector-files to flink-dist, make dependencies explicit

2020-11-18 Thread GitBox
aljoscha commented on pull request #14122: URL: https://github.com/apache/flink/pull/14122#issuecomment-729672038 Second time might work. 😅 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on pull request #14122: [FLINK-20098] Don't add flink-connector-files to flink-dist, make dependencies explicit

2020-11-18 Thread GitBox
flinkbot commented on pull request #14122: URL: https://github.com/apache/flink/pull/14122#issuecomment-729672078 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 #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: * 7bd218f99c49a08cc83bb39f8fbf199947ed117a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14098: [FLINK-17049][table-planner-blink] Support casting of rows

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

[GitHub] [flink] flinkbot edited a comment on pull request #14099: [Flink-20190][API/DataStream]A New Window Trigger that can trigger window operation both by event time interval、event count

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

[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: * 0c28ec6e3b331f9fc367b910a63a3c9dc3edbd02 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14121: [FLINK-20158][connectors/kafka] Add ResultTypeQueryable interface to …

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

[jira] [Created] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-18 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-20221: -- Summary: DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss Key: FLINK-20221 URL: https://issues.apache.org/jira/browse/FLINK-20221

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234617#comment-17234617 ] Aljoscha Krettek commented on FLINK-17470: -- This fails on my machine with {cod

[GitHub] [flink] dawidwys commented on a change in pull request #14098: [FLINK-17049][table-planner-blink] Support casting of rows

2020-11-18 Thread GitBox
dawidwys commented on a change in pull request #14098: URL: https://github.com/apache/flink/pull/14098#discussion_r526091834 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/RowTypeTest.scala ## @@ -142,14 +142,11 @@

[jira] [Created] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.

2020-11-18 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-20222: Summary: The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint. Key: FLINK-20222 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Assigned] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.

2020-11-18 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20222: Assignee: Stephan Ewen > The CheckpointCoordinator should reset the OperatorCoordinators

[GitHub] [flink] flinkbot edited a comment on pull request #13291: [FLINK-18988][table] Continuous query with LATERAL and LIMIT produces…

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

[GitHub] [flink] dufeng1010 commented on pull request #14086: [hotfix][docs]fix_docs_typo

2020-11-18 Thread GitBox
dufeng1010 commented on pull request #14086: URL: https://github.com/apache/flink/pull/14086#issuecomment-729686369 PTAL @wuchong This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Updated] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20222: --- Fix Version/s: 1.12.0 > The CheckpointCoordinator should reset the OperatorCoordinators when

[jira] [Updated] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20222: --- Priority: Critical (was: Major) > The CheckpointCoordinator should reset the OperatorCoordi

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234626#comment-17234626 ] Robert Metzger commented on FLINK-17470: Can you share more details on your envi

[GitHub] [flink] lirui-apache opened a new pull request #14123: [FLINK-19653][hive] Reduce our dependency on hive runner for tests

2020-11-18 Thread GitBox
lirui-apache opened a new pull request #14123: URL: https://github.com/apache/flink/pull/14123 ## What is the purpose of the change Reduce dependency on hive runner for tests, so that tests will be more stable and faster. Besides, tests with hive runner are difficult to debug

[jira] [Updated] (FLINK-19653) HiveCatalogITCase fails on azure

2020-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19653: --- Labels: pull-request-available test-stability (was: test-stability) > HiveCatalogITCase fai

[GitHub] [flink] flinkbot edited a comment on pull request #14099: [Flink-20190][API/DataStream]A New Window Trigger that can trigger window operation both by event time interval、event count

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

[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=17234629#comment-17234629 ] Robert Metzger commented on FLINK-19461: No. FLINK-20212 is about the command li

[GitHub] [flink] flinkbot edited a comment on pull request #14121: [FLINK-20158][connectors/kafka] Add ResultTypeQueryable interface to …

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

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234630#comment-17234630 ] Aljoscha Krettek commented on FLINK-17470: -- Ah sorry, yes. I'm running macOS Ca

[GitHub] [flink] flinkbot commented on pull request #14123: [FLINK-19653][hive] Reduce our dependency on hive runner for tests

2020-11-18 Thread GitBox
flinkbot commented on pull request #14123: URL: https://github.com/apache/flink/pull/14123#issuecomment-729689736 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 commented on pull request #14122: [FLINK-20098] Don't add flink-connector-files to flink-dist, make dependencies explicit

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

[jira] [Created] (FLINK-20223) The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader.

2020-11-18 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-20223: Summary: The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader. Key: FLINK-20223 URL: https://issues.apache.org/jira/browse

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

2020-11-18 Thread GitBox
twalthr closed pull request #14106: URL: https://github.com/apache/flink/pull/14106 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] [Assigned] (FLINK-20223) The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader.

2020-11-18 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20223: Fix Version/s: 1.12.0 Assignee: Jiangjie Qin Description: The {{RecreateOnR

[jira] [Closed] (FLINK-17424) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to download error

2020-11-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17424. Resolution: Fixed Fixed in 1.12.0: 71ef64f9afab3472f0372415c13f1bc2b14b00cc > SQL Client end-to-e

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234638#comment-17234638 ] Robert Metzger commented on FLINK-17470: Damn. Looks like I have "timeout" throu

[jira] [Reopened] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-17470: > Flink task executor process permanently hangs on `flink-daemon.sh stop`, > deletes PID file

[jira] [Assigned] (FLINK-20194) KafkaSourceFetcherManager.commitOffsets() should handle the case when there is no split fetcher.

2020-11-18 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20194: Assignee: Jiangjie Qin > KafkaSourceFetcherManager.commitOffsets() should handle the case

[GitHub] [flink] flinkbot edited a comment on pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #13998: URL: https://github.com/apache/flink/pull/13998#issuecomment-724001789 ## CI report: * 6beffeeaa6311b7d58dca3eea2d876ce03bbd816 Azure: [SUCCESS](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

[GitHub] [flink] flinkbot edited a comment on pull request #14122: [FLINK-20098] Don't add flink-connector-files to flink-dist, make dependencies explicit

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

[GitHub] [flink] flinkbot commented on pull request #14123: [FLINK-19653][hive] Reduce our dependency on hive runner for tests

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

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234681#comment-17234681 ] Roman Khachatryan commented on FLINK-19940: --- So it looks like this name is gen

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

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20170: --- Assignee: CaoZhen > json deserialize decimal loses precision >

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

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234682#comment-17234682 ] Jark Wu commented on FLINK-20170: - Assigned to you [~caozhen1937]. > json deserialize d

[GitHub] [flink] wuchong merged pull request #13933: [FLINK-19946][Connectors / HBase]Support sink parallelism configuration for Hbase connector

2020-11-18 Thread GitBox
wuchong merged pull request #13933: URL: https://github.com/apache/flink/pull/13933 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-19946) Support sink parallelism configuration to Hbase connector

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

[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: * 76d8fc44bd6f73200fd57f76cc3ebd64f176eb63 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

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

[GitHub] [flink] wuchong merged pull request #14086: [hotfix][docs]fix_docs_typo

2020-11-18 Thread GitBox
wuchong merged pull request #14086: URL: https://github.com/apache/flink/pull/14086 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] 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 #14123: [FLINK-19653][hive] Reduce our dependency on hive runner for tests

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

[jira] [Created] (FLINK-20224) add username&password to provide a credential for es rest client

2020-11-18 Thread jiang7chengzitc (Jira)
jiang7chengzitc created FLINK-20224: --- Summary: add username&password to provide a credential for es rest client Key: FLINK-20224 URL: https://issues.apache.org/jira/browse/FLINK-20224 Project: Flink

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234691#comment-17234691 ] Jark Wu commented on FLINK-19687: - Thanks [~twalthr]. I think {{attachToStream}} may not

[jira] [Assigned] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19687: --- Assignee: xiaozilong > Support to get execution plan in `StatementSet` > --

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234692#comment-17234692 ] Jark Wu commented on FLINK-19687: - Assigned this issue to you [~xiaozilong]. > Support

[GitHub] [flink] wuchong commented on pull request #14117: [BP-1.11][FLINK-20200][table-planner] Fix SQL Hints is not allowed in CREATE VIEW syntax

2020-11-18 Thread GitBox
wuchong commented on pull request #14117: URL: https://github.com/apache/flink/pull/14117#issuecomment-729736473 Build is passed: https://dev.azure.com/imjark/Flink/_build/results?buildId=332&view=results This is an automate

[GitHub] [flink] wuchong merged pull request #14117: [BP-1.11][FLINK-20200][table-planner] Fix SQL Hints is not allowed in CREATE VIEW syntax

2020-11-18 Thread GitBox
wuchong merged pull request #14117: URL: https://github.com/apache/flink/pull/14117 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-20200) SQL Hints are not supported in "Create View" syntax

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20200. --- Resolution: Fixed > SQL Hints are not supported in "Create View" syntax > -

[jira] [Comment Edited] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

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

[jira] [Updated] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20200: Fix Version/s: (was: 1.11.4) 1.11.3 > SQL Hints are not supported in "Create View"

[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: (was: Deployment / Kubernetes) Documentation > Could not find any do

[jira] [Created] (FLINK-20225) Break link in the document

2020-11-18 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20225: - Summary: Break link in the document Key: FLINK-20225 URL: https://issues.apache.org/jira/browse/FLINK-20225 Project: Flink Issue Type: Improvement Compon

[jira] [Updated] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

2020-11-18 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20215: -- Component/s: (was: Deployment / Kubernetes) Documentation > Keep the "Access the

[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: -- Component/s: (was: Deployment / Kubernetes) Documentation > Can not get the JobMa

[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: * deefe94f7e88be11ad13c0a54dc526cc01fd9783 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

2020-11-18 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234722#comment-17234722 ] Aljoscha Krettek commented on FLINK-20115: -- [~dwysakowicz] & [~kkl0u] I think T

[jira] [Closed] (FLINK-20224) add username&password to provide a credential for es rest client

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20224. --- Fix Version/s: (was: 1.11.3) Resolution: Duplicate > add username&password to provide a credentia

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234737#comment-17234737 ] Jark Wu commented on FLINK-19940: - Hi [~TsReaper], I think it would be easier to underst

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

2020-11-18 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234734#comment-17234734 ] Guowei Ma commented on FLINK-20113: --- I test four scenarios # Kubernetes ## Session C

[jira] [Commented] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

2020-11-18 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234754#comment-17234754 ] Yun Gao commented on FLINK-20208: - Hi [~trushev], very thanks for bringing this up, and

[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: * 7a31bb52f16f4da8af82b71aa903f00b70aaf590 Azure: [SUCCESS](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: * 48066f6023041f70d24b4724b757701f31e1f543 UNKNOWN * 0a6e76c9be744738d60158b3176ad8fc1a6bed37 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[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 * 021cac170ea26cddfd8af0a2bec5fea4e6a76b69 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: * b15be6a32e44adf7989dbf763821bb2ea7d7ad9a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

2020-11-18 Thread GitBox
flinkbot edited a comment on pull request #13900: URL: https://github.com/apache/flink/pull/13900#issuecomment-720989833 ## CI report: * d9e47451664a976692e4e6110bbffa2842f2ae7a UNKNOWN * a232820a4e31c675922a555e36e26b7084f6370c Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14116: [FLINK-20213][fs-connector] Partition commit is delayed when records keep coming

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

2020-11-18 Thread GitBox
rkhachatryan commented on a change in pull request #14052: URL: https://github.com/apache/flink/pull/14052#discussion_r526233564 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -506,43 +514,75 @@ pu

[GitHub] [flink] flinkbot edited a comment on pull request #14118: [FLINK-20165][1.11] Update test docker image & improve YARN logging

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

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

2020-11-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234827#comment-17234827 ] Till Rohrmann commented on FLINK-20115: --- [~kkl0u] are you creating a ticket for ad

[GitHub] [flink] twalthr closed pull request #14098: [FLINK-17049][table-planner-blink] Support casting of rows

2020-11-18 Thread GitBox
twalthr closed pull request #14098: URL: https://github.com/apache/flink/pull/14098 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-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_r526256830 ## File path: docker-entrypoint.sh ## @@ -93,21 +94,41 @@ prepare_job_manager_start() { envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "$

<    1   2   3   4   5   >