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

[ 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

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

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-18073) AvroRowDataSerializationSchema is not always serializable

[ 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] pnowojski merged pull request #12401: [FLINK-16057] Optimize ContinuousFileReaderOperator

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] [Closed] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

[ 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] flinkbot edited a comment on pull request #12428: [FLINK-18049] the AvroRowDeserializationSchema can not read the avro …

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

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

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] kl0u commented on a change in pull request #12412: [FLINK-18011] Make WatermarkStrategy/WatermarkStrategies more ergonomic

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

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

[ 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] rmetzger opened a new pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

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

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

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] flinkbot commented on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

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] rmetzger commented on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

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] rmetzger opened a new pull request #12448: [FLINK-18051][AZP] Fail Maven setup stage on error

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

[jira] [Updated] (FLINK-18051) Fail Maven setup on AZP if download fails

[ 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] flinkbot commented on pull request #12448: [FLINK-18051][AZP] Fail Maven setup stage on error

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

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

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

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

[ 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

[ 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] flinkbot commented on pull request #12449: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

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

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

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 edited a comment on pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

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

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

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

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

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

[ 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

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

[ 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-17637) HadoopS3RecoverableWriterITCase fails with Expected exception: java.io.FileNotFoundException

[ 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] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ 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] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ 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-18073) AvroRowDataSerializationSchema is not always serializable

[ 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

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] [Commented] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

[ 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

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

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

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

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

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

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 edited a comment on pull request #12449: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

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

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

[ 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

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

[ 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

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

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] [Created] (FLINK-18076) Sql client uses wrong class loader when parsing queries

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] dawidwys opened a new pull request #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

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

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

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

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

[ 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

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

[ 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 {{

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

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

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

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

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 #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

flinkbot edited a comment on pull request #12450: URL: https://github.com/apache/flink/pull/12450#issuecomment-637826630 ## CI report: * 56691cd5ec9a8bdffbb1b8df8cb85f89be3004a2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #12449: URL: https://github.com/apache/flink/pull/12449#issuecomment-637766783 ## CI report: * 6b8472f55ee2fdddeaa353c6bfb5acce2b834589 Azure: [FAILURE](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

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

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

flinkbot edited a comment on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632360179 ## CI report: * b8e66f5b74af55d5ed6edb262170fd9a759f89d2 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124497#comment-17124497 ] Yun Gao commented on FLINK-18056: - Hi [~sjwiesman]is this error has the same stack with

[GitHub] [flink] dianfu closed pull request #12370: [FLINK-17923][python] Allow Python worker to use off-heap memory

dianfu closed pull request #12370: URL: https://github.com/apache/flink/pull/12370 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 #12450: [FLINK-18075] Call open method of SerializationSchema in Kafka producer

flinkbot edited a comment on pull request #12450: URL: https://github.com/apache/flink/pull/12450#issuecomment-637826630 ## CI report: * 56691cd5ec9a8bdffbb1b8df8cb85f89be3004a2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 3df97a6fdb130416fa447295f4ac7eb174be9cc4 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124514#comment-17124514 ] Dian Fu commented on FLINK-17923: - [~sewen] Thanks for the confirmation.  Merged to mas

[jira] [Closed] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17923. --- Resolution: Fixed > It will throw MemoryAllocationException if rocksdb statebackend and Python > UDF are us

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

wangyang0918 commented on a change in pull request #12444: URL: https://github.com/apache/flink/pull/12444#discussion_r434265825 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -508,7 +508,9 @@ public void killCluster(ApplicationId

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

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124530#comment-17124530 ] Seth Wiesman commented on FLINK-18056: -- Yes, it occured during a checkpoint while w

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

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124531#comment-17124531 ] Seth Wiesman commented on FLINK-18056: -- The job was running at parallelism > 1 if t

[GitHub] [flink] zhijiangW merged pull request #12438: [FLINK-17992][checkpointing] Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

zhijiangW merged pull request #12438: URL: https://github.com/apache/flink/pull/12438 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

[GitHub] [flink] wangyang0918 opened a new pull request #12451: [FLINK-17857][e2e] Fix Kubernetes and docker e2e tests on Mac OS

wangyang0918 opened a new pull request #12451: URL: https://github.com/apache/flink/pull/12451 ## What is the purpose of the change In FLINK-17656, we migrate all the e2e tests from flink-container/docker to apache/flink-docker. After the migration, when building a docker ima

[jira] [Comment Edited] (FLINK-17992) Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

[ https://issues.apache.org/jira/browse/FLINK-17992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119309#comment-17119309 ] Zhijiang edited comment on FLINK-17992 at 6/3/20, 2:33 AM: --- Me

[jira] [Updated] (FLINK-17857) Kubernetes and docker e2e tests could not run on Mac OS after migration

[ https://issues.apache.org/jira/browse/FLINK-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17857: --- Labels: pull-request-available (was: ) > Kubernetes and docker e2e tests could not run on M

[GitHub] [flink] flinkbot commented on pull request #12451: [FLINK-17857][e2e] Fix Kubernetes and docker e2e tests on Mac OS

flinkbot commented on pull request #12451: URL: https://github.com/apache/flink/pull/12451#issuecomment-637917385 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] JingsongLi merged pull request #12333: [FLINK-17937][hive] Change some hive connector tests to IT cases

JingsongLi merged pull request #12333: URL: https://github.com/apache/flink/pull/12333 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

[jira] [Updated] (FLINK-18021) Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18021: --- Priority: Blocker (was: Critical) > Manually tests for 1.11 SQL features >

[GitHub] [flink] gaoyunhaii opened a new pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

gaoyunhaii opened a new pull request #12452: URL: https://github.com/apache/flink/pull/12452 ## What is the purpose of the change Currently the Hadoop path-based file writer does not remove the in-progress file remaining from last run on startup. However, some users (like Hive) of th

[jira] [Closed] (FLINK-17937) Change some hive connector tests to IT cases

[ https://issues.apache.org/jira/browse/FLINK-17937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17937. Resolution: Fixed master: 21cb58625b607cf227cfd298595fdda3ed7c579a release-1.11: 636901c1e29b6337

[jira] [Updated] (FLINK-18021) Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18021: --- Summary: Manually tests for 1.11 SQL features (was: Complement tests for 1.11 SQL) > Manually test

[jira] [Updated] (FLINK-18021) Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18021: --- Priority: Critical (was: Major) > Manually tests for 1.11 SQL features > --

[GitHub] [flink] dianfu commented on a change in pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

dianfu commented on a change in pull request #12422: URL: https://github.com/apache/flink/pull/12422#discussion_r434276134 ## File path: flink-python/pyflink/table/tests/test_table_environment_api.py ## @@ -628,6 +628,15 @@ def test_table_environment_with_blink_planner(self):

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

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18056: --- Labels: pull-request-available (was: ) > Hive file sink throws exception when the target in

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

Jiayi-Liao commented on a change in pull request #12444: URL: https://github.com/apache/flink/pull/12444#discussion_r434277415 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -508,7 +508,9 @@ public void killCluster(ApplicationId a

[GitHub] [flink] flinkbot commented on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

flinkbot commented on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637919303 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] Jiayi-Liao commented on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

Jiayi-Liao commented on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637920335 @wangyang0918 Thanks for your review. I've addressed your comments and also update the description. Please take another look when you can spare time. --

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

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124542#comment-17124542 ] Yun Gao commented on FLINK-18056: - Hi [~sjwiesman] I'm a little confusing on the scenari

[jira] [Updated] (FLINK-18025) E2E tests manually for Hive streaming sink

[ https://issues.apache.org/jira/browse/FLINK-18025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18025: - Summary: E2E tests manually for Hive streaming sink (was: E2E tests manually for Hive integrate

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 3df97a6fdb130416fa447295f4ac7eb174be9cc4 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-18025) E2E tests manually for Hive streaming sink

[ https://issues.apache.org/jira/browse/FLINK-18025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18025: - Description: - hive streaming sink failover - hive streaming sink job re-run - hive streaming

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

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

[jira] [Created] (FLINK-18077) E2E tests manually for Hive streaming source

Jingsong Lee created FLINK-18077: Summary: E2E tests manually for Hive streaming source Key: FLINK-18077 URL: https://issues.apache.org/jira/browse/FLINK-18077 Project: Flink Issue Type: Sub-

[GitHub] [flink] flinkbot commented on pull request #12451: [FLINK-17857][e2e] Fix Kubernetes and docker e2e tests on Mac OS

flinkbot commented on pull request #12451: URL: https://github.com/apache/flink/pull/12451#issuecomment-637922585 ## CI report: * 4c93b68fa64dd913f53d69dad4eab467e78e6507 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

flinkbot commented on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124547#comment-17124547 ] Jark Wu commented on FLINK-18076: - >From the recently bug issues, it seems that it's urg

[jira] [Created] (FLINK-18078) E2E tests manually for Hive streaming dim join

Jingsong Lee created FLINK-18078: Summary: E2E tests manually for Hive streaming dim join Key: FLINK-18078 URL: https://issues.apache.org/jira/browse/FLINK-18078 Project: Flink Issue Type: Su

[jira] [Closed] (FLINK-17940) It will throw NullPointerException when write data with Avro format using new property key in SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-17940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17940. --- Fix Version/s: (was: 1.12.0) Resolution: Duplicate > It will throw NullPointerException when writ

[GitHub] [flink] danny0405 commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

danny0405 commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r434281449 ## File path: docs/dev/table/connectors/index.zh.md ## @@ -0,0 +1,268 @@ +--- +title: "Table & SQL Connectors" +nav-id: sql-connectors +nav-parent_id: c

[GitHub] [flink] flinkbot edited a comment on pull request #12451: [FLINK-17857][e2e] Fix Kubernetes and docker e2e tests on Mac OS

flinkbot edited a comment on pull request #12451: URL: https://github.com/apache/flink/pull/12451#issuecomment-637922585 ## CI report: * 4c93b68fa64dd913f53d69dad4eab467e78e6507 Azure: [PENDING](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…

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

[jira] [Created] (FLINK-18079) KafkaShuffle Manual Tests

Yuan Mei created FLINK-18079: Summary: KafkaShuffle Manual Tests Key: FLINK-18079 URL: https://issues.apache.org/jira/browse/FLINK-18079 Project: Flink Issue Type: Improvement Component

[GitHub] [flink] flinkbot edited a comment on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

flinkbot edited a comment on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18079) KafkaShuffle Manual Tests

[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18079: - Description: Manual Tests and Results to demonstrate KafkaShuffle working as expected. (was: Manual Tes

[jira] [Updated] (FLINK-16448) add documentation for Hive table source and sink parallelism setting strategy

[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16448: --- Priority: Critical (was: Major) > add documentation for Hive table source and sink parallelism sett

[jira] [Updated] (FLINK-16448) add documentation for Hive table source and sink parallelism setting strategy

[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16448: --- Component/s: Documentation > add documentation for Hive table source and sink parallelism setting st

[jira] [Updated] (FLINK-13866) develop testing plan for many Hive versions that we support

[ https://issues.apache.org/jira/browse/FLINK-13866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13866: --- Fix Version/s: (was: 1.11.0) > develop testing plan for many Hive versions that we support > ---

[jira] [Updated] (FLINK-17635) Add documentation about view support

[ https://issues.apache.org/jira/browse/FLINK-17635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17635: --- Priority: Blocker (was: Major) > Add documentation about view support > --

[jira] [Updated] (FLINK-14256) [Umbrella] Introduce FileSystemTableFactory with partitioned support

[ https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14256: --- Summary: [Umbrella] Introduce FileSystemTableFactory with partitioned support (was: Introduce FileS

<    1   2   3   4   5   6   7   >