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

2020-05-18 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 @@ pr

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

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

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

2020-05-18 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 whic

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

2020-05-18 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 insensitiv

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

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

[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-18 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 messag

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

2020-05-18 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&view=results --

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

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

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

2020-05-18 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-17800) RocksDB optimizeForPointLookup results in missing time windows

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

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

2020-05-18 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] flinkbot edited a comment on pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

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

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

2020-05-18 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 #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-18 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: [FAILURE](https://dev.azure.com/apache-fl

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

2020-05-18 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] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-18 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} -

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

2020-05-18 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-18 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-18 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] [Closed] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

2020-05-18 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 TableEnvir

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

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

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

2020-05-18 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

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

2020-05-18 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-statefun] slinkydeveloper commented on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-18 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 that

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

2020-05-18 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 r

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

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

[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-18 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2020-05-18 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

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

2020-05-18 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 T

[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-18 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-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110766#comment-17110766 ] Yang Wang edited comment on FLINK-15792 at 5/19/20, 6:02 AM: -

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

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

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

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

[GitHub] [flink] libenchao commented on pull request #11191: [FLINK-16094][docs] Translate /dev/table/functions/udfs.zh.md

2020-05-18 Thread GitBox
libenchao commented on pull request #11191: URL: https://github.com/apache/flink/pull/11191#issuecomment-630598222 @wuchong Thanks for the reminder and merging. This is an automated message from the Apache Git Service. To res

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

2020-05-18 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-16076. - Resolution: Done Merged into master via 4cfd23a8a0454b321616e9acd91faebbda42ca27 > Translate "Queryable State"

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

2020-05-18 Thread GitBox
flinkbot commented on pull request #12238: URL: https://github.com/apache/flink/pull/12238#issuecomment-630595564 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] carp84 closed pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

2020-05-18 Thread GitBox
carp84 closed pull request #12139: URL: https://github.com/apache/flink/pull/12139 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 #12138: [FLINK-16611] [datadog-metrics] Make number of metrics per request configurable

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

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

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

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

2020-05-18 Thread GitBox
wangyang0918 commented on pull request #12236: URL: https://github.com/apache/flink/pull/12236#issuecomment-630590441 cc @tillrohrmann Could you please help to review this change? This is an automated message from the Apache

[GitHub] [flink] JingsongLi opened a new pull request #12238: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

2020-05-18 Thread GitBox
JingsongLi opened a new pull request #12238: URL: https://github.com/apache/flink/pull/12238 ## What is the purpose of the change This is 1.11 cherry-pick for https://github.com/apache/flink/pull/12212 Fs connector should use FLIP-122 format options style. Like: ``` creat

[jira] [Closed] (FLINK-16094) Translate "User-defined Functions" page of "Functions" into Chinese

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

[GitHub] [flink] yangyichao-mango edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-18 Thread GitBox
yangyichao-mango edited a comment on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-630550918 That is the result of check_links.sh. 找到 1 个死链接。 http://localhost:4000/zh/ops/memory/mem_detail.html When I try to fix http://localhost:4000/zh/op

[GitHub] [flink] yangyichao-mango edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-18 Thread GitBox
yangyichao-mango edited a comment on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-630550918 That is the result of check_links.sh. 找到 1 个死链接。 http://localhost:4000/zh/ops/memory/mem_detail.html When I try to fix http://localhost:4000/zh/op

[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-18 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

[jira] [Commented] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

2020-05-18 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110852#comment-17110852 ] lining commented on FLINK-17378: Another instance:  [https://dev.azure.com/apache-flink/

[GitHub] [flink] flinkbot edited a comment on pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

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

[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-18 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

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

[GitHub] [flink] wuchong closed pull request #11191: [FLINK-16094][docs] Translate /dev/table/functions/udfs.zh.md

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

[jira] [Comment Edited] (FLINK-14255) Integrate hive to streaming file sink

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109820#comment-17109820 ] Jingsong Lee edited comment on FLINK-14255 at 5/19/20, 4:36 AM: --

[jira] [Closed] (FLINK-14255) Integrate hive to streaming file sink

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14255. Resolution: Implemented > Integrate hive to streaming file sink >

[GitHub] [flink] JingsongLi closed pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

2020-05-18 Thread GitBox
JingsongLi closed pull request #12220: URL: https://github.com/apache/flink/pull/12220 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] wuchong commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-18 Thread GitBox
wuchong commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427022575 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -116,6 +122,36 @

[jira] [Updated] (FLINK-17803) Flink batch sql job read hive table which contains map type, raise exception: " scala.MatchError: MAP"

2020-05-18 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-17803: - Description: We use flink 1.10.0 ,  blink planner,  to  submit a batch sql job to read from a hive tabl

[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-18 Thread GitBox
flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

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

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

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

[jira] [Updated] (FLINK-17803) Flink batch sql job read hive table which contains map type, raise exception: " scala.MatchError: MAP"

2020-05-18 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-17803: - Description: We use flink 1.10.0 ,  blink planner,  to  submit a batch sql job to read from a hive tabl

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

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

[jira] [Created] (FLINK-17803) Flink batch sql job read hive table with map type, raise exception: " scala.MatchError: MAP"

2020-05-18 Thread zouyunhe (Jira)
zouyunhe created FLINK-17803: Summary: Flink batch sql job read hive table with map type, raise exception: " scala.MatchError: MAP" Key: FLINK-17803 URL: https://issues.apache.org/jira/browse/FLINK-17803

[jira] [Updated] (FLINK-17803) Flink batch sql job read hive table which contains map type, raise exception: " scala.MatchError: MAP"

2020-05-18 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-17803: - Summary: Flink batch sql job read hive table which contains map type, raise exception: " scala.MatchErro

[GitHub] [flink] flinkbot edited a comment on pull request #12138: [FLINK-16611] [datadog-metrics] Make number of metrics per request configurable

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

[jira] [Issue Comment Deleted] (FLINK-14255) Integrate hive to streaming file sink

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14255: - Comment: was deleted (was: master: 547c168a8978a80072187a80d84d53d6e7f02260) > Integrate hive t

[jira] [Comment Edited] (FLINK-17594) Support Hadoop path-based PartFileWriter with renaming committer

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109573#comment-17109573 ] Jingsong Lee edited comment on FLINK-17594 at 5/19/20, 4:11 AM: --

[jira] [Comment Edited] (FLINK-17594) Support Hadoop path-based PartFileWriter with renaming committer

2020-05-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109573#comment-17109573 ] Jingsong Lee edited comment on FLINK-17594 at 5/19/20, 4:11 AM: --

[GitHub] [flink] JingsongLi merged pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
JingsongLi merged pull request #12224: URL: https://github.com/apache/flink/pull/12224 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] JingsongLi closed pull request #12235: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

2020-05-18 Thread GitBox
JingsongLi closed pull request #12235: URL: https://github.com/apache/flink/pull/12235 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 #12138: [FLINK-16611] [datadog-metrics] Make number of metrics per request configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

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

[GitHub] [flink] flinkbot commented on pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-18 Thread GitBox
flinkbot commented on pull request #12237: URL: https://github.com/apache/flink/pull/12237#issuecomment-630566246 ## CI report: * 0c911fb0b8ae6fc7dabf929ae10b27b24e0b604d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

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

[jira] [Created] (FLINK-17802) Set offset commit only if group id is configured for new Kafka Table source

2020-05-18 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-17802: -- Summary: Set offset commit only if group id is configured for new Kafka Table source Key: FLINK-17802 URL: https://issues.apache.org/jira/browse/FLINK-17802 Project: Flin

[GitHub] [flink] wuchong 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-18 Thread GitBox
wuchong commented on pull request #12221: URL: https://github.com/apache/flink/pull/12221#issuecomment-630563803 Rebased to resolve compile problem and updated. This is an automated message from the Apache Git Service. To res

[GitHub] [flink] wanglijie95 commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
wanglijie95 commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427015357 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java ## @@ -186,6 +212,15 @@ private CloseableReaperThread

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * 2712496dd23e43f1660d98dee5bf622a590f1357 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

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

[GitHub] [flink] flinkbot edited a comment on pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427012948 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java ## @@ -186,6 +212,15 @@ private CloseableReaperThread()

[GitHub] [flink] swhelan091 commented on a change in pull request #12138: [FLINK-16611] [datadog-metrics] Make number of metrics per request configurable

2020-05-18 Thread GitBox
swhelan091 commented on a change in pull request #12138: URL: https://github.com/apache/flink/pull/12138#discussion_r427013055 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java ## @@ -137,15 +140,21 @@ pub

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

2020-05-18 Thread GitBox
wuchong commented on a change in pull request #12221: URL: https://github.com/apache/flink/pull/12221#discussion_r427012826 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcLookupTableITCase.java ## @@ -46,24 +46,28 @@

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427010925 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java ## @@ -73,8 +73,34 @@ synchronized (REAP

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

2020-05-18 Thread GitBox
zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427010925 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java ## @@ -73,8 +73,34 @@ synchronized (REAP

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

2020-05-18 Thread GitBox
wuchong commented on a change in pull request #12221: URL: https://github.com/apache/flink/pull/12221#discussion_r427009783 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java ## @@ -126,9 +128,20

[GitHub] [flink] flinkbot commented on pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-18 Thread GitBox
flinkbot commented on pull request #12237: URL: https://github.com/apache/flink/pull/12237#issuecomment-630556678 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-17290) Translate Streaming Analytics training lesson to Chinese

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17290: --- Labels: pull-request-available (was: ) > Translate Streaming Analytics training lesson to C

[GitHub] [flink] twentyworld opened a new pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-18 Thread GitBox
twentyworld opened a new pull request #12237: URL: https://github.com/apache/flink/pull/12237 This PR is used to translate Flink tutorials page to Chinese, as no test should be involved. It cost a lot of time to weigh every sentence to prevent my translation from causing confusion

[GitHub] [flink] flinkbot edited a comment on pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

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

[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-18 Thread GitBox
flinkbot edited a comment on pull request #12236: URL: https://github.com/apache/flink/pull/12236#issuecomment-630547436 ## CI report: * c3caf6974bdf8298376d150b00fd7e7125089986 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

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

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

2020-05-18 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110805#comment-17110805 ] Echo Lee edited comment on FLINK-17745 at 5/19/20, 3:08 AM:

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

2020-05-18 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110805#comment-17110805 ] Echo Lee commented on FLINK-17745: -- [~kkl0u] I don't think nested jar should be removed

[GitHub] [flink] yangyichao-mango commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

2020-05-18 Thread GitBox
yangyichao-mango commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-630550918 That is the result of check_links.sh. 找到 1 个死链接。 http://localhost:4000/zh/ops/memory/mem_detail.html When I try to fix http://localhost:4000/zh/ops/memor

[GitHub] [flink] klion26 commented on a change in pull request #12139: [FLINK-16076] Translate "Queryable State" page into Chinese

2020-05-18 Thread GitBox
klion26 commented on a change in pull request #12139: URL: https://github.com/apache/flink/pull/12139#discussion_r426997228 ## File path: docs/dev/stream/state/queryable_state.zh.md ## @@ -27,75 +27,54 @@ under the License. {:toc} - Note: The client APIs for queryable sta

[jira] [Closed] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

2020-05-18 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-15813. --- Resolution: Fixed done via master b425c05d57ace5cf27591dbd6798b6131211f6c1 release-1.1 6fa0c92567a9d8163

  1   2   3   4   5   6   7   8   9   >