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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-633558182 ## CI report: * 3153508b46fd876ac1ffd0710e54b7ec3756007f Azure:

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

2020-05-28 Thread GitBox
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=results Merging This is an automated

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

2020-05-28 Thread GitBox
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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-633558182 ## CI report: * 1ad6eea2421dd2c9950f19ff2fd5ee54bb66c6f0 Azure:

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12368: URL: https://github.com/apache/flink/pull/12368#issuecomment-635063638 ## CI report: * d346d64a63a3b91f18251b7e30bb9f839ffe68cd Azure:

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * f49fb611425fd075c0818233472ece2a4a824d71 Azure:

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12370: URL: https://github.com/apache/flink/pull/12370#issuecomment-635122965 ## CI report: * 40e6ca73fd8bb7ba734a78cafb7a16d3d1cf521f Azure:

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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

[jira] [Created] (FLINK-17995) Add a new overview page for the new SQL connectors

2020-05-28 Thread Jark Wu (Jira)
Jark Wu created FLINK-17995: --- Summary: Add a new overview page for the new SQL connectors Key: FLINK-17995 URL: https://issues.apache.org/jira/browse/FLINK-17995 Project: Flink Issue Type:

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118392#comment-17118392 ] Robert Metzger commented on FLINK-16572: This failure is from a pull request which is based on

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

2020-05-28 Thread GitBox
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] [Updated] (FLINK-16589) Flink Table SQL fails/crashes with big queries with lots of fields

2020-05-28 Thread Jark Wu (Jira)
[ 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

2020-05-28 Thread Jark Wu (Jira)
[ 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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread Jark Wu (Jira)
[ 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:

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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

[GitHub] [flink] Myasuka opened a new pull request #12373: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * f49fb611425fd075c0818233472ece2a4a824d71 Azure:

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-633558182 ## CI report: * 1ad6eea2421dd2c9950f19ff2fd5ee54bb66c6f0 Azure:

[jira] [Updated] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

2020-05-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17996: --- Affects Version/s: (was: 1.11.0) > NEP in CatalogTableStatisticsConverter.convertToColumnStats

[jira] [Updated] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

2020-05-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17996: --- Fix Version/s: 1.11.0 > NEP in CatalogTableStatisticsConverter.convertToColumnStats method >

[jira] [Commented] (FLINK-17857) All Kubernetes e2e tests could not run on Mac after migration

2020-05-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118383#comment-17118383 ] Robert Metzger commented on FLINK-17857: I agree with Yang that it would be useful to have some

[jira] [Created] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

2020-05-28 Thread godfrey he (Jira)
godfrey he created FLINK-17996: -- Summary: NEP in CatalogTableStatisticsConverter.convertToColumnStats method Key: FLINK-17996 URL: https://issues.apache.org/jira/browse/FLINK-17996 Project: Flink

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

2020-05-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17992: --- Labels: pull-request-available (was: ) > Exception from RemoteInputChannel#onBuffer should

[GitHub] [flink] zhijiangW opened a new pull request #12374: [FLINK-17992][checkpointing] Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

2020-05-28 Thread GitBox
zhijiangW opened a new pull request #12374: URL: https://github.com/apache/flink/pull/12374 ## What is the purpose of the change RemoteInputChannel#onBuffer is invoked by CreditBasedPartitionRequestClientHandler while receiving and decoding the network data. #onBuffer can throw

[jira] [Commented] (FLINK-17375) Clean up CI system related scripts

2020-05-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118393#comment-17118393 ] Robert Metzger commented on FLINK-17375: Merged a small follow up fixing the stacktrace

[GitHub] [flink] flinkbot commented on pull request #12373: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-28 Thread GitBox
flinkbot commented on pull request #12373: URL: https://github.com/apache/flink/pull/12373#issuecomment-635160213 ## CI report: * 5771a99b8c3a5491e4114c3e3c75a1d86a1c17b3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12372: URL: https://github.com/apache/flink/pull/12372#issuecomment-635142364 ## CI report: * 65c92cf7403d9a42250667682184481e3dd76c92 Azure:

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

2020-05-28 Thread Aven Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118360#comment-17118360 ] Aven Wu commented on FLINK-17967: - Hi, I build the docs with MacOS 14. Branch master, \{% link

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

2020-05-28 Thread Piotr Nowojski (Jira)
[ 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

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

2020-05-28 Thread Jark Wu (Jira)
[ 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 > --- > >

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

2020-05-28 Thread ASF GitHub Bot (Jira)
[ 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.

2020-05-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118361#comment-17118361 ] Xintong Song commented on FLINK-15687: -- For all the rest of test cases listed above, the

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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 ```

[GitHub] [flink] flinkbot commented on pull request #12373: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
rmetzger merged pull request #12371: URL: https://github.com/apache/flink/pull/12371 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

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

2020-05-28 Thread GitBox
rmetzger commented on pull request #12371: URL: https://github.com/apache/flink/pull/12371#issuecomment-635153196 Thanks! merging This is an automated message from the Apache Git Service. To respond to the message, please

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

2020-05-28 Thread GitBox
rkhachatryan commented on a change in pull request #12365: URL: https://github.com/apache/flink/pull/12365#discussion_r431629099 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java ## @@ -231,8 +232,7 @@ public void

[jira] [Updated] (FLINK-17736) Add flink CEP examples

2020-05-28 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17736: - Labels: pull-request-available starter (was: pull-request-available starer) > Add

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-635056734 ## CI report: * 164103e96608f5dd8c00e020f55716de23bd3019 Azure:

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118341#comment-17118341 ] sunjincheng commented on FLINK-17923: - Thanks for the PR Dian Fu.  Overall, It's looks good. If

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

2020-05-28 Thread Jark Wu (Jira)
[ 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

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

2020-05-28 Thread GitBox
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

2020-05-28 Thread Jark Wu (Jira)
[ 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:

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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

[jira] [Updated] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

2020-05-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17996: --- Affects Version/s: 1.9.0 1.10.0 > NEP in

[jira] [Updated] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

2020-05-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17996: --- Affects Version/s: 1.11.0 > NEP in CatalogTableStatisticsConverter.convertToColumnStats method >

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

2020-05-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17404: --- Summary: Running HA per-job cluster (rocks, non-incremental) gets stuck killing a

[jira] [Commented] (FLINK-17736) Add flink CEP examples

2020-05-28 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118400#comment-17118400 ] Dawid Wysakowicz commented on FLINK-17736: -- I agree with Robert here. Just a personal opinion

[GitHub] [flink] flinkbot commented on pull request #12374: [FLINK-17992][checkpointing] Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

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

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

2020-05-28 Thread Jark Wu (Jira)
[ 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

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

2020-05-28 Thread Piotr Nowojski (Jira)
[ 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 >

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

2020-05-28 Thread Piotr Nowojski (Jira)
[ 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

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

2020-05-28 Thread GitBox
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

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

2020-05-28 Thread GitBox
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

[jira] [Updated] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

2020-05-28 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17996: --- Affects Version/s: (was: 1.11.0) (was: 1.10.0)

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

2020-05-28 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118389#comment-17118389 ] Lijie Wang commented on FLINK-16681: Thank you [~jark], I see, I will also fix 

[jira] [Commented] (FLINK-17736) Add flink CEP examples

2020-05-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118397#comment-17118397 ] Robert Metzger commented on FLINK-17736: [~dwysakowicz] I would value your opinion here > Add

[jira] [Created] (FLINK-17997) Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact

2020-05-28 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-17997: --- Summary: Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact Key: FLINK-17997 URL:

[jira] [Updated] (FLINK-17997) Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact

2020-05-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-17997: Component/s: Stateful Functions > Revert manual merging of AWS KPL's

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12367: URL: https://github.com/apache/flink/pull/12367#issuecomment-635056734 ## CI report: * 4b6d0edc58e4ae0b5ab77f65a73f9219dd6eee16 Azure:

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * 5addfcff9eb59b5153e76627ed74e7255fe8b69b Azure:

[jira] [Commented] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

2020-05-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118473#comment-17118473 ] Yuan Mei commented on FLINK-17916: -- This one is moved to 1.12.0 PR is ready, the review is postponed

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

2020-05-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118478#comment-17118478 ] Dian Fu commented on FLINK-17923: - [~xintongsong] Appreciated your suggestions. It makes sense to me. I

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

2020-05-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118478#comment-17118478 ] Dian Fu edited comment on FLINK-17923 at 5/28/20, 9:16 AM: --- [~xintongsong] 

[jira] [Created] (FLINK-17998) Support limiting job history size

2020-05-28 Thread Daniel Laszlo Magyar (Jira)
Daniel Laszlo Magyar created FLINK-17998: Summary: Support limiting job history size Key: FLINK-17998 URL: https://issues.apache.org/jira/browse/FLINK-17998 Project: Flink Issue

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

2020-05-28 Thread GitBox
WeiZhong94 commented on pull request #12372: URL: https://github.com/apache/flink/pull/12372#issuecomment-635164299 @dianfu Thanks for your review! I have addressed your comments. It is unnecessary to execute `_before_execute()` in `sql_update` as it won't execute the pipeline really.

[GitHub] [flink] zhuzhurk commented on a change in pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-05-28 Thread GitBox
zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r430231588 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java ## @@ -562,4 +575,110 @@ private void

[jira] [Closed] (FLINK-17989) java.lang.NoClassDefFoundError: org/apache/flink/fs/azure/common/hadoop/HadoopRecoverableWriter

2020-05-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17989. Fix Version/s: (was: 1.11.1) (was: 1.10.1)

[jira] [Commented] (FLINK-17961) Create an Elasticsearch source

2020-05-28 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118405#comment-17118405 ] Etienne Chauchot commented on FLINK-17961: -- [~aljoscha] can you assign me this ticket? >

[GitHub] [flink] flinkbot edited a comment on pull request #12365: [FLINK-17988][checkpointing] Discard only unique channel state delegates

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12365: URL: https://github.com/apache/flink/pull/12365#issuecomment-634981483 ## CI report: * fbdee39abdb6795fb67caeb907adf0f9d2619d8b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12373: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12373: URL: https://github.com/apache/flink/pull/12373#issuecomment-635160213 ## CI report: * 5771a99b8c3a5491e4114c3e3c75a1d86a1c17b3 Azure:

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12372: URL: https://github.com/apache/flink/pull/12372#issuecomment-635142364 ## CI report: * 65c92cf7403d9a42250667682184481e3dd76c92 Azure:

[GitHub] [flink] flinkbot commented on pull request #12374: [FLINK-17992][checkpointing] Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

2020-05-28 Thread GitBox
flinkbot commented on pull request #12374: URL: https://github.com/apache/flink/pull/12374#issuecomment-635171486 ## CI report: * eeaa680286b6dd389acebbf1d8695ba94ff5ec59 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] curcur edited a comment on pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

2020-05-28 Thread GitBox
curcur edited a comment on pull request #12353: URL: https://github.com/apache/flink/pull/12353#issuecomment-635161998 Hey @AHeise , I've spent some time walking through the code. I think the bug is clear that the consumer's reference counter of `bufferBuilder` for `randomEmit` is not

[GitHub] [flink] flinkbot edited a comment on pull request #12364: [FLINK-17986] Fix check in FsCheckpointStateOutputStream.write

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12364: URL: https://github.com/apache/flink/pull/12364#issuecomment-634816980 ## CI report: * 6eef6ad43c519d62837d4e22246a4090a1aa1bd8 Azure:

[GitHub] [flink] curcur edited a comment on pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

2020-05-28 Thread GitBox
curcur edited a comment on pull request #12353: URL: https://github.com/apache/flink/pull/12353#issuecomment-635161998 Hey @AHeise , I've spent some time walking through the code. I think the bug is clear that the consumer's reference counter of `bufferBuilder` for `randomEmit` is not

[GitHub] [flink] curcur edited a comment on pull request #12353: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

2020-05-28 Thread GitBox
curcur edited a comment on pull request #12353: URL: https://github.com/apache/flink/pull/12353#issuecomment-635161998 Hey @AHeise , I've spent some time walking through the code. I think the bug is clear that the consumer's reference counter of `bufferBuilder` for `randomEmit` is not

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-633558182 ## CI report: * 1ad6eea2421dd2c9950f19ff2fd5ee54bb66c6f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * bb313e40f5a72dbf20cd0a8b48267063fd4f00af UNKNOWN *

[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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12355: URL: https://github.com/apache/flink/pull/12355#issuecomment-634548726 ## CI report: * 1c6c2a8dc337e9d01bfbe48af599441571b0d4ee Azure:

[GitHub] [flink] zhuzhurk opened a new pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-05-28 Thread GitBox
zhuzhurk opened a new pull request #12375: URL: https://github.com/apache/flink/pull/12375 ## What is the purpose of the change This PR introduces a BulkSlotProvider which supports bulk slot allocation. In this way we are able to check whether the resource requirements of a slot

[GitHub] [flink] zhuzhurk commented on pull request #12256: [FLINK-17018][runtime] Allocates slots in bulks for pipelined region scheduling

2020-05-28 Thread GitBox
zhuzhurk commented on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-635178001 @azagrebin @GJL #12375 is opened for bulk slot allocation part with a `BulkSlotProvider` introduced. Related comments above are also addressed in it. Would you take a look?

[GitHub] [flink] flinkbot commented on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-05-28 Thread GitBox
flinkbot commented on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635177408 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

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

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12320: URL: https://github.com/apache/flink/pull/12320#issuecomment-633558182 ## CI report: * 1ad6eea2421dd2c9950f19ff2fd5ee54bb66c6f0 Azure:

[jira] [Updated] (FLINK-17963) Revert execution environment patching in StatefulFunctionsJob (FLINK-16926)

2020-05-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-17963: Fix Version/s: statefun-2.1.0 statefun-2.0.1 > Revert

[jira] [Closed] (FLINK-17963) Revert execution environment patching in StatefulFunctionsJob (FLINK-16926)

2020-05-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-17963. --- Resolution: Fixed master: c14d07af0853d698fadaf183468c591f7101067c release-2.0:

[GitHub] [flink-statefun] tzulitai opened a new pull request #121: [FLINK-17997] [legal] Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE content

2020-05-28 Thread GitBox
tzulitai opened a new pull request #121: URL: https://github.com/apache/flink-statefun/pull/121 We manually merged the contents in FLINK-16901, because at the time the upstream Flink Kinesis connector wasn't yet properly handling the content. Now that this is fixed upstream, we can

[jira] [Updated] (FLINK-17997) Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact

2020-05-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17997: --- Labels: pull-request-available (was: ) > Revert manual merging of AWS KPL's

[GitHub] [flink] EchoLee5 commented on pull request #12339: [FLINK-17744] StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

2020-05-28 Thread GitBox
EchoLee5 commented on pull request #12339: URL: https://github.com/apache/flink/pull/12339#issuecomment-635200665 @kl0u I got it. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #12375: [FLINK-17017][runtime] Implements bulk allocation for physical slots

2020-05-28 Thread GitBox
flinkbot edited a comment on pull request #12375: URL: https://github.com/apache/flink/pull/12375#issuecomment-635184560 ## CI report: * 4fe765587c0423b2d29d5dde946b94edff79398b Azure:

  1   2   3   4   5   6   >