[jira] [Updated] (FLINK-16074) Translate the "Overview" page for "State & Fault Tolerance" into Chinese

2020-05-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16074: --- Labels: pull-request-available (was: ) > Translate the "Overview" page for "State & Fault

[GitHub] [flink] carp84 commented on a change in pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-19 Thread GitBox
carp84 commented on a change in pull request #12096: URL: https://github.com/apache/flink/pull/12096#discussion_r427048919 ## File path: docs/dev/stream/state/index.zh.md ## @@ -25,34 +25,17 @@ specific language governing permissions and limitations under the License. -->

[jira] [Comment Edited] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110766#comment-17110766 ] Yang Wang edited comment on FLINK-15792 at 5/19/20, 6:02 AM: - Make sense to

[GitHub] [flink-statefun] slinkydeveloper edited a comment on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-19 Thread GitBox
slinkydeveloper edited a comment on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-630606294 > would you like me to complete this over my branch or would you like to continue working on that? I think it's more practical if you continue to work

[jira] [Comment Edited] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

2020-05-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110012#comment-17110012 ] Jark Wu edited comment on FLINK-16160 at 5/19/20, 6:17 AM: --- Fixed in -

[jira] [Closed] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

2020-05-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16160. --- Fix Version/s: 1.10.2 Resolution: Fixed > Schema#proctime and Schema#rowtime don't work in

[GitHub] [flink-statefun] slinkydeveloper commented on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-19 Thread GitBox
slinkydeveloper commented on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-630606294 > would you like me to complete this over my branch or would you like to continue working on that? I think it's more practical if you continue to work on

[GitHub] [flink] wuchong merged pull request #12218: [FLINK-16160][table] Fix proctime()/rowtime() doesn't work for TableE…

2020-05-19 Thread GitBox
wuchong merged pull request #12218: URL: https://github.com/apache/flink/pull/12218 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] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427057355 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[GitHub] [flink] flinkbot edited a comment on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630603058 ## CI report: * 50937916a7724ea232c71a6a42510984187adb19 Azure:

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427057624 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[GitHub] [flink] lirui-apache commented on pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

2020-05-19 Thread GitBox
lirui-apache commented on pull request #12217: URL: https://github.com/apache/flink/pull/12217#issuecomment-630614093 My personal pipeline has passed: https://dev.azure.com/lirui-apache/flink/_build/results?buildId=78=results

[GitHub] [flink] godfreyhe commented on pull request #12221: [FLINK-17797][FLINK-17798][hbase][jdbc] Align the behavior between the new and legacy HBase/JDBC table source

2020-05-19 Thread GitBox
godfreyhe commented on pull request #12221: URL: https://github.com/apache/flink/pull/12221#issuecomment-630614848 thanks for the update, LGTM This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17474: - Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Test and correct case

[jira] [Updated] (FLINK-17786) Cannot switch dialect in SQL CLI

2020-05-19 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-17786: --- Description: In {{ExecutionContext::initializeTableEnvironment}} we set dialect with the ExecutionEntry

[GitHub] [flink] pnowojski commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
pnowojski commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427070669 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@

[jira] [Closed] (FLINK-17786) Cannot switch dialect in SQL CLI

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17786. Resolution: Fixed master: ce0f334713a4d994183cc5f415fcf8896cd793fc release-1.11: 

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

2020-05-19 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110916#comment-17110916 ] Yang Wang commented on FLINK-17565: --- Yes, i agree with you that 4.9.x is more stable. > Bump fabric8

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110918#comment-17110918 ] Timo Walther commented on FLINK-17793: -- Computed columns, atermarks, primary key are not needed in

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

2020-05-19 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110878#comment-17110878 ] Yang Wang commented on FLINK-17745: --- [~KevinZwx] I am not sure why the fat jar and extracted jar are

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

2020-05-19 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110879#comment-17110879 ] Yu Li commented on FLINK-13598: --- The RocksDB [regression

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * 757a2307f027acba2aca26f7f5ec6f9639ce9079 Azure:

[GitHub] [flink] flinkbot commented on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot commented on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630603058 ## CI report: * 50937916a7724ea232c71a6a42510984187adb19 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427055344 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427058760 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[jira] [Commented] (FLINK-17804) Follow the spec when decoding Parquet logical DECIMAL type

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110893#comment-17110893 ] Jingsong Lee commented on FLINK-17804: -- Yes, you are right. Previous implementation looks totally

[jira] [Commented] (FLINK-17619) Only set offset commit if group id is configured for Kafka Table source

2020-05-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110903#comment-17110903 ] Gyula Fora commented on FLINK-17619: We could do it either way, If you review the PR and happy I can

[jira] [Created] (FLINK-17805) InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly

2020-05-19 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17805: -- Summary: InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly Key: FLINK-17805 URL: https://issues.apache.org/jira/browse/FLINK-17805

[jira] [Updated] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17639: -- Fix Version/s: 1.11.0 > Document which FileSystems are supported by the StreamingFileSink >

[jira] [Created] (FLINK-17804) Follow the spec when decoding Parquet logical DECIMAL type

2020-05-19 Thread Sergii Mikhtoniuk (Jira)
Sergii Mikhtoniuk created FLINK-17804: - Summary: Follow the spec when decoding Parquet logical DECIMAL type Key: FLINK-17804 URL: https://issues.apache.org/jira/browse/FLINK-17804 Project: Flink

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427054850 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427054290 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

2020-05-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110892#comment-17110892 ] Yun Tang commented on FLINK-17800: -- [~YordanPavlov] Thanks for reporting this. Have you tried

[jira] [Commented] (FLINK-17786) Cannot switch dialect in SQL CLI

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110898#comment-17110898 ] Jingsong Lee commented on FLINK-17786: -- Why not work? [~lirui] Can you explain this in description?

[jira] [Assigned] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17474: Assignee: Jingsong Lee > Test and correct case insensitive for parquet and orc in hive >

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427056379 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[GitHub] [flink] twalthr commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-19 Thread GitBox
twalthr commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630625826 Thanks for opening a PR for this topic @dawidwys. I wish we could avoid this but I don't see a possibility to prevent this change. The clash with the Scala macro and the

[GitHub] [flink] JingsongLi merged pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

2020-05-19 Thread GitBox
JingsongLi merged pull request #12217: URL: https://github.com/apache/flink/pull/12217 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

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 14ab5f81d7f9d7324e3a0f7ab51d47bf9242abee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * cff8424e532db0bfc3ca58b8b6da13d3d69b0559 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457 ## CI report: * de4251b2c2ee31ababe1c82505c15822546a59b1 Azure:

[jira] [Comment Edited] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110918#comment-17110918 ] Timo Walther edited comment on FLINK-17793 at 5/19/20, 7:19 AM: Computed

[GitHub] [flink] klion26 commented on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-19 Thread GitBox
klion26 commented on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-630634589 @carp84 thanks for the review, addressed the comment, please take another look when you're free. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * cff8424e532db0bfc3ca58b8b6da13d3d69b0559 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630603058 ## CI report: * 50937916a7724ea232c71a6a42510984187adb19 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

2020-05-19 Thread GitBox
rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r427084714 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int

[jira] [Commented] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110921#comment-17110921 ] Till Rohrmann commented on FLINK-15792: --- Done [~fly_in_gis]. > Make Flink logs accessible via

[jira] [Assigned] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15792: - Assignee: Yang Wang > Make Flink logs accessible via kubectl logs per default >

[GitHub] [flink] dawidwys commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-19 Thread GitBox
dawidwys commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630636630 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 58f57832797464a1a9646223926eefe3cce2840a Azure:

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-19 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427056510 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc}

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110911#comment-17110911 ] Robert Metzger commented on FLINK-12030:

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@

[GitHub] [flink] curcur commented on a change in pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-19 Thread GitBox
curcur commented on a change in pull request #12205: URL: https://github.com/apache/flink/pull/12205#discussion_r427066016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java ## @@ -79,7 +84,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * caf4400401fbaffaaeb0e16fafe3de1bcee1cc8b Azure:

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110910#comment-17110910 ] Robert Metzger commented on FLINK-12030:

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110919#comment-17110919 ] Robert Metzger commented on FLINK-12030:

[jira] [Updated] (FLINK-17801) TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17801: -- Fix Version/s: 1.11.0 > TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout >

[GitHub] [flink] tillrohrmann commented on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
tillrohrmann commented on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630638359 Sounds good @zentol. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] tillrohrmann commented on pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

2020-05-19 Thread GitBox
tillrohrmann commented on pull request #12211: URL: https://github.com/apache/flink/pull/12211#issuecomment-630638234 Ok, will merge my commit now. This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110922#comment-17110922 ] Robert Metzger commented on FLINK-17730: Case with 15 minutes :(

[jira] [Updated] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16911: --- Priority: Critical (was: Major) > PrestoS3FileSystemITCase#testSimpleFileWriteAndRead

[jira] [Commented] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110924#comment-17110924 ] Robert Metzger commented on FLINK-16911:

[jira] [Assigned] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-19 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17790: - Assignee: Till Rohrmann (was: Chesnay Schepler) > flink-connector-kafka-base does not

[jira] [Commented] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

2020-05-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110927#comment-17110927 ] Robert Metzger commented on FLINK-17721:

[jira] [Created] (FLINK-17807) Fix the broken link "/zh/ops/memory/mem_detail.html" in documentation

2020-05-19 Thread Jark Wu (Jira)
Jark Wu created FLINK-17807: --- Summary: Fix the broken link "/zh/ops/memory/mem_detail.html" in documentation Key: FLINK-17807 URL: https://issues.apache.org/jira/browse/FLINK-17807 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #12239: [FLINK-17027][hotfix] Rename back-off infix to backoff in new Elasticsearch properties

2020-05-19 Thread GitBox
flinkbot commented on pull request #12239: URL: https://github.com/apache/flink/pull/12239#issuecomment-630648333 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] wuchong commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-19 Thread GitBox
wuchong commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-630648400 Merged and created an following up issue FLINK-17807 to resolve this brocken link. This is an automated

[GitHub] [flink] flinkbot commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread GitBox
flinkbot commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630653015 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] zentol commented on pull request #12100: [FLINK-17634][rest] Reject multiple registration for the same endpoint

2020-05-19 Thread GitBox
zentol commented on pull request #12100: URL: https://github.com/apache/flink/pull/12100#issuecomment-630661752 @tillrohrmann The branch did not include the fix for FLINK-17562, and failed accordingly. So it works at least, an the build is now green after a rebase.

[jira] [Assigned] (FLINK-17805) InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly

2020-05-19 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17805: -- Assignee: Piotr Nowojski > InputProcessorUtil doesn't handle indexes for multiple

[jira] [Updated] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive

2020-05-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17474: --- Labels: pull-request-available (was: ) > Test and correct case insensitive for parquet and

[jira] [Closed] (FLINK-17353) Broken links in Flink docs master

2020-05-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17353. --- Fix Version/s: 1.11.0 Resolution: Fixed - master (1.12.0): 4dc3bdaa460f35ea6e0fa31ce9068a7dba54316d

[jira] [Commented] (FLINK-16076) Translate "Queryable State" page into Chinese

2020-05-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110966#comment-17110966 ] Jark Wu commented on FLINK-16076: - Cherry-picked to 1.11.0: 2f1a6b0aa3eeae973e8a6124bef888f223bf43ae >

[GitHub] [flink] JingsongLi opened a new pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-19 Thread GitBox
JingsongLi opened a new pull request #12241: URL: https://github.com/apache/flink/pull/12241 ## What is the purpose of the change Parquet reader should be case insensitive field names for hive ## Brief change log - Introduce case sensitive flag to parquet reader

[jira] [Commented] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110976#comment-17110976 ] Kurt Young commented on FLINK-17806: cc [~TsReaper] >

[jira] [Comment Edited] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110976#comment-17110976 ] Kurt Young edited comment on FLINK-17806 at 5/19/20, 8:46 AM: -- cc

[jira] [Assigned] (FLINK-17806) CollectSinkFunctionTest.testCheckpointedFunction fails with expected:<50> but was:<0>

2020-05-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17806: -- Assignee: Caizhi Weng > CollectSinkFunctionTest.testCheckpointedFunction fails with

[jira] [Updated] (FLINK-17666) Insert into partitioned table can fail with select *

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17666: - Fix Version/s: 1.11.0 > Insert into partitioned table can fail with select * >

[GitHub] [flink] zentol edited a comment on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
zentol edited a comment on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630688114 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] zentol edited a comment on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
zentol edited a comment on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630688114 @tillrohrmann Escaped quotes don't; but I found another solution using arrays in the [BashFAQ|http://mywiki.wooledge.org/BashFAQ/050]. This seems to work. ... I also

[jira] [Commented] (FLINK-16818) Optimize data skew when flink write data to hive dynamic partition table

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110984#comment-17110984 ] Jingsong Lee commented on FLINK-16818: -- Hi [~zhangjun], already finish in FLINK-15006 , default

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase.testExactlyOnceRegularSink fails with "The producer has already been closed"

2020-05-19 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110983#comment-17110983 ] Lijie Wang commented on FLINK-16383: I meet the same problem. 

[GitHub] [flink] zentol commented on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
zentol commented on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630688114 @tillrohrmann Escaped quotes don't; but I found another solution using arrays in the [BashFAQ|http://mywiki.wooledge.org/BashFAQ/050]. This seems to work. Well, I just saw the

[jira] [Updated] (FLINK-16568) Cannot call Hive UDAF that requires constant arguments

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16568: - Fix Version/s: 1.11.0 > Cannot call Hive UDAF that requires constant arguments >

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * 97f9193f189afae6147d9d1bdd68beb132bc63ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 7a972db935a0bcc39d7979358962538fd8790a9c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12234: URL: https://github.com/apache/flink/pull/12234#issuecomment-630433269 ## CI report: * c39a9703b6e8d5fe3ecc4cd59d2e5c5d4dd1c82e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630019128 ## CI report: * 74c9e440c684f255faa2075c12e4438590631dae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-630388527 ## CI report: * 08d1dabd6e910a0560299200129951ecf811af99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12236: [FLINK-17527][flink-dist] Make kubernetes-session.sh use session log4j/logback configuration files

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12236: URL: https://github.com/apache/flink/pull/12236#issuecomment-630547436 ## CI report: * c3caf6974bdf8298376d150b00fd7e7125089986 Azure:

[jira] [Commented] (FLINK-16402) Alter table fails on Hive catalog

2020-05-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110996#comment-17110996 ] Jingsong Lee commented on FLINK-16402: -- Looks like needs hive dialect support, in 1.11, maybe it is

[GitHub] [flink] wangyang0918 commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-19 Thread GitBox
wangyang0918 commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630701881 cc @tillrohrmann Follow what we have discussed in FLINK-15792, this PR will make logs accessible via `kubectl logs` by default. Please have a look at your convenience.

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

2020-05-19 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111007#comment-17111007 ] Kostas Kloudas commented on FLINK-17745: Hi all, from the removed code in the PR, we were

[GitHub] [flink] flinkbot commented on pull request #12242: [FLINK-17801][tests] Increase timeout of TaskExecutorTest.testHeartbeatTimeoutWithResourceManager

2020-05-19 Thread GitBox
flinkbot commented on pull request #12242: URL: https://github.com/apache/flink/pull/12242#issuecomment-630705504 ## CI report: * 58cbed744b4830522b9f4e410ca820cd902fae01 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-19 Thread GitBox
flinkbot edited a comment on pull request #12241: URL: https://github.com/apache/flink/pull/12241#issuecomment-630692649 ## CI report: * 784c1dc168979a6165e22ea31cd1d152dbb818e2 Azure:

[GitHub] [flink] zentol edited a comment on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

2020-05-19 Thread GitBox
zentol edited a comment on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630688114 @tillrohrmann Escaped quotes don't; but I found another solution using arrays in the [BashFAQ](http://mywiki.wooledge.org/BashFAQ/050). This seems to work. ... I

  1   2   3   4   5   6   7   >