[jira] [Comment Edited] (FLINK-19419) "null-string-literal" does not work in HBaseSource decoder

2020-09-27 Thread CaoZhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202733#comment-17202733 ] CaoZhen edited comment on FLINK-19419 at 9/28/20, 6:48 AM: --- Bu

[jira] [Updated] (FLINK-17341) freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException

2020-09-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17341: -- Affects Version/s: 1.10.2 1.11.2 > freeSlot in TaskExecutor.closeJobMan

[jira] [Commented] (FLINK-17341) freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException

2020-09-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203034#comment-17203034 ] Till Rohrmann commented on FLINK-17341: --- Thanks for reporting this issue [~huwh].

[jira] [Updated] (FLINK-17341) freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException

2020-09-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17341: -- Fix Version/s: 1.11.3 1.10.3 1.12.0 > freeSlot in TaskEx

[GitHub] [flink] flinkbot edited a comment on pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

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

[jira] [Commented] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

2020-09-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203033#comment-17203033 ] Yun Gao commented on FLINK-18818: - The detailed exception of the error is attached in th

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

2020-09-27 Thread GitBox
JingsongLi commented on a change in pull request #13216: URL: https://github.com/apache/flink/pull/13216#discussion_r495718639 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java ## @@ -109,11 +109,27 @@ public static Dy

[jira] [Updated] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

2020-09-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18818: Attachment: image-2020-09-28-14-40-28-859.png > HadoopRenameCommitterHDFSTest.testCommitOneFile[Override:

[GitHub] [flink] JingsongLi commented on pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

2020-09-27 Thread GitBox
JingsongLi commented on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-699805304 CC: @lirui-apache This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

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

[GitHub] [flink-web] tzulitai closed pull request #379: [release] [statefun] Announcement post and downloads for Stateful Functions v2.2.0

2020-09-27 Thread GitBox
tzulitai closed pull request #379: URL: https://github.com/apache/flink-web/pull/379 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-19408) Update flink-statefun-docker release scripts for cross release Java 8 and 11

2020-09-27 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19408. --- Fix Version/s: (was: statefun-2.3.0) statefun-2.2.0 Res

[GitHub] [flink-statefun-docker] tzulitai merged pull request #8: [FLINK-19408] Update add-version.sh for cross-releasing Java 8 and 11

2020-09-27 Thread GitBox
tzulitai merged pull request #8: URL: https://github.com/apache/flink-statefun-docker/pull/8 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-statefun-docker] tzulitai merged pull request #10: [release] Add Dockerfiles for 2.2.0 release

2020-09-27 Thread GitBox
tzulitai merged pull request #10: URL: https://github.com/apache/flink-statefun-docker/pull/10 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Commented] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

2020-09-27 Thread Zhengchao Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203008#comment-17203008 ] Zhengchao Shi commented on FLINK-19432: --- But sometimes this will cause a lot of "-

[jira] [Closed] (FLINK-19417) Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19417. --- Resolution: Fixed master: 900071bb7a9073f67b8af1097ee858e59626593c > Fix the bug of the method from_data_st

[jira] [Updated] (FLINK-19417) Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19417: Affects Version/s: 1.12.0 > Fix the bug of the method from_data_stream in table_environement > ---

[GitHub] [flink] dianfu closed pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
dianfu closed pull request #13491: URL: https://github.com/apache/flink/pull/13491 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] flinkbot edited a comment on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * f998eecfa23b9ed74ac2eb95a4b390d8efb6d849 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-19416) Support Python datetime object in from_collection of Python DataStream

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202997#comment-17202997 ] Dian Fu commented on FLINK-19416: - [~nicholasjiang] Have assigned it to you. > Support

[jira] [Assigned] (FLINK-19416) Support Python datetime object in from_collection of Python DataStream

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19416: --- Assignee: Nicholas Jiang > Support Python datetime object in from_collection of Python DataStream >

[GitHub] [flink-web] tzulitai commented on pull request #379: [release] [statefun] Announcement post and downloads for Stateful Functions v2.2.0

2020-09-27 Thread GitBox
tzulitai commented on pull request #379: URL: https://github.com/apache/flink-web/pull/379#issuecomment-699761575 Thanks a lot for the review and corrections @morsapaes @alpinegizmo! I'm merging this now for the announcement along with your fixes. ---

[GitHub] [flink] flinkbot edited a comment on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

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

[GitHub] [flink] flinkbot commented on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-27 Thread GitBox
flinkbot commented on pull request #13495: URL: https://github.com/apache/flink/pull/13495#issuecomment-699753576 ## CI report: * b64812a0cb08a25ee0853c57230ffe12ccc9ceb3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

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

[GitHub] [flink] flinkbot commented on pull request #13495: [Test]Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-27 Thread GitBox
flinkbot commented on pull request #13495: URL: https://github.com/apache/flink/pull/13495#issuecomment-699750515 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] hehuiyuan opened a new pull request #13495: Fix case demo is more obvious to understand for ReinterpretAsKeyedStream

2020-09-27 Thread GitBox
hehuiyuan opened a new pull request #13495: URL: https://github.com/apache/flink/pull/13495 ## What is the purpose of the change To make case demo more obvious. Change ![image](https://user-images.githubusercontent.com/18002496/94387913-2567d180-017e-11eb-9adb-44e3167cc

[jira] [Commented] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

2020-09-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202984#comment-17202984 ] Benchao Li commented on FLINK-19432: [~tinny] IMHO, this may introduce some overhead

[GitHub] [flink] flinkbot commented on pull request #13494: [kafka connector]Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-27 Thread GitBox
flinkbot commented on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-699748753 ## CI report: * b139f0662c5c86ae97742c6dc6742aaef4f97a97 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

2020-09-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18112: - Description: This is the Jira ticket for Milestone One of [FLIP-135 Approximate Task-Local Recovery|htt

[jira] [Updated] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

2020-09-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18112: - Description: This is the Jira ticket for Milestone One of [FLIP-135 Approximate Task-Local Recovery|[ht

[GitHub] [flink] HuangXingBo commented on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

2020-09-27 Thread GitBox
HuangXingBo commented on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699746710 @dianfu The memory configuration shown in the python udf related documents is as follows `table_env.get_config().get_configuration().set_string("taskmanager.memory.task.

[GitHub] [flink] HuangXingBo commented on a change in pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

2020-09-27 Thread GitBox
HuangXingBo commented on a change in pull request #13492: URL: https://github.com/apache/flink/pull/13492#discussion_r495662360 ## File path: flink-python/src/main/java/org/apache/flink/python/PythonOptions.java ## @@ -156,7 +156,7 @@ */ public static final Con

[GitHub] [flink] flinkbot commented on pull request #13494: Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-27 Thread GitBox
flinkbot commented on pull request #13494: URL: https://github.com/apache/flink/pull/13494#issuecomment-699743921 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 #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * 20a9a58f2aa694681754572c716ee0b408484315 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * 5fb5255b9edc3cd74b836a89489a0a81591a514f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-18112) Approximate Task-Local Recovery -- Milestone One

2020-09-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18112: - Summary: Approximate Task-Local Recovery -- Milestone One (was: Approximate Task-Local Recovery) > App

[jira] [Updated] (FLINK-18112) Approximate Task-Local Recovery

2020-09-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18112: - Summary: Approximate Task-Local Recovery (was: Single Task Approximate Failure Recovery) > Approximate

[GitHub] [flink] hehuiyuan opened a new pull request #13494: Fix cast question for properies() method in kafka ConnectorDescriptor

2020-09-27 Thread GitBox
hehuiyuan opened a new pull request #13494: URL: https://github.com/apache/flink/pull/13494 ## What is the purpose of the change This pull resquest fixes Kafka connector. There is a cast problem when use properties method. ``` Properties props = new Properties();

[jira] [Updated] (FLINK-18112) Single Task Approximate Failure Recovery

2020-09-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18112: - Summary: Single Task Approximate Failure Recovery (was: Single Task Failure Recovery Prototype) > Sing

[GitHub] [flink] wangyang0918 commented on a change in pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

2020-09-27 Thread GitBox
wangyang0918 commented on a change in pull request #13322: URL: https://github.com/apache/flink/pull/13322#discussion_r495664630 ## File path: flink-end-to-end-tests/test-scripts/test_kubernetes_pyflink_application.sh ## @@ -0,0 +1,83 @@ +#!/usr/bin/env bash +#

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * 5fb5255b9edc3cd74b836a89489a0a81591a514f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

2020-09-27 Thread Kenzyme Le (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202969#comment-17202969 ] Kenzyme Le commented on FLINK-15578: Great! Thanks for the update. > Implement exac

[jira] [Commented] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

2020-09-27 Thread Zhengchao Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202968#comment-17202968 ] Zhengchao Shi commented on FLINK-19432: --- [~libenchao] What do you think about this

[GitHub] [flink] HuangXingBo commented on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
HuangXingBo commented on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699735286 @SteNicholas Thanks a lot for the update. LGTM. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

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

[jira] [Updated] (FLINK-19438) Queryable State needs to support both read-uncommitted and read-committed

2020-09-27 Thread sheep (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sheep updated FLINK-19438: -- Summary: Queryable State needs to support both read-uncommitted and read-committed (was: Queryable State nee

[jira] [Updated] (FLINK-19438) Queryable State need implement both read-uncommitted and read-committed

2020-09-27 Thread sheep (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sheep updated FLINK-19438: -- Summary: Queryable State need implement both read-uncommitted and read-committed (was: Queryable State need

[jira] [Created] (FLINK-19438) Queryable State need implement both read-uncommitted and read-committed

2020-09-27 Thread sheep (Jira)
sheep created FLINK-19438: - Summary: Queryable State need implement both read-uncommitted and read-committed Key: FLINK-19438 URL: https://issues.apache.org/jira/browse/FLINK-19438 Project: Flink Is

[GitHub] [flink] zhijiangW commented on pull request #13482: test

2020-09-27 Thread GitBox
zhijiangW commented on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-699733170 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * 20a9a58f2aa694681754572c716ee0b408484315 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-19416) Support Python datetime object in from_collection of Python DataStream

2020-09-27 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202951#comment-17202951 ] Huang Xingbo commented on FLINK-19416: -- [~nicholasjiang] Thanks a lot. [~dianfu] Co

[GitHub] [flink] dianfu commented on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
dianfu commented on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699719124 @SteNicholas Thanks for the update. LGTM. There are check style issues. Could you take a look at? This is an aut

[jira] [Updated] (FLINK-19437) FileSourceTextLinesITCase.testContinuousTextFileSource failed with "SimpleStreamFormat is not splittable, but found split end (0) different from file length (198)"

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19437: Labels: test-stability (was: ) > FileSourceTextLinesITCase.testContinuousTextFileSource failed with > "S

[jira] [Commented] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202949#comment-17202949 ] Dian Fu commented on FLINK-18818: - HadoopRenameCommitterHDFSTest.testCommitMultipleFiles

[jira] [Created] (FLINK-19437) FileSourceTextLinesITCase.testContinuousTextFileSource failed with "SimpleStreamFormat is not splittable, but found split end (0) different from file length (198)"

2020-09-27 Thread Dian Fu (Jira)
Dian Fu created FLINK-19437: --- Summary: FileSourceTextLinesITCase.testContinuousTextFileSource failed with "SimpleStreamFormat is not splittable, but found split end (0) different from file length (198)" Key: FLINK-19437

[jira] [Updated] (FLINK-19437) FileSourceTextLinesITCase.testContinuousTextFileSource failed with "SimpleStreamFormat is not splittable, but found split end (0) different from file length (198)"

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19437: Component/s: Tests > FileSourceTextLinesITCase.testContinuousTextFileSource failed with > "SimpleStreamFo

[jira] [Commented] (FLINK-19437) FileSourceTextLinesITCase.testContinuousTextFileSource failed with "SimpleStreamFormat is not splittable, but found split end (0) different from file length (198)"

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202948#comment-17202948 ] Dian Fu commented on FLINK-19437: - cc [~sewen] > FileSourceTextLinesITCase.testContinuo

[jira] [Updated] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19436: Labels: test-stability (was: ) > TPC-DS end-to-end test (Blink planner) failed during shutdown >

[jira] [Created] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

2020-09-27 Thread Dian Fu (Jira)
Dian Fu created FLINK-19436: --- Summary: TPC-DS end-to-end test (Blink planner) failed during shutdown Key: FLINK-19436 URL: https://issues.apache.org/jira/browse/FLINK-19436 Project: Flink Issue Ty

[jira] [Updated] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19436: Component/s: Tests > TPC-DS end-to-end test (Blink planner) failed during shutdown > -

[jira] [Updated] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19430: Affects Version/s: (was: 1.11.0) > Translate page 'datastream_tutorial' into Chinese > ---

[jira] [Commented] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202945#comment-17202945 ] Dian Fu commented on FLINK-19430: - [~hailong wang] Have assigned it to you. > Translate

[jira] [Assigned] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19430: --- Assignee: hailong wang > Translate page 'datastream_tutorial' into Chinese > --

[jira] [Assigned] (FLINK-19429) Translate page 'Data Types' into Chinese

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19429: --- Assignee: hailong wang > Translate page 'Data Types' into Chinese > ---

[jira] [Commented] (FLINK-19429) Translate page 'Data Types' into Chinese

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202944#comment-17202944 ] Dian Fu commented on FLINK-19429: - [~hailong wang] Thanks for working on this issue. I h

[jira] [Updated] (FLINK-19429) Translate page 'Data Types' into Chinese

2020-09-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19429: Affects Version/s: (was: 1.11.0) > Translate page 'Data Types' into Chinese >

[jira] [Commented] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-27 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202936#comment-17202936 ] Liu commented on FLINK-19409: - Hi, [~jark]. Please review the code. Thank you. > The commen

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

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

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

2020-09-27 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202915#comment-17202915 ] Roman Khachatryan commented on FLINK-15578: --- Hi [~klden], There no blockers,

[GitHub] [flink] flinkbot edited a comment on pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

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

[GitHub] [flink] flinkbot edited a comment on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * 20a9a58f2aa694681754572c716ee0b408484315 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 ## CI report: * 060bb38dd26df122e05fc232cd730b35717e84b0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13410: URL: https://github.com/apache/flink/pull/13410#issuecomment-694211098 ## CI report: * 69930ae1221864a5ccc986ac23c6010b76043759 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

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

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 ## CI report: * 060bb38dd26df122e05fc232cd730b35717e84b0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13410: URL: https://github.com/apache/flink/pull/13410#issuecomment-694211098 ## CI report: * 69930ae1221864a5ccc986ac23c6010b76043759 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Shawn-Hx commented on pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

2020-09-27 Thread GitBox
Shawn-Hx commented on pull request #13410: URL: https://github.com/apache/flink/pull/13410#issuecomment-699653704 Hi, @klion26 Thanks for your good suggestions ! I have make some changes according to your advice. Please take a look. --

[GitHub] [flink] flinkbot edited a comment on pull request #13493: [FLINK-19433] [docs] Correct example of FROM_UNIXTIME function in document

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

[GitHub] [flink] Shawn-Hx commented on a change in pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

2020-09-27 Thread GitBox
Shawn-Hx commented on a change in pull request #13410: URL: https://github.com/apache/flink/pull/13410#discussion_r495586969 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -23,90 +23,32 @@ specific language governing permissions and limitations under the License. --> +

[GitHub] [flink] flinkbot edited a comment on pull request #13482: test

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13482: URL: https://github.com/apache/flink/pull/13482#issuecomment-698903502 ## CI report: * 5fb5255b9edc3cd74b836a89489a0a81591a514f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * 994b24ac690a8ef806bd1f051fa14c22c76dda96 Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-19429) Translate page 'Data Types' into Chinese

2020-09-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202845#comment-17202845 ] hailong wang commented on FLINK-19429: -- Hi [~hequn8128] [~dianfu], Could you please

[jira] [Commented] (FLINK-19430) Translate page 'datastream_tutorial' into Chinese

2020-09-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202844#comment-17202844 ] hailong wang commented on FLINK-19430: -- Hi [~hequn8128] [~dianfu], Could you please

[jira] [Issue Comment Deleted] (FLINK-19429) Translate page 'Data Types' into Chinese

2020-09-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19429: - Comment: was deleted (was: I did not find the issue that deduplicate with it. If so, thank you f

[GitHub] [flink] flinkbot edited a comment on pull request #13493: [FLINK-19433] [docs] Correct example of FROM_UNIXTIME function in document

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

[jira] [Commented] (FLINK-19416) Support Python datetime object in from_collection of Python DataStream

2020-09-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202841#comment-17202841 ] Nicholas Jiang commented on FLINK-19416: [~hxbks2ks], if no one pick this issue,

[GitHub] [flink] klion26 commented on a change in pull request #13410: [FLINK-19247][docs-zh] Update Chinese documentation after removal of Kafka 0.10 and 0.11

2020-09-27 Thread GitBox
klion26 commented on a change in pull request #13410: URL: https://github.com/apache/flink/pull/13410#discussion_r495574668 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -23,90 +23,32 @@ specific language governing permissions and limitations under the License. --> +F

[GitHub] [flink] flinkbot commented on pull request #13493: [FLINK-19433] [docs] Correct example of FROM_UNIXTIME function in document

2020-09-27 Thread GitBox
flinkbot commented on pull request #13493: URL: https://github.com/apache/flink/pull/13493#issuecomment-699640495 ## CI report: * 18baa5ec57c9dd038aa04bf84b81488ece0bb220 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * 994b24ac690a8ef806bd1f051fa14c22c76dda96 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #13493: [FLINK-19433] [docs] Correct example of FROM_UNIXTIME function in document

2020-09-27 Thread GitBox
flinkbot commented on pull request #13493: URL: https://github.com/apache/flink/pull/13493#issuecomment-699637870 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-19433) An Error example of FROM_UNIXTIME function in document

2020-09-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19433: --- Labels: pull-request-available (was: ) > An Error example of FROM_UNIXTIME function in docu

[GitHub] [flink] secondChoice opened a new pull request #13493: [FLINK-19433] [docs] Correct example of FROM_UNIXTIME function in document

2020-09-27 Thread GitBox
secondChoice opened a new pull request #13493: URL: https://github.com/apache/flink/pull/13493 ## What is the purpose of the change Correct the example of FROM_UNIXTIME function in document ## Verifying this change This change is a trivial rework / code cleanup w

[GitHub] [flink] flinkbot edited a comment on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699620559 ## CI report: * 0131e7e07336c24798a7d3b6692807c93a96a42c UNKNOWN * 994b24ac690a8ef806bd1f051fa14c22c76dda96 Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Assigned] (FLINK-19433) An Error example of FROM_UNIXTIME function in document

2020-09-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-19433: -- Assignee: Kyle Zhang > An Error example of FROM_UNIXTIME function in document > -

[jira] [Commented] (FLINK-19433) An Error example of FROM_UNIXTIME function in document

2020-09-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202825#comment-17202825 ] Benchao Li commented on FLINK-19433: [~KyleZhang] Thanks for reporting this, assigne

[GitHub] [flink] SteNicholas commented on pull request #13491: [FLINK-19417][python] Fix the bug of the method from_data_stream in table_environement

2020-09-27 Thread GitBox
SteNicholas commented on pull request #13491: URL: https://github.com/apache/flink/pull/13491#issuecomment-699631774 @HuangXingBo @dianfu I have already followed up with your comments. Please review this again. This is an a

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

2020-09-27 Thread GitBox
flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * ad9145cd549c242e40862c8ce21cf52b06927f00 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

2020-09-27 Thread xiaodao (Jira)
xiaodao created FLINK-19435: --- Summary: jdbc JDBCOutputFormat open function invoke Class.forName(drivername) Key: FLINK-19435 URL: https://issues.apache.org/jira/browse/FLINK-19435 Project: Flink I

[jira] [Commented] (FLINK-19433) An Error example of FROM_UNIXTIME function in document

2020-09-27 Thread Kyle Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202818#comment-17202818 ] Kyle Zhang commented on FLINK-19433: Hi [~libenchao], if you are watching is issue, 

  1   2   >