[jira] [Updated] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22297: Description: For Pandas UDF, the input type for each input argument is Pandas.Series and the result type

[GitHub] [flink] flinkbot commented on pull request #15640: [FLINK-22276][runtime] Fixes concurrency bug in exception history

2021-04-15 Thread GitBox
flinkbot commented on pull request #15640: URL: https://github.com/apache/flink/pull/15640#issuecomment-820927356 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

[GitHub] [flink] flinkbot edited a comment on pull request #15630: [FLINK-22119][hive][doc] Update document for hive dialect

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15630: URL: https://github.com/apache/flink/pull/15630#issuecomment-820444005 ## CI report: * f33cb990e19b5fc09bf689e084d534ba12c8c518 Azure:

[jira] [Comment Edited] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

2021-04-15 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322616#comment-17322616 ] Bhagi edited comment on FLINK-22139 at 4/16/21, 5:50 AM: - Hi Till Rohrmann , I

[jira] [Updated] (FLINK-22276) ExceptionHistoryEntryExtractor throws fatal error when task failure

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22276: --- Labels: pull-request-available (was: ) > ExceptionHistoryEntryExtractor throws fatal error

[GitHub] [flink] XComp opened a new pull request #15640: [FLINK-22276][runtime] Fixes concurrency bug in exception history

2021-04-15 Thread GitBox
XComp opened a new pull request #15640: URL: https://github.com/apache/flink/pull/15640 ## What is the purpose of the change This commit fixes a case where multiple failures can occur close to each other. In that case, the `DefaultScheduler`'s [restart

[jira] [Created] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

2021-04-15 Thread Bo Huang (Jira)
Bo Huang created FLINK-22300: Summary: Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic Key: FLINK-22300 URL: https://issues.apache.org/jira/browse/FLINK-22300

[GitHub] [flink] rkhachatryan commented on pull request #15632: [FLINK-22288][connectors / jdbc] Remove unnecessary argument in JdbcSink

2021-04-15 Thread GitBox
rkhachatryan commented on pull request #15632: URL: https://github.com/apache/flink/pull/15632#issuecomment-820919032 Build failure unrelated (FLINK-20928). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322623#comment-17322623 ] Roman Khachatryan commented on FLINK-20928: ---

[jira] [Closed] (FLINK-22229) Noise stacktraces if checkpoints fails because sources are not ready

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-9. - Resolution: Duplicate > Noise stacktraces if checkpoints fails because sources are not

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

2021-04-15 Thread Bhagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322616#comment-17322616 ] Bhagi commented on FLINK-22139: --- Hi Till Rohrmann , I deployed Flink with HA jobmanager on standalone

[GitHub] [flink] flinkbot edited a comment on pull request #15630: [FLINK-22119][hive][doc] Update document for hive dialect

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15630: URL: https://github.com/apache/flink/pull/15630#issuecomment-820444005 ## CI report: * f33cb990e19b5fc09bf689e084d534ba12c8c518 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15634: [FLINK-22177][table-api/doc] Add docs for time functions and time zone support

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15634: URL: https://github.com/apache/flink/pull/15634#issuecomment-820553845 ## CI report: * 97aaa0f13eeb77011b7b92cb600570992c676fd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 97eccbddbeffb29f4eede4983d4dd1edaf284543 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15639: [FLINK-22298][table-planner-blink] The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15639: URL: https://github.com/apache/flink/pull/15639#issuecomment-820894934 ## CI report: * 905886a20ea74e9e6182d0cd094a7ad340668fb2 Azure:

[jira] [Created] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed

2021-04-15 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22299: Summary: should remind users to ignoreParseErrors option when parser failed Key: FLINK-22299 URL: https://issues.apache.org/jira/browse/FLINK-22299 Project: Flink

[GitHub] [flink] JingsongLi commented on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

2021-04-15 Thread GitBox
JingsongLi commented on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-820897329 The root cause is that there is a custom `MapData` implementation from iceberg source. You can create a custom source with custom `MapData` to re-produce this problem.

[GitHub] [flink] flinkbot commented on pull request #15639: [FLINK-22298][table-planner-blink] The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread GitBox
flinkbot commented on pull request #15639: URL: https://github.com/apache/flink/pull/15639#issuecomment-820894934 ## CI report: * 905886a20ea74e9e6182d0cd094a7ad340668fb2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15634: [FLINK-22177][table-api/doc] Add docs for time functions and time zone support

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15634: URL: https://github.com/apache/flink/pull/15634#issuecomment-820553845 ## CI report: * 97aaa0f13eeb77011b7b92cb600570992c676fd5 Azure:

[GitHub] [flink] flinkbot commented on pull request #15639: [FLINK-22298][table-planner-blink] The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread GitBox
flinkbot commented on pull request #15639: URL: https://github.com/apache/flink/pull/15639#issuecomment-820889243 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

[GitHub] [flink] flinkbot edited a comment on pull request #15638: [FLINK-22272][table/catalog]Some scenes can't drop table by hive catalog

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15638: URL: https://github.com/apache/flink/pull/15638#issuecomment-820876469 ## CI report: * bbf0d4c3c52601b09827a1b2d82fa0f8417063f6 UNKNOWN * f8b4e4d8a298f9386e1da94762db23b7fb4b3466 Azure:

[jira] [Updated] (FLINK-22298) The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22298: --- Labels: pull-request-available (was: ) > The ExecNode's id should always start from 1 in

[GitHub] [flink] godfreyhe opened a new pull request #15639: [FLINK-22298][table-planner-blink] The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread GitBox
godfreyhe opened a new pull request #15639: URL: https://github.com/apache/flink/pull/15639 ## What is the purpose of the change *The ExecNode's id should always start from 1 in json plan test, which could make the test more stable* ## Brief change log -

[jira] [Created] (FLINK-22298) The ExecNode's id should always start from 1 in json plan test

2021-04-15 Thread godfrey he (Jira)
godfrey he created FLINK-22298: -- Summary: The ExecNode's id should always start from 1 in json plan test Key: FLINK-22298 URL: https://issues.apache.org/jira/browse/FLINK-22298 Project: Flink

[jira] [Commented] (FLINK-22156) HiveDialectQueryITCase fails on Azure because of no output for 900 seconds

2021-04-15 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322597#comment-17322597 ] Rui Li commented on FLINK-22156: The thread dump here is similar to the ones reported in FLINK-22129 and

[jira] [Updated] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22297: Description: For Pandas UDF, the input type for each input argument is Pandas.Series and the result type

[GitHub] [flink] fsk119 commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

2021-04-15 Thread GitBox
fsk119 commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r614510927 ## File path: docs/content.zh/docs/dev/table/sql/show.md ## @@ -346,12 +370,18 @@ Flink SQL> CREATE TABLE my_table (...) WITH (...); Flink SQL> SHOW

[GitHub] [flink] flinkbot edited a comment on pull request #15638: [FLINK-22272][table/catalog]Some scenes can't drop table by hive catalog

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15638: URL: https://github.com/apache/flink/pull/15638#issuecomment-820876469 ## CI report: * bbf0d4c3c52601b09827a1b2d82fa0f8417063f6 UNKNOWN * f8b4e4d8a298f9386e1da94762db23b7fb4b3466 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820206631 ## CI report: * 2e986775d3770ea31bef2c5c649dc39cb2da458b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15633: URL: https://github.com/apache/flink/pull/15633#issuecomment-820496249 ## CI report: * 903a703f2544d2497a73003c0ccc7ad269c7454a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15559: URL: https://github.com/apache/flink/pull/15559#issuecomment-817479787 ## CI report: * 32b7789699122e7e4e495de4d3f7df282ba8d2b5 UNKNOWN * 627e5ba06f413851352c6c37c13505816e54cfd8 Azure:

[jira] [Commented] (FLINK-22135) Test the adaptive scheduler

2021-04-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322591#comment-17322591 ] Xintong Song commented on FLINK-22135: -- cc [~trohrmann][~rmetzger] > Test the adaptive scheduler >

[GitHub] [flink] KurtYoung commented on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

2021-04-15 Thread GitBox
KurtYoung commented on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-820879599 The reported case is failed to covert table to datastream when the table contains filed with MAP type. It's better to also verify that your fix can really unblock this use

[GitHub] [flink] flinkbot commented on pull request #15638: [FLINK-22272][table/catalog]Some scenes can't drop table by hive catalog

2021-04-15 Thread GitBox
flinkbot commented on pull request #15638: URL: https://github.com/apache/flink/pull/15638#issuecomment-820876469 ## CI report: * bbf0d4c3c52601b09827a1b2d82fa0f8417063f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15633: URL: https://github.com/apache/flink/pull/15633#issuecomment-820496249 ## CI report: * 903a703f2544d2497a73003c0ccc7ad269c7454a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15637: [FLINK-22286][python] Fix picklebytescoder doesn't support custom pyt…

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15637: URL: https://github.com/apache/flink/pull/15637#issuecomment-820870678 ## CI report: * fdb9b054ca6e050ea6c669e4f6488f470d3935fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15622: URL: https://github.com/apache/flink/pull/15622#issuecomment-820290426 ## CI report: * af4135b758aa97ee2690a18bb244c95e82d33df5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820206631 ## CI report: * 2e986775d3770ea31bef2c5c649dc39cb2da458b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817676016 ## CI report: * 68d7b85d10b28b3f6970b435460c28df27efef3f Azure:

[jira] [Assigned] (FLINK-22177) Add docs for consistent time functions and compatibility specification

2021-04-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22177: --- Assignee: Leonard Xu > Add docs for consistent time functions and compatibility specification >

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Commented] (FLINK-22296) Introduce Preconditions-util into Python API

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322580#comment-17322580 ] Dian Fu commented on FLINK-22296: - [~RocMarshal] Is this intended to add precondition check utils to

[jira] [Assigned] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-22297: --- Assignee: (was: Dian Fu) > Perform early check to ensure that the length of the result is the

[jira] [Created] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

2021-04-15 Thread Dian Fu (Jira)
Dian Fu created FLINK-22297: --- Summary: Perform early check to ensure that the length of the result is the same as the input for Pandas UDF Key: FLINK-22297 URL: https://issues.apache.org/jira/browse/FLINK-22297

[GitHub] [flink] dianfu commented on a change in pull request #15635: [FLINK-22290][checkpointing] Polishing unaligned checkpoint API.

2021-04-15 Thread GitBox
dianfu commented on a change in pull request #15635: URL: https://github.com/apache/flink/pull/15635#discussion_r614522682 ## File path: flink-python/pyflink/datastream/checkpoint_config.py ## @@ -330,6 +331,48 @@ def disable_unaligned_checkpoints(self) -> 'CheckpointConfig':

[GitHub] [flink] flinkbot commented on pull request #15638: [FLINK-22272][table/catalog]Some scenes can't drop table by hive catalog

2021-04-15 Thread GitBox
flinkbot commented on pull request #15638: URL: https://github.com/apache/flink/pull/15638#issuecomment-820872541 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

[jira] [Updated] (FLINK-22272) Some scenes can't drop table by hive catalog

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22272: --- Labels: pull-request-available (was: ) > Some scenes can't drop table by hive catalog >

[GitHub] [flink] hameizi opened a new pull request #15638: [FLINK-22272][table/catalog]Some scenes can't drop table by hive catalog

2021-04-15 Thread GitBox
hameizi opened a new pull request #15638: URL: https://github.com/apache/flink/pull/15638 ### What is the purpose of the change There are some scenes we can't drop table by hive catalog because of we execute error create table sql like "caeate table tableName". And then when we execute

[GitHub] [flink] zoltar9264 commented on pull request #15619: [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart

2021-04-15 Thread GitBox
zoltar9264 commented on pull request #15619: URL: https://github.com/apache/flink/pull/15619#issuecomment-820871599 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot commented on pull request #15637: [FLINK-22286][python] Fix picklebytescoder doesn't support custom pyt…

2021-04-15 Thread GitBox
flinkbot commented on pull request #15637: URL: https://github.com/apache/flink/pull/15637#issuecomment-820870678 ## CI report: * fdb9b054ca6e050ea6c669e4f6488f470d3935fc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15622: URL: https://github.com/apache/flink/pull/15622#issuecomment-820290426 ## CI report: * af4135b758aa97ee2690a18bb244c95e82d33df5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820375204 ## CI report: * ebfb4a57819562cc8627585648e97c8d843bd30b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817676016 ## CI report: * e6c2c43918883fb8c412a1bd80309496f2e239c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15559: URL: https://github.com/apache/flink/pull/15559#issuecomment-817479787 ## CI report: * 32b7789699122e7e4e495de4d3f7df282ba8d2b5 UNKNOWN * 627e5ba06f413851352c6c37c13505816e54cfd8 Azure:

[GitHub] [flink] cshuo commented on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

2021-04-15 Thread GitBox
cshuo commented on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-820870075 > Could you also add some test cases similar with the case reported in the jira? I think what the similar case validates is the coping of input record with custom map data

[GitHub] [flink] lindong28 commented on a change in pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

2021-04-15 Thread GitBox
lindong28 commented on a change in pull request #15633: URL: https://github.com/apache/flink/pull/15633#discussion_r614521887 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailureHandler.java ## @@ -48,6 +48,9 @@

[GitHub] [flink] lindong28 commented on a change in pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

2021-04-15 Thread GitBox
lindong28 commented on a change in pull request #15633: URL: https://github.com/apache/flink/pull/15633#discussion_r614520175 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailureHandler.java ## @@ -73,8 +76,10 @@

[GitHub] [flink] spoon-lz commented on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

2021-04-15 Thread GitBox
spoon-lz commented on pull request #15622: URL: https://github.com/apache/flink/pull/15622#issuecomment-820860498 @flinkbot run azure -- 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-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-04-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322562#comment-17322562 ] Yang Wang commented on FLINK-22262: --- Do you have called {{System.exit}} in the

[GitHub] [flink] flinkbot edited a comment on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820375204 ## CI report: * ebfb4a57819562cc8627585648e97c8d843bd30b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #15637: [FLINK-22286][python] Fix picklebytescoder doesn't support custom pyt…

2021-04-15 Thread GitBox
flinkbot commented on pull request #15637: URL: https://github.com/apache/flink/pull/15637#issuecomment-820858906 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

[GitHub] [flink] HuangXingBo opened a new pull request #15637: [FLINK-22286][python] Fix picklebytescoder doesn't support custom pyt…

2021-04-15 Thread GitBox
HuangXingBo opened a new pull request #15637: URL: https://github.com/apache/flink/pull/15637 ## What is the purpose of the change *This pull request will fix picklebytescoder doesn't support custom python class* ## Brief change log - *replace `pickle` with

[jira] [Comment Edited] (FLINK-22296) Introduce Preconditions-util into Python API

2021-04-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322557#comment-17322557 ] Nicholas Jiang edited comment on FLINK-22296 at 4/16/21, 1:58 AM: --

[jira] [Commented] (FLINK-22296) Introduce Preconditions-util into Python API

2021-04-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322557#comment-17322557 ] Nicholas Jiang commented on FLINK-22296: [~RocMarshal], IMO, the

[GitHub] [flink] HuangXingBo closed pull request #15626: [FLINK-22286][python] Fix picklebytescoder doesn't support custom python class

2021-04-15 Thread GitBox
HuangXingBo closed pull request #15626: URL: https://github.com/apache/flink/pull/15626 -- 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 specific comment. For queries about this service,

[jira] [Closed] (FLINK-20761) Cannot read hive table/partition whose location path contains comma

2021-04-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20761. -- Resolution: Fixed 1.13.0: 45e2fb584579952d6abc9a4507cbc3b09b071c12 1.12.3: 

[GitHub] [flink] KurtYoung merged pull request #15625: [FLINK-20761][hive] Escape the location path when creating input spli…

2021-04-15 Thread GitBox
KurtYoung merged pull request #15625: URL: https://github.com/apache/flink/pull/15625 -- 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 specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * eaae75c64ff71555cb3fe92d15c5f1d7fcc06c61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 9e999a5bf826fc57c055c91a4a89e696111239e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 9e999a5bf826fc57c055c91a4a89e696111239e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 ## CI report: * 9d3d899a56d344f6537ec493ca74d6e876739b76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 9e999a5bf826fc57c055c91a4a89e696111239e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 9e999a5bf826fc57c055c91a4a89e696111239e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * 6213fbca23020a9ef8064ea8bb83be3d1a7ca365 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15605: [FLINK-21996][coordination] - Part 3&4: Ensure OperatorEvent transport losses are handled

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15605: URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302 ## CI report: * 5f7d95b42cee8deadf10ac7b41570348f595b5c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15601: URL: https://github.com/apache/flink/pull/15601#issuecomment-819126497 ## CI report: * fc1d4ce14380f49215081b07ac639c4849a95fd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 9e999a5bf826fc57c055c91a4a89e696111239e4 Azure:

[GitHub] [flink] flinkbot commented on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot commented on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * 9e999a5bf826fc57c055c91a4a89e696111239e4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-22239) Improve support for JdbcXaSinkFunction

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-22239: - Assignee: Roman Khachatryan > Improve support for JdbcXaSinkFunction >

[GitHub] [flink] flinkbot commented on pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
flinkbot commented on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820710996 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

[jira] [Commented] (FLINK-22141) Manually test exactly-once JDBC sink

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322475#comment-17322475 ] Roman Khachatryan commented on FLINK-22141: --- You are right, postgres has the same limitation

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22239: --- Labels: pull-request-available (was: ) > Improve support for JdbcXaSinkFunction >

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-22239: -- Fix Version/s: (was: 1.14.0) 1.13.0 > Improve support for

[GitHub] [flink] rkhachatryan opened a new pull request #15636: [WIP][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-15 Thread GitBox
rkhachatryan opened a new pull request #15636: URL: https://github.com/apache/flink/pull/15636 ## What is the purpose of the change Implement workaround for limitation of some XA-compliant databases of a single XA-transaction per connection by pooling connections. ##

[jira] [Updated] (FLINK-22239) Improve support for JdbcXaSinkFunction

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-22239: -- Issue Type: Bug (was: Improvement) > Improve support for JdbcXaSinkFunction >

[GitHub] [flink] flinkbot edited a comment on pull request #15633: [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15633: URL: https://github.com/apache/flink/pull/15633#issuecomment-820496249 ## CI report: * 903a703f2544d2497a73003c0ccc7ad269c7454a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15635: [FLINK-22290][checkpointing] Polishing unaligned checkpoint API.

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15635: URL: https://github.com/apache/flink/pull/15635#issuecomment-820669890 ## CI report: * 60e29ec75bac95feb8623a2fc37ecddbf8457194 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * 0fc1dafabbea6050e6d08009fbeb61c8ec71d381 Azure:

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322455#comment-17322455 ] Dawid Wysakowicz commented on FLINK-22085: --

[GitHub] [flink] rmetzger commented on pull request #15592: [FLINK-22244][docs] Adjust Reactive Mode docs

2021-04-15 Thread GitBox
rmetzger commented on pull request #15592: URL: https://github.com/apache/flink/pull/15592#issuecomment-820680960 Thanks a lot for your review. I'll merge this PR soon! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Closed] (FLINK-22158) Test native Kubernetes pod template

2021-04-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22158. -- Resolution: Fixed > Test native Kubernetes pod template > ---

[jira] [Commented] (FLINK-22158) Test native Kubernetes pod template

2021-04-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322454#comment-17322454 ] Robert Metzger commented on FLINK-22158: Thanks a lot for your quick response. You are right,

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 ## CI report: * 831c83e7eb7b0646f73a4b1632dd09759c52e627 Azure:

[jira] [Closed] (FLINK-7503) Config options taskmanager.log.path and jobmanager.web.log.path are misleading, if not broken

2021-04-15 Thread Felix Dreissig (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix Dreissig closed FLINK-7503. - Resolution: Abandoned > Config options taskmanager.log.path and jobmanager.web.log.path are >

[GitHub] [flink] flinkbot commented on pull request #15635: [FLINK-22290][checkpointing] Polishing unaligned checkpoint API.

2021-04-15 Thread GitBox
flinkbot commented on pull request #15635: URL: https://github.com/apache/flink/pull/15635#issuecomment-820669890 ## CI report: * 60e29ec75bac95feb8623a2fc37ecddbf8457194 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15632: [FLINK-22288][connectors / jdbc] Remove unnecessary argument in JdbcSink

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15632: URL: https://github.com/apache/flink/pull/15632#issuecomment-820496105 ## CI report: * 57ca63cc6b76e823e57f24752e89a564dd38a538 Azure:

[jira] [Commented] (FLINK-7503) Config options taskmanager.log.path and jobmanager.web.log.path are misleading, if not broken

2021-04-15 Thread Felix Dreissig (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322443#comment-17322443 ] Felix Dreissig commented on FLINK-7503: --- >From what I could briefly see, the situation (at least

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 ## CI report: * 831c83e7eb7b0646f73a4b1632dd09759c52e627 Azure:

[jira] [Updated] (FLINK-7503) Config options taskmanager.log.path and jobmanager.web.log.path are misleading, if not broken

2021-04-15 Thread Felix Dreissig (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix Dreissig updated FLINK-7503: -- Labels: (was: stale-minor) > Config options taskmanager.log.path and jobmanager.web.log.path

  1   2   3   4   5   >