rdhabalia opened a new pull request #2503: add auto ack and timeout configurable
URL: https://github.com/apache/incubator-pulsar/pull/2503
### Motivation
we need a way to configure to ack-timeout and auto-ack for the pulsar source
consumer.
srkukarni commented on a change in pull request #2502: Fix Handling of user
defined nar sources/sinks
URL: https://github.com/apache/incubator-pulsar/pull/2502#discussion_r214486344
##
File path:
rdhabalia closed pull request #2492: add sub-name option to function cli
URL: https://github.com/apache/incubator-pulsar/pull/2492
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
rdhabalia commented on a change in pull request #2502: Fix Handling of user
defined nar sources/sinks
URL: https://github.com/apache/incubator-pulsar/pull/2502#discussion_r214484215
##
File path:
srkukarni commented on issue #2502: Fix Handling of user defined nar
sources/sinks
URL: https://github.com/apache/incubator-pulsar/pull/2502#issuecomment-417799172
run integration tests
This is an automated message from the
jerrypeng closed pull request #2479: Initial SQL documentation and
DataGeneratorSource
URL: https://github.com/apache/incubator-pulsar/pull/2479
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
srkukarni opened a new pull request #2502: Fix Handling of user defined nar
sources/sinks
URL: https://github.com/apache/incubator-pulsar/pull/2502
### Motivation
Currently for all Java functions(and by extension all sources/sinks) the
file from bookkeeper is downloaded and stored
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417790982
run integration tests
run cpp tests
This is an automated message from the
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417770947
run java8 tests
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417769795
run java8 tests
This is an automated message from the Apache Git Service.
To
srkukarni closed pull request #2501: Fix Trigger Functionality
URL: https://github.com/apache/incubator-pulsar/pull/2501
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull
srkukarni closed pull request #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull
srkukarni closed pull request #2490: Attach Producer/Consumer property tags so
its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490
This is a PR merged from a forked repository.
As GitHub hides the original diff on
srkukarni commented on issue #2409: Added HDFS Sink
URL: https://github.com/apache/incubator-pulsar/pull/2409#issuecomment-417757018
run integration tests
This is an automated message from the Apache Git Service.
To respond
srkukarni commented on issue #2409: Added HDFS Sink
URL: https://github.com/apache/incubator-pulsar/pull/2409#issuecomment-417756978
run java8 tests
This is an automated message from the Apache Git Service.
To respond to the
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417749205
run integration tests
This is an automated message from the Apache Git Service.
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417743190
run java8 tests
run integration tests
This is an automated message from the
srkukarni commented on issue #2501: Fix Trigger Functionality
URL: https://github.com/apache/incubator-pulsar/pull/2501#issuecomment-417742271
run integration tests
run java8 tests
This is an automated message from the
srkukarni opened a new pull request #2501: Fix Trigger Functinality
URL: https://github.com/apache/incubator-pulsar/pull/2501
### Motivation
When we moved to support schemas on functions, we moved away from
customSerdeInputMap as the base structure for FunctionDetails, but rather went
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417735623
run integration tests
This is an automated message from the Apache Git Service.
rdhabalia closed pull request #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417735545
run integration tests
This is an automated message from the Apache Git Service.
merlimat commented on issue #2464: Copy ByteBufPair buffers when using with SSL
(#2401)
URL: https://github.com/apache/incubator-pulsar/pull/2464#issuecomment-417723526
run cpp tests
run integration tests
This is an
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417715687
run integration tests
This is an automated message from the Apache Git Service.
srkukarni commented on issue #2490: Attach Producer/Consumer property tags so
its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490#issuecomment-417715753
run integration tests
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417715607
run integration tests
This is an automated message from the Apache Git Service.
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417715563
run java8 tests
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417672846
run integration tests
This is an automated message from the Apache Git Service.
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417672807
run java8 tests
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417672144
run cpp tests
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417672074
run integration tests
This is an automated message from the Apache Git Service.
srkukarni commented on issue #2490: Attach Producer/Consumer property tags so
its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490#issuecomment-417671930
run integration tests
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417630240
run java8 tests
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2490: Attach Producer/Consumer property tags so
its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490#issuecomment-417623974
run java8 tests
srkukarni commented on issue #2490: Attach Producer/Consumer property tags so
its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490#issuecomment-417624023
run cpp tests
ivankelly commented on issue #2464: Copy ByteBufPair buffers when using with
SSL (#2401)
URL: https://github.com/apache/incubator-pulsar/pull/2464#issuecomment-417622553
run integration tests
run cpp tests
This is an
sijie opened a new pull request #2500: [schema] add schemas for primtive types
URL: https://github.com/apache/incubator-pulsar/pull/2500
This is an automated message from the Apache Git Service.
To respond to the message,
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417612761
retest this please
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2468: Fix semantics of skip output
URL: https://github.com/apache/incubator-pulsar/pull/2468#issuecomment-417612670
retest this please
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2472: Create function assignment topic during
standalone mode
URL: https://github.com/apache/incubator-pulsar/pull/2472#issuecomment-417612166
#2474 makes this unncesessary
This is an automated
srkukarni closed pull request #2472: Create function assignment topic during
standalone mode
URL: https://github.com/apache/incubator-pulsar/pull/2472
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
sijie commented on a change in pull request #2497: [schema] implement generic
schema/record for Schema.JSON
URL: https://github.com/apache/incubator-pulsar/pull/2497#discussion_r214287201
##
File path:
sijie commented on issue #2494: [Schema] Introduce Schema.AUTO to detect schema
automatically for consumers and readers
URL: https://github.com/apache/incubator-pulsar/pull/2494#issuecomment-417594791
retest this please
This
sijie commented on issue #2484: Fixed the issue 2481 by not to take PULSAR_MEM
from env.
URL: https://github.com/apache/incubator-pulsar/pull/2484#issuecomment-417586470
retest this please
This is an automated message from
sijie commented on issue #2434: Add pulsar flink sink connector
URL: https://github.com/apache/incubator-pulsar/pull/2434#issuecomment-417584159
retest this please
This is an automated message from the Apache Git Service.
To
sijie commented on issue #2440: Issue 2313: create a JDBC sink connector
URL: https://github.com/apache/incubator-pulsar/pull/2440#issuecomment-417584094
rerun integration tests
This is an automated message from the Apache
merlimat commented on issue #2447: Added producer/consumer properties in Go
client
URL: https://github.com/apache/incubator-pulsar/pull/2447#issuecomment-417566143
run java8 tests
This is an automated message from the Apache
merlimat closed pull request #2470: Clarified project roles in team page
URL: https://github.com/apache/incubator-pulsar/pull/2470
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
merlimat closed pull request #2459: Added Contributing page on website
URL: https://github.com/apache/incubator-pulsar/pull/2459
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
sijie commented on issue #2440: Issue 2313: create a JDBC sink connector
URL: https://github.com/apache/incubator-pulsar/pull/2440#issuecomment-417563273
retest this please
This is an automated message from the Apache Git
sijie commented on issue #2471: PIP-23: Pulsar Java Client Interceptors.
URL: https://github.com/apache/incubator-pulsar/pull/2471#issuecomment-417563224
retest this please
This is an automated message from the Apache Git
rdhabalia commented on issue #2492: add sub-name option to function cli
URL: https://github.com/apache/incubator-pulsar/pull/2492#issuecomment-417561334
rerun tests
This is an automated message from the Apache Git Service.
To
rdhabalia removed a comment on issue #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#issuecomment-417561251
rerun tests
This is an automated message from the Apache Git
rdhabalia commented on issue #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#issuecomment-417561251
rerun tests
This is an automated message from the Apache Git Service.
To
rdhabalia removed a comment on issue #2492: add sub-name option to function cli
URL: https://github.com/apache/incubator-pulsar/pull/2492#issuecomment-417561334
rerun tests
This is an automated message from the Apache Git
merlimat commented on issue #2464: Copy ByteBufPair buffers when using with SSL
(#2401)
URL: https://github.com/apache/incubator-pulsar/pull/2464#issuecomment-417559636
run cpp tests
This is an automated message from the
merlimat closed pull request #2474: Revert "Fix: Function assignment can
support large number of topics (#2438)"
URL: https://github.com/apache/incubator-pulsar/pull/2474
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
merlimat commented on issue #2470: Clarified project roles in team page
URL: https://github.com/apache/incubator-pulsar/pull/2470#issuecomment-417553002
run cpp tests
run java8 tests
This is an automated message from the
merlimat commented on issue #2459: Added Contributing page on website
URL: https://github.com/apache/incubator-pulsar/pull/2459#issuecomment-417552892
run cpp tests
run java8 tests
This is an automated message from the
srkukarni commented on issue #2490: Attach Producer/Consumer property tags so
its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490#issuecomment-417548005
retest this please
srkukarni commented on issue #2474: Revert "Fix: Function assignment can
support large number of topics (#2438)"
URL: https://github.com/apache/incubator-pulsar/pull/2474#issuecomment-417548054
retest this please
This is an
srkukarni commented on issue #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485#issuecomment-417547993
retest this please
This is an automated message from the Apache Git Service.
To
srkukarni commented on issue #2486: Added the --custom-schema-inputs cli arg to
allow custom schema input to functions
URL: https://github.com/apache/incubator-pulsar/pull/2486#issuecomment-417547917
retest this please
This
kesavkolla opened a new issue #2499: Support for passing basic auth credentials
from Python client
URL: https://github.com/apache/incubator-pulsar/issues/2499
If broker is setup with BasicAuth (**AuthenticationProviderBasic**)
currently Python client doesn't have an ability to pass the
rdhabalia opened a new pull request #2498: Fix: avoid continuous acking with
invalid msgId for cumulative ack
URL: https://github.com/apache/incubator-pulsar/pull/2498
### Motivation
Right now, If Consumer does cumulative ack then Ack-Tracker continuously
acking with invalid
merlimat commented on a change in pull request #2497: [schema] implement
generic schema/record for Schema.JSON
URL: https://github.com/apache/incubator-pulsar/pull/2497#discussion_r214220260
##
File path:
rdhabalia commented on issue #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#issuecomment-417510937
@merlimat @srkukarni fixed it.
This is an automated message from the
rdhabalia commented on a change in pull request #2496: Fix: auto-ack flag
always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#discussion_r214217355
##
File path:
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
##
@@
rdhabalia commented on issue #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#issuecomment-417508347
> shouldn't be working to pass --auto-ack=false ?
uumm.. I get `Unknown option: --auto-ack=false` .. I don't think it's valid
merlimat commented on a change in pull request #2496: Fix: auto-ack flag always
set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#discussion_r214215855
##
File path:
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
##
@@
merlimat commented on a change in pull request #2496: Fix: auto-ack flag always
set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#discussion_r214215417
##
File path:
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java
##
@@
srkukarni commented on issue #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#issuecomment-417506463
+1 to the approach
This is an automated message from the Apache Git
rdhabalia commented on issue #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496#issuecomment-417503927
> The default value of auto ack should be true.
right now, there is no way, we can set this flag false because it's a flag
and it
sijie opened a new pull request #2497: [schema] implement generic schema/record
for Schema.JSON
URL: https://github.com/apache/incubator-pulsar/pull/2497
### Motivation
The `GenericSchema` and `GenericRecord` are used for schema auto detection.
Currently it only supports Avro.
sijie commented on issue #2497: [schema] implement generic schema/record for
Schema.JSON
URL: https://github.com/apache/incubator-pulsar/pull/2497#issuecomment-417500301
*NOTES*
Currently the generic json deserialization is mapped to a Map. not sure if
it is the best solution. but
rdhabalia opened a new pull request #2496: Fix: auto-ack flag always set true
URL: https://github.com/apache/incubator-pulsar/pull/2496
### Motivation
cli should have primitive boolean for any flag but it wasn't there for
auto-ack because of that we were also setting auto-ack flag
merlimat commented on a change in pull request #2487: Ensure standalone service
comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214203315
##
File path:
rdhabalia commented on issue #2492: add sub-name option to function cli
URL: https://github.com/apache/incubator-pulsar/pull/2492#issuecomment-417491399
@srkukarni updated it.
This is an automated message from the Apache Git
aahmed-se opened a new issue #2495: Trigger function not update function
metrics correctly
URL: https://github.com/apache/incubator-pulsar/issues/2495
When running a pulsar function and triggering it via command line the
metrics of the function are not updated correctly.
```
sijie opened a new pull request #2494: [Schema] Introduce Schema.AUTO to detect
schema automatically for consumers and readers
URL: https://github.com/apache/incubator-pulsar/pull/2494
### Motivation
Sometimes consumers and readers don't have the pojo for the message schemas.
rdhabalia opened a new pull request #2493: Fix: function worker startup with
empty assignments
URL: https://github.com/apache/incubator-pulsar/pull/2493
### Motivation
This will fix #2474, when function-worker startup stuck if worker has empty
assignments.
rdhabalia opened a new pull request #2492: add sub-name option to function cli
URL: https://github.com/apache/incubator-pulsar/pull/2492
### Motivation
as a user, we need to add sub-name for the function. adding support to
attach custom sub-name.
sijie opened a new pull request #2491: Include pulsar python client
dependencies in pulsar image
URL: https://github.com/apache/incubator-pulsar/pull/2491
### Motivation
when running python functions, we need python client dependencies. so better
to include python dependencies in
srkukarni opened a new pull request #2490: Attach Producer/Consumer property
tags so its easier to identify topics being produced/consumed by functions
URL: https://github.com/apache/incubator-pulsar/pull/2490
### Motivation
Explain here the context, and why you're making that
sijie opened a new issue #2489: Function State
URL: https://github.com/apache/incubator-pulsar/issues/2489
This is the master ticket for tracking state related requirements/tasks.
- [ ] Python State Support
- [ ] State lifecycle management (how do we manage the lifecycle of state
sijie opened a new pull request #2488: [functions] Don't set the state storage
url if state is not enabled.
URL: https://github.com/apache/incubator-pulsar/pull/2488
### Motivation
Explain here the context, and why you're making that change.
What is the problem you're trying to
rdhabalia commented on a change in pull request #2487: Ensure standalone
service comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214143078
##
File path:
merlimat commented on issue #2487: Ensure standalone service comes back quickly
after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#issuecomment-417418584
Updated
This is an automated message
merlimat commented on a change in pull request #2487: Ensure standalone service
comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214123225
##
File path:
sijie commented on a change in pull request #2487: Ensure standalone service
comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214123073
##
File path:
merlimat commented on a change in pull request #2487: Ensure standalone service
comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214122745
##
File path:
sijie commented on a change in pull request #2487: Ensure standalone service
comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214121564
##
File path:
sijie commented on a change in pull request #2487: Ensure standalone service
comes back quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487#discussion_r214122399
##
File path:
merlimat opened a new pull request #2487: Ensure standalone service comes back
quickly after ungraceful restarts
URL: https://github.com/apache/incubator-pulsar/pull/2487
### Motivation
After an ungraceful restart of Pulsar standalone, it might take few
iterations of restart to get
srkukarni opened a new pull request #2486: Added the --custom-schema-inputs cli
arg to allow custom schema input to functions
URL: https://github.com/apache/incubator-pulsar/pull/2486
### Motivation
This makes the cli interface consistent with custom-serde-inputs
###
srkukarni opened a new pull request #2485: Added a no args constructor
URL: https://github.com/apache/incubator-pulsar/pull/2485
### Motivation
Avro schema requires no arg constructor for object.
### Modifications
Describe the modifications you've done.
### Result
vli02 opened a new pull request #2484: Fixed the issue 2481 by not to take
PULSAR_MEM from env.
URL: https://github.com/apache/incubator-pulsar/pull/2484
### Motivation
Command `./bin/pulsar-admin clusters list` failed with `Error: Could not
find or load main class "` in my k8s
ivankelly closed issue #42: Configuration should be immutable
URL: https://github.com/apache/incubator-pulsar/issues/42
This is an automated message from the Apache Git Service.
To respond to the message, please log on
ivankelly commented on issue #42: Configuration should be immutable
URL: https://github.com/apache/incubator-pulsar/issues/42#issuecomment-417358801
This seems to have gone quiet. Closing. Please reopen if you want this work
to continue.
ivankelly commented on issue #58: Possible Message Loss
URL: https://github.com/apache/incubator-pulsar/issues/58#issuecomment-417357140
@sschepens has this happened again?
This is an automated message from the Apache Git
801 - 900 of 10667 matches
Mail list logo
