[GitHub] [flink] flinkbot edited a comment on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

flinkbot edited a comment on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-817675895 ## CI report: * 567f33cdbb0bcba800140cecb357c294800e7dfc Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324168#comment-17324168 ] Yuan Mei edited comment on FLINK-22239 at 4/17/21, 5:30 AM: I am reviewing

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

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324168#comment-17324168 ] Yuan Mei edited comment on FLINK-22239 at 4/17/21, 5:29 AM: I am reviewing

[jira] [Commented] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working

[ https://issues.apache.org/jira/browse/FLINK-22311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324171#comment-17324171 ] Maciej Bryński commented on FLINK-22311: This is the log. I have few duplicate records with 

[GitHub] [flink] flinkbot edited a comment on pull request #15651: [FLINK-22307][network] Increase the data writing cache size of sort-merge blocking shuffle

flinkbot edited a comment on pull request #15651: URL: https://github.com/apache/flink/pull/15651#issuecomment-821767454 ## CI report: * 3d65a719c16d9aaf8a44f843e2e21d1719947559 UNKNOWN * c840d852f79ed239c164c4809f36529bed7ffe5d UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

flinkbot edited a comment on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-817675895 ## CI report: * 567f33cdbb0bcba800140cecb357c294800e7dfc Azure:

[GitHub] [flink] flinkbot commented on pull request #15651: [FLINK-22307][network] Increase the data writing cache size of sort-merge blocking shuffle

flinkbot commented on pull request #15651: URL: https://github.com/apache/flink/pull/15651#issuecomment-821767454 ## CI report: * 3d65a719c16d9aaf8a44f843e2e21d1719947559 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15650: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot edited a comment on pull request #15650: URL: https://github.com/apache/flink/pull/15650#issuecomment-821690895 ## CI report: * 4387620cbddec2fdc5bab18a8ac1db4883a48e09 Azure:

[GitHub] [flink] flinkbot commented on pull request #15651: [FLINK-22307][network] Increase the data writing cache size of sort-merge blocking shuffle

flinkbot commented on pull request #15651: URL: https://github.com/apache/flink/pull/15651#issuecomment-821765833 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22307) Increase the data writing cache size of sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22307: --- Labels: pull-request-available (was: ) > Increase the data writing cache size of

[GitHub] [flink] wsry opened a new pull request #15651: [FLINK-22307][network] Increase the data writing cache size of sort-merge blocking shuffle

wsry opened a new pull request #15651: URL: https://github.com/apache/flink/pull/15651 ## What is the purpose of the change Currently, the data writing cache of sort-merge blocking shuffle is 8M, which can be not enough if data compression is enabled. This patch increases the cache

[GitHub] [flink] flinkbot edited a comment on pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot edited a comment on pull request #15649: URL: https://github.com/apache/flink/pull/15649#issuecomment-821690480 ## CI report: * f432e9a62391d3896739928c26434f09027aa5ff Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324168#comment-17324168 ] Yuan Mei commented on FLINK-22239: -- I am reviewing the fix-PR, With FLINK-22311, I suggest releasing

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

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324166#comment-17324166 ] Yuan Mei edited comment on FLINK-22141 at 4/17/21, 4:01 AM: [~maver1ck]

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

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324166#comment-17324166 ] Yuan Mei commented on FLINK-22141: -- [~maver1ck] Thanks so much for reporting this. > Manually test

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Labels: pull-request-available (was: pull-request-available stale-assigned) > Reduce the default

[jira] [Commented] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324164#comment-17324164 ] Yingjie Cao commented on FLINK-16012: - I am still working on it. > Reduce the default number of

[jira] [Updated] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

[ https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16641: Labels: pull-request-available (was: pull-request-available stale-assigned) > Announce sender's

[jira] [Commented] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324161#comment-17324161 ] Yingjie Cao commented on FLINK-21788: - I am still working on it. > Throw PartitionNotFoundException

[jira] [Commented] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

[ https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324162#comment-17324162 ] Yingjie Cao commented on FLINK-16641: - I am still working on it. > Announce sender's backlog to

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-21788: Labels: pull-request-available (was: pull-request-available stale-assigned) > Throw

[jira] [Closed] (FLINK-20855) Calculating numBuckets exceeds the maximum value of int and got a negative number

[ https://issues.apache.org/jira/browse/FLINK-20855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20855. -- Resolution: Fixed Thanks [~hejiefang] for the contribution. Merged: 

[GitHub] [flink] KurtYoung merged pull request #14566: FLINK-20855 Calculating numBuckets exceeds the maximum value of int a…

KurtYoung merged pull request #14566: URL: https://github.com/apache/flink/pull/14566 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Closed] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22100. -- Resolution: Duplicate > BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no >

[jira] [Closed] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20254. -- Resolution: Duplicate > HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out >

[jira] [Closed] (FLINK-22129) OrcFileSystemITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22129. -- Resolution: Duplicate > OrcFileSystemITCase hangs on azure > -- > >

[jira] [Closed] (FLINK-22308) Fix CliTableauResultView print results after cancel in STREAMING mode

[ https://issues.apache.org/jira/browse/FLINK-22308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22308. -- Assignee: Shengkai Fang Resolution: Fixed fixed: e4a2738e8b9badf37eab4874109a3e49ad47a341 >

[jira] [Closed] (FLINK-22016) PushFilterIntoTableSourceScanRule fails to deal with NULLs

[ https://issues.apache.org/jira/browse/FLINK-22016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22016. -- Resolution: Fixed fixed: 1562ed02796798ad450b3d4a778974ec086e0419 >

[GitHub] [flink] KurtYoung merged pull request #15644: [FLINK-22308][sql-client] Fix CliTableauResultView print results afte…

KurtYoung merged pull request #15644: URL: https://github.com/apache/flink/pull/15644 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] KurtYoung merged pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

KurtYoung merged pull request #15570: URL: https://github.com/apache/flink/pull/15570 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

flinkbot edited a comment on pull request #15577: URL: https://github.com/apache/flink/pull/15577#issuecomment-817795011 ## CI report: * 83c5cb20c323f63788825df61646876ac185543e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot edited a comment on pull request #15649: URL: https://github.com/apache/flink/pull/15649#issuecomment-821690480 ## CI report: * f432e9a62391d3896739928c26434f09027aa5ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15650: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot edited a comment on pull request #15650: URL: https://github.com/apache/flink/pull/15650#issuecomment-821690895 ## CI report: * 4387620cbddec2fdc5bab18a8ac1db4883a48e09 Azure:

[GitHub] [flink] flinkbot commented on pull request #15650: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot commented on pull request #15650: URL: https://github.com/apache/flink/pull/15650#issuecomment-821690895 ## CI report: * 4387620cbddec2fdc5bab18a8ac1db4883a48e09 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot commented on pull request #15649: URL: https://github.com/apache/flink/pull/15649#issuecomment-821690480 ## CI report: * f432e9a62391d3896739928c26434f09027aa5ff UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-14763) flink sql cep parallelism error

[ https://issues.apache.org/jira/browse/FLINK-14763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324118#comment-17324118 ] Flink Jira Bot commented on FLINK-14763: This issue is assigned but has not received an update

[jira] [Closed] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-21996. > Transient RPC failure without TaskManager failure can lead to split > assignment loss >

[jira] [Resolved] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-21996. -- Resolution: Fixed Fixed in 1.13.0 via - de509fc2439c2cacb02c9caa40168b3765e84ceb -

[jira] [Commented] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

[ https://issues.apache.org/jira/browse/FLINK-14361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324119#comment-17324119 ] Flink Jira Bot commented on FLINK-14361: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-16032) Depends on core classifier hive-exec in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324117#comment-17324117 ] Flink Jira Bot commented on FLINK-16032: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

[ https://issues.apache.org/jira/browse/FLINK-14361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14361: --- Labels: stale-assigned (was: ) > Decorrelate subQuery fail when multi correlate in project

[jira] [Updated] (FLINK-14763) flink sql cep parallelism error

[ https://issues.apache.org/jira/browse/FLINK-14763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14763: --- Labels: stale-assigned (was: ) > flink sql cep parallelism error >

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

[ https://issues.apache.org/jira/browse/FLINK-16568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324116#comment-17324116 ] Flink Jira Bot commented on FLINK-16568: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-16688) Hive-connector should set SessionState for hive

[ https://issues.apache.org/jira/browse/FLINK-16688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324115#comment-17324115 ] Flink Jira Bot commented on FLINK-16688: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-16032) Depends on core classifier hive-exec in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16032: --- Labels: stale-assigned (was: ) > Depends on core classifier hive-exec in hive connector >

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

[ https://issues.apache.org/jira/browse/FLINK-16568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16568: --- Labels: stale-assigned (was: ) > Cannot call Hive UDAF that requires constant arguments >

[jira] [Updated] (FLINK-16688) Hive-connector should set SessionState for hive

[ https://issues.apache.org/jira/browse/FLINK-16688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16688: --- Labels: stale-assigned (was: ) > Hive-connector should set SessionState for hive >

[jira] [Commented] (FLINK-17964) Hivemodule does not support map type

[ https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324114#comment-17324114 ] Flink Jira Bot commented on FLINK-17964: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-17964) Hivemodule does not support map type

[ https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17964: --- Labels: stale-assigned (was: ) > Hivemodule does not support map type >

[jira] [Commented] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324111#comment-17324111 ] Flink Jira Bot commented on FLINK-20484: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

[ https://issues.apache.org/jira/browse/FLINK-21224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21224: --- Labels: stale-assigned (was: ) > Remove BatchExecExchange and StreamExecExchange, and

[jira] [Commented] (FLINK-19739) CompileException when windowing in batch mode: A method named "replace" is not declared in any enclosing class nor any supertype

[ https://issues.apache.org/jira/browse/FLINK-19739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324112#comment-17324112 ] Flink Jira Bot commented on FLINK-19739: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18701: --- Labels: stale-assigned (was: ) > NOT NULL constraint is not guaranteed when aggregation

[jira] [Updated] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21301: --- Labels: stale-assigned (was: ) > Decouple window aggregate allow lateness with state ttl

[jira] [Updated] (FLINK-21519) SQLClientHBaseITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21519: --- Labels: stale-assigned test-stability (was: test-stability) > SQLClientHBaseITCase hangs

[jira] [Commented] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324109#comment-17324109 ] Flink Jira Bot commented on FLINK-21073: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324113#comment-17324113 ] Flink Jira Bot commented on FLINK-18701: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-19739) CompileException when windowing in batch mode: A method named "replace" is not declared in any enclosing class nor any supertype

[ https://issues.apache.org/jira/browse/FLINK-19739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19739: --- Labels: stale-assigned (was: ) > CompileException when windowing in batch mode: A method

[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21637: --- Labels: stale-assigned (was: ) > Wrong results when filtering by timestamp type >

[jira] [Commented] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

[ https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324105#comment-17324105 ] Flink Jira Bot commented on FLINK-21613: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20951: --- Labels: stale-assigned (was: ) > IllegalArgumentException when reading Hive parquet table

[jira] [Commented] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324110#comment-17324110 ] Flink Jira Bot commented on FLINK-20951: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

[ https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21613: --- Labels: stale-assigned (was: ) > Parse Compute Column with `IN` expression throws NPE >

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20484: --- Labels: stale-assigned (was: ) > Improve hive temporal table exception >

[jira] [Commented] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324107#comment-17324107 ] Flink Jira Bot commented on FLINK-21301: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21073: --- Labels: pull-request-available stale-assigned (was: pull-request-available) > Mention that

[jira] [Commented] (FLINK-21519) SQLClientHBaseITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324106#comment-17324106 ] Flink Jira Bot commented on FLINK-21519: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-21667) Standby RM might remove resources from Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324103#comment-17324103 ] Flink Jira Bot commented on FLINK-21667: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

[ https://issues.apache.org/jira/browse/FLINK-21224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324108#comment-17324108 ] Flink Jira Bot commented on FLINK-21224: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324104#comment-17324104 ] Flink Jira Bot commented on FLINK-21637: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-21667) Standby RM might remove resources from Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21667: --- Labels: pull-request-available stale-assigned (was: pull-request-available) > Standby RM

[jira] [Updated] (FLINK-21962) SQL Group Windows do not work on Flink 1.11

[ https://issues.apache.org/jira/browse/FLINK-21962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21962: --- Labels: stale-assigned (was: ) > SQL Group Windows do not work on Flink 1.11 >

[jira] [Commented] (FLINK-21962) SQL Group Windows do not work on Flink 1.11

[ https://issues.apache.org/jira/browse/FLINK-21962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324102#comment-17324102 ] Flink Jira Bot commented on FLINK-21962: This issue is assigned but has not received an update

[jira] [Commented] (FLINK-22036) Document Jira Bot in Flink Confluence

[ https://issues.apache.org/jira/browse/FLINK-22036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324101#comment-17324101 ] Flink Jira Bot commented on FLINK-22036: This issue is assigned but has not received an update

[jira] [Updated] (FLINK-22036) Document Jira Bot in Flink Confluence

[ https://issues.apache.org/jira/browse/FLINK-22036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22036: --- Labels: stale-assigned (was: ) > Document Jira Bot in Flink Confluence >

[jira] [Updated] (FLINK-22128) Window aggregation should have unique keys

[ https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22128: --- Labels: stale-assigned (was: ) > Window aggregation should have unique keys >

[jira] [Commented] (FLINK-22128) Window aggregation should have unique keys

[ https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324100#comment-17324100 ] Flink Jira Bot commented on FLINK-22128: This issue is assigned but has not received an update

[GitHub] [flink] flinkbot commented on pull request #15650: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot commented on pull request #15650: URL: https://github.com/apache/flink/pull/15650#issuecomment-821627335 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

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

[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324096#comment-17324096 ] Dian Fu edited comment on FLINK-22297 at 4/16/21, 10:22 PM: After debugging

[GitHub] [flink] dianfu opened a new pull request #15650: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

dianfu opened a new pull request #15650: URL: https://github.com/apache/flink/pull/15650 ## What is the purpose of the change *This pull request sets bundleStarted to false even if it throws exception in finishBundle. Otherwise, if it throws exceptions in finishBundle during job

[GitHub] [flink] flinkbot commented on pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

flinkbot commented on pull request #15649: URL: https://github.com/apache/flink/pull/15649#issuecomment-821619638 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22327: --- Labels: pull-request-available (was: ) > NPE exception happens if it throws exception in

[GitHub] [flink] dianfu opened a new pull request #15649: [FLINK-22327][python] Set bundleStarted to false even if it throws exception in finishBundle

dianfu opened a new pull request #15649: URL: https://github.com/apache/flink/pull/15649 ## What is the purpose of the change *This pull request sets bundleStarted to false even if it throws exception in finishBundle. Otherwise, if it throws exceptions in finishBundle during job

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

[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324096#comment-17324096 ] Dian Fu commented on FLINK-22297: - After debugging of this problem, I found that the issue described in

[jira] [Created] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

Dian Fu created FLINK-22327: --- Summary: NPE exception happens if it throws exception in finishBundle during job shutdown Key: FLINK-22327 URL: https://issues.apache.org/jira/browse/FLINK-22327 Project:

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

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

[GitHub] [flink] tillrohrmann closed pull request #15648: [FLINK-22276][runtime] Adds workaround for FLINK-22276

tillrohrmann closed pull request #15648: URL: https://github.com/apache/flink/pull/15648 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

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

[ https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324083#comment-17324083 ] Till Rohrmann commented on FLINK-22276: --- Temporary workaround merged via

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

flinkbot edited a comment on pull request #15640: URL: https://github.com/apache/flink/pull/15640#issuecomment-820935727 ## CI report: * 1b352ff5dca37e0dcbbe704f94e95db91319fc77 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15647: fix typos

flinkbot edited a comment on pull request #15647: URL: https://github.com/apache/flink/pull/15647#issuecomment-821289177 ## CI report: * 44905b147315ec1f4abe9d4a72c7402fb8a7408d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15646: [FLINK-22325][runtime] Synchronize access to iterator when writing channel state

flinkbot edited a comment on pull request #15646: URL: https://github.com/apache/flink/pull/15646#issuecomment-821289074 ## CI report: * 6b27de1307c73279da31b6b4ab0ef15c96a58af7 Azure:

[GitHub] [flink-statefun] SiddiqueAhmad opened a new pull request #225: Update overview.md

SiddiqueAhmad opened a new pull request #225: URL: https://github.com/apache/flink-statefun/pull/225 extra tags -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For

[GitHub] [flink] flinkbot edited a comment on pull request #15577: [FLINK-22001] Forward exceptions thrown during initialization to the user

flinkbot edited a comment on pull request #15577: URL: https://github.com/apache/flink/pull/15577#issuecomment-817795011 ## CI report: * c5b5770a5bf28fe31662e99669771f453d2ccfe7 Azure:

[jira] [Commented] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324045#comment-17324045 ] Lu Niu commented on FLINK-22326: This is a bit urgent on our side. Please let me know how we can address

[jira] [Updated] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Niu updated FLINK-22326: --- Description: Job contains Iterate Operator will always fail on checkpoint. How to reproduce: 

[jira] [Updated] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Niu updated FLINK-22326: --- Description: Job contains Iterate Operator will always fail on checkpoint. How to reproduce: 

[jira] [Updated] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Niu updated FLINK-22326: --- Description: Job contains Iterate Operator will always fail on checkpoint. How to reproduce: 

[jira] [Updated] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Niu updated FLINK-22326: --- Attachment: Screen Shot 2021-04-16 at 12.40.34 PM.png > Job contains Iterate Operator always fails on

[jira] [Updated] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Niu updated FLINK-22326: --- Attachment: Screen Shot 2021-04-16 at 12.43.38 PM.png > Job contains Iterate Operator always fails on

[jira] [Created] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

Lu Niu created FLINK-22326: -- Summary: Job contains Iterate Operator always fails on Checkpoint Key: FLINK-22326 URL: https://issues.apache.org/jira/browse/FLINK-22326 Project: Flink Issue Type:

  1   2   3   4   5   6   7   8   9   10   >