[GitHub] [flink] flinkbot commented on pull request #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

2020-06-02 Thread GitBox
flinkbot commented on pull request #12450: URL: https://github.com/apache/flink/pull/12450#issuecomment-637826630 ## CI report: * 56691cd5ec9a8bdffbb1b8df8cb85f89be3004a2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

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

[GitHub] [flink] flinkbot commented on pull request #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

2020-06-02 Thread GitBox
flinkbot commented on pull request #12450: URL: https://github.com/apache/flink/pull/12450#issuecomment-637818796 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-18076) Sql client uses wrong class loader when parsing queries

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18076: - Description: Sql-client when parsing queries does not use the user class loader from {{

[jira] [Updated] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18075: --- Labels: pull-request-available (was: ) > Kafka connector does not call open method of (de)s

[GitHub] [flink] dawidwys commented on pull request #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

2020-06-02 Thread GitBox
dawidwys commented on pull request #12450: URL: https://github.com/apache/flink/pull/12450#issuecomment-637810726 cc @aljoscha @sjwiesman This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] dawidwys opened a new pull request #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

2020-06-02 Thread GitBox
dawidwys opened a new pull request #12450: URL: https://github.com/apache/flink/pull/12450 ## What is the purpose of the change The open method of SerializationSchema was not called in the universal Kafka producer. ## Verifying this change I verified it by writing rec

[jira] [Created] (FLINK-18076) Sql client uses wrong class loader when parsing queries

2020-06-02 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-18076: Summary: Sql client uses wrong class loader when parsing queries Key: FLINK-18076 URL: https://issues.apache.org/jira/browse/FLINK-18076 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

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

[jira] [Commented] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

2020-06-02 Thread Rong Rong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124277#comment-17124277 ] Rong Rong commented on FLINK-18045: --- yeah. that makes sense. +1 on the proposed soluti

[jira] [Assigned] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-18075: Assignee: Dawid Wysakowicz > Kafka connector does not call open method of (de)ser

[GitHub] [flink] flinkbot edited a comment on pull request #12449: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12449: URL: https://github.com/apache/flink/pull/12449#issuecomment-637766783 ## CI report: * 6b8472f55ee2fdddeaa353c6bfb5acce2b834589 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12448: [FLINK-18051][AZP] Fail Maven setup stage on error

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

[GitHub] [flink] sjwiesman commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-06-02 Thread GitBox
sjwiesman commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r434134153 ## File path: docs/dev/table/connectors/filesystem.zh.md ## @@ -0,0 +1,359 @@ +--- +title: "FileSystem Connector" +nav-title: FileSystem Connector +nav-

[GitHub] [flink] flinkbot commented on pull request #12449: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

2020-06-02 Thread GitBox
flinkbot commented on pull request #12449: URL: https://github.com/apache/flink/pull/12449#issuecomment-637766783 ## CI report: * 6b8472f55ee2fdddeaa353c6bfb5acce2b834589 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

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

[jira] [Commented] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

2020-06-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124249#comment-17124249 ] Seth Wiesman commented on FLINK-18056: -- [~gaoyunhaii] [~jinsong] I also observed t

[jira] [Commented] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable

2020-06-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124247#comment-17124247 ] Seth Wiesman commented on FLINK-18073: -- Update, I can confirm the issue also exists

[jira] [Created] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema

2020-06-02 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18075: Summary: Kafka connector does not call open method of (de)serialization schema Key: FLINK-18075 URL: https://issues.apache.org/jira/browse/FLINK-18075 Project: Flink

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

2020-06-02 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-17800: - Priority: Blocker (was: Critical) > RocksDB optimizeForPointLookup results in missing time wind

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124242#comment-17124242 ] Robert Metzger commented on FLINK-17260: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-17637) HadoopS3RecoverableWriterITCase fails with Expected exception: java.io.FileNotFoundException

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124238#comment-17124238 ] Robert Metzger commented on FLINK-17637: Travis in the release 1.10 branch: htt

[jira] [Updated] (FLINK-17637) HadoopS3RecoverableWriterITCase fails with Expected exception: java.io.FileNotFoundException

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17637: --- Affects Version/s: 1.10.2 > HadoopS3RecoverableWriterITCase fails with Expected exception:

[jira] [Commented] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

2020-06-02 Thread Bart Krasinski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124237#comment-17124237 ] Bart Krasinski commented on FLINK-18045: Honestly at first I was thinking about

[GitHub] [flink] flinkbot edited a comment on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-637634184 ## CI report: * 38922d36f2a8b5aa25ca882dfb2b89d0963ccaf4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-636063842 ## CI report: * 0c7efdd8b719ab6267cb70435f5ce43fbecbe105 UNKNOWN * d31906be96d953c66880832c12bb6a0fa161c69b Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12448: [FLINK-18051][AZP] Fail Maven setup stage on error

2020-06-02 Thread GitBox
flinkbot commented on pull request #12448: URL: https://github.com/apache/flink/pull/12448#issuecomment-637753717 ## CI report: * e5efa321d462aeb3aba4fd1db32d59b1024e7add UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

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

[GitHub] [flink] flinkbot edited a comment on pull request #12446: [FLINK-16225] Implement user class loading exception handler

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12446: URL: https://github.com/apache/flink/pull/12446#issuecomment-637647665 ## CI report: * 2dc640e5a98af1e9a066b86d539f5f48c06256b0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12449: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

2020-06-02 Thread GitBox
flinkbot commented on pull request #12449: URL: https://github.com/apache/flink/pull/12449#issuecomment-637751985 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-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid in Hadoop 3 build profile

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17404: --- Fix Version/s: 1.11.0 > Running HA per-job cluster (rocks, non-incremental) gets stuck killi

[jira] [Updated] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid in Hadoop 3 build profile

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17404: --- Labels: pull-request-available test-stability (was: test-stability) > Running HA per-job cl

[GitHub] [flink] rmetzger opened a new pull request #12449: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

2020-06-02 Thread GitBox
rmetzger opened a new pull request #12449: URL: https://github.com/apache/flink/pull/12449 Due to the recent changes in https://issues.apache.org/jira/browse/FLINK-11086 ("Add support for Hadoop 3"), the shaded netty dependency in flink-runtime changed depending on the Hadoop dependency

[GitHub] [flink] flinkbot commented on pull request #12448: [FLINK-18051][AZP] Fail Maven setup stage on error

2020-06-02 Thread GitBox
flinkbot commented on pull request #12448: URL: https://github.com/apache/flink/pull/12448#issuecomment-637747386 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-18051) Fail Maven setup on AZP if download fails

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18051: --- Labels: pull-request-available (was: ) > Fail Maven setup on AZP if download fails > --

[GitHub] [flink] rmetzger opened a new pull request #12448: [FLINK-18051][AZP] Fail Maven setup stage on error

2020-06-02 Thread GitBox
rmetzger opened a new pull request #12448: URL: https://github.com/apache/flink/pull/12448 ## What is the purpose of the change Before this change, the e2e test were failing with a cryptic error message, when the maven setup failed (for example because the certificate of the

[GitHub] [flink] rmetzger commented on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-02 Thread GitBox
rmetzger commented on pull request #12447: URL: https://github.com/apache/flink/pull/12447#issuecomment-637745380 Note: This PR depends on https://github.com/apache/flink/pull/12443 :) This is an automated message from the A

[GitHub] [flink] flinkbot commented on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-02 Thread GitBox
flinkbot commented on pull request #12447: URL: https://github.com/apache/flink/pull/12447#issuecomment-637744551 ## CI report: * cc6305f57a1171863414ac5d61226d0875a5cdf4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-02 Thread GitBox
flinkbot commented on pull request #12447: URL: https://github.com/apache/flink/pull/12447#issuecomment-637738145 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] rmetzger opened a new pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

2020-06-02 Thread GitBox
rmetzger opened a new pull request #12447: URL: https://github.com/apache/flink/pull/12447 # What is the purpose of the change We are currently only checking if the Scaladocs are passing when building the flink docs on buildbot. With this change, we are checking if generating the

[jira] [Commented] (FLINK-18069) Scaladocs not building since inner Java interfaces cannot be recognized

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124181#comment-17124181 ] Robert Metzger commented on FLINK-18069: As part of this ticket, I will open a s

[GitHub] [flink] kl0u commented on a change in pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
kl0u commented on a change in pull request #12412: URL: https://github.com/apache/flink/pull/12412#discussion_r434086063 ## File path: flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java ## @@ -49,4 +53,158 @@ */ @Override

[GitHub] [flink] rmetzger commented on a change in pull request #12446: [FLINK-16225] Implement user class loading exception handler

2020-06-02 Thread GitBox
rmetzger commented on a change in pull request #12446: URL: https://github.com/apache/flink/pull/12446#discussion_r43408 ## File path: azure-pipelines.yml ## @@ -61,7 +61,107 @@ variables: jobs: - template: tools/azure-pipelines/jobs-template.yml parameters: # see

[GitHub] [flink] flinkbot edited a comment on pull request #12428: [FLINK-18049] the AvroRowDeserializationSchema can not read the avro …

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

[jira] [Closed] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

2020-06-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-16057. -- Resolution: Fixed Merged to release-1.11 as 6551b6b592..e514c71b09 and to master as 78b4e3da

[GitHub] [flink] pnowojski merged pull request #12401: [FLINK-16057] Optimize ContinuousFileReaderOperator

2020-06-02 Thread GitBox
pnowojski merged pull request #12401: URL: https://github.com/apache/flink/pull/12401 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 t

[jira] [Commented] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable

2020-06-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124092#comment-17124092 ] Seth Wiesman commented on FLINK-18073: -- I did a cursory search of the serialization

[GitHub] [flink] dawidwys commented on a change in pull request #12411: [FLINK-18005][table] Implement type inference for CAST

2020-06-02 Thread GitBox
dawidwys commented on a change in pull request #12411: URL: https://github.com/apache/flink/pull/12411#discussion_r434029476 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/TypeStrategiesTest.java ## @@ -113,37 +113,60 @@

[jira] [Commented] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out

2020-06-02 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124060#comment-17124060 ] Yun Tang commented on FLINK-18074: -- [~pnowojski] What do you think of this problem? I c

[jira] [Created] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out

2020-06-02 Thread Yun Tang (Jira)
Yun Tang created FLINK-18074: Summary: Confirm checkpoint completed on task side would not fail the task if exception thrown out Key: FLINK-18074 URL: https://issues.apache.org/jira/browse/FLINK-18074 Pro

[jira] [Commented] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable

2020-06-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124054#comment-17124054 ] Seth Wiesman commented on FLINK-18073: -- cc [~twalthr] [~jark] > AvroRowDataSeriali

[jira] [Created] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable

2020-06-02 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18073: Summary: AvroRowDataSerializationSchema is not always serializable Key: FLINK-18073 URL: https://issues.apache.org/jira/browse/FLINK-18073 Project: Flink Iss

[GitHub] [flink] flinkbot edited a comment on pull request #12443: [FLINK-18069] [scala, docs] Scaladocs 2.12 fails to recognize inner interfaces

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

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-636063842 ## CI report: * 0461a736a590e75496c19176292fb96dcd148196 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12442: [FLINK-12428][docs-zh] Translate the "Event Time" page into Chinese

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12442: URL: https://github.com/apache/flink/pull/12442#issuecomment-637524638 ## CI report: * 299e411050af80788def253e928c44865483f1b3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12446: [FLINK-16225] Implement user class loading exception handler

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

[GitHub] [flink] flinkbot edited a comment on pull request #12417: [hotfix][docs] Remove the redundant punctuation in dev/training/index.md

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12417: URL: https://github.com/apache/flink/pull/12417#issuecomment-636417776 ## CI report: * 97a36238a06f1fb8ad4fe48f0fdf30a6623ec567 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-636063842 ## CI report: * 55b61138a63ce9fde288910e00e533798c8cbaec Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18068) Job scheduling stops but not exits after throwing non-fatal exception

2020-06-02 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123980#comment-17123980 ] Andrey Zagrebin edited comment on FLINK-18068 at 6/2/20, 4:11 PM:

[jira] [Commented] (FLINK-18068) Job scheduling stops but not exits after throwing non-fatal exception

2020-06-02 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123980#comment-17123980 ] Andrey Zagrebin commented on FLINK-18068: - [~wind_ljy] There is a timeout but on

[GitHub] [flink] flinkbot commented on pull request #12446: [FLINK-16225] Implement user class loading exception handler

2020-06-02 Thread GitBox
flinkbot commented on pull request #12446: URL: https://github.com/apache/flink/pull/12446#issuecomment-637647665 ## CI report: * 2dc640e5a98af1e9a066b86d539f5f48c06256b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-636063842 ## CI report: * 55b61138a63ce9fde288910e00e533798c8cbaec Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12439: [FLINK-17776][hive][doc] Add documentation for DDL&DML in hive dialect

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12439: URL: https://github.com/apache/flink/pull/12439#issuecomment-637513668 ## CI report: * a8e8962ad90e67b78240a2a9023e15dec1df UNKNOWN * 723262421f8fbf9a4b86639ef8be6d6651f26bba Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-637634184 ## CI report: * 38922d36f2a8b5aa25ca882dfb2b89d0963ccaf4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12411: [FLINK-18005][table] Implement type inference for CAST

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12411: URL: https://github.com/apache/flink/pull/12411#issuecomment-63596 ## CI report: * 26fa4d87100fbf2604c4d92df360e1020d3e38dc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123960#comment-17123960 ] Dawid Wysakowicz commented on FLINK-18049: -- Have you verified that it can work

[jira] [Commented] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

2020-06-02 Thread ZhuShang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123949#comment-17123949 ] ZhuShang commented on FLINK-18037: -- [~jark] [~lzljs3620320] > The doc of StreamTaskNet

[GitHub] [flink] flinkbot edited a comment on pull request #12438: [FLINK-17992][checkpointing] Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12438: URL: https://github.com/apache/flink/pull/12438#issuecomment-637482992 ## CI report: * 2e5eee9964e83d15c823b3865f8d15bd295d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-02 Thread GitBox
flinkbot commented on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-637634184 ## CI report: * 38922d36f2a8b5aa25ca882dfb2b89d0963ccaf4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] azagrebin commented on pull request #12446: [FLINK-16225] Implement user class loading exception handler

2020-06-02 Thread GitBox
azagrebin commented on pull request #12446: URL: https://github.com/apache/flink/pull/12446#issuecomment-637634003 About the approaches: - **The inheritance approach** looks simple and reliable but ugly from oop/maintenance perspective but acceptable if there is no better idea

[GitHub] [flink] flinkbot edited a comment on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

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

[GitHub] [flink] flinkbot edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN * 59c44869c548ce9b1930d5b742a6f2c256c5a5b5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12411: [FLINK-18005][table] Implement type inference for CAST

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

[GitHub] [flink] flinkbot edited a comment on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-636063842 ## CI report: * 55b61138a63ce9fde288910e00e533798c8cbaec Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12446: [FLINK-16225] Implement user class loading exception handler

2020-06-02 Thread GitBox
flinkbot commented on pull request #12446: URL: https://github.com/apache/flink/pull/12446#issuecomment-637633353 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] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123939#comment-17123939 ] Zheng Hu commented on FLINK-18049: -- > The Flink's documentation refers to "Avro type st

[GitHub] [flink] azagrebin opened a new pull request #12446: [FLINK-16225] Implement user class loading exception handler

2020-06-02 Thread GitBox
azagrebin opened a new pull request #12446: URL: https://github.com/apache/flink/pull/12446 ## What is the purpose of the change Currently, if - the JVM Metaspace OOM happens in user class loader in user threads - and the OOM is not handled properly and forwarded to the task th

[jira] [Updated] (FLINK-16225) Metaspace Out Of Memory should be handled as Fatal Error in TaskManager

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16225: --- Labels: pull-request-available usability (was: usability) > Metaspace Out Of Memory should

[jira] [Created] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData

2020-06-02 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18072: -- Summary: HBaseLookupFunction can not work with new internal data structure RowData Key: FLINK-18072 URL: https://issues.apache.org/jira/browse/FLINK-18072 Project: Flink

[jira] [Comment Edited] (FLINK-15363) Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4)

2020-06-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123928#comment-17123928 ] Leonard Xu edited comment on FLINK-15363 at 6/2/20, 3:29 PM: -

[jira] [Commented] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

2020-06-02 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123931#comment-17123931 ] Stephan Ewen commented on FLINK-17723: -- One more thought: Some NullPointerExceptio

[jira] [Resolved] (FLINK-15363) Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4)

2020-06-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-15363. Resolution: Fixed > Hbase connector do not support datatypes with precision like TIMESTAMP(9) and

[GitHub] [flink] flinkbot commented on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-02 Thread GitBox
flinkbot commented on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-637614173 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] [Commented] (FLINK-15363) Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4)

2020-06-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123928#comment-17123928 ] Leonard Xu commented on FLINK-15363: After we replaced `TypeInformation` with `DataT

[GitHub] [flink] dawidwys opened a new pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-02 Thread GitBox
dawidwys opened a new pull request #12445: URL: https://github.com/apache/flink/pull/12445 ## What is the purpose of the change We always overwrite the RestClientFactory in order to workaround an issue with shading classes in lambdas deserialization method. That way we never use

[GitHub] [flink] dawidwys commented on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

2020-06-02 Thread GitBox
dawidwys commented on pull request #12445: URL: https://github.com/apache/flink/pull/12445#issuecomment-637611810 cc @wuchong @twalthr This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Updated] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18006: --- Labels: pull-request-available (was: ) > It will throw Invalid lambda deserialization Excep

[jira] [Commented] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

2020-06-02 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123927#comment-17123927 ] Stephan Ewen commented on FLINK-17723: -- We have a bigger effort to rewrite major pa

[jira] [Commented] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

2020-06-02 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123926#comment-17123926 ] Stephan Ewen commented on FLINK-17723: -- *TL;DR The threading model is single-thread

[GitHub] [flink] aljoscha commented on pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

2020-06-02 Thread GitBox
aljoscha commented on pull request #12412: URL: https://github.com/apache/flink/pull/12412#issuecomment-637610435 I think I addressed all the comments, please take another look. This is an automated message from the Apache Gi

[jira] [Commented] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123924#comment-17123924 ] Dawid Wysakowicz commented on FLINK-18006: -- It turned out to be more complicate

[GitHub] [flink] flinkbot edited a comment on pull request #12411: [FLINK-18005][table] Implement type inference for CAST

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

[GitHub] [flink] flinkbot edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN * 59c44869c548ce9b1930d5b742a6f2c256c5a5b5 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] azagrebin commented on a change in pull request #11245: [FLINK-15794][Kubernetes] Generate the Kubernetes default image version

2020-06-02 Thread GitBox
azagrebin commented on a change in pull request #11245: URL: https://github.com/apache/flink/pull/11245#discussion_r433950543 ## File path: docs/ops/deployment/kubernetes.md ## @@ -262,7 +262,7 @@ spec: spec: containers: - name: jobmanager -image: fli

[jira] [Comment Edited] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123909#comment-17123909 ] Dawid Wysakowicz edited comment on FLINK-18049 at 6/2/20, 3:07 PM: ---

[jira] [Comment Edited] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123909#comment-17123909 ] Dawid Wysakowicz edited comment on FLINK-18049 at 6/2/20, 3:06 PM: ---

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123909#comment-17123909 ] Dawid Wysakowicz commented on FLINK-18049: -- The Flink's documentation refers to

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123902#comment-17123902 ] Zheng Hu commented on FLINK-18049: -- Thanks for your reply, [~dwysakowicz]. I read the

[GitHub] [flink] flinkbot commented on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
flinkbot commented on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12441: [FLINK-17918][table-blink] Fix AppendOnlyTopNFunction shouldn't mutate list value of MapState

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

<    1   2   3   4   5   6   7   >