[jira] [Updated] (FLINK-22328) Failed to send data to Kafka: Producer attempted an operation with an old epoch

[ https://issues.apache.org/jira/browse/FLINK-22328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙峰 updated FLINK-22328: --- Environment: kafka 3.0.0 Flink 1.11.1 was:kafka 3.0.0 Labels: Transactional kafka (was: ) > Failed t

[jira] [Created] (FLINK-22328) Failed to send data to Kafka: Producer attempted an operation with an old epoch

孙峰 created FLINK-22328: -- Summary: Failed to send data to Kafka: Producer attempted an operation with an old epoch Key: FLINK-22328 URL: https://issues.apache.org/jira/browse/FLINK-22328 Project: Flink

[jira] [Updated] (FLINK-22305) Improve log messages of sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22305: Summary: Improve log messages of sort-merge blocking shuffle (was: Improve log message of sort-me

[jira] [Updated] (FLINK-22305) Improve log message of sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22305: Summary: Improve log message of sort-merge blocking shuffle (was: Increase the default value of t

[jira] [Commented] (FLINK-22305) Increase the default value of taskmanager.network.sort-shuffle.min-buffers

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324181#comment-17324181 ] Yingjie Cao commented on FLINK-22305: - After some tests, I find that increasing this

[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 Azure: [PENDING](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17324168#comment-17324168 ] Yuan Mei edited comment on FLINK-22239 at 4/17/21, 5:30 AM:

[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&focusedCommentId=17324168#comment-17324168 ] Yuan Mei edited comment on FLINK-22239 at 4/17/21, 5:29 AM:

[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&focusedCommentId=17324171#comment-17324171 ] Maciej Bryński commented on FLINK-22311: This is the log. I have few duplicate r

[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 @flinkbo

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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 sort-merge

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17324168#comment-17324168 ] Yuan Mei commented on FLINK-22239: -- I am reviewing the fix-PR, With FLINK-22311, I sug

[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&focusedCommentId=17324166#comment-17324166 ] Yuan Mei edited comment on FLINK-22141 at 4/17/21, 4:01 AM:

[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&focusedCommentId=17324166#comment-17324166 ] Yuan Mei commented on FLINK-22141: -- [~maver1ck] Thanks so much for reporting this. > M

[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&focusedCommentId=17324164#comment-17324164 ] Yingjie Cao commented on FLINK-16012: - I am still working on it. > Reduce the defau

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

[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&focusedCommentId=17324161#comment-17324161 ] Yingjie Cao commented on FLINK-21788: - I am still working on it. > Throw PartitionN

[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&focusedCommentId=17324162#comment-17324162 ] Yingjie Cao commented on FLINK-16641: - I am still working on it. > Announce sender'

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

[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: fd8e34c03b663aff96a625ed751b66244

[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, plea

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

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

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

[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, plea

[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, plea

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[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&focusedCommentId=17324118#comment-17324118 ] Flink Jira Bot commented on FLINK-14763: This issue is assigned but has not rece

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

[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&focusedCommentId=17324119#comment-17324119 ] Flink Jira Bot commented on FLINK-14361: This issue is assigned but has not rece

[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&focusedCommentId=17324117#comment-17324117 ] Flink Jira Bot commented on FLINK-16032: This issue is assigned but has not rece

[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] [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&focusedCommentId=17324116#comment-17324116 ] Flink Jira Bot commented on FLINK-16568: This issue is assigned but has not rece

[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-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&focusedCommentId=17324115#comment-17324115 ] Flink Jira Bot commented on FLINK-16688: This issue is assigned but has not rece

[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&focusedCommentId=17324114#comment-17324114 ] Flink Jira Bot commented on FLINK-17964: This issue is assigned but has not rece

[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&focusedCommentId=17324111#comment-17324111 ] Flink Jira Bot commented on FLINK-20484: This issue is assigned but has not rece

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

[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&focusedCommentId=17324112#comment-17324112 ] Flink Jira Bot commented on FLINK-19739: This issue is assigned but has not rece

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

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

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

[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&focusedCommentId=17324109#comment-17324109 ] Flink Jira Bot commented on FLINK-21073: This issue is assigned but has not rece

[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&focusedCommentId=17324113#comment-17324113 ] Flink Jira Bot commented on FLINK-18701: This issue is assigned but has not rece

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

[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&focusedCommentId=17324105#comment-17324105 ] Flink Jira Bot commented on FLINK-21613: This issue is assigned but has not rece

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

[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&focusedCommentId=17324110#comment-17324110 ] Flink Jira Bot commented on FLINK-20951: This issue is assigned but has not rece

[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&focusedCommentId=17324107#comment-17324107 ] Flink Jira Bot commented on FLINK-21301: This issue is assigned but has not rece

[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&focusedCommentId=17324106#comment-17324106 ] Flink Jira Bot commented on FLINK-21519: This issue is assigned but has not rece

[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&focusedCommentId=17324103#comment-17324103 ] Flink Jira Bot commented on FLINK-21667: This issue is assigned but has not rece

[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&focusedCommentId=17324108#comment-17324108 ] Flink Jira Bot commented on FLINK-21224: This issue is assigned but has not rece

[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&focusedCommentId=17324104#comment-17324104 ] Flink Jira Bot commented on FLINK-21637: This issue is assigned but has not rece

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

[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&focusedCommentId=17324102#comment-17324102 ] Flink Jira Bot commented on FLINK-21962: This issue is assigned but has not rece

[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&focusedCommentId=17324101#comment-17324101 ] Flink Jira Bot commented on FLINK-22036: This issue is assigned but has not rece

[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&focusedCommentId=17324100#comment-17324100 ] Flink Jira Bot commented on FLINK-22128: This issue is assigned but has not rece

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

[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&focusedCommentId=17324096#comment-17324096 ] Dian Fu edited comment on FLINK-22297 at 4/16/21, 10:22 PM:

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

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

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

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

[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&focusedCommentId=17324096#comment-17324096 ] Dian Fu commented on FLINK-22297: - After debugging of this problem, I found that the iss

[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: Flink

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

[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, p

[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&focusedCommentId=17324083#comment-17324083 ] Till Rohrmann commented on FLINK-22276: --- Temporary workaround merged via fe41a87d3

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17324045#comment-17324045 ] Lu Niu commented on FLINK-22326: This is a bit urgent on our side. Please let me know ho

  1   2   3   4   5   6   7   8   9   10   >