[GitHub] [flink-statefun] tzulitai opened a new pull request #119: [FLINK-17875] [core] Refactor JsonModule

tzulitai opened a new pull request #119: URL: https://github.com/apache/flink-statefun/pull/119 This PR is a pre-requisite preparation for adding state TTL for remote functions. It refactors the `JsonModule`, so that it'll be easier to manage the parsing logic of JSON application entiti

[GitHub] [flink] flinkbot commented on pull request #12372: [FLINK-17946][python] fix the bug that the config option 'pipeline.jars' doesn't work.

flinkbot commented on pull request #12372: URL: https://github.com/apache/flink/pull/12372#issuecomment-635142364 ## CI report: * 65c92cf7403d9a42250667682184481e3dd76c92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #12371: [FLINK-17375][hotfix] Fix print_stacktraces multiline-behavior

flinkbot commented on pull request #12371: URL: https://github.com/apache/flink/pull/12371#issuecomment-635142268 ## CI report: * 48af18cc064a184c35c12b5b57be2db4b44eb99e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12369: [Flink-17678][Connectors/HBase]Support fink-sql-connector-hbase

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

[GitHub] [flink] flinkbot edited a comment on pull request #12320: [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory

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

[GitHub] [flink] rmetzger commented on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

rmetzger commented on pull request #12146: URL: https://github.com/apache/flink/pull/12146#issuecomment-635139128 @zenfenan Thanks a lot for your summary. I will respond to you on the mailing list, to get this module merged. @Tartarus0zm Thanks a lot for fixing this issue. I p

[GitHub] [flink-statefun] tzulitai commented on pull request #116: [FLINK-17875] Initial support of state TTL for remote functions

tzulitai commented on pull request #116: URL: https://github.com/apache/flink-statefun/pull/116#issuecomment-635138920 I'll close this, and have 2 new PRs - one with the new refactoring approach we discussed offline, and another one on top of what which includes the actual changes for th

[GitHub] [flink-statefun] tzulitai closed pull request #116: [FLINK-17875] Initial support of state TTL for remote functions

tzulitai closed pull request #116: URL: https://github.com/apache/flink-statefun/pull/116 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 #12373: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

flinkbot commented on pull request #12373: URL: https://github.com/apache/flink/pull/12373#issuecomment-635138596 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] Myasuka opened a new pull request #12373: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

Myasuka opened a new pull request #12373: URL: https://github.com/apache/flink/pull/12373 ## What is the purpose of the change Increase the default value of state.backend.fs.memory-threshold from 1K to 20K as thread discussed. ## Brief change log Increase default si

[GitHub] [flink] flinkbot edited a comment on pull request #12369: [Flink-17678][Connectors/HBase]Support fink-sql-connector-hbase

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

[GitHub] [flink] flinkbot edited a comment on pull request #12370: [FLINK-17923][python] Allow Python worker to use off-heap memory

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

[GitHub] [flink] flinkbot edited a comment on pull request #12368: [FLINK-15507][state backends] Activate local recovery by default (on release-1.11)

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

[GitHub] [flink] flinkbot edited a comment on pull request #12320: [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory

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

[GitHub] [flink] pnowojski commented on a change in pull request #12365: [FLINK-17988][checkpointing] Discard only unique channel state delegates

pnowojski commented on a change in pull request #12365: URL: https://github.com/apache/flink/pull/12365#discussion_r431606416 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java ## @@ -231,8 +232,7 @@ public void discardState

[GitHub] [flink] flinkbot commented on pull request #12372: [FLINK-17946][python] fix the bug that the config option 'pipeline.jars' doesn't work.

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

[GitHub] [flink] flinkbot commented on pull request #12371: [FLINK-17375][hotfix] Fix print_stacktraces multiline-behavior

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

[jira] [Commented] (FLINK-17967) Could not find document *** in docs

[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118360#comment-17118360 ] Aven Wu commented on FLINK-17967: - Hi, I build the docs with MacOS 14. Branch master,

[jira] [Updated] (FLINK-17988) Checkpointing slows down after reaching state.checkpoints.num-retained

[ https://issues.apache.org/jira/browse/FLINK-17988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17988: --- Priority: Critical (was: Major) > Checkpointing slows down after reaching state.checkpoints

[jira] [Updated] (FLINK-17946) The config option "pipeline.jars" doesn't work if the job was executed via TableEnvironment.execute_sql and StatementSet.execute

[ https://issues.apache.org/jira/browse/FLINK-17946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17946: --- Labels: pull-request-available (was: ) > The config option "pipeline.jars" doesn't work if

[jira] [Commented] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118361#comment-17118361 ] Xintong Song commented on FLINK-15687: -- For all the rest of test cases listed above

[GitHub] [flink] WeiZhong94 opened a new pull request #12372: [FLINK-17946][python] fix the bug that the config option 'pipeline.jars' doesn't work.

WeiZhong94 opened a new pull request #12372: URL: https://github.com/apache/flink/pull/12372 ## What is the purpose of the change *This pull request fixes the bug that the config option 'pipeline.jars' doesn't work.* ## Brief change log - *Transfer the configurati

[jira] [Closed] (FLINK-15331) Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15331. --- Resolution: Fixed > Create a table from a changelog > --- > > Ke

[GitHub] [flink] rmetzger opened a new pull request #12371: [FLINK-17375][hotfix] Fix print_stacktraces multiline-behavior

rmetzger opened a new pull request #12371: URL: https://github.com/apache/flink/pull/12371 ## What is the purpose of the change ```bash echo $VAR # does not preserve newlines echo "$VAR" # does print newlines as well ``` ---

[jira] [Closed] (FLINK-17928) Incorrect state size reported when using unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17928. -- Resolution: Fixed merged to release-1.11 as a9782a2483 merged to master as f89c606f12 > Incor

[jira] [Closed] (FLINK-17861) Channel state handles, when inlined, duplicate underlying data

[ https://issues.apache.org/jira/browse/FLINK-17861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17861. -- Resolution: Fixed Merged to release-1.11 as bd22ebf971^^..bd22ebf971 Merged to master as 1b824

[jira] [Updated] (FLINK-16589) Flink Table SQL fails/crashes with big queries with lots of fields

[ https://issues.apache.org/jira/browse/FLINK-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16589: Priority: Major (was: Critical) > Flink Table SQL fails/crashes with big queries with lots of fields > --

[jira] [Updated] (FLINK-16589) Flink Table SQL fails/crashes with big queries with lots of fields

[ https://issues.apache.org/jira/browse/FLINK-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16589: Fix Version/s: (was: 1.10.2) > Flink Table SQL fails/crashes with big queries with lots of fields > --

[GitHub] [flink] pnowojski merged pull request #12362: [FLINK-17928][checkpointing] Fix ChannelStateHandle size

pnowojski merged pull request #12362: URL: https://github.com/apache/flink/pull/12362 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[GitHub] [flink] pnowojski closed pull request #12292: [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

pnowojski closed pull request #12292: URL: https://github.com/apache/flink/pull/12292 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[GitHub] [flink] pnowojski commented on pull request #12292: [FLINK-17861][task][checkpointing] Split channel state handles sent to JM

pnowojski commented on pull request #12292: URL: https://github.com/apache/flink/pull/12292#issuecomment-635128589 Merging from https://github.com/apache/flink/pull/12362 . Build was successful there, here e2e timed out because of getting artefacts from mvn cache took very long time

[jira] [Closed] (FLINK-17657) Fix reading BIGINT UNSIGNED type field not work in JDBC

[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17657. --- Resolution: Fixed master (1.12.0): 8bc76955b527b6905049346eb1eaa9ce1ab03409 1.11.0: beb0c1c5bab09feb525f2bd8

[jira] [Updated] (FLINK-17657) Fix reading BIGINT UNSIGNED type field not work in JDBC

[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17657: Summary: Fix reading BIGINT UNSIGNED type field not work in JDBC (was: jdbc not support read BIGINT UNSIG

[GitHub] [flink] wuchong merged pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

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

[jira] [Closed] (FLINK-17689) Add integeration tests for changelog formats

[ https://issues.apache.org/jira/browse/FLINK-17689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17689. --- Resolution: Fixed master (1.12.0): f47ffc26aa893b19cad935e6656fda199d12281d 1.11.0: 3aeaa552a7640c86f591c144

[GitHub] [flink] wuchong commented on pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

wuchong commented on pull request #12284: URL: https://github.com/apache/flink/pull/12284#issuecomment-635126463 Passed: https://dev.azure.com/imjark/Flink/_build/results?buildId=111&view=results Merging This is an automa

[GitHub] [flink] wuchong merged pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

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

[GitHub] [flink] pnowojski commented on a change in pull request #12364: [FLINK-17986] Fix check in FsCheckpointStateOutputStream.write

pnowojski commented on a change in pull request #12364: URL: https://github.com/apache/flink/pull/12364#discussion_r431601126 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactoryTest.java ## @@ -57,6 +57,23 @@ public voi

[jira] [Closed] (FLINK-16086) Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16086. --- Fix Version/s: 1.11.0 Resolution: Fixed master (1.12.0): be7b7aeec360b79be79d0e1666c5e0afe5b95ffc 1.1

[GitHub] [flink] wuchong merged pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

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

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

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118341#comment-17118341 ] sunjincheng commented on FLINK-17923: - Thanks for the PR Dian Fu.  Overall, It's loo

[GitHub] [flink] flinkbot edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12320: [FLINK-17887][table][connector] Improve interface of ScanFormatFactory and SinkFormatFactory

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

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

flinkbot commented on pull request #12370: URL: https://github.com/apache/flink/pull/12370#issuecomment-635122965 ## CI report: * 40e6ca73fd8bb7ba734a78cafb7a16d3d1cf521f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118281#comment-17118281 ] Xintong Song edited comment on FLINK-15687 at 5/28/20, 5:55 AM: --

[jira] [Comment Edited] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118281#comment-17118281 ] Xintong Song edited comment on FLINK-15687 at 5/28/20, 5:54 AM: --

[jira] [Comment Edited] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118281#comment-17118281 ] Xintong Song edited comment on FLINK-15687 at 5/28/20, 5:54 AM: --

[jira] [Created] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

Zhijiang created FLINK-17994: Summary: Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived Key: FLINK-17994 URL: https://issues.apache.org/jira/browse/FLINK-17994

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118335#comment-17118335 ] Robert Metzger commented on FLINK-17825: Another case in the Scala 2.12 profile

[jira] [Updated] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17825: --- Description: CI (normal profile): https://dev.azure.com/apache-flink/apache-flink/_build/re

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118330#comment-17118330 ] Dian Fu commented on FLINK-17923: - [~sunjincheng121] [~xintongsong] [~zhuzh] I have subm

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

dianfu opened a new pull request #12370: URL: https://github.com/apache/flink/pull/12370 ## What is the purpose of the change *This pull request allows Python worker to use off-heap memory by default. This is to make it Python UDF could work together RocksDB state backend as cur

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

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17923: --- Labels: pull-request-available (was: ) > It will throw MemoryAllocationException if rocksdb

[GitHub] [flink] flinkbot edited a comment on pull request #12366: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

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

[GitHub] [flink] flinkbot edited a comment on pull request #12259: [hotfix][k8s] Remove unused constant variable

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

[jira] [Commented] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118328#comment-17118328 ] Robert Metzger commented on FLINK-17194: Again Hadoop 3.1.3: https://dev.azure.

[jira] [Commented] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118324#comment-17118324 ] Jark Wu commented on FLINK-16681: - [~wanglijie95], please also fix {{JdbcRowDataOutputFo

[jira] [Assigned] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16681: --- Assignee: Lijie Wang (was: LakeShen) > Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStat

[jira] [Updated] (FLINK-16496) Improve default flush strategy for HBase sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16496: Fix Version/s: (was: 1.12.0) 1.11.0 > Improve default flush strategy for HBase sink

[jira] [Updated] (FLINK-15339) Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-15339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15339: Fix Version/s: (was: 1.12.0) 1.11.0 > Correct the terminology of "Time-windowed Joi

[jira] [Updated] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16497: Fix Version/s: (was: 1.12.0) 1.11.0 > Improve default flush strategy for JDBC sink

[jira] [Commented] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118322#comment-17118322 ] Robert Metzger commented on FLINK-17404: {code}Running HA per-job cluster (file,

[GitHub] [flink] flinkbot edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

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

[jira] [Created] (FLINK-17993) read schema from orc file

dingli123 created FLINK-17993: - Summary: read schema from orc file Key: FLINK-17993 URL: https://issues.apache.org/jira/browse/FLINK-17993 Project: Flink Issue Type: Improvement Compone

[GitHub] [flink] flinkbot edited a comment on pull request #12369: Flink 17678

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

[GitHub] [flink] flinkbot edited a comment on pull request #12367: [FLINK-17960][python][docs] Improve commands in the "Common Questions" document for PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

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

[GitHub] [flink] flinkbot edited a comment on pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

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

[jira] [Commented] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118310#comment-17118310 ] Jark Wu commented on FLINK-14356: - Responsed in the PR. > Introduce "single-field" form

[GitHub] [flink] wuchong commented on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

wuchong commented on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-635094908 Hi @hackergin , thanks a lot for the contribution. However, the community is moving to a new format factory interface called `DeserializationFormatFactory` and `SerializationFor

[jira] [Closed] (FLINK-17991) Add JdbcAsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17991. --- Fix Version/s: (was: 1.12.0) Resolution: Duplicate Let's move the discussion to FLINK-14902, we s

[jira] [Updated] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17869: - Description: On ChannelStateWriter side, the lifecycle of checkpoint should be as follows: start -> in

[jira] [Closed] (FLINK-17600) Blink Planner fails to generate RowtimeAttribute based on TableSource's DefinedRowtimeAttributes implementation

[ https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17600. --- Resolution: Duplicate close since it is fixed by FLINK-16160 > Blink Planner fails to generate RowtimeAttri

[jira] [Commented] (FLINK-17967) Could not find document *** in docs

[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118298#comment-17118298 ] Jark Wu commented on FLINK-17967: - I didn't get what's the problem. There is already a f

[GitHub] [flink] flinkbot edited a comment on pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

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

[GitHub] [flink] flinkbot commented on pull request #12369: Flink 17678

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

[GitHub] [flink] flinkbot edited a comment on pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

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

[jira] [Closed] (FLINK-17284) Support serial field type in PostgresCatalog

[ https://issues.apache.org/jira/browse/FLINK-17284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17284. --- Fix Version/s: 1.11.0 Resolution: Fixed master (1.12.0): b0dd0aa639ef973db0341ade7d2fe73384cf2ed3 1.1

[GitHub] [flink] wuchong merged pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

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

[jira] [Commented] (FLINK-17991) Add JdbcAsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118285#comment-17118285 ] 底限 commented on FLINK-17991: Some functions overlap, but the implementation is different: 1.

[jira] [Commented] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118281#comment-17118281 ] Xintong Song commented on FLINK-15687: -- I've printed the thread names for all testi

[GitHub] [flink] flinkbot commented on pull request #12369: Flink 17678

flinkbot commented on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635081028 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] hequn8128 commented on a change in pull request #12367: [FLINK-17960][document] Improve commands in the "Common Questions" document for PyFlink

hequn8128 commented on a change in pull request #12367: URL: https://github.com/apache/flink/pull/12367#discussion_r431566416 ## File path: docs/dev/table/python/common_questions.md ## @@ -33,10 +33,11 @@ You can download a [convenience script]({{ site.baseurl }}/downloads/set

[GitHub] [flink] hequn8128 commented on a change in pull request #12367: [FLINK-17960][document] Improve commands in the "Common Questions" document for PyFlink

hequn8128 commented on a change in pull request #12367: URL: https://github.com/apache/flink/pull/12367#discussion_r431566416 ## File path: docs/dev/table/python/common_questions.md ## @@ -33,10 +33,11 @@ You can download a [convenience script]({{ site.baseurl }}/downloads/set

[GitHub] [flink] DashShen opened a new pull request #12369: Flink 17678

DashShen opened a new pull request #12369: URL: https://github.com/apache/flink/pull/12369 ## What is the purpose of the change Flink doesn't contains a hbase shade jar right now, so users have to add hbase dependency manually. This pull request is trying to solve this problem.

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

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

[GitHub] [flink] flinkbot edited a comment on pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

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

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

lirui-apache commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r431563579 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,355 @@ +--- +title: "FileSystem Connector" +nav-title: FileSystem Connector +nav-

[jira] [Commented] (FLINK-17991) Add JdbcAsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118265#comment-17118265 ] Benchao Li commented on FLINK-17991: [~ChaseDream] Does this issue a duplicate of h

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

lirui-apache commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r431551933 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,355 @@ +--- +title: "FileSystem Connector" +nav-title: FileSystem Connector +nav-

[GitHub] [flink] flinkbot edited a comment on pull request #12290: [FLINK-17657][jdbc] jdbc not support read BIGINT UNSIGNED field

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

[GitHub] [flink] flinkbot edited a comment on pull request #12368: [FLINK-15507][state backends] Activate local recovery by default (on release-1.11)

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

[GitHub] [flink] flinkbot edited a comment on pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

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

[GitHub] [flink] klion26 commented on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

klion26 commented on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-635072086 @wuchong @caozhen1937 I'll give a final review today. This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-17942) Count distinct could not clean state in WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-17942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17942. --- Resolution: Fixed master (1.12.0): b6f92febd1f03152541432492820a5f2a12be6c4 1.11.0: 661541a1f002778df0691b05

[GitHub] [flink] wuchong merged pull request #12358: [FLINK-17942][table-planner-blink] Fix WindowOperator not call StateM…

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

[jira] [Comment Edited] (FLINK-17788) scala shell in yarn mode is broken

[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118249#comment-17118249 ] Jeff Zhang edited comment on FLINK-17788 at 5/28/20, 3:09 AM:

[GitHub] [flink] wuchong commented on a change in pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

wuchong commented on a change in pull request #12289: URL: https://github.com/apache/flink/pull/12289#discussion_r431556847 ## File path: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/util/HBaseTypeUtils.java ## @@ -81,13 +81,16 @@ public static Obje

  1   2   3   4   5   6   7   >