czy006 commented on PR #21012:
URL: https://github.com/apache/flink/pull/21012#issuecomment-1296123544
@zentol PLAT
--
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 specific comment.
To
[
https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626171#comment-17626171
]
nobleyd commented on FLINK-27341:
-
Hi, this issue is not resolve in flink1.16, whilte I think it is
[
https://issues.apache.org/jira/browse/FLINK-29797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangmenglong updated FLINK-29797:
-
Description:
If I set the value of *fs.default-scheme* to other scheme and run a job on yarn.
wangmenglong created FLINK-29797:
Summary: can't run a job on yarn, if set fs.default-scheme
Key: FLINK-29797
URL: https://issues.apache.org/jira/browse/FLINK-29797
Project: Flink
Issue
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1003526661
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,179 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1008763069
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java:
##
@@ -0,0 +1,104 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1008763133
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -0,0 +1,179 @@
+/*
+ *
YuriGusev commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1008763069
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/PrimaryKeyBuilder.java:
##
@@ -0,0 +1,104 @@
+/*
+ *
Jorge Villatoro created FLINK-29796:
---
Summary: pyflink protobuf requirement out of date
Key: FLINK-29796
URL: https://issues.apache.org/jira/browse/FLINK-29796
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626127#comment-17626127
]
Mason Chen commented on FLINK-29711:
[~durgeshkumarmishragfx] can you post a minimal example of your
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 3:49 PM:
-
Thanks [~mason6345]!
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 3:49 PM:
-
Thanks [~mason6345]!
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 3:48 PM:
-
Thanks [~mason6345].
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 3:48 PM:
-
Thanks [~mason6345],
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 2:06 PM:
-
Thanks [~mason6345],
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 2:05 PM:
-
Thanks [~mason6345],
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 2:04 PM:
-
Thanks [~mason6345],
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 2:03 PM:
-
Thanks [~mason6345],
jiangxin369 commented on PR #162:
URL: https://github.com/apache/flink-ml/pull/162#issuecomment-1295843245
Thanks for the review. Seems that all comments are resolved, could you help
to merge this PR? @zhipeng93
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626053#comment-17626053
]
Sriram Ganesh edited comment on FLINK-29609 at 10/29/22 1:34 PM:
-
Please
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626053#comment-17626053
]
Sriram Ganesh commented on FLINK-29609:
---
Please don't reassign to others for sometime unless it is
1996fanrui commented on PR #21193:
URL: https://github.com/apache/flink/pull/21193#issuecomment-1295826469
@flinkbot run azure
--
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 specific
gaborgsomogyi commented on PR #21190:
URL: https://github.com/apache/flink/pull/21190#issuecomment-1295824376
cc @gyfora @mbalassi
--
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 specific
1996fanrui commented on PR #21193:
URL: https://github.com/apache/flink/pull/21193#issuecomment-1295811598
@flinkbot run azure
--
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 specific
gaborgsomogyi commented on PR #21192:
URL: https://github.com/apache/flink/pull/21192#issuecomment-1295790149
Since the main concept of the delegation token framework is based on the
Spark solution the documentation is also based on that. I would like to mark
that as main source and would
1996fanrui commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1008667842
##
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerStaticFileServerHandler.java:
##
@@ -266,6 +324,18 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625871#comment-17625871
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 10/29/22 8:24 AM:
flinkbot commented on PR #21193:
URL: https://github.com/apache/flink/pull/21193#issuecomment-1295770634
## CI report:
* 0594258cbac3359edf0e97ddfc429266ff2db281 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626018#comment-17626018
]
Aitozi commented on FLINK-29795:
A reasonable fix to my mind, is to expose the original options in the
[
https://issues.apache.org/jira/browse/FLINK-29795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29795:
---
Summary: The source.file.stream.io-fetch-size can not be set by table
properties (was: The
1996fanrui opened a new pull request, #21193:
URL: https://github.com/apache/flink/pull/21193
## What is the purpose of the change
Add the final and fix typo
## Brief change log
Add the final and fix typo
## Verifying this change
This change is a
[
https://issues.apache.org/jira/browse/FLINK-29795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626017#comment-17626017
]
Aitozi commented on FLINK-29795:
BTW, I think this option is used in the format's code, but actually
[
https://issues.apache.org/jira/browse/FLINK-29795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29795:
---
Description: The {{source.file.stream.io-fetch-size}} is used in the bulk
format mode, but it is not
Aitozi created FLINK-29795:
--
Summary: The source.file.stream.io-fetch-size can not be set by
with properties
Key: FLINK-29795
URL: https://issues.apache.org/jira/browse/FLINK-29795
Project: Flink
flinkbot commented on PR #21192:
URL: https://github.com/apache/flink/pull/21192#issuecomment-1295761868
## CI report:
* f4eeef060c12b852bc515d49b2642a090e714251 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25911:
---
Labels: pull-request-available (was: )
> Add delegation token framework documentation
>
gaborgsomogyi commented on PR #21192:
URL: https://github.com/apache/flink/pull/21192#issuecomment-1295761172
cc @mbalassi
--
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 specific comment.
gaborgsomogyi opened a new pull request, #21192:
URL: https://github.com/apache/flink/pull/21192
## What is the purpose of the change
In FLINK-21232 umbrella ticket delegation token support has been added but
during implementation no documentation added for the small pieces. In this
[ https://issues.apache.org/jira/browse/FLINK-29480 ]
Salva deleted comment on FLINK-29480:
---
was (Author: JIRAUSER287051):
[~martijnvisser] This is the error I'm getting when I run `mvn -DskipTests
clean package -e`:
{code:java}
[ERROR] Failed to
[ https://issues.apache.org/jira/browse/FLINK-29480 ]
Salva deleted comment on FLINK-29480:
---
was (Author: JIRAUSER287051):
Can someone provide any guidance on how to fix those errors?
> Skip invalid messages when writing
>
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva commented on FLINK-29480:
---
Thanks [~mason6345]. I've finally switched to another laptop where things
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626011#comment-17626011
]
Salva edited comment on FLINK-29480 at 10/29/22 6:45 AM:
-
Thanks [~mason6345].
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625619#comment-17625619
]
Salva edited comment on FLINK-29480 at 10/29/22 6:45 AM:
-
[~martijnvisser] This
[ https://issues.apache.org/jira/browse/FLINK-29480 ]
Salva deleted comment on FLINK-29480:
---
was (Author: JIRAUSER287051):
!Screenshot 2022-10-28 at 13.48.12.png!
> Skip invalid messages when writing
> --
>
>
gaborgsomogyi commented on PR #21190:
URL: https://github.com/apache/flink/pull/21190#issuecomment-1295747110
This is definitely missing no question, so +1 from my side. The only thing
what I'm wondering is why Kafka not blown up with
GROUP_COORDINATOR_NOT_AVAILABLE. This has been added in
45 matches
Mail list logo
