[jira] [Commented] (FLINK-23390) FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed

[ https://issues.apache.org/jira/browse/FLINK-23390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398471#comment-17398471 ] Xintong Song commented on FLINK-23390: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] twalthr commented on pull request #16793: [FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment

twalthr commented on pull request #16793: URL: https://github.com/apache/flink/pull/16793#issuecomment-898236773 @flinkbot run azure -- 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

[jira] [Assigned] (FLINK-22751) Reduce JVM Metaspace memory for StateFun

[ https://issues.apache.org/jira/browse/FLINK-22751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-22751: --- Assignee: Tzu-Li (Gordon) Tai > Reduce JVM Metaspace memory for StateFun >

[jira] [Assigned] (FLINK-22752) Add robust default state configuration to StateFun

[ https://issues.apache.org/jira/browse/FLINK-22752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-22752: --- Assignee: Tzu-Li (Gordon) Tai > Add robust default state configuration to S

[jira] [Commented] (FLINK-23755) Modify the default value of table.dynamic-table-options.enabled to true

[ https://issues.apache.org/jira/browse/FLINK-23755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398472#comment-17398472 ] Ingo Bürk commented on FLINK-23755: --- Yes, please! +1 > Modify the default value of ta

[jira] [Commented] (FLINK-22752) Add robust default state configuration to StateFun

[ https://issues.apache.org/jira/browse/FLINK-22752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398473#comment-17398473 ] Tzu-Li (Gordon) Tai commented on FLINK-22752: - These are good suggestions. W

[GitHub] [flink] dmvk commented on a change in pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

dmvk commented on a change in pull request #16652: URL: https://github.com/apache/flink/pull/16652#discussion_r688292166 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStoreUtils.java ## @@ -0,0 +1,116 @@ +/* + * License

[jira] [Commented] (FLINK-22871) Support to execute PyFlink jobs in YARN application mode

[ https://issues.apache.org/jira/browse/FLINK-22871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398475#comment-17398475 ] Dian Fu commented on FLINK-22871: - [~wukong] Not sure if you are still working on this i

[GitHub] [flink] autophagy removed a comment on pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

autophagy removed a comment on pull request #16794: URL: https://github.com/apache/flink/pull/16794#issuecomment-898185254 @flinkbot run azure -- 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

[jira] [Created] (FLINK-23757) Support JSON methods in pyFlink

Ingo Bürk created FLINK-23757: - Summary: Support JSON methods in pyFlink Key: FLINK-23757 URL: https://issues.apache.org/jira/browse/FLINK-23757 Project: Flink Issue Type: Sub-task Comp

[GitHub] [flink] flinkbot commented on pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

flinkbot commented on pull request #16805: URL: https://github.com/apache/flink/pull/16805#issuecomment-898240944 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] dmvk commented on a change in pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

dmvk commented on a change in pull request #16652: URL: https://github.com/apache/flink/pull/16652#discussion_r688294526 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherFailoverITCase.java ## @@ -68,11 +67,20 @@ @Before public

[jira] [Created] (FLINK-23758) PyFlink __invert__ has wrong semantics

Ingo Bürk created FLINK-23758: - Summary: PyFlink __invert__ has wrong semantics Key: FLINK-23758 URL: https://issues.apache.org/jira/browse/FLINK-23758 Project: Flink Issue Type: Bug Co

[jira] [Updated] (FLINK-23755) Modify the default value of table.dynamic-table-options.enabled to true

[ https://issues.apache.org/jira/browse/FLINK-23755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23755: - Component/s: (was: API / Core) Table SQL / API > Modify the default value o

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][connector-kafka] FlinkKafkaProducerMigrationTest fails …

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

[GitHub] [flink] gaoyunhaii commented on pull request #16784: [FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished

gaoyunhaii commented on pull request #16784: URL: https://github.com/apache/flink/pull/16784#issuecomment-898243366 Very thanks Roman @rkhachatryan for the review! I also agree with that it would also be solved by not taking snapshot for the coordinator whose tasks are fully finished, and

[GitHub] [flink] flinkbot edited a comment on pull request #16590: [FLINK-19554][connector/testing-framework] Connector Testing Framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #16689: [FLINK-21290][table-planner] Support project push down for window TVF.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

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

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN * 6dba75fbedb5ad1651f267f976d20acab761

[GitHub] [flink] flinkbot edited a comment on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

flinkbot edited a comment on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-896705916 ## CI report: * bb43d8daea78de87fa0d1a504cee8141fe09cec8 UNKNOWN * 382dd2b528a35c32577de8f5107921157b79bb3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16793: [FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment

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

[GitHub] [flink] predatorray commented on pull request #16746: [FLINK-22452][docs] list the configuration methods of FlinkKafkaProducer and add ProducerFencedException in Troubleshooting

predatorray commented on pull request #16746: URL: https://github.com/apache/flink/pull/16746#issuecomment-898244311 @pnowojski Thanks for your review! -- 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

[GitHub] [flink] flinkbot commented on pull request #16804: [FLINK-23616][python] Support to chain the Python DataStream operators in execute_and_collect and print

flinkbot commented on pull request #16804: URL: https://github.com/apache/flink/pull/16804#issuecomment-898244461 ## CI report: * 8e9b78bebd8de5243624c32809fd06788e38fae5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] Myasuka commented on a change in pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

Myasuka commented on a change in pull request #16794: URL: https://github.com/apache/flink/pull/16794#discussion_r688299250 ## File path: docs/layouts/shortcodes/generated/rocksdb_configurable_configuration.html ## @@ -48,7 +48,7 @@ state.backend.rocksdb.compactio

[jira] [Created] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState

Arvid Heise created FLINK-23759: --- Summary: notifyCheckpointComplete without corresponding snapshotState Key: FLINK-23759 URL: https://issues.apache.org/jira/browse/FLINK-23759 Project: Flink I

[jira] [Updated] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState

[ https://issues.apache.org/jira/browse/FLINK-23759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23759: Description: In a private run on AZP, I found a run where {{notifyCheckpointComplete}} was invoke

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

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398481#comment-17398481 ] Yun Tang commented on FLINK-13598: -- [~WangHui] Since we decide to upgrade base version

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

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-13598: Assignee: Mika Naylor > frocksdb doesn't have arm release > -- >

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

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13598: - Fix Version/s: 1.14.0 > frocksdb doesn't have arm release > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13598: - Affects Version/s: (was: 2.0.0) > frocksdb doesn't have arm release > -

[jira] [Updated] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState

[ https://issues.apache.org/jira/browse/FLINK-23759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23759: --- Fix Version/s: 1.14.0 > notifyCheckpointComplete without corresponding snapshotState > -

[jira] [Created] (FLINK-23760) Static methods in interface require -target:jvm-1.8

liyongguang created FLINK-23760: --- Summary: Static methods in interface require -target:jvm-1.8 Key: FLINK-23760 URL: https://issues.apache.org/jira/browse/FLINK-23760 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-19710. -- Resolution: Information Provided As wrote in the [announcement email|https://lists.apache.org/thread.

[GitHub] [flink] flinkbot edited a comment on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

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

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16769: [FLINK-23639][connectors/kafka] Migrate Table API Kafka connector to use FLIP-143 KafkaSink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16776: [FLINK-16201][table] Support JSON_VALUE

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

[GitHub] [flink] autophagy commented on a change in pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

autophagy commented on a change in pull request #16794: URL: https://github.com/apache/flink/pull/16794#discussion_r688312998 ## File path: flink-state-backends/flink-statebackend-rocksdb/pom.xml ## @@ -36,6 +36,24 @@ under the License. jar + +

[GitHub] [flink] rkhachatryan commented on pull request #16784: [FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished

rkhachatryan commented on pull request #16784: URL: https://github.com/apache/flink/pull/16784#issuecomment-898262943 That makes sense, thanks for the explanation @gaoyunhaii . -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r688319196 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -329,

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r688319196 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -329,

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r688319196 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -329,

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r688319196 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -329,

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r688319196 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -329,

[jira] [Commented] (FLINK-23702) SQL casting to decimal which cannot hold its original value throws 'Column 'EXPR$0' is NOT NULL, however, a null value is being written into it'

[ https://issues.apache.org/jira/browse/FLINK-23702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398491#comment-17398491 ] Timo Walther commented on FLINK-23702: -- If there are no objections, I would like to

[GitHub] [flink-statefun] tzulitai commented on pull request #249: [FLINK-23709] Remove SanityVerificationE2E and ExactlyOnceRemoteE2E

tzulitai commented on pull request #249: URL: https://github.com/apache/flink-statefun/pull/249#issuecomment-898267693 After an offline discussion, we've decided to merge this as is and add a Kafka E2E later. Bottom line is, during release testing we should be giving the release a spin

[GitHub] [flink] Airblader commented on a change in pull request #16793: [FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment

Airblader commented on a change in pull request #16793: URL: https://github.com/apache/flink/pull/16793#discussion_r688307794 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #16784: [FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished

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

[GitHub] [flink] flinkbot commented on pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

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

[GitHub] [flink] flinkbot edited a comment on pull request #16804: [FLINK-23616][python] Support to chain the Python DataStream operators in execute_and_collect and print

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

[jira] [Commented] (FLINK-23436) When implements the LookupFunction In SQL that indirect extends (Async)TableFunction, throw exception

[ https://issues.apache.org/jira/browse/FLINK-23436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398497#comment-17398497 ] 吴彦祖 commented on FLINK-23436: - [~twalthr]  hi, I have commit the PR few days ago. Could yo

[jira] [Created] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result

zhengjiewen created FLINK-23761: --- Summary: FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result Key: FLINK-23761 URL: https://issues.apache.org/jira/browse/FLINK-23761 Projec

[jira] [Updated] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result

[ https://issues.apache.org/jira/browse/FLINK-23761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengjiewen updated FLINK-23761: Attachment: image-2021-08-13-16-08-31-970.png > FlinkSQL1.12 BatchMode Group By with INT type can

[jira] [Updated] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result

[ https://issues.apache.org/jira/browse/FLINK-23761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengjiewen updated FLINK-23761: Attachment: image-2021-08-13-16-09-19-951.png > FlinkSQL1.12 BatchMode Group By with INT type can

[GitHub] [flink] saddays commented on pull request #16803: [FLINK-23744][sql-client] Fix unstable CliClientTest

saddays commented on pull request #16803: URL: https://github.com/apache/flink/pull/16803#issuecomment-898273159 I'm sorry about that introduce a bug, i should have noticed this unstable behaviour. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-23709) Remove SanityVerificationE2E and ExactlyOnceRemoteE2E

[ https://issues.apache.org/jira/browse/FLINK-23709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-23709. --- Fix Version/s: statefun-3.1.0 Resolution: Fixed flink-statefun/master: 6300f6

[GitHub] [flink-statefun] tzulitai closed pull request #249: [FLINK-23709] Remove SanityVerificationE2E and ExactlyOnceRemoteE2E

tzulitai closed pull request #249: URL: https://github.com/apache/flink-statefun/pull/249 -- 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. To unsubscribe, e-mail: issues-u

[jira] [Updated] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result

[ https://issues.apache.org/jira/browse/FLINK-23761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengjiewen updated FLINK-23761: Component/s: Table SQL / API > FlinkSQL1.12 BatchMode Group By with INT type can not produce the c

[jira] [Updated] (FLINK-23761) FlinkSQL1.12 BatchMode Group By with INT type can not produce the correct result

[ https://issues.apache.org/jira/browse/FLINK-23761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengjiewen updated FLINK-23761: Description: When Run a Flink Sql which have Group By oprator, and filed type is INT type，the res

[GitHub] [flink] Myasuka commented on pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

Myasuka commented on pull request #16794: URL: https://github.com/apache/flink/pull/16794#issuecomment-898274895 @autophagy I checked the https://oss.sonatype.org/content/repositories/comververica-1006/com/ververica/frocksdbjni/6.20.3-ververica-1.0/frocksdbjni-6.20.3-ververica-1.0.jar and

[GitHub] [flink] twalthr commented on a change in pull request #16793: [FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment

twalthr commented on a change in pull request #16793: URL: https://github.com/apache/flink/pull/16793#discussion_r688331267 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkContext.scala ## @@ -28,6 +28,11 @@ import org.a

[GitHub] [flink] autophagy commented on pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

autophagy commented on pull request #16794: URL: https://github.com/apache/flink/pull/16794#issuecomment-898277607 @Myasuka Great! I've published the jar from staging. Once it appears on Maven, i'll remove the sonatype repo from this PR, push up a fix and rebase to fix the pyflink test fai

[GitHub] [flink] Airblader commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

Airblader commented on a change in pull request #16805: URL: https://github.com/apache/flink/pull/16805#discussion_r688336142 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/IsJsonFunctionITCase.java ## @@ -0,0 +1,157 @@ +/*

[jira] [Assigned] (FLINK-23738) Hide any configuration, API or docs

[ https://issues.apache.org/jira/browse/FLINK-23738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-23738: - Assignee: Roman Khachatryan > Hide any configuration, API or docs > ---

[jira] [Comment Edited] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398421#comment-17398421 ] Yun Tang edited comment on FLINK-14482 at 8/13/21, 8:26 AM:

[jira] [Assigned] (FLINK-23738) Hide any configuration, API or docs

[ https://issues.apache.org/jira/browse/FLINK-23738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-23738: - Assignee: Roman Khachatryan (was: Roman Khachatryan) > Hide any configuration,

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

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

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16750: [FLINK-23627] [Runtime / Metrics] Migrate all OperatorMG instantiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #16769: [FLINK-23639][connectors/kafka] Migrate Table API Kafka connector to use FLIP-143 KafkaSink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16784: [FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished

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

[GitHub] [flink] flinkbot edited a comment on pull request #16794: [FLINK-14482][rocksdb] Bump FRocksDB version to 6.20.3

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

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * f8933682134ebc6c8b7ca40a56852a1459854fb1 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16776: [FLINK-16201][table] Support JSON_VALUE

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

[GitHub] [flink] flinkbot edited a comment on pull request #16805: [FLINK-16501][table] Support IS JSON for Table API

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

[jira] [Created] (FLINK-23762) Revisit RequestReplyFunctionTest unit tests

Tzu-Li (Gordon) Tai created FLINK-23762: --- Summary: Revisit RequestReplyFunctionTest unit tests Key: FLINK-23762 URL: https://issues.apache.org/jira/browse/FLINK-23762 Project: Flink Iss

[GitHub] [flink-statefun] tzulitai commented on pull request #256: [FLINK-20574] [core] Block first request to mitigate excessive IncompleteInvocationContext roundtrips in RequestReplyFunction

tzulitai commented on pull request #256: URL: https://github.com/apache/flink-statefun/pull/256#issuecomment-898286438 As discussed offline with @igalshilman, we're not going to add any extra unit test coverage for this change for now. We workaround the unit tests by toggling the `isFirs

[GitHub] [flink-statefun] tzulitai commented on pull request #256: [FLINK-20574] [core] Block first request to mitigate excessive IncompleteInvocationContext roundtrips in RequestReplyFunction

tzulitai commented on pull request #256: URL: https://github.com/apache/flink-statefun/pull/256#issuecomment-898286531 Merging this now .. -- 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 spe

[GitHub] [flink] dmvk commented on a change in pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

dmvk commented on a change in pull request #16652: URL: https://github.com/apache/flink/pull/16652#discussion_r688343874 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherFailoverITCase.java ## @@ -68,11 +67,20 @@ @Before public

[GitHub] [flink-statefun] tzulitai closed pull request #256: [FLINK-20574] [core] Block first request to mitigate excessive IncompleteInvocationContext roundtrips in RequestReplyFunction

tzulitai closed pull request #256: URL: https://github.com/apache/flink-statefun/pull/256 -- 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. To unsubscribe, e-mail: issues-u

[jira] [Closed] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs

[ https://issues.apache.org/jira/browse/FLINK-20574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20574. --- Fix Version/s: statefun-3.1.0 Resolution: Fixed flink-statefun/master: 8f66f0

[jira] [Created] (FLINK-23763) Use yarn config in sql but not yarn magic properties file

wangzeyu created FLINK-23763: Summary: Use yarn config in sql but not yarn magic properties file Key: FLINK-23763 URL: https://issues.apache.org/jira/browse/FLINK-23763 Project: Flink Issue Type:

[GitHub] [flink] Airblader commented on a change in pull request #16776: [FLINK-16201][table] Support JSON_VALUE

Airblader commented on a change in pull request #16776: URL: https://github.com/apache/flink/pull/16776#discussion_r688349588 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java ## @@ -1504,6 +1506,23 @@

[GitHub] [flink] dmvk commented on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

dmvk commented on pull request #16720: URL: https://github.com/apache/flink/pull/16720#issuecomment-898294308 After giving this some more thoughts, I'm switching default value to `InternalIP`. From a quick research: - Minikube: Has only InternalIP assigned - GKE: Has both external

[GitHub] [flink] dmvk edited a comment on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

dmvk edited a comment on pull request #16720: URL: https://github.com/apache/flink/pull/16720#issuecomment-898294308 After giving this some more thoughts, I'm switching default value to `InternalIP`. From a quick research: - Minikube: Has only InternalIP assigned - GKE: Has both e

[GitHub] [flink] flinkbot edited a comment on pull request #15237: [FLINK-21278][streaming-java] NullpointExecption error is reported wh…

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

[jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

[ https://issues.apache.org/jira/browse/FLINK-23737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23737: -- Fix Version/s: 1.14.0 > Ensure publish-to-dockerhub.sh only publish specific flink versions >

[jira] [Updated] (FLINK-23763) Use yarn config in sql but not yarn magic properties file

[ https://issues.apache.org/jira/browse/FLINK-23763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangzeyu updated FLINK-23763: - Component/s: (was: Table SQL / Client) > Use yarn config in sql but not yarn magic properties file >

[jira] [Commented] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

[ https://issues.apache.org/jira/browse/FLINK-23737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398516#comment-17398516 ] Till Rohrmann commented on FLINK-23737: --- cc [~xtsong] as our release manager. > E

[GitHub] [flink] dmvk commented on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

dmvk commented on pull request #16720: URL: https://github.com/apache/flink/pull/16720#issuecomment-898297034 This is a breaking change (even thought it's fix), so I'm adding release notes for this. -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Created] (FLINK-23764) add RuntimeContext to SourceReaderContext

Hang Ruan created FLINK-23764: - Summary: add RuntimeContext to SourceReaderContext Key: FLINK-23764 URL: https://issues.apache.org/jira/browse/FLINK-23764 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-23507) The node IP obtained in NodePort mode is a VIP

[ https://issues.apache.org/jira/browse/FLINK-23507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-23507: -- Release Note: When using "kubernetes.rest-service.exposed.type=NodePort", connection string f

[jira] [Updated] (FLINK-23507) The node IP obtained in NodePort mode is a VIP

[ https://issues.apache.org/jira/browse/FLINK-23507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-23507: -- Release Note: When using "kubernetes.rest-service.exposed.type=NodePort", connection string f

[GitHub] [flink] fapaul commented on a change in pull request #16796: [FLINK-23735][connectors/kafka] Migrate BufferedUpsertSinkFunction to FLIP-143 Sink API

fapaul commented on a change in pull request #16796: URL: https://github.com/apache/flink/pull/16796#discussion_r688358744 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/BufferedUpsertSink.java ## @@ -0,0 +1

[GitHub] [flink] pnowojski commented on a change in pull request #16772: [FLINK-23560][runtime] Calculate absoluteTimeMillis only once for idle metric and throughput calculation.

pnowojski commented on a change in pull request #16772: URL: https://github.com/apache/flink/pull/16772#discussion_r688356378 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/throughput/ThroughputCalculator.java ## @@ -36,36 +36,49 @@ public ThroughputCalcula

[GitHub] [flink] hameizi opened a new pull request #16806: [FLINK-23763][Deployment/YARN]Use yarn config in sql but not yarn mag…

hameizi opened a new pull request #16806: URL: https://github.com/apache/flink/pull/16806 …ic properties file ## What is the purpose of the change As discusstion in https://issues.apache.org/jira/browse/FLINK-15470, the config in YARN magic properties file will effect

[GitHub] [flink] wuchong commented on a change in pull request #16793: [FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment

wuchong commented on a change in pull request #16793: URL: https://github.com/apache/flink/pull/16793#discussion_r688359209 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/delegation/DefaultExecutorTest.java ## @@ -105,6 +72,35 @@ pub

[jira] [Updated] (FLINK-23763) Use yarn config in sql but not yarn magic properties file

[ https://issues.apache.org/jira/browse/FLINK-23763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23763: --- Labels: pull-request-available (was: ) > Use yarn config in sql but not yarn magic properti

  1   2   3   4   5   6   7   >