[GitHub] [flink] kl0u commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-11 Thread GitBox
kl0u commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725908109 Also why not putting the logic directly in the `JobResult.toJobExecutionResult()`, instead of keeping it separately to each client? This will lead to more robust code. --

[GitHub] [flink] SteNicholas commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-11 Thread GitBox
SteNicholas commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725907605 > Hi @SteNicholas , I reviewing your PR now. One thing to add is some tests (for each client) that verify that all clients throw the expected type of exception. This is to m

[jira] [Updated] (FLINK-20098) Don't add flink-connector-files to flink-dist

2020-11-11 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20098: - Issue Type: Improvement (was: Bug) > Don't add flink-connector-files to flink-dist > --

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

2020-11-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230407#comment-17230407 ] Arvid Heise commented on FLINK-20013: - Could you please create PRs for the backports

[jira] [Closed] (FLINK-19872) Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19872. --- Resolution: Fixed Fixed in master (1.12.0): e86b40909dcd4a0f53fa900989cf2655ff8f6c19 > Fix CSV format is un

[GitHub] [flink] wuchong commented on pull request #13834: [FLINK-19872][csv] Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread GitBox
wuchong commented on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-725904101 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] wuchong merged pull request #13834: [FLINK-19872][csv] Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread GitBox
wuchong merged pull request #13834: URL: https://github.com/apache/flink/pull/13834 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-20101) Fix the wrong documentation of FROM_UNIXTIME function

2020-11-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20101: Description: The return value should be '1970-01-01 00:00:44' in UTC time zone. https://ci.apache.org/pr

[GitHub] [flink] flinkbot commented on pull request #14043: [FLINK-20046][python] Fix the unstable test case 'StreamTableAggregateTests.test_map_view_iterate'.

2020-11-11 Thread GitBox
flinkbot commented on pull request #14043: URL: https://github.com/apache/flink/pull/14043#issuecomment-725903766 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-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

2020-11-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230405#comment-17230405 ] Arvid Heise commented on FLINK-19585: - Backport will happen after [~trohrmann] fixed

[GitHub] [flink] twalthr commented on pull request #14035: [FLINK-19340][table-runtime-blink] Support NestedRowData in RowDataSerializer#copy

2020-11-11 Thread GitBox
twalthr commented on pull request #14035: URL: https://github.com/apache/flink/pull/14035#issuecomment-725903180 Thanks @wuchong. I updated the PR. This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] WeiZhong94 opened a new pull request #14043: [FLINK-20046][python] Fix the unstable test case 'StreamTableAggregateTests.test_map_view_iterate'.

2020-11-11 Thread GitBox
WeiZhong94 opened a new pull request #14043: URL: https://github.com/apache/flink/pull/14043 ## What is the purpose of the change *This pull request fixes the unstable test case 'StreamTableAggregateTests.test_map_view_iterate'.* ## Brief change log - *Fix the uns

[jira] [Updated] (FLINK-20046) StreamTableAggregateTests.test_map_view_iterate is instable

2020-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20046: --- Labels: pull-request-available test-stability (was: test-stability) > StreamTableAggregateT

[GitHub] [flink] kl0u commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-11 Thread GitBox
kl0u commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725901773 Hi @SteNicholas , I reviewing your PR now. One thing to add is some tests (for each client) that verify that all clients throw the expected type of exception. This is to make sure

[jira] [Created] (FLINK-20101) Fix the wrong documentation of FROM_UNIXTIME function

2020-11-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-20101: --- Summary: Fix the wrong documentation of FROM_UNIXTIME function Key: FLINK-20101 URL: https://issues.apache.org/jira/browse/FLINK-20101 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-19667) Add integration with AWS Glue

2020-11-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230398#comment-17230398 ] Robert Metzger commented on FLINK-19667: Yes, the cutoff date for new features w

[GitHub] [flink] morsapaes commented on a change in pull request #14041: [FLINK-20096][docs] Clean up PyFlink docs

2020-11-11 Thread GitBox
morsapaes commented on a change in pull request #14041: URL: https://github.com/apache/flink/pull/14041#discussion_r521887420 ## File path: docs/dev/python/table-api-users-guide/index.md ## @@ -24,7 +24,6 @@ under the License. --> Python Table API allows users to develop [T

[GitHub] [flink] morsapaes commented on a change in pull request #14041: [FLINK-20096][docs] Clean up PyFlink docs

2020-11-11 Thread GitBox
morsapaes commented on a change in pull request #14041: URL: https://github.com/apache/flink/pull/14041#discussion_r521870246 ## File path: docs/dev/python/table-api-users-guide/conversion_of_pandas.md ## @@ -22,17 +22,18 @@ specific language governing permissions and limitatio

[GitHub] [flink] morsapaes commented on a change in pull request #14041: [FLINK-20096][docs] Clean up PyFlink docs

2020-11-11 Thread GitBox
morsapaes commented on a change in pull request #14041: URL: https://github.com/apache/flink/pull/14041#discussion_r521871549 ## File path: docs/dev/python/table-api-users-guide/conversion_of_pandas.md ## @@ -60,11 +61,11 @@ table = t_env.from_pandas(pdf, ## Convert PyFlink

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][csv] Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718406146 ## CI report: * 6dd7a167a257fe6379340600a53ab4262c35f62f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

2020-11-11 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230377#comment-17230377 ] Xuannan Su commented on FLINK-19253: [~becket_qin] I think https://issues.apache.org

[jira] [Updated] (FLINK-20100) Lag aggregate function does not return lag, but current row

2020-11-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20100: Component/s: Table SQL / Planner > Lag aggregate function does not return lag, but current row > -

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][csv] Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718406146 ## CI report: * 63f6644db59a1a512ceef894317b3bf29355b7a0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-20100) Lag aggregate function does not return lag, but current row

2020-11-11 Thread Thilo Schneider (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thilo Schneider updated FLINK-20100: Description: The lag aggregate function seems to always return the current row and not the

[jira] [Updated] (FLINK-20100) Lag aggregate function does not return lag, but current row

2020-11-11 Thread Thilo Schneider (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thilo Schneider updated FLINK-20100: Description: The lag aggregate function seems to always return the current row and not the

[jira] [Created] (FLINK-20100) Lag aggregate function does not return lag, but current row

2020-11-11 Thread Thilo Schneider (Jira)
Thilo Schneider created FLINK-20100: --- Summary: Lag aggregate function does not return lag, but current row Key: FLINK-20100 URL: https://issues.apache.org/jira/browse/FLINK-20100 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-724437611 ## CI report: * 19fdb8c1ce84f1a0c8b432331e8da5678fd98383 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-15906) physical memory exceeded causing being killed by yarn

2020-11-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230365#comment-17230365 ] Xintong Song commented on FLINK-15906: -- Hi [~清月], If the problem does not happen f

[GitHub] [flink] flinkbot edited a comment on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * 789adc9519b48d6474d12b282d529ea0a024bfc9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14032: [FLINK-19863][tests] check embedded zookeeper status when start/close hbase resource

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14032: URL: https://github.com/apache/flink/pull/14032#issuecomment-725359904 ## CI report: * b201454a7b90b9f332263f5e2b7013d67d11a8fe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-724437611 ## CI report: * 1793e46f94174a314f182dbf7845cd229d014d70 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14032: [FLINK-19863][tests] check embedded zookeeper status when start/close hbase resource

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14032: URL: https://github.com/apache/flink/pull/14032#issuecomment-725359904 ## CI report: * b201454a7b90b9f332263f5e2b7013d67d11a8fe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-724437611 ## CI report: * 1793e46f94174a314f182dbf7845cd229d014d70 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on a change in pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

2020-11-11 Thread GitBox
leonardBang commented on a change in pull request #14027: URL: https://github.com/apache/flink/pull/14027#discussion_r521808438 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecJoin.scala ##

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][csv] Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718406146 ## CI report: * dc0a2a29d0fba59d7b7769353bd4d91aa1307ecb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on a change in pull request #14027: [FLINK-20074][table-planner-blink] Fix can't generate plan when joining on changelog source without updates

2020-11-11 Thread GitBox
leonardBang commented on a change in pull request #14027: URL: https://github.com/apache/flink/pull/14027#discussion_r521808720 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.sc

[jira] [Commented] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230341#comment-17230341 ] ChangZhuo Chen (陳昌倬) commented on FLINK-20082: -- There are some finding for

[GitHub] [flink] flinkbot edited a comment on pull request #14040: [FLINK-20097][checkpointing] Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14040: URL: https://github.com/apache/flink/pull/14040#issuecomment-725585398 ## CI report: * 5f1010916f552c9a4ae623a7154ccaaa2b1fdb76 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][csv] Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718406146 ## CI report: * dc0a2a29d0fba59d7b7769353bd4d91aa1307ecb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19872) Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19872: Fix Version/s: 1.12.0 > Fix CSV format is unable to parse millisecond for TIME type >

[jira] [Updated] (FLINK-19872) Fix CSV format is unable to parse millisecond for TIME type

2020-11-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19872: Summary: Fix CSV format is unable to parse millisecond for TIME type (was: Support to parse millisecond f

[GitHub] [flink] wangyang0918 commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-11 Thread GitBox
wangyang0918 commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r521791380 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,74 @@ Starting zookeeper daemon on host localhost. $ bin/yarn-session.

[GitHub] [flink] wuchong commented on a change in pull request #14035: [FLINK-19340][table-runtime-blink] Support NestedRowData in RowDataSerializer#copy

2020-11-11 Thread GitBox
wuchong commented on a change in pull request #14035: URL: https://github.com/apache/flink/pull/14035#discussion_r521786370 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/RowDataSerializerTest.java ## @@ -205,44 +243,

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718406146 ## CI report: * dc0a2a29d0fba59d7b7769353bd4d91aa1307ecb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19667) Add integration with AWS Glue

2020-11-11 Thread Mohit Paliwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230327#comment-17230327 ] Mohit Paliwal commented on FLINK-19667: --- Hi Robert - One more question, do you hav

[jira] [Commented] (FLINK-18932) Add a "Overview" document under the "Python API" section

2020-11-11 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230326#comment-17230326 ] Wei Zhong commented on FLINK-18932: --- [~sjwiesman] Of course. Thank you! > Add a "Over

[GitHub] [flink] dianfu commented on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

2020-11-11 Thread GitBox
dianfu commented on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-725787288 @becketqin Fair enough for me. +1 from my side. This is an automated message from the Apache Git Service. To resp

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-11-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230324#comment-17230324 ] Dian Fu commented on FLINK-19863: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] dianfu commented on a change in pull request #14041: [FLINK-20096][docs] Clean up PyFlink docs

2020-11-11 Thread GitBox
dianfu commented on a change in pull request #14041: URL: https://github.com/apache/flink/pull/14041#discussion_r521771064 ## File path: docs/dev/python/index.zh.md ## @@ -22,3 +23,43 @@ KIND, either express or implied. See the License for the specific language governing perm

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718406146 ## CI report: * dc0a2a29d0fba59d7b7769353bd4d91aa1307ecb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pyscala commented on a change in pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

2020-11-11 Thread GitBox
pyscala commented on a change in pull request #13834: URL: https://github.com/apache/flink/pull/13834#discussion_r521769804 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvRowDataSerDeSchemaTest.java ## @@ -150,6 +151,24 @@ public void testS

[GitHub] [flink] xccui commented on pull request #13974: [hotfix][doc] Fix a concurrent issue in testing.md

2020-11-11 Thread GitBox
xccui commented on pull request #13974: URL: https://github.com/apache/flink/pull/13974#issuecomment-725765326 I've done that 😊 This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

2020-11-11 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230315#comment-17230315 ] Kezhu Wang commented on FLINK-19864: I think this is probably caused by misuse of {{

[jira] [Comment Edited] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230308#comment-17230308 ] ChangZhuo Chen (陳昌倬) edited comment on FLINK-20082 at 11/12/20, 1:02 AM: -

[jira] [Updated] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-20082: - Environment: * Flink 1.11.2 * Java 11 * Scala 2.12.11 was: * Flink 1.11.2

[jira] [Updated] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-20082: - Attachment: Flink-1.11.2_Scala-2.12.log > Cannot start Flink application due to

[GitHub] [flink] flinkbot edited a comment on pull request #14040: [FLINK-20097][checkpointing] Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14040: URL: https://github.com/apache/flink/pull/14040#issuecomment-725585398 ## CI report: * 690c631a452a67702d2191c5dc2b3146e7338322 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * 789adc9519b48d6474d12b282d529ea0a024bfc9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230308#comment-17230308 ] ChangZhuo Chen (陳昌倬) commented on FLINK-20082: -- [~gaoyunhaii], * The full

[GitHub] [flink] flinkbot commented on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-11 Thread GitBox
flinkbot commented on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * 789adc9519b48d6474d12b282d529ea0a024bfc9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-20082: - Attachment: Flink-1.11.2_Scala-2.11.log > Cannot start Flink application due to

[jira] [Updated] (FLINK-20082) Cannot start Flink application due to "cannot assign instance of java.lang.invoke.SerializedLambda to type scala.Function1

2020-11-11 Thread 陳昌倬
[ https://issues.apache.org/jira/browse/FLINK-20082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangZhuo Chen (陳昌倬) updated FLINK-20082: - Environment: * Flink 1.11.2 * Java 11 * Scala 2.11.12 was: * Flink 1.11.2

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-11 Thread Xiang Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230306#comment-17230306 ] Xiang Gao commented on FLINK-19300: --- Created a PR. Seems like in case of non-versioned

[GitHub] [flink] flinkbot commented on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

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

[jira] [Updated] (FLINK-19300) Timer loss after restoring from savepoint

2020-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19300: --- Labels: pull-request-available (was: ) > Timer loss after restoring from savepoint > --

[GitHub] [flink] Acesine opened a new pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-11 Thread GitBox
Acesine opened a new pull request #14042: URL: https://github.com/apache/flink/pull/14042 ## What is the purpose of the change This pull request fixes a timer loss issue when deserializing heap based timers, by fully reading input stream. Currently we depend on InputSt

[jira] [Created] (FLINK-20099) HeapStateBackend checkpoint error hidden under cryptic message

2020-11-11 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-20099: --- Summary: HeapStateBackend checkpoint error hidden under cryptic message Key: FLINK-20099 URL: https://issues.apache.org/jira/browse/FLINK-20099 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14040: [FLINK-20097][checkpointing] Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14040: URL: https://github.com/apache/flink/pull/14040#issuecomment-725585398 ## CI report: * d95bf0fdccd16306024e3d37b81f7704cd618dc4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Resolved] (FLINK-9300) Improve error message when in-memory state is too large

2020-11-11 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9300. Resolution: Cannot Reproduce Closing due to inactivity. > Improve error message when in-memory sta

[GitHub] [flink] flinkbot edited a comment on pull request #14040: [FLINK-20097][checkpointing] Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14040: URL: https://github.com/apache/flink/pull/14040#issuecomment-725585398 ## CI report: * d95bf0fdccd16306024e3d37b81f7704cd618dc4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] gvauvert opened a new pull request #173: Fix some typos in Java code in documentation

2020-11-11 Thread GitBox
gvauvert opened a new pull request #173: URL: https://github.com/apache/flink-statefun/pull/173 Hi, I propose to fix obvious typos in Java code in documentation. Thanks. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-725222918 ## CI report: * 7eeaee3de15449732a05aa075b10cbbf9e152c2a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20097: -- Priority: Critical (was: Major) > Race conditions in InputChannel.ChannelStatePersist

[GitHub] [flink] flinkbot edited a comment on pull request #14037: Revert "[FLINK-20033] Ensure that stopping a JobMaster will suspend the running job"

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14037: URL: https://github.com/apache/flink/pull/14037#issuecomment-725562164 ## CI report: * 9e33b284267c603bbd75fd933b2a1fffd1a4a748 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230255#comment-17230255 ] Roman Khachatryan commented on FLINK-20097: --- Please note, that even with a sin

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230241#comment-17230241 ] Arvid Heise commented on FLINK-20097: - > In AC mode, it seems to always pass (didn't

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230236#comment-17230236 ] Arvid Heise commented on FLINK-20097: - ``` Caused by: java.util.NoSuchElementExcepti

[jira] [Comment Edited] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230236#comment-17230236 ] Arvid Heise edited comment on FLINK-20097 at 11/11/20, 9:25 PM: --

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230235#comment-17230235 ] Arvid Heise commented on FLINK-20097: - You are right that the code currently is not

[GitHub] [flink] flinkbot edited a comment on pull request #14038: [BP-1.11] Revert "[FLINK-20033] Ensure that stopping a JobMaster will suspend the running job"

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14038: URL: https://github.com/apache/flink/pull/14038#issuecomment-725562511 ## CI report: * 20a93f5e041c8414e5cf1b91d73b1d76b25e42ad Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14040: [FLINK-20097][checkpointing] Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14040: URL: https://github.com/apache/flink/pull/14040#issuecomment-725585398 ## CI report: * d95bf0fdccd16306024e3d37b81f7704cd618dc4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14040: [FLINK-20097][checkpointing] Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14040: URL: https://github.com/apache/flink/pull/14040#issuecomment-725585398 ## CI report: * d95bf0fdccd16306024e3d37b81f7704cd618dc4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20097: -- Summary: Race conditions in InputChannel.ChannelStatePersister (was: Race conditions

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230202#comment-17230202 ] Roman Khachatryan commented on FLINK-20097: --- Fixing the original issues with C

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230195#comment-17230195 ] Roman Khachatryan commented on FLINK-20097: --- Just to clarify, I used shouldP

[jira] [Comment Edited] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230183#comment-17230183 ] Roman Khachatryan edited comment on FLINK-20097 at 11/11/20, 8:05 PM:

[GitHub] [flink] flinkbot edited a comment on pull request #14041: [FLINK-20096][docs] Add clean up PyFlink docs

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14041: URL: https://github.com/apache/flink/pull/14041#issuecomment-725623844 ## CI report: * 8db7bc182e4c999ac23507ab6c691c09c6fa265b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14035: [FLINK-19340][table-runtime-blink] Support NestedRowData in RowDataSerializer#copy

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14035: URL: https://github.com/apache/flink/pull/14035#issuecomment-725492251 ## CI report: * fa239b08ec2237f4c47fd9871b37017a177fef9a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230189#comment-17230189 ] Roman Khachatryan edited comment on FLINK-20097 at 11/11/20, 7:58 PM:

[jira] [Comment Edited] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230189#comment-17230189 ] Roman Khachatryan edited comment on FLINK-20097 at 11/11/20, 7:55 PM:

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230189#comment-17230189 ] Roman Khachatryan commented on FLINK-20097: --- And with {code} e

[GitHub] [flink] flinkbot commented on pull request #14041: [FLINK-20096][docs] Add clean up PyFlink docs

2020-11-11 Thread GitBox
flinkbot commented on pull request #14041: URL: https://github.com/apache/flink/pull/14041#issuecomment-725623844 ## CI report: * 8db7bc182e4c999ac23507ab6c691c09c6fa265b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister (confirm)

2020-11-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230183#comment-17230183 ] Roman Khachatryan commented on FLINK-20097: --- OK, the tests fail with the incre

[GitHub] [flink] flinkbot commented on pull request #14041: [FLINK-20096][docs] Add clean up PyFlink docs

2020-11-11 Thread GitBox
flinkbot commented on pull request #14041: URL: https://github.com/apache/flink/pull/14041#issuecomment-725616287 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] sjwiesman commented on pull request #14041: [FLINK-20096][docs] Add clean up PyFlink docs

2020-11-11 Thread GitBox
sjwiesman commented on pull request #14041: URL: https://github.com/apache/flink/pull/14041#issuecomment-725615134 cc @morsapaes This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #14039: [BP-1.10] Revert "[FLINK-20033] Ensure that stopping a JobMaster will suspend the running job"

2020-11-11 Thread GitBox
flinkbot edited a comment on pull request #14039: URL: https://github.com/apache/flink/pull/14039#issuecomment-725563191 ## CI report: * f63c90a10178063598a6b7c91f6325a8f191479a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/200081234) Bot comman

[jira] [Updated] (FLINK-20096) Clean up PyFlink documentation

2020-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20096: --- Labels: pull-request-available (was: ) > Clean up PyFlink documentation > -

[GitHub] [flink] sjwiesman opened a new pull request #14041: [FLINK-20096][docs] Add clean up PyFlink docs

2020-11-11 Thread GitBox
sjwiesman opened a new pull request #14041: URL: https://github.com/apache/flink/pull/14041 ## What is the purpose of the change This cleans up the PyFlink documentation. Mostly fixing English grammar and adding additional cross-links. I've also added an overview page to the section.

[GitHub] [flink] sjwiesman commented on a change in pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

2020-11-11 Thread GitBox
sjwiesman commented on a change in pull request #14003: URL: https://github.com/apache/flink/pull/14003#discussion_r521573057 ## File path: docs/dev/table/sql/gettingStarted.md ## @@ -0,0 +1,200 @@ +--- +title: "Getting Started - Flink SQL" +nav-parent_id: sql +nav-pos: 0 +---

[GitHub] [flink] sjwiesman commented on a change in pull request #14036: [FLINK-20093] Create a download page for all optional sql client components

2020-11-11 Thread GitBox
sjwiesman commented on a change in pull request #14036: URL: https://github.com/apache/flink/pull/14036#discussion_r521571620 ## File path: docs/_data/sql-connectors.yml ## @@ -0,0 +1,86 @@ +avro: Review comment: Could you also add a comment explaining how to add a new

  1   2   3   4   >