[jira] [Updated] (FLINK-19212) Failed to serialize the result for RPC call : requestTaskManagerInfo.

2020-09-12 Thread Kenzyme Le (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19212: --- Environment: (was: * Debian 9 * 2 TMs * 2 JMs * 3 ZKs * S3 for checkpoints/savepoints) > Fa

[jira] [Commented] (FLINK-19212) Failed to serialize the result for RPC call : requestTaskManagerInfo.

2020-09-12 Thread Kenzyme Le (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194926#comment-17194926 ] Kenzyme Le commented on FLINK-19212: Here is the related mailing list: [http://mail

[jira] [Created] (FLINK-19212) Failed to serialize the result for RPC call : requestTaskManagerInfo.

2020-09-12 Thread Ken (Jira)
Ken created FLINK-19212: --- Summary: Failed to serialize the result for RPC call : requestTaskManagerInfo. Key: FLINK-19212 URL: https://issues.apache.org/jira/browse/FLINK-19212 Project: Flink Issue T

[jira] [Updated] (FLINK-19211) SQL Read Decimal In Parquet Error

2020-09-12 Thread nyq (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyq updated FLINK-19211: Description: Use impala-3.2.0-cdh6.3.2 to create a parquet table with a decimal column:      create table test (a

[jira] [Updated] (FLINK-19211) SQL Read Decimal In Parquet Error

2020-09-12 Thread nyq (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyq updated FLINK-19211: Description: I use impala-3.2.0-cdh6.3.2 generate a parquet table with a decimal column:      create table test (

[jira] [Created] (FLINK-19211) SQL Read Decimal In Parquet Error

2020-09-12 Thread nyq (Jira)
nyq created FLINK-19211: --- Summary: SQL Read Decimal In Parquet Error Key: FLINK-19211 URL: https://issues.apache.org/jira/browse/FLINK-19211 Project: Flink Issue Type: Bug Components: Connect

[jira] [Comment Edited] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

2020-09-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194912#comment-17194912 ] Dian Fu edited comment on FLINK-17912 at 9/13/20, 12:29 AM:

[jira] [Commented] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

2020-09-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194912#comment-17194912 ] Dian Fu commented on FLINK-17912: - Another instance on 1.11: https://dev.azure.com/apach

[jira] [Created] (FLINK-19210) TPC-DS end-to-end test (Blink planner) failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout"

2020-09-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-19210: --- Summary: TPC-DS end-to-end test (Blink planner) failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout" Key: FLINK-19210 URL: https://i

[jira] [Updated] (FLINK-19210) TPC-DS end-to-end test (Blink planner) failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout"

2020-09-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19210: Labels: test-stability (was: ) > TPC-DS end-to-end test (Blink planner) failed with > "NoResourceAvailab

[jira] [Created] (FLINK-19209) Single bucket

2020-09-12 Thread Jira
Michał Strużek created FLINK-19209: -- Summary: Single bucket Key: FLINK-19209 URL: https://issues.apache.org/jira/browse/FLINK-19209 Project: Flink Issue Type: Bug Components: API /

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

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

[GitHub] [flink] flinkbot commented on pull request #13372: [FLINK-19187][examples-table] Add a new basic Table API example

2020-09-12 Thread GitBox
flinkbot commented on pull request #13372: URL: https://github.com/apache/flink/pull/13372#issuecomment-691067862 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #13376: [FLINK-19208] Refine the tuple's equals

2020-09-12 Thread GitBox
flinkbot commented on pull request #13376: URL: https://github.com/apache/flink/pull/13376#issuecomment-691477620 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #147: [FLINK-19197] [docs] Add documentation for PersistedStateRegistry

2020-09-12 Thread GitBox
sjwiesman commented on a change in pull request #147: URL: https://github.com/apache/flink-statefun/pull/147#discussion_r487120168 ## File path: docs/sdk/java.md ## @@ -364,6 +364,43 @@ PersistedTable table = PersistedTable.of("my-table", String.cla PersistedAppendingBuffer b

[GitHub] [flink-web] zhuzhurk edited a comment on pull request #378: Add xtsong to the committer list.

2020-09-12 Thread GitBox
zhuzhurk edited a comment on pull request #378: URL: https://github.com/apache/flink-web/pull/378#issuecomment-691136281 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] aljoscha commented on a change in pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
aljoscha commented on a change in pull request #13360: URL: https://github.com/apache/flink/pull/13360#discussion_r487121698 ## File path: docs/dev/connectors/kafka.md ## @@ -405,8 +385,7 @@ Consider setting appropriate [idelness timeouts]({{ site.baseurl }}/dev/event_ti #

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink-statefun] sjwiesman closed pull request #149: [FLINK-19203] Use Scala 2.12 Flink variants

2020-09-12 Thread GitBox
sjwiesman closed pull request #149: URL: https://github.com/apache/flink-statefun/pull/149 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 g

[GitHub] [flink] flinkbot commented on pull request #13374: [FLINK-19109][streaming] Disallow chaining of CFRO and ProcessingTimeCallback. [1.10]

2020-09-12 Thread GitBox
flinkbot commented on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691168441 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-web] zhuzhurk commented on pull request #378: Add xtsong to the committer list.

2020-09-12 Thread GitBox
zhuzhurk commented on pull request #378: URL: https://github.com/apache/flink-web/pull/378#issuecomment-691131606 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13376: [FLINK-19208] Refine the tuple's equals

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13376: URL: https://github.com/apache/flink/pull/13376#issuecomment-691478919 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zhuzhurk merged pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

2020-09-12 Thread GitBox
zhuzhurk merged pull request #13284: URL: https://github.com/apache/flink/pull/13284 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] flinkbot edited a comment on pull request #13374: [FLINK-19109][streaming] Disallow chaining of CFRO and ProcessingTimeCallback. [1.10]

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zjffdu closed pull request #6245: [FLINK-9718][scala-shell]. Add enviroment variable in start-scala-shell.sh and flink to enable remote debug

2020-09-12 Thread GitBox
zjffdu closed pull request #6245: URL: https://github.com/apache/flink/pull/6245 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink] rmetzger commented on pull request #6689: [FLINK-8247] [Mesos] Support case where hadoop is not on classpath

2020-09-12 Thread GitBox
rmetzger commented on pull request #6689: URL: https://github.com/apache/flink/pull/6689#issuecomment-690992858 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zhuzhurk commented on pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

2020-09-12 Thread GitBox
zhuzhurk commented on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-691124551 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys commented on a change in pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
dawidwys commented on a change in pull request #13360: URL: https://github.com/apache/flink/pull/13360#discussion_r486946393 ## File path: docs/dev/connectors/kafka.md ## @@ -466,12 +445,12 @@ Through the producer record you can: ### Kafka Producers and Fault Tolerance - -

[GitHub] [flink-playgrounds] morsapaes commented on a change in pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

2020-09-12 Thread GitBox
morsapaes commented on a change in pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#discussion_r486966065 ## File path: pyflink-walkthrough/payment_msg_proccessing.py ## @@ -0,0 +1,93 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13360: URL: https://github.com/apache/flink/pull/13360#issuecomment-689414065 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] pnowojski commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

2020-09-12 Thread GitBox
pnowojski commented on a change in pull request #13228: URL: https://github.com/apache/flink/pull/13228#discussion_r487038327 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -167,23 +171,46 @@ private boo

[GitHub] [flink] dawidwys commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
dawidwys commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487027309 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java ## @@ -58,7 +55,7 @@ @RunWith(Parameteri

[GitHub] [flink] zjffdu closed pull request #7214: [FLINK-11049] Unable to execute partial DAG

2020-09-12 Thread GitBox
zjffdu closed pull request #7214: URL: https://github.com/apache/flink/pull/7214 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink] walterddr commented on a change in pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-12 Thread GitBox
walterddr commented on a change in pull request #13356: URL: https://github.com/apache/flink/pull/13356#discussion_r487432460 ## File path: docs/_includes/generated/execution_config_configuration.html ## @@ -106,6 +100,12 @@ Boolean Whether to compress

[GitHub] [flink] twalthr commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
twalthr commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487029161 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java ## @@ -176,14 +181,25 @@ public void getFlatCompar

[GitHub] [flink] kezhuw commented on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

2020-09-12 Thread GitBox
kezhuw commented on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691409015 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] zjffdu closed pull request #6236: [FLINK-9699] [table] Add api to replace registered table

2020-09-12 Thread GitBox
zjffdu closed pull request #6236: URL: https://github.com/apache/flink/pull/6236 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink] flinkbot edited a comment on pull request #13372: [FLINK-19187][examples-table] Add a new basic Table API example

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13372: URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

2020-09-12 Thread GitBox
flinkbot commented on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691408906 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] aljoscha commented on pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
aljoscha commented on pull request #13360: URL: https://github.com/apache/flink/pull/13360#issuecomment-691176913 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys commented on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
dawidwys commented on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691240195 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] aljoscha commented on pull request #13343: [FLINK-19083] Remove deprecated DataStream#split

2020-09-12 Thread GitBox
aljoscha commented on pull request #13343: URL: https://github.com/apache/flink/pull/13343#issuecomment-691149771 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
flinkbot commented on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691077759 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] rmetzger closed pull request #6689: [FLINK-8247] [Mesos] Support case where hadoop is not on classpath

2020-09-12 Thread GitBox
rmetzger closed pull request #6689: URL: https://github.com/apache/flink/pull/6689 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691410175 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13376: [FLINK-19208] Refine the tuple's equals

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13376: URL: https://github.com/apache/flink/pull/13376#issuecomment-691478919 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zhuzhurk merged pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

2020-09-12 Thread GitBox
zhuzhurk merged pull request #13284: URL: https://github.com/apache/flink/pull/13284 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13374: [FLINK-19109][streaming] Disallow chaining of CFRO and ProcessingTimeCallback. [1.10]

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zjffdu closed pull request #6245: [FLINK-9718][scala-shell]. Add enviroment variable in start-scala-shell.sh and flink to enable remote debug

2020-09-12 Thread GitBox
zjffdu closed pull request #6245: URL: https://github.com/apache/flink/pull/6245 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink] rmetzger commented on pull request #6689: [FLINK-8247] [Mesos] Support case where hadoop is not on classpath

2020-09-12 Thread GitBox
rmetzger commented on pull request #6689: URL: https://github.com/apache/flink/pull/6689#issuecomment-690992858 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zhuzhurk commented on pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

2020-09-12 Thread GitBox
zhuzhurk commented on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-691124551 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys commented on a change in pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
dawidwys commented on a change in pull request #13360: URL: https://github.com/apache/flink/pull/13360#discussion_r486946393 ## File path: docs/dev/connectors/kafka.md ## @@ -466,12 +445,12 @@ Through the producer record you can: ### Kafka Producers and Fault Tolerance - -

[GitHub] [flink-playgrounds] morsapaes commented on a change in pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

2020-09-12 Thread GitBox
morsapaes commented on a change in pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#discussion_r486966065 ## File path: pyflink-walkthrough/payment_msg_proccessing.py ## @@ -0,0 +1,93 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13360: URL: https://github.com/apache/flink/pull/13360#issuecomment-689414065 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] pnowojski commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

2020-09-12 Thread GitBox
pnowojski commented on a change in pull request #13228: URL: https://github.com/apache/flink/pull/13228#discussion_r487038327 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -167,23 +171,46 @@ private boo

[GitHub] [flink] dawidwys commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
dawidwys commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487027309 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java ## @@ -58,7 +55,7 @@ @RunWith(Parameteri

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #147: [FLINK-19197] [docs] Add documentation for PersistedStateRegistry

2020-09-12 Thread GitBox
sjwiesman commented on a change in pull request #147: URL: https://github.com/apache/flink-statefun/pull/147#discussion_r487120168 ## File path: docs/sdk/java.md ## @@ -364,6 +364,43 @@ PersistedTable table = PersistedTable.of("my-table", String.cla PersistedAppendingBuffer b

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #13376: [FLINK-19208] Refine the tuple's equals

2020-09-12 Thread GitBox
flinkbot commented on pull request #13376: URL: https://github.com/apache/flink/pull/13376#issuecomment-691477620 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #13372: [FLINK-19187][examples-table] Add a new basic Table API example

2020-09-12 Thread GitBox
flinkbot commented on pull request #13372: URL: https://github.com/apache/flink/pull/13372#issuecomment-691067862 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-web] zhuzhurk edited a comment on pull request #378: Add xtsong to the committer list.

2020-09-12 Thread GitBox
zhuzhurk edited a comment on pull request #378: URL: https://github.com/apache/flink-web/pull/378#issuecomment-691136281 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679099456 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] aljoscha commented on a change in pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
aljoscha commented on a change in pull request #13360: URL: https://github.com/apache/flink/pull/13360#discussion_r487121698 ## File path: docs/dev/connectors/kafka.md ## @@ -405,8 +385,7 @@ Consider setting appropriate [idelness timeouts]({{ site.baseurl }}/dev/event_ti #

[GitHub] [flink-statefun] sjwiesman closed pull request #149: [FLINK-19203] Use Scala 2.12 Flink variants

2020-09-12 Thread GitBox
sjwiesman closed pull request #149: URL: https://github.com/apache/flink-statefun/pull/149 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 g

[GitHub] [flink] flinkbot commented on pull request #13374: [FLINK-19109][streaming] Disallow chaining of CFRO and ProcessingTimeCallback. [1.10]

2020-09-12 Thread GitBox
flinkbot commented on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691168441 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-web] zhuzhurk commented on pull request #378: Add xtsong to the committer list.

2020-09-12 Thread GitBox
zhuzhurk commented on pull request #378: URL: https://github.com/apache/flink-web/pull/378#issuecomment-691131606 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] zjffdu closed pull request #7214: [FLINK-11049] Unable to execute partial DAG

2020-09-12 Thread GitBox
zjffdu closed pull request #7214: URL: https://github.com/apache/flink/pull/7214 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink] walterddr commented on a change in pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-12 Thread GitBox
walterddr commented on a change in pull request #13356: URL: https://github.com/apache/flink/pull/13356#discussion_r487432460 ## File path: docs/_includes/generated/execution_config_configuration.html ## @@ -106,6 +100,12 @@ Boolean Whether to compress

[GitHub] [flink] twalthr commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
twalthr commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487029161 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java ## @@ -176,14 +181,25 @@ public void getFlatCompar

[GitHub] [flink] kezhuw commented on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

2020-09-12 Thread GitBox
kezhuw commented on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691409015 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] zjffdu closed pull request #6236: [FLINK-9699] [table] Add api to replace registered table

2020-09-12 Thread GitBox
zjffdu closed pull request #6236: URL: https://github.com/apache/flink/pull/6236 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink] flinkbot edited a comment on pull request #13372: [FLINK-19187][examples-table] Add a new basic Table API example

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13372: URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691085636 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

2020-09-12 Thread GitBox
flinkbot commented on pull request #13375: URL: https://github.com/apache/flink/pull/13375#issuecomment-691408906 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys commented on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
dawidwys commented on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691240195 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] aljoscha commented on pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
aljoscha commented on pull request #13360: URL: https://github.com/apache/flink/pull/13360#issuecomment-691176913 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #147: [FLINK-19197] [docs] Add documentation for PersistedStateRegistry

2020-09-12 Thread GitBox
sjwiesman commented on a change in pull request #147: URL: https://github.com/apache/flink-statefun/pull/147#discussion_r487120168 ## File path: docs/sdk/java.md ## @@ -364,6 +364,43 @@ PersistedTable table = PersistedTable.of("my-table", String.cla PersistedAppendingBuffer b

[GitHub] [flink] aljoscha commented on pull request #13343: [FLINK-19083] Remove deprecated DataStream#split

2020-09-12 Thread GitBox
aljoscha commented on pull request #13343: URL: https://github.com/apache/flink/pull/13343#issuecomment-691149771 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] rmetzger closed pull request #6689: [FLINK-8247] [Mesos] Support case where hadoop is not on classpath

2020-09-12 Thread GitBox
rmetzger closed pull request #6689: URL: https://github.com/apache/flink/pull/6689 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 t

[GitHub] [flink] flinkbot commented on pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
flinkbot commented on pull request #13373: URL: https://github.com/apache/flink/pull/13373#issuecomment-691077759 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13375: [FLINK-18815][filesystems][tests] Join SafetyNetCloseableRegistry's reaper thread before assertion

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

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #13376: [FLINK-19208] Refine the tuple's equals

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13376: URL: https://github.com/apache/flink/pull/13376#issuecomment-691478919 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zhuzhurk merged pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

2020-09-12 Thread GitBox
zhuzhurk merged pull request #13284: URL: https://github.com/apache/flink/pull/13284 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-web] xintongsong commented on pull request #378: Add xtsong to the committer list.

2020-09-12 Thread GitBox
xintongsong commented on pull request #378: URL: https://github.com/apache/flink-web/pull/378#issuecomment-690824584 Thanks for the reminder @zhuzhurk, and thanks for the pointer @morsapaes (Marta!) PR updated. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #13374: [FLINK-19109][streaming] Disallow chaining of CFRO and ProcessingTimeCallback. [1.10]

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zjffdu closed pull request #6245: [FLINK-9718][scala-shell]. Add enviroment variable in start-scala-shell.sh and flink to enable remote debug

2020-09-12 Thread GitBox
zjffdu closed pull request #6245: URL: https://github.com/apache/flink/pull/6245 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] rmetzger commented on pull request #6689: [FLINK-8247] [Mesos] Support case where hadoop is not on classpath

2020-09-12 Thread GitBox
rmetzger commented on pull request #6689: URL: https://github.com/apache/flink/pull/6689#issuecomment-690992858 I have the feeling that this ticket is stale. I will close it for now. If you or somebody else wants to work on it, please reopen or re-submit it. --

[GitHub] [flink] flinkbot edited a comment on pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13356: URL: https://github.com/apache/flink/pull/13356#issuecomment-688955548 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] zhuzhurk commented on pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

2020-09-12 Thread GitBox
zhuzhurk commented on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-691124551 Thanks for reviewing! @azagrebin Merging. This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] dawidwys commented on a change in pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
dawidwys commented on a change in pull request #13360: URL: https://github.com/apache/flink/pull/13360#discussion_r486946393 ## File path: docs/dev/connectors/kafka.md ## @@ -466,12 +445,12 @@ Through the producer record you can: ### Kafka Producers and Fault Tolerance - -

[GitHub] [flink-playgrounds] morsapaes commented on a change in pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

2020-09-12 Thread GitBox
morsapaes commented on a change in pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#discussion_r486966065 ## File path: pyflink-walkthrough/payment_msg_proccessing.py ## @@ -0,0 +1,93 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #13360: [FLINK-19152] Remove Kafka 0.10.x and 0.11.x connectors

2020-09-12 Thread GitBox
flinkbot edited a comment on pull request #13360: URL: https://github.com/apache/flink/pull/13360#issuecomment-689414065 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] dawidwys commented on a change in pull request #13373: [FLINK-18802] Upgrade avro to 1.10

2020-09-12 Thread GitBox
dawidwys commented on a change in pull request #13373: URL: https://github.com/apache/flink/pull/13373#discussion_r487027309 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java ## @@ -58,7 +55,7 @@ @RunWith(Parameteri

[GitHub] [flink] pnowojski commented on a change in pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

2020-09-12 Thread GitBox
pnowojski commented on a change in pull request #13228: URL: https://github.com/apache/flink/pull/13228#discussion_r487038327 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -167,23 +171,46 @@ private boo

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

2020-09-12 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194832#comment-17194832 ] Galen Warren commented on FLINK-19176: -- Hi [~igal] - I've forked the project and ta

  1   2   >