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

[ https://issues.apache.org/jira/browse/FLINK-17994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17994: - Fix Version/s: 1.12.0 > Fix the race condition between CheckpointBarrierUnaligner#processBarrier and >

[jira] [Commented] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120847#comment-17120847 ] Zhiye Zou commented on FLINK-18043: --- OK :) > Translate "Scala API Extensions" page of "DataStream

[GitHub] [flink] zhuzhurk commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

zhuzhurk commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r433114179 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java ## @@ -698,13 +680,13 @@ boolean offerSlot(

[GitHub] [flink] zhuzhurk commented on a change in pull request #12278: [FLINK-17019][runtime] Fulfill slot requests in request order

zhuzhurk commented on a change in pull request #12278: URL: https://github.com/apache/flink/pull/12278#discussion_r433113663 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolRequestCompletionTest.java ## @@ -103,7 +123,7 @@ private

[jira] [Commented] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120837#comment-17120837 ] Jark Wu commented on FLINK-18006: - This maybe a bug of JDK:

[jira] [Updated] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-18047: - Description: using filesystem batch write csv data to file, we set parallelism to 1, but

[GitHub] [flink] zhijiangW merged pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW merged pull request #12406: URL: https://github.com/apache/flink/pull/12406 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] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * a0fd8094daa24b484fbfdf2f2a0ec6d2b79271e6 Azure:

[jira] [Commented] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120834#comment-17120834 ] Jark Wu commented on FLINK-18006: - I also reproduced this problem by using SQL CLIENT. But I didn't find

[GitHub] [flink] zhijiangW commented on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW commented on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636698426 Thanks for the review @pnowojski , merging! This is an automated message from the Apache Git Service. To

[GitHub] [flink] zhijiangW edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW edited a comment on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-636698426 Thanks for the review @pnowojski , i will squash the last two commits and merge! This is an automated

[GitHub] [flink] flinkbot commented on pull request #12423: [FLINK-18034][runtime] Introduce PreferredLocationsRetriever

flinkbot commented on pull request #12423: URL: https://github.com/apache/flink/pull/12423#issuecomment-636697058 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-18034) Introduce PreferredLocationsRetriever

[ https://issues.apache.org/jira/browse/FLINK-18034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18034: --- Labels: pull-request-available (was: ) > Introduce PreferredLocationsRetriever >

[jira] [Comment Edited] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li edited comment on FLINK-18043 at 6/1/20, 8:27 AM: --- Hi [~zouzhiye],

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

zhuzhurk commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r433106488 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java ## @@ -96,52 +97,88 @@ public

[jira] [Comment Edited] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li edited comment on FLINK-18043 at 6/1/20, 8:26 AM: --- Hi [~zouzhiye],

[GitHub] [flink] zhuzhurk opened a new pull request #12423: [FLINK-18034][runtime] Introduce PreferredLocationsRetriever

zhuzhurk opened a new pull request #12423: URL: https://github.com/apache/flink/pull/12423 ## What is the purpose of the change Preferred locations based on state and inputs are scattered into multiple components, which makes it harder to reasoning the calculation and complicates

[jira] [Updated] (FLINK-18006) It will throw Invalid lambda deserialization Exception when writing to elastic search with new format

[ https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18006: Priority: Blocker (was: Critical) > It will throw Invalid lambda deserialization Exception when writing

[jira] [Updated] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-18047: - Description: using filesystem batch write csv data to file, we set parallelism to 1, but

[jira] [Comment Edited] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li edited comment on FLINK-18043 at 6/1/20, 8:24 AM: --- Hi [~zouzhiye],

[jira] [Commented] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120829#comment-17120829 ] Yubin Li commented on FLINK-18043: -- Hi [~zouzhiye], Sorry, I am also a starter, I dont have the right

[GitHub] [flink] senegalo commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-636692690 @austince and @dawidwys it seems there is an issue with azure can't rerun the pipeline and when it ran on Saturday i couldn't find mvn in the e2e tests. Please advise.

[jira] [Updated] (FLINK-18016) Document Unix Socket Remote Functions

[ https://issues.apache.org/jira/browse/FLINK-18016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18016: --- Labels: pull-request-available (was: ) > Document Unix Socket Remote Functions >

[GitHub] [flink-statefun] tzulitai opened a new pull request #124: [FLINK-18016] [doc] Add documentation for UDS domain socket transport

tzulitai opened a new pull request #124: URL: https://github.com/apache/flink-statefun/pull/124 Based on #123 just to avoid any merge conflicts in the docs. cc @sjwiesman @igalshilman This is an automated message from

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

tzulitai commented on a change in pull request #123: URL: https://github.com/apache/flink-statefun/pull/123#discussion_r433101941 ## File path: docs/sdk/python.md ## @@ -158,9 +158,8 @@ All stateful functions may contain state by merely storing values within the ``c The data

[jira] [Updated] (FLINK-18015) Document state TTL support in stateful functions

[ https://issues.apache.org/jira/browse/FLINK-18015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18015: --- Labels: pull-request-available (was: ) > Document state TTL support in stateful functions

[GitHub] [flink-statefun] tzulitai opened a new pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

tzulitai opened a new pull request #123: URL: https://github.com/apache/flink-statefun/pull/123 cc @sjwiesman for review. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #123: [FLINK-18015] [doc] Add documentation for state expiration

tzulitai commented on a change in pull request #123: URL: https://github.com/apache/flink-statefun/pull/123#discussion_r433101685 ## File path: docs/sdk/java.md ## @@ -364,6 +364,47 @@ PersistedTable table = PersistedTable.of("my-table", String.cla PersistedAppendingBuffer

[GitHub] [flink] flinkbot edited a comment on pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

flinkbot edited a comment on pull request #12421: URL: https://github.com/apache/flink/pull/12421#issuecomment-636607751 ## CI report: * 4947ec157537f1bc8dfab601ab8ad885eb725200 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12378: [FLINK-17965][sql-parser-hive] Hive dialect needs to unescape backslash in string literals

flinkbot edited a comment on pull request #12378: URL: https://github.com/apache/flink/pull/12378#issuecomment-635291016 ## CI report: * 4b4156796eded5a87a097c589c2d7d06a829bafa Azure:

[jira] [Commented] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120817#comment-17120817 ] Zhiye Zou commented on FLINK-18043: --- HI,[~liyubin117] . I'm a starter. I'm willing to translate this

[jira] [Comment Edited] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120814#comment-17120814 ] Piotr Nowojski edited comment on FLINK-17230 at 6/1/20, 7:59 AM: - merged

[jira] [Closed] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17230. -- Fix Version/s: (was: 1.12.0) Resolution: Fixed merged commit 9737f50 into

[GitHub] [flink] pnowojski merged pull request #12397: [FLINK-17230] Fix incorrect address of Endpoint for external Service with ClusterIP type

pnowojski merged pull request #12397: URL: https://github.com/apache/flink/pull/12397 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] flinkbot edited a comment on pull request #12406: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

flinkbot edited a comment on pull request #12406: URL: https://github.com/apache/flink/pull/12406#issuecomment-635907759 ## CI report: * b47a7645fd5636a98050231522a076537576e9a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12378: [FLINK-17965][sql-parser-hive] Hive dialect needs to unescape backslash in string literals

flinkbot edited a comment on pull request #12378: URL: https://github.com/apache/flink/pull/12378#issuecomment-635291016 ## CI report: * 4b4156796eded5a87a097c589c2d7d06a829bafa Azure:

[jira] [Updated] (FLINK-18046) Decimal column stats not supported for Hive table

[ https://issues.apache.org/jira/browse/FLINK-18046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18046: --- Description: For now, we can just return {{CatalogColumnStatisticsDataDouble}} for decimal columns. >

[GitHub] [flink] flinkbot edited a comment on pull request #12419: [FLINK-17996][table-planner-blink] NPE in CatalogTableStatisticsConverter.convertToColumnStats method

flinkbot edited a comment on pull request #12419: URL: https://github.com/apache/flink/pull/12419#issuecomment-636436128 ## CI report: * 64195fc52bf63e7631d059f87b63cc6dcd3b9b8d Azure:

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

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 497b8ff078b4055c3a69b56e762dfecb7973c3a6 Azure:

[jira] [Updated] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

[ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengnengsong updated FLINK-18047: - Issue Type: Bug (was: Improvement) > [DDL] ExecutotionEnvironment set the parallelism did not

[jira] [Created] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

pengnengsong created FLINK-18047: Summary: [DDL] ExecutotionEnvironment set the parallelism did not take effect Key: FLINK-18047 URL: https://issues.apache.org/jira/browse/FLINK-18047 Project: Flink

[jira] [Updated] (FLINK-18030) Hive UDF doesn't accept empty string literal parameter

[ https://issues.apache.org/jira/browse/FLINK-18030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18030: --- Fix Version/s: (was: 1.12.0) 1.11.0 > Hive UDF doesn't accept empty string literal

[jira] [Created] (FLINK-18046) Decimal column stats not supported for Hive table

Rui Li created FLINK-18046: -- Summary: Decimal column stats not supported for Hive table Key: FLINK-18046 URL: https://issues.apache.org/jira/browse/FLINK-18046 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

flinkbot edited a comment on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f Azure:

[jira] [Created] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

Bartosz Krasiński created FLINK-18045: - Summary: Newest version reintroduced a bug causing not working on secured MapR Key: FLINK-18045 URL: https://issues.apache.org/jira/browse/FLINK-18045

[jira] [Created] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

Jiangjie Qin created FLINK-18044: Summary: Add the subtask index information to the SourceReaderContext. Key: FLINK-18044 URL: https://issues.apache.org/jira/browse/FLINK-18044 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

flinkbot edited a comment on pull request #12421: URL: https://github.com/apache/flink/pull/12421#issuecomment-636607751 ## CI report: * 4947ec157537f1bc8dfab601ab8ad885eb725200 Azure:

[GitHub] [flink] flinkbot commented on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

flinkbot commented on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 497b8ff078b4055c3a69b56e762dfecb7973c3a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12146: [FLINK-17968][hbase] Fix Hadoop Configuration is not properly serialized in HBaseRowInputFormat

flinkbot edited a comment on pull request #12146: URL: https://github.com/apache/flink/pull/12146#issuecomment-628508688 ## CI report: * ea008e0dffab41f7f3ac373746605cdc3f6a2388 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

flinkbot edited a comment on pull request #12421: URL: https://github.com/apache/flink/pull/12421#issuecomment-636607751 ## CI report: * 4947ec157537f1bc8dfab601ab8ad885eb725200 Azure:

[GitHub] [flink] flinkbot commented on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

flinkbot commented on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636639198 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-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10954: - Priority: Critical (was: Major) > Hardlink from files of previous local stored state might cross

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10954: - Fix Version/s: (was: 1.11.0) 1.12.0 > Hardlink from files of previous local

[jira] [Updated] (FLINK-17901) Add module interface in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17901: --- Labels: pull-request-available starter (was: starter) > Add module interface in PyFlink >

[GitHub] [flink] SteNicholas opened a new pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

SteNicholas opened a new pull request #12422: URL: https://github.com/apache/flink/pull/12422 ## What is the purpose of the change *Method ```loadModule``` and ```unloadModule``` interfaces in the Java TableEnvironment are not available in the PyFlink Table API, that should provide

[GitHub] [flink] libenchao commented on a change in pull request #12421: [FLINK-18002][json] Correct the behavior for ContainerNode as varchar…

libenchao commented on a change in pull request #12421: URL: https://github.com/apache/flink/pull/12421#discussion_r433055376 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java ## @@ -375,8 +375,12 @@ private

<    1   2   3